JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
ha-core-infra 7.36.0-SNAPSHOT
Prev
Next
Frames
No Frames
All Classes
A
B
C
D
E
G
H
I
K
L
O
P
R
S
T
U
V
A
addCallbacks(List<LeadershipCallback>)
- Method in interface org.kie.hacep.core.infra.election.
LeaderElection
addCallbacks(List<LeadershipCallback>)
- Method in class org.kie.hacep.core.infra.election.
LeaderElectionImpl
addToClusterLabels(String, String)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
askAndProcessSnapshotOnDemand(SnapshotInfos)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
askASnapshotOnDemand(EnvConfig, SessionSnapshooter, Producer)
- Static method in class org.kie.hacep.core.infra.utils.
SnapshotOnDemandUtilsImpl
assign()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
assignAndStartConsume()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
assignAsALeader()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
assignConsumer(Consumer<String, T>, String)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
assignReplica()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
B
Bootstrap
- Class in
org.kie.hacep.core
Here is where we start all the services needed by the POD
C
ConfigMapLockUtils
- Class in
org.kie.hacep.core.infra.election
from org.apache.camel.component.kubernetes.cluster.lock Utilities for managing ConfigMaps that contain lock information.
consume()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
consumeControlFromBufferAsAReplica()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
consumeEventsFromBufferAsALeader()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
consumeEventsFromBufferAsAReplica()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
ConsumerUtilsCoreImpl
- Class in
org.kie.hacep.core.infra.utils
ConsumerUtilsCoreImpl()
- Constructor for class org.kie.hacep.core.infra.utils.
ConsumerUtilsCoreImpl
CoreKube
- Class in
org.kie.hacep.core
CoreKube(String, State)
- Constructor for class org.kie.hacep.core.
CoreKube
createNewConfigMap(String, LeaderInfo)
- Static method in class org.kie.hacep.core.infra.election.
ConfigMapLockUtils
createRemoteKieSession(Properties, Listener, Producer)
- Static method in class org.kie.hacep.core.
InfraFactory
createRemoteStreamingKieSession(Properties, Listener, Producer)
- Static method in class org.kie.hacep.core.
InfraFactory
D
DEFAULT_CONFIGMAP_NAME
- Static variable in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
DEFAULT_JITTER_FACTOR
- Static variable in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
DEFAULT_LEASE_DURATION_MILLIS
- Static variable in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
DEFAULT_RENEW_DEADLINE_MILLIS
- Static variable in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
DEFAULT_RETRY_PERIOD_MILLIS
- Static variable in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
DefaultKafkaConsumer
<
T
> - Class in
org.kie.hacep.core.infra.consumer
The default consumer relies on the Consumer thread and is based on the loop around poll method.
DefaultKafkaConsumer(EnvConfig, Producer)
- Constructor for class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
DefaultKafkaConsumer.PolledTopic
- Enum in
org.kie.hacep.core.infra.consumer
defaultProcessAsAReplica()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
defaultProcessAsLeader()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
DefaultSessionSnapShooter
- Class in
org.kie.hacep.core.infra
DefaultSessionSnapShooter(EnvConfig)
- Constructor for class org.kie.hacep.core.infra.
DefaultSessionSnapShooter
deserialize()
- Method in class org.kie.hacep.core.infra.
DefaultSessionSnapShooter
E
enableConsumeAndStartLoop(State)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
G
getClusterLabels()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getConfigMapName()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getConfigMapWithNewLeader(ConfigMap, LeaderInfo)
- Static method in class org.kie.hacep.core.infra.election.
ConfigMapLockUtils
getConfiguredSnapshotConsumer(EnvConfig)
- Static method in class org.kie.hacep.core.infra.utils.
SnapshotOnDemandUtilsImpl
getConsumer(String, Properties)
- Static method in class org.kie.hacep.core.
InfraFactory
getConsumerController()
- Static method in class org.kie.hacep.core.
Bootstrap
getConsumerHandler(Producer, EnvConfig)
- Static method in class org.kie.hacep.core.
InfraFactory
getEventConsumer(EnvConfig)
- Static method in class org.kie.hacep.core.
InfraFactory
getFhManager()
- Method in class org.kie.hacep.core.infra.message.
SnapshotMessage
getFhMapKeys()
- Method in class org.kie.hacep.core.infra.message.
SnapshotMessage
getGroupName()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getGroupName()
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
getItemToProcess(ConsumerRecord)
- Static method in class org.kie.hacep.core.
InfraFactory
getJitterFactor()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getKjarGAV()
- Method in class org.kie.hacep.core.infra.message.
SnapshotMessage
getKubernetesResourcesNamespace()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getKubernetesResourcesNamespaceOrDefault(KubernetesClient)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getLastEvent(String, Integer)
- Method in class org.kie.hacep.core.infra.utils.
ConsumerUtilsCoreImpl
getLastEvent(String, Properties, Integer)
- Method in class org.kie.hacep.core.infra.utils.
ConsumerUtilsCoreImpl
getLastInsertedEventkey()
- Method in class org.kie.hacep.core.infra.message.
SnapshotMessage
getLastInsertedEventOffset()
- Method in class org.kie.hacep.core.infra.message.
SnapshotMessage
getLastSnapshotTime()
- Method in class org.kie.hacep.core.infra.
DefaultSessionSnapShooter
getLeader()
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
getLeaderElection()
- Method in class org.kie.hacep.core.
CoreKube
getLeaderInfo(ConfigMap, Set<String>, String)
- Static method in class org.kie.hacep.core.infra.election.
ConfigMapLockUtils
getLeaseDurationMillis()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getLocalTimestamp()
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
getMembers()
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
getPodName()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getProducer(boolean)
- Static method in class org.kie.hacep.core.
InfraFactory
getRenewDeadlineMillis()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getRetryPeriodMillis()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
getSerializedSession()
- Method in class org.kie.hacep.core.infra.message.
SnapshotMessage
getSnapshooter(EnvConfig)
- Static method in class org.kie.hacep.core.
InfraFactory
getTime()
- Method in class org.kie.hacep.core.infra.message.
SnapshotMessage
H
handleSnapshotBetweenIteration(ConsumerRecord<String, T>)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
hasEmptyLeader()
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
hasValidLeader()
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
I
InfraFactory
- Class in
org.kie.hacep.core
initConsumer(ConsumerHandler)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
isValidLeader(String)
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
K
KEY
- Static variable in class org.kie.hacep.core.infra.
DefaultSessionSnapShooter
KubernetesLockConfiguration
- Class in
org.kie.hacep.core.infra.election
from org.apache.camel.component.kubernetes.cluster.lock Configuration for Kubernetes Lock.
KubernetesLockConfiguration(String)
- Constructor for class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
L
LeaderElection
- Interface in
org.kie.hacep.core.infra.election
LeaderElectionImpl
- Class in
org.kie.hacep.core.infra.election
from from org.apache.camel.component.kubernetes.cluster.lock Monitors current status and participate to leader election when no active leaders are present.
LeaderElectionImpl(KubernetesClient, KubernetesLockConfiguration, State)
- Constructor for class org.kie.hacep.core.infra.election.
LeaderElectionImpl
LeaderInfo
- Class in
org.kie.hacep.core.infra.election
from org.apache.camel.component.kubernetes.cluster.lock Overview of a leadership status.
LeaderInfo(String, String, Date, Set<String>)
- Constructor for class org.kie.hacep.core.infra.election.
LeaderInfo
lookupNewLeaderInfo()
- Method in class org.kie.hacep.core.infra.election.
LeaderElectionImpl
O
org.kie.hacep.core
- package org.kie.hacep.core
org.kie.hacep.core.infra
- package org.kie.hacep.core.infra
org.kie.hacep.core.infra.consumer
- package org.kie.hacep.core.infra.consumer
org.kie.hacep.core.infra.election
- package org.kie.hacep.core.infra.election
org.kie.hacep.core.infra.message
- package org.kie.hacep.core.infra.message
org.kie.hacep.core.infra.utils
- package org.kie.hacep.core.infra.utils
P
poll()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
pollControl()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
pollEvents()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
PRIMARY_CONSUMER
- Static variable in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
processControlAsAReplica(ConsumerRecord<String, T>)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
processEventsAsAReplica(ConsumerRecord<String, T>)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
processLeader(ConsumerRecord<String, T>)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
pullClusterMembers()
- Method in class org.kie.hacep.core.infra.election.
LeaderElectionImpl
R
refreshStatus()
- Method in class org.kie.hacep.core.infra.election.
LeaderElectionImpl
restart(State)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
restartConsumer()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
S
saveOffset(ConsumerRecord<String, T>, Consumer<String, T>)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
SECONDARY_CONSUMER
- Static variable in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
serialize(KieSessionContext, String, long)
- Method in class org.kie.hacep.core.infra.
DefaultSessionSnapShooter
setClusterLabels(Map<String, String>)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setConfigMapName(String)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setGroupName(String)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setJitterFactor(double)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setKubernetesResourcesNamespace(String)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setLastProcessedKey()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
setLeaseDurationMillis(long)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setPodName(String)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setRenewDeadlineMillis(long)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
setRetryPeriodMillis(long)
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
settingsOnAEmptyControlTopic(ControlMessage)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
SnapshotMessage
- Class in
org.kie.hacep.core.infra.message
SnapshotMessage()
- Constructor for class org.kie.hacep.core.infra.message.
SnapshotMessage
SnapshotMessage(String, String, byte[], FactHandlesManager, String, long, LocalDateTime)
- Constructor for class org.kie.hacep.core.infra.message.
SnapshotMessage
SnapshotOnDemandUtilsImpl
- Class in
org.kie.hacep.core.infra.utils
start()
- Method in interface org.kie.hacep.core.infra.election.
LeaderElection
start()
- Method in class org.kie.hacep.core.infra.election.
LeaderElectionImpl
startConsume()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
startEngine(EnvConfig)
- Static method in class org.kie.hacep.core.
Bootstrap
stop()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
stop()
- Method in interface org.kie.hacep.core.infra.election.
LeaderElection
stop()
- Method in class org.kie.hacep.core.infra.election.
LeaderElectionImpl
stopConsume()
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
stopEngine()
- Static method in class org.kie.hacep.core.
Bootstrap
T
toString()
- Method in class org.kie.hacep.core.infra.election.
KubernetesLockConfiguration
toString()
- Method in class org.kie.hacep.core.infra.election.
LeaderInfo
U
updateOnRunningConsumer(State)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
updateStatus(State)
- Method in class org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer
V
valueOf(String)
- Static method in enum org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer.PolledTopic
Returns the enum constant of this type with the specified name.
values()
- Static method in enum org.kie.hacep.core.infra.consumer.
DefaultKafkaConsumer.PolledTopic
Returns an array containing the constants of this enum type, in the order they are declared.
A
B
C
D
E
G
H
I
K
L
O
P
R
S
T
U
V
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
ha-core-infra 7.36.0-SNAPSHOT
Prev
Next
Frames
No Frames
All Classes
Copyright © 2001–2020
JBoss by Red Hat
. All rights reserved.