Skip navigation links
openshift-kie-hacep 7.33.0.Final-redhat-00002
A B C D E F G H I K L M N O P R S T U V W 

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
 
anEnvConfig() - Static method in class org.kie.hacep.EnvConfig
 
askAndProcessSnapshotOnDemand() - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
askASnapshotOnDemand(EnvConfig, SessionSnapshooter) - Static method in class org.kie.hacep.core.infra.utils.SnapshotOnDemandUtils
 
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

BidirectionalMap<K,V> - Class in org.kie.hacep.consumer
 
BidirectionalMap() - Constructor for class org.kie.hacep.consumer.BidirectionalMap
 
Bootstrap - Class in org.kie.hacep.core
Here is where we start all the services needed by the POD
Bootstrap() - Constructor for class org.kie.hacep.core.Bootstrap
 
BOOTSTRAP_SERVERS_KEY - Static variable in class org.kie.hacep.Config
 
BROKER_URL - Static variable in class org.kie.hacep.Config
 

C

canBecomeLeader - Static variable in class org.kie.hacep.core.GlobalStatus
 
clone() - Method in class org.kie.hacep.EnvConfig
 
CommandHandler - Class in org.kie.hacep.consumer
 
CommandHandler(KieSessionContext, EnvConfig, Producer, SessionSnapshooter) - Constructor for class org.kie.hacep.consumer.CommandHandler
 
Config - Class in org.kie.hacep
 
Config() - Constructor for class org.kie.hacep.Config
 
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
 
ConsumerController - Class in org.kie.hacep.core.infra.consumer
 
ConsumerController(EnvConfig, Producer) - Constructor for class org.kie.hacep.core.infra.consumer.ConsumerController
 
ConsumerHandler - Interface in org.kie.hacep.core.infra.consumer
 
ConsumerThread - Class in org.kie.hacep.core.infra.consumer
 
ConsumerThread(ConsumerController) - Constructor for class org.kie.hacep.core.infra.consumer.ConsumerThread
 
ConsumerUtils - Class in org.kie.hacep.core.infra.utils
 
ConsumerUtils() - Constructor for class org.kie.hacep.core.infra.utils.ConsumerUtils
 
copy() - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
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
 

D

DEFAULT_CONFIGMAP_NAME - Static variable in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
DEFAULT_CONTROL_TOPIC - Static variable in class org.kie.hacep.Config
 
DEFAULT_ITERATION_BETWEEN_SNAPSHOT - Static variable in class org.kie.hacep.Config
 
DEFAULT_JITTER_FACTOR - Static variable in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
DEFAULT_KAFKA_PORT - Static variable in class org.kie.hacep.Config
 
DEFAULT_LEASE_DURATION_MILLIS - Static variable in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
DEFAULT_MAX_SNAPSHOT_AGE_SEC - Static variable in class org.kie.hacep.Config
 
DEFAULT_MAX_SNAPSHOT_REQUEST_ATTEMPTS - Static variable in class org.kie.hacep.Config
 
DEFAULT_POLL_SNAPSHOT_TIMEOUT - Static variable in class org.kie.hacep.Config
 
DEFAULT_POLL_TIMEOUT - Static variable in class org.kie.hacep.Config
 
DEFAULT_PRINTER_TYPE - Static variable in class org.kie.hacep.Config
 
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
 
DEFAULT_SNAPSHOT_TOPIC - Static variable in class org.kie.hacep.Config
 
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) - 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
 
deserialize() - Method in interface org.kie.hacep.core.infra.SessionSnapshooter
 
DroolsConsumerHandler - Class in org.kie.hacep.consumer
 
DroolsConsumerHandler(Producer, EnvConfig) - Constructor for class org.kie.hacep.consumer.DroolsConsumerHandler
 

E

enableConsumeAndStartLoop(State) - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
EnvConfig - Class in org.kie.hacep
 
EventConsumer - Interface in org.kie.hacep.core.infra.consumer
 

F

FactHandlesManager - Class in org.kie.hacep.consumer
 
FactHandlesManager() - Constructor for class org.kie.hacep.consumer.FactHandlesManager
 
FactHandlesManager(KieSession) - Constructor for class org.kie.hacep.consumer.FactHandlesManager
 

G

GAVUtils - Class in org.kie.hacep.util
 
GAVUtils() - Constructor for class org.kie.hacep.util.GAVUtils
 
get(EnvConfig) - Static method in interface org.kie.hacep.core.infra.consumer.EventConsumer
 
getBootStrapServers() - Static method in class org.kie.hacep.Config
 
getCallback() - Method in class org.kie.hacep.core.infra.consumer.ConsumerController
 
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
 
getConsumer() - Method in class org.kie.hacep.core.infra.consumer.ConsumerController
 
getConsumerConfig(String) - Static method in class org.kie.hacep.Config
 
getConsumerController() - Static method in class org.kie.hacep.core.Bootstrap
 
getControlTopicName() - Method in class org.kie.hacep.EnvConfig
 
getControlTopicOffset() - Static method in class org.kie.hacep.core.infra.OffsetManager
 
getDefaultConfig() - Static method in class org.kie.hacep.Config
 
getDefaultConfigFromProps(String) - Static method in class org.kie.hacep.Config
 
getDefaultEnvConfig() - Static method in class org.kie.hacep.EnvConfig
 
getEventsTopicName() - Method in class org.kie.hacep.EnvConfig
 
getEventsTopicOffset() - Static method in class org.kie.hacep.core.infra.OffsetManager
 
getFactCount(RemoteFactHandle, EnvConfig, Properties) - Static method in class org.kie.hacep.core.infra.utils.ConsumerUtils
 
getFhManager() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getFhManager() - Method in class org.kie.hacep.core.KieSessionContext
 
getFhManager() - Method in class org.kie.hacep.message.SnapshotMessage
 
getFhMapKeys() - Method in class org.kie.hacep.consumer.FactHandlesManager
 
getFhMapKeys() - Method in class org.kie.hacep.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.infra.consumer.ItemToProcess
 
getIterationBetweenSnapshot() - Method in class org.kie.hacep.EnvConfig
 
getJitterFactor() - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
getKafkaLoggerForTest(EnvConfig) - Static method in class org.kie.hacep.util.PrinterUtil
 
getKey(V) - Method in class org.kie.hacep.consumer.BidirectionalMap
 
getKey() - Method in class org.kie.hacep.core.infra.consumer.ItemToProcess
 
getKeyDuringSnaphot() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getKieContainer(EnvConfig, KieServices) - Static method in class org.kie.hacep.consumer.KieContainerUtils
 
getKieContainer() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getKieContainer() - Method in class org.kie.hacep.core.KieSessionContext
 
getKieSession() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getKieSession() - Method in class org.kie.hacep.core.KieSessionContext
 
getKieSessionInfosTopicName() - Method in class org.kie.hacep.EnvConfig
 
getkJarGAV() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getKJarGAV() - Method in class org.kie.hacep.EnvConfig
 
getKjarGAV() - Method in class org.kie.hacep.message.SnapshotMessage
 
getKjarGAVUsed() - Method in class org.kie.hacep.core.KieSessionContext
 
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) - Static method in class org.kie.hacep.core.infra.utils.ConsumerUtils
 
getLastEvent(String, Properties, Integer) - Static method in class org.kie.hacep.core.infra.utils.ConsumerUtils
 
getLastInsertedEventkey() - Method in class org.kie.hacep.message.SnapshotMessage
 
getLastInsertedEventOffset() - Method in class org.kie.hacep.message.SnapshotMessage
 
getLastSnapshotTime() - Method in class org.kie.hacep.core.infra.DefaultSessionSnapShooter
 
getLastSnapshotTime() - Method in interface org.kie.hacep.core.infra.SessionSnapshooter
 
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
 
getMaxSnapshotAge() - Method in class org.kie.hacep.EnvConfig
 
getMaxSnapshotRequestAttempts() - Method in class org.kie.hacep.EnvConfig
 
getMembers() - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 
getNamespace() - Method in class org.kie.hacep.EnvConfig
 
getObject() - Method in class org.kie.hacep.core.infra.consumer.ItemToProcess
 
getObjectsFilterByClassType(Class, KieSession) - Static method in class org.kie.hacep.consumer.ObjectFilterHelper
 
getObjectsFilterByNamedQuery(String, String, Object[], KieSession) - Static method in class org.kie.hacep.consumer.ObjectFilterHelper
 
getOffset() - Method in class org.kie.hacep.core.infra.consumer.ItemToProcess
 
getOffsetDuringSnapshot() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getOffsets(String) - Method in class org.kie.hacep.core.infra.utils.ConsumerUtils
 
getOffsets(String) - Method in class org.kie.hacep.util.PrinterLogImpl
 
getPodName() - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
getPollDuration() - Method in class org.kie.hacep.EnvConfig
 
getPollSnapshotDuration() - Method in class org.kie.hacep.EnvConfig
 
getPollSnapshotTimeout() - Method in class org.kie.hacep.EnvConfig
 
getPollSnapshotUnit() - Method in class org.kie.hacep.EnvConfig
 
getPollTimeout() - Method in class org.kie.hacep.EnvConfig
 
getPollUnit() - Method in class org.kie.hacep.EnvConfig
 
getPrinter(EnvConfig) - Static method in class org.kie.hacep.util.PrinterUtil
 
getPrinterType() - Method in class org.kie.hacep.EnvConfig
 
getProducerConfig(String) - Static method in class org.kie.hacep.Config
 
getReleaseID(String, KieServices) - Static method in class org.kie.hacep.util.GAVUtils
 
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.message.SnapshotMessage
 
getSessionSnapShooter() - Method in class org.kie.hacep.consumer.DroolsConsumerHandler
 
getSnapshotConsumerConfig() - Static method in class org.kie.hacep.Config
 
getSnapshotProducerConfig() - Static method in class org.kie.hacep.Config
 
getSnapshotTopicName() - Method in class org.kie.hacep.EnvConfig
 
getSplittedGav(String) - Static method in class org.kie.hacep.util.GAVUtils
 
getTime() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getTime() - Method in class org.kie.hacep.message.SnapshotMessage
 
GlobalStatus - Class in org.kie.hacep.core
Shared global status
GlobalStatus() - Constructor for class org.kie.hacep.core.GlobalStatus
 

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
 
hasTimestamp(Object) - Static method in class org.kie.hacep.consumer.CommandHandler
 
hasValidLeader() - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 

I

InfraCallback - Class in org.kie.hacep.core.infra.consumer
 
InfraCallback() - Constructor for class org.kie.hacep.core.infra.consumer.InfraCallback
 
init(KieContainer, KieSession) - Method in class org.kie.hacep.core.KieSessionContext
 
initConsumer(ConsumerHandler) - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
initConsumer(ConsumerHandler) - Method in interface org.kie.hacep.core.infra.consumer.EventConsumer
 
initConsumer(ConsumerHandler) - Method in class org.kie.hacep.core.infra.consumer.LocalConsumer
 
initFromKieSession(KieSession) - Method in class org.kie.hacep.consumer.FactHandlesManager
 
initFromSnapshot(SnapshotInfos) - Method in class org.kie.hacep.core.KieSessionContext
 
initializeKieSessionFromSnapshotOnDemand(EnvConfig) - Method in class org.kie.hacep.consumer.DroolsConsumerHandler
 
isEvent(Object) - Static method in class org.kie.hacep.consumer.CommandHandler
 
isFiringUntilHalt() - Method in class org.kie.hacep.consumer.CommandHandler
 
isLocal() - Method in class org.kie.hacep.EnvConfig
 
isSkipOnDemandSnapshot() - Method in class org.kie.hacep.EnvConfig
 
isUnderTest() - Method in class org.kie.hacep.EnvConfig
 
isUpdatableKJar() - Method in class org.kie.hacep.EnvConfig
 
isValidLeader(String) - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 
ItemToProcess - Class in org.kie.hacep.core.infra.consumer
 
ItemToProcess(String, long, Object) - Constructor for class org.kie.hacep.core.infra.consumer.ItemToProcess
 
ITERATION_BETWEEN_SNAPSHOT - Static variable in class org.kie.hacep.Config
 

K

KieContainerUtils - Class in org.kie.hacep.consumer
 
KieContainerUtils() - Constructor for class org.kie.hacep.consumer.KieContainerUtils
 
KieSessionContext - Class in org.kie.hacep.core
 
KieSessionContext() - Constructor for class org.kie.hacep.core.KieSessionContext
 
KJAR_GAV - Static variable in class org.kie.hacep.Config
 
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() - Constructor for class org.kie.hacep.core.infra.election.LeaderInfo
 
LeaderInfo(String, String, Date, Set<String>) - Constructor for class org.kie.hacep.core.infra.election.LeaderInfo
 
LeadershipCallback - Interface in org.kie.hacep.core.infra.election
 
load() - Static method in class org.kie.hacep.core.infra.OffsetManager
 
local(boolean) - Method in class org.kie.hacep.EnvConfig
 
LocalConsumer - Class in org.kie.hacep.core.infra.consumer
 
LocalConsumer(EnvConfig) - Constructor for class org.kie.hacep.core.infra.consumer.LocalConsumer
 
logRecord(RecordMetadata) - Static method in class org.kie.hacep.core.infra.utils.RecordMetadataUtil
 

M

mapRemoteFactHandle(RemoteFactHandle) - Method in class org.kie.hacep.consumer.FactHandlesManager
 
MAX_SNAPSHOT_AGE - Static variable in class org.kie.hacep.Config
 
MAX_SNAPSHOT_REQUEST_ATTEMPTS - Static variable in class org.kie.hacep.Config
 
MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_HOST - Static variable in class org.kie.hacep.Config
 

N

NAMESPACE - Static variable in class org.kie.hacep.Config
 
nodeLive - Static variable in class org.kie.hacep.core.GlobalStatus
 
nodeReady - Static variable in class org.kie.hacep.core.GlobalStatus
 

O

ObjectFilterHelper - Class in org.kie.hacep.consumer
 
ObjectFilterHelper() - Constructor for class org.kie.hacep.consumer.ObjectFilterHelper
 
OffsetManager - Class in org.kie.hacep.core.infra
Used when is required to store the current offset between operation in the cluster
OffsetManager() - Constructor for class org.kie.hacep.core.infra.OffsetManager
 
org.kie.hacep - package org.kie.hacep
 
org.kie.hacep.consumer - package org.kie.hacep.consumer
 
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.utils - package org.kie.hacep.core.infra.utils
 
org.kie.hacep.message - package org.kie.hacep.message
 
org.kie.hacep.util - package org.kie.hacep.util
 

P

poll() - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
poll() - Method in interface org.kie.hacep.core.infra.consumer.EventConsumer
 
poll() - Method in class org.kie.hacep.core.infra.consumer.LocalConsumer
 
POLL_TIMEOUT - Static variable in class org.kie.hacep.Config
 
POLL_TIMEOUT_DEFAULT_UNIT - Static variable in class org.kie.hacep.Config
 
POLL_TIMEOUT_SNAPSHOT - Static variable in class org.kie.hacep.Config
 
POLL_TIMEOUT_SNAPSHOT_DEFAULT_UNIT - Static variable in class org.kie.hacep.Config
 
POLL_TIMEOUT_UNIT - Static variable in class org.kie.hacep.Config
 
POLL_TIMEOUT_UNIT_SNAPSHOT - Static variable in class org.kie.hacep.Config
 
pollControl() - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
pollEvents() - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
PollUnit - Enum in org.kie.hacep
 
prettyPrinter(String, ConsumerRecord, boolean) - Method in interface org.kie.hacep.util.Printer
 
prettyPrinter(String, ConsumerRecord, boolean) - Method in class org.kie.hacep.util.PrinterLogImpl
 
Printer - Interface in org.kie.hacep.util
 
PrinterLogImpl - Class in org.kie.hacep.util
 
PrinterLogImpl() - Constructor for class org.kie.hacep.util.PrinterLogImpl
 
PrinterUtil - Class in org.kie.hacep.util
 
PrinterUtil() - Constructor for class org.kie.hacep.util.PrinterUtil
 
process(ItemToProcess, State) - Method in class org.kie.hacep.consumer.DroolsConsumerHandler
 
process(RemoteCommand, State) - Method in class org.kie.hacep.consumer.DroolsConsumerHandler
 
process(ItemToProcess, State) - Method in interface org.kie.hacep.core.infra.consumer.ConsumerHandler
 
process(RemoteCommand, State) - Method in interface org.kie.hacep.core.infra.consumer.ConsumerHandler
 
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
 
processSideEffectsOnReplica(Queue<Object>) - Method in class org.kie.hacep.consumer.DroolsConsumerHandler
 
processWithSnapshot(ItemToProcess, State) - Method in class org.kie.hacep.consumer.DroolsConsumerHandler
 
processWithSnapshot(ItemToProcess, State) - Method in interface org.kie.hacep.core.infra.consumer.ConsumerHandler
 
put(K, V) - Method in class org.kie.hacep.consumer.BidirectionalMap
 

R

RecordMetadataUtil - Class in org.kie.hacep.core.infra.utils
 
RecordMetadataUtil() - Constructor for class org.kie.hacep.core.infra.utils.RecordMetadataUtil
 
registerHandle(RemoteFactHandle, FactHandle) - Method in class org.kie.hacep.consumer.FactHandlesManager
 
remove(Object) - Method in class org.kie.hacep.consumer.BidirectionalMap
 
removeValue(V) - Method in class org.kie.hacep.consumer.BidirectionalMap
 
restart(State) - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
restartConsumer() - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
run() - Method in class org.kie.hacep.core.infra.consumer.ConsumerThread
 

S

saveControlTopic(Map<TopicPartition, Long>) - Static method in class org.kie.hacep.core.infra.OffsetManager
 
saveEventsTopic(Map<TopicPartition, Long>) - Static method in class org.kie.hacep.core.infra.OffsetManager
 
saveOffset(ConsumerRecord<String, T>, Consumer<String, T>) - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
serialize(KieSessionContext, String, long) - Method in class org.kie.hacep.core.infra.DefaultSessionSnapShooter
 
serialize(KieSessionContext, String, long) - Method in interface org.kie.hacep.core.infra.SessionSnapshooter
 
SessionSnapshooter - Interface in org.kie.hacep.core.infra
 
setClockAt(long) - Method in class org.kie.hacep.core.KieSessionContext
 
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
 
setConsumer(LeadershipCallback) - Method in class org.kie.hacep.core.infra.consumer.InfraCallback
 
setGroupName(String) - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
setGroupName(String) - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 
setJitterFactor(double) - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
setKubernetesResourcesNamespace(String) - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
setLastInsertedEventkey(String) - Method in class org.kie.hacep.message.SnapshotMessage
 
setLastInsertedEventOffset(long) - Method in class org.kie.hacep.message.SnapshotMessage
 
setLastProcessedKey() - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
setLeader(String) - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 
setLeaseDurationMillis(long) - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
setLocalTimestamp(Date) - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 
setMembers(Set<String>) - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 
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
 
setSerializedSession(byte[]) - Method in class org.kie.hacep.message.SnapshotMessage
 
settingsOnAEmptyControlTopic(ControlMessage) - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
SKIP_ON_DEMAND_SNAPSHOT - Static variable in class org.kie.hacep.Config
 
skipOnDemandSnapshot(String) - Method in class org.kie.hacep.EnvConfig
 
SnapshotInfos - Class in org.kie.hacep.core.infra
 
SnapshotInfos(KieSession, KieContainer, FactHandlesManager, String, long, LocalDateTime, String) - Constructor for class org.kie.hacep.core.infra.SnapshotInfos
 
SnapshotMessage - Class in org.kie.hacep.message
 
SnapshotMessage() - Constructor for class org.kie.hacep.message.SnapshotMessage
 
SnapshotMessage(String, String, byte[], FactHandlesManager, String, long, LocalDateTime) - Constructor for class org.kie.hacep.message.SnapshotMessage
 
SnapshotOnDemandUtils - Class in org.kie.hacep.core.infra.utils
 
SnapshotOnDemandUtils() - Constructor for class org.kie.hacep.core.infra.utils.SnapshotOnDemandUtils
 
start() - Method in class org.kie.hacep.core.infra.consumer.ConsumerController
 
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
 
State - Enum in org.kie.hacep.core.infra.election
 
stop() - Method in class org.kie.hacep.consumer.DroolsConsumerHandler
 
stop() - Method in class org.kie.hacep.core.infra.consumer.ConsumerController
 
stop() - Method in interface org.kie.hacep.core.infra.consumer.ConsumerHandler
 
stop() - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
stop() - Method in interface org.kie.hacep.core.infra.consumer.EventConsumer
 
stop() - Method in class org.kie.hacep.core.infra.consumer.LocalConsumer
 
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
 
store(Map<TopicPartition, OffsetAndMetadata>) - Static method in class org.kie.hacep.core.infra.OffsetManager
 

T

TEST - Static variable in class org.kie.hacep.Config
 
toString() - Method in class org.kie.hacep.consumer.FactHandlesManager
 
toString() - Method in class org.kie.hacep.core.infra.consumer.ItemToProcess
 
toString() - Method in class org.kie.hacep.core.infra.election.KubernetesLockConfiguration
 
toString() - Method in class org.kie.hacep.core.infra.election.LeaderInfo
 
toString() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
toString() - Method in class org.kie.hacep.EnvConfig
 
toString() - Method in class org.kie.hacep.message.SnapshotMessage
 

U

UNDER_TEST - Static variable in class org.kie.hacep.Config
 
underTest(String) - Method in class org.kie.hacep.EnvConfig
 
underTest(boolean) - Method in class org.kie.hacep.EnvConfig
 
UPDATABLE_KJAR - Static variable in class org.kie.hacep.Config
 
updateOnRunningConsumer(State) - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
updateStatus(State) - Method in class org.kie.hacep.core.infra.consumer.DefaultKafkaConsumer
 
updateStatus(State) - Method in class org.kie.hacep.core.infra.consumer.InfraCallback
 
updateStatus(State) - Method in class org.kie.hacep.core.infra.consumer.LocalConsumer
 
updateStatus(State) - Method in interface org.kie.hacep.core.infra.election.LeadershipCallback
 

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.
valueOf(String) - Static method in enum org.kie.hacep.core.infra.election.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.kie.hacep.PollUnit
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.
values() - Static method in enum org.kie.hacep.core.infra.election.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.kie.hacep.PollUnit
Returns an array containing the constants of this enum type, in the order they are declared.
visit(FireAllRulesCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(FireUntilHaltCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(HaltCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(InsertCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(EventInsertCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(DeleteCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(UpdateCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(ListObjectsCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(ListObjectsCommandClassType) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(GetObjectCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(ListObjectsCommandNamedQuery) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(FactCountCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(SnapshotOnDemandCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(UpdateKJarCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 
visit(GetKJarGAVCommand) - Method in class org.kie.hacep.consumer.CommandHandler
 

W

withControlTopicName(String) - Method in class org.kie.hacep.EnvConfig
 
withEventsTopicName(String) - Method in class org.kie.hacep.EnvConfig
 
withIterationBetweenSnapshot(String) - Method in class org.kie.hacep.EnvConfig
 
withKieSessionInfosTopicName(String) - Method in class org.kie.hacep.EnvConfig
 
withKJarGAV(String) - Method in class org.kie.hacep.EnvConfig
 
withMaxSnapshotAgeSeconds(String) - Method in class org.kie.hacep.EnvConfig
 
withMaxSnapshotRequestAttempts(String) - Method in class org.kie.hacep.EnvConfig
 
withNamespace(String) - Method in class org.kie.hacep.EnvConfig
 
withPollSnapshotTimeout(String) - Method in class org.kie.hacep.EnvConfig
 
withPollSnapshotTimeUnit(String) - Method in class org.kie.hacep.EnvConfig
 
withPollTimeout(String) - Method in class org.kie.hacep.EnvConfig
 
withPollTimeUnit(String) - Method in class org.kie.hacep.EnvConfig
 
withPrinterType(String) - Method in class org.kie.hacep.EnvConfig
 
withSnapshotTopicName(String) - Method in class org.kie.hacep.EnvConfig
 
withUpdatableKJar(String) - Method in class org.kie.hacep.EnvConfig
 
A B C D E F G H I K L M N O P R S T U V W 
Skip navigation links
openshift-kie-hacep 7.33.0.Final-redhat-00002

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