Package | Description |
---|---|
org.kie.hacep.consumer | |
org.kie.hacep.core | |
org.kie.hacep.core.infra.consumer | |
org.kie.hacep.core.infra.election |
Modifier and Type | Method and Description |
---|---|
void |
DroolsConsumerHandler.process(ItemToProcess item,
State state) |
void |
DroolsConsumerHandler.process(RemoteCommand command,
State state) |
void |
DroolsConsumerHandler.processWithSnapshot(ItemToProcess item,
State currentState) |
Constructor and Description |
---|
CoreKube(String namespace,
State initialState) |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultKafkaConsumer.enableConsumeAndStartLoop(State state) |
void |
ConsumerHandler.process(ItemToProcess item,
State currentState) |
void |
ConsumerHandler.process(RemoteCommand command,
State state) |
void |
ConsumerHandler.processWithSnapshot(ItemToProcess item,
State currentState) |
protected void |
DefaultKafkaConsumer.restart(State state) |
protected void |
DefaultKafkaConsumer.updateOnRunningConsumer(State state) |
void |
LocalConsumer.updateStatus(State state) |
void |
DefaultKafkaConsumer.updateStatus(State state) |
void |
InfraCallback.updateStatus(State state) |
Modifier and Type | Method and Description |
---|---|
static State |
State.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static State[] |
State.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
LeadershipCallback.updateStatus(State state) |
Constructor and Description |
---|
LeaderElectionImpl(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
KubernetesLockConfiguration lockConfiguration,
State initialState) |
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.