Skip navigation links
Drools :: High Availability :: HA-Core 7.39.0.Final-redhat-00007
A B C D E F G H I K L M N O P R S T U V W 

A

anEnvConfig() - Static method in class org.kie.hacep.EnvConfig
 

B

BidirectionalMap<K,V> - Class in org.kie.hacep.consumer
 
BidirectionalMap() - Constructor for class org.kie.hacep.consumer.BidirectionalMap
 
BOOTSTRAP_SERVERS_KEY - Static variable in class org.kie.hacep.Config
 
BROKER_URL - Static variable in class org.kie.hacep.Config
 

C

canBecomeLeader() - Static method in class org.kie.hacep.core.GlobalStatus
 
CommandHandler - Class in org.kie.hacep.consumer
 
CommandHandler(KieSessionContext, EnvConfig, Producer, SessionSnapshooter, ConsumerUtilsCore) - Constructor for class org.kie.hacep.consumer.CommandHandler
 
Config - Class in org.kie.hacep
 
ConsumerController - Class in org.kie.hacep.core.infra.consumer
 
ConsumerController(ConsumerHandler, EventConsumer) - 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
 
ConsumerUtilsCore - Interface in org.kie.hacep.util
Util class used to perform a single read and then close its consumer on the specific topic

D

DEFAULT_CONTROL_TOPIC - Static variable in class org.kie.hacep.Config
 
DEFAULT_ITERATION_BETWEEN_SNAPSHOT - Static variable in class org.kie.hacep.Config
 
DEFAULT_KAFKA_PORT - Static variable in class org.kie.hacep.Config
 
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_SNAPSHOT_TOPIC - Static variable in class org.kie.hacep.Config
 
deserialize() - Method in interface org.kie.hacep.core.infra.SessionSnapshooter
 
DroolsConsumerHandler - Class in org.kie.hacep.consumer
 
DroolsConsumerHandler(Producer, EnvConfig, SessionSnapshooter, ConsumerUtilsCore) - Constructor for class org.kie.hacep.consumer.DroolsConsumerHandler
 

E

EnvConfig - Class in org.kie.hacep
 
equals(Object) - Method in class org.kie.hacep.consumer.BidirectionalMap
 
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
 
getBootStrapServers() - Static method in class org.kie.hacep.Config
 
getCallback() - Method in class org.kie.hacep.core.infra.consumer.ConsumerController
 
getConsumer() - Method in class org.kie.hacep.core.infra.consumer.ConsumerController
 
getConsumerConfig(String) - Static method in class org.kie.hacep.Config
 
getControlTopicName() - Method in class org.kie.hacep.EnvConfig
 
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
 
getFhManager() - Method in class org.kie.hacep.core.infra.SnapshotInfos
 
getFhManager() - Method in class org.kie.hacep.core.KieSessionContext
 
getFhMapKeys() - Method in class org.kie.hacep.consumer.FactHandlesManager
 
getIterationBetweenSnapshot() - Method in class org.kie.hacep.EnvConfig
 
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
 
getKjarGAVUsed() - Method in class org.kie.hacep.core.KieSessionContext
 
getLastEvent(String, Integer) - Method in interface org.kie.hacep.util.ConsumerUtilsCore
Return the current last event in a specific topic
getLastEvent(String, Properties, Integer) - Method in interface org.kie.hacep.util.ConsumerUtilsCore
Return the current last event
getLastSnapshotTime() - Method in interface org.kie.hacep.core.infra.SessionSnapshooter
 
getMaxSnapshotAge() - Method in class org.kie.hacep.EnvConfig
 
getMaxSnapshotRequestAttempts() - Method in class org.kie.hacep.EnvConfig
 
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
 
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
 
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
 
GlobalStatus - Class in org.kie.hacep.core
Shared global status

H

hashCode() - Method in class org.kie.hacep.consumer.BidirectionalMap
 
hasTimestamp(Object) - Static method in class org.kie.hacep.consumer.CommandHandler
 

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 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, SnapshotInfos) - 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
 
isNodeLive() - Static method in class org.kie.hacep.core.GlobalStatus
 
isNodeReady() - Static method in class org.kie.hacep.core.GlobalStatus
 
isSkipOnDemandSnapshot() - Method in class org.kie.hacep.EnvConfig
 
isUnderTest() - Method in class org.kie.hacep.EnvConfig
 
isUpdatableKJar() - Method in class org.kie.hacep.EnvConfig
 
ItemToProcess - Class in org.kie.hacep.core.infra.consumer
 
ItemToProcess(String, long, Serializable) - 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
 
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
 

L

LeadershipCallback - Interface in org.kie.hacep.core.infra.election
 
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
 

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
 
MILLISEC - Static variable in class org.kie.hacep.EnvConfig
 
MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_HOST - Static variable in class org.kie.hacep.Config
 

N

NAMESPACE - Static variable in class org.kie.hacep.Config
 

O

ObjectFilterHelper - Class in org.kie.hacep.consumer
 
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.util - package org.kie.hacep.util
 

P

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
 
PollUnit - Enum in org.kie.hacep
 
prettyPrinter(String, String, int, long, String, boolean) - Method in interface org.kie.hacep.util.Printer
 
prettyPrinter(String, String, int, long, String, 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
 
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
 
processSideEffectsOnReplica(Queue<Serializable>) - 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

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
 
run() - Method in class org.kie.hacep.core.infra.consumer.ConsumerThread
 

S

SECONDS - Static variable in class org.kie.hacep.EnvConfig
 
serialize(KieSessionContext, String, long) - Method in interface org.kie.hacep.core.infra.SessionSnapshooter
 
SessionSnapshooter - Interface in org.kie.hacep.core.infra
 
setCanBecomeLeader(boolean) - Static method in class org.kie.hacep.core.GlobalStatus
 
setClockAt(long) - Method in class org.kie.hacep.core.KieSessionContext
 
setConsumer(LeadershipCallback) - Method in class org.kie.hacep.core.infra.consumer.InfraCallback
 
setNodeLive(boolean) - Static method in class org.kie.hacep.core.GlobalStatus
 
setNodeReady(boolean) - Static method in class org.kie.hacep.core.GlobalStatus
 
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
 
start() - Method in class org.kie.hacep.core.infra.consumer.ConsumerController
 
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 interface org.kie.hacep.core.infra.consumer.EventConsumer
 
stop() - Method in class org.kie.hacep.core.infra.consumer.LocalConsumer
 

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.EnvConfig
 

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
 
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.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.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
Drools :: High Availability :: HA-Core 7.39.0.Final-redhat-00007

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