Skip navigation links
ha-core-infra 7.36.0-SNAPSHOT
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
ha-core-infra 7.36.0-SNAPSHOT

Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.