A B C D E F G H I K L M N O P Q R S T V W Z 

A

AbstractEventProducer<K,V> - Class in org.cg.eventbus.producer
Producer using string key to partition
AbstractEventProducer(String) - Constructor for class org.cg.eventbus.producer.AbstractEventProducer
 
AbstractEventProducer(String, String) - Constructor for class org.cg.eventbus.producer.AbstractEventProducer
 
AbstractEventProducer(Configuration, String) - Constructor for class org.cg.eventbus.producer.AbstractEventProducer
 
AbstractEventProducer(Configuration) - Constructor for class org.cg.eventbus.producer.AbstractEventProducer
 
AUTO_CREATE - Static variable in interface org.cg.eventbus.IEventBus
 
AvroSerializer<T> - Class in org.cg.eventbus
Event bus Avro serializer/deserializer.
AvroSerializer(Class<T>) - Constructor for class org.cg.eventbus.AvroSerializer
 

B

BaseManager<V> - Class in org.cg.eventbus.producer.manager
 
BaseManager() - Constructor for class org.cg.eventbus.producer.manager.BaseManager
 
beforeProcess(K, V) - Method in interface org.cg.eventbus.IEventListener
 
borrowProducer(String) - Method in class org.cg.eventbus.producer.manager.BaseManager
 
BROKER_LIST - Static variable in interface org.cg.eventbus.IProducer
 
build() - Method in class org.cg.eventbus.consumer.bytestream.ConsumerConfigFactory
 
BYTE_SERIALIZER_CLASS - Static variable in interface org.cg.eventbus.IProducer
 

C

cloneTaskConfig(Configuration, String, int) - Static method in class org.cg.eventbus.producer.manager.ManagerConfigurator
 
close() - Method in class org.cg.eventbus.AvroSerializer
 
close() - Method in class org.cg.eventbus.consumer.bytestream.GenericFetcher
 
close() - Method in interface org.cg.eventbus.IProducer
 
close() - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
close() - Method in class org.cg.eventbus.producer.manager.BaseManager
Release resources manager and its producers/pools have.
close() - Method in class org.cg.eventbus.stream.Dispatcher
 
close() - Method in class org.cg.eventbus.stream.Fetcher
 
close() - Method in interface org.cg.eventbus.stream.IReporter
 
commit - Variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
commit() - Method in class org.cg.eventbus.consumer.bytestream.GenericFetcher
 
commit() - Method in class org.cg.eventbus.stream.Fetcher
 
COMMIT_INTERVAL - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
CommitPolicy - Class in org.cg.eventbus.policy
 
CommitPolicy() - Constructor for class org.cg.eventbus.policy.CommitPolicy
 
config - Variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
configKeyDecoder(Properties) - Static method in class org.cg.eventbus.consumer.ConsumerConfigrator
 
configTopicListenersMap(Properties) - Static method in class org.cg.eventbus.consumer.ConsumerConfigrator
 
configTopicStreamsMap(Properties) - Static method in class org.cg.eventbus.consumer.ConsumerConfigrator
 
configure(Map<String, ?>, boolean) - Method in class org.cg.eventbus.AvroSerializer
 
ConfigUtil - Class in org.cg.eventbus
 
ConfigUtil() - Constructor for class org.cg.eventbus.ConfigUtil
 
configValueDecoder(Properties) - Static method in class org.cg.eventbus.consumer.ConsumerConfigrator
 
CONSUMER_LISTENERS - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
CONSUMER_STREAMS - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
CONSUMER_THREAD_POOL_SIZE - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
CONSUMER_TOPICS - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
ConsumerConfigFactory - Class in org.cg.eventbus.consumer.bytestream
Building a consumer config factory,
using configuration, or building it step by step
ConsumerConfigFactory() - Constructor for class org.cg.eventbus.consumer.bytestream.ConsumerConfigFactory
 
ConsumerConfigrator - Class in org.cg.eventbus.consumer
 
ConsumerConfigrator() - Constructor for class org.cg.eventbus.consumer.ConsumerConfigrator
 
create() - Method in class org.cg.eventbus.producer.PooledEventProducerFactory
 
createTopic(String, int, int) - Method in class org.cg.eventbus.EventBusManager
 

D

DEFAULT_BROKER_LIST - Static variable in class org.cg.eventbus.producer.AbstractEventProducer
 
DEFAULT_COMMIT_INTERVAL - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_CONNECTION_TIMEOUT - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_GROUP_ID - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_KEY - Static variable in interface org.cg.eventbus.IProducer
 
DEFAULT_PARTITION - Static variable in class org.cg.eventbus.producer.AbstractEventProducer
 
DEFAULT_PRO_ZK_CONNECT - Static variable in interface org.cg.eventbus.IEventBus
 
DEFAULT_SINGLE_TOPIC - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_STREAM_THREADS - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_SUB_ZK_CONNECT - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_THREAD_POOL_SIZE - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_ZKCLIENT_CONNECTION_TIMEOUT - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_ZKCLIENT_SERVER - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
DEFAULT_ZKCLIENT_SESSION_TIMEOUT - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
deleteTopic(String) - Method in class org.cg.eventbus.EventBusManager
 
deserialize(String, byte[]) - Method in class org.cg.eventbus.AvroSerializer
 
destroyObject(PooledObject<AbstractEventProducer<K, V>>) - Method in class org.cg.eventbus.producer.PooledEventProducerFactory
 
Dispatcher - Class in org.cg.eventbus.consumer.bytestream
 
Dispatcher(Configuration, Configuration, Configuration, CommitPolicy) - Constructor for class org.cg.eventbus.consumer.bytestream.Dispatcher
 
Dispatcher<K,V> - Class in org.cg.eventbus.stream
 
Dispatcher(Configuration, IHandler, IReporter, IPolicy) - Constructor for class org.cg.eventbus.stream.Dispatcher
 

E

EventBusManager - Class in org.cg.eventbus
 
EventBusManager(String) - Constructor for class org.cg.eventbus.EventBusManager
 
EventBusManager.Connection - Class in org.cg.eventbus
 
EventBusManager.Connection() - Constructor for class org.cg.eventbus.EventBusManager.Connection
 
EventBusManager.Connection(String, int) - Constructor for class org.cg.eventbus.EventBusManager.Connection
 
EventProducerPool<K,V> - Class in org.cg.eventbus.producer
 
EventProducerPool(Class<? extends AbstractEventProducer>, Configuration) - Constructor for class org.cg.eventbus.producer.EventProducerPool
 
extractConfiguration(Properties, String) - Static method in class org.cg.eventbus.ConfigUtil
extract sub domain configurations
extractConfiguration(Configuration, String) - Static method in class org.cg.eventbus.ConfigUtil
 
extractProperties(Properties, String) - Static method in class org.cg.eventbus.ConfigUtil
 

F

fetcher - Variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
Fetcher<K,V> - Class in org.cg.eventbus.stream
 
Fetcher(Configuration) - Constructor for class org.cg.eventbus.stream.Fetcher
 
FetcherHook - Class in org.cg.eventbus.hook
Hook for event bus Fetcher.
FetcherHook(ConsumerConnector) - Constructor for class org.cg.eventbus.hook.FetcherHook
 
fromBytes(byte[]) - Method in class org.cg.eventbus.AvroSerializer
 

G

GenericFetcher - Class in org.cg.eventbus.consumer.bytestream
Generic Kafka Consumer
GenericFetcher(Configuration) - Constructor for class org.cg.eventbus.consumer.bytestream.GenericFetcher
 
getAllPartitions() - Method in class org.cg.eventbus.EventBusManager
 
getAllTopics() - Method in class org.cg.eventbus.EventBusManager
 
getConfig() - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
getConfig(Configuration) - Static method in class org.cg.eventbus.producer.manager.ManagerConfigurator
 
getEventBusInfo() - Method in class org.cg.eventbus.EventBusManager
 
getEventBusSize() - Method in class org.cg.eventbus.EventBusManager
 
getGroupId() - Method in class org.cg.eventbus.consumer.SymmetricDispatcher
Just get client ID
getHost() - Method in class org.cg.eventbus.EventBusManager.Connection
 
getInstance(Configuration) - Static method in class org.cg.eventbus.producer.manager.BaseManager
 
getKey(V) - Method in interface org.cg.eventbus.IProducer
 
getKey() - Method in class org.cg.eventbus.message.Message
 
getLogger() - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
getOffset() - Method in class org.cg.eventbus.ICallback.Response
 
getOffset() - Method in class org.cg.eventbus.message.Message
 
getPartition() - Method in class org.cg.eventbus.ICallback.Response
 
getPartition() - Method in class org.cg.eventbus.message.Message
 
getPartitionByTopic(String) - Method in class org.cg.eventbus.EventBusManager
 
getPayload() - Method in class org.cg.eventbus.message.Message
 
getPort() - Method in class org.cg.eventbus.EventBusManager.Connection
 
getStream() - Method in class org.cg.eventbus.stream.Fetcher
 
getTopic() - Method in class org.cg.eventbus.ICallback.Response
 
getTopic() - Method in class org.cg.eventbus.message.Message
 
GROUP_ID - Static variable in interface org.cg.eventbus.consumer.IConsumer
 

H

handle(T) - Method in interface org.cg.eventbus.message.MessageHandler
 
handle(MessageAndMetadata<K, V>, IReporter) - Method in interface org.cg.eventbus.stream.IHandler
 
handler - Variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
handlerConfig - Variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
hasNext() - Method in class org.cg.eventbus.consumer.bytestream.GenericFetcher
 
hasNext() - Method in class org.cg.eventbus.stream.Fetcher
 
hasTopic(String) - Method in class org.cg.eventbus.EventBusManager
 

I

ICallback - Interface in org.cg.eventbus
 
ICallback.Response - Class in org.cg.eventbus
 
ICallback.Response() - Constructor for class org.cg.eventbus.ICallback.Response
 
IConsumer<K,V> - Interface in org.cg.eventbus.consumer
 
IDLE_SIZE - Static variable in class org.cg.eventbus.producer.EventProducerPool
 
IEventBus - Interface in org.cg.eventbus
 
IEventBusSerializer<T> - Interface in org.cg.eventbus
Combination of serializer and deseriliazer for producer and consumer to use it in event bus, create a default constructor.
IEventListener<K,V> - Interface in org.cg.eventbus
 
IHandler<K,V> - Interface in org.cg.eventbus.stream
 
IManager<K,V> - Interface in org.cg.eventbus
 
increasePartitionByTopic(String, int) - Method in class org.cg.eventbus.EventBusManager
 
init(Configuration) - Method in interface org.cg.eventbus.message.MessageHandler
 
init() - Method in interface org.cg.eventbus.policy.IPolicy
 
initHandler() - Method in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
initialize(Configuration) - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
IPolicy - Interface in org.cg.eventbus.policy
 
IProducer<K,V> - Interface in org.cg.eventbus
interface to further simplify the pub sub api
IReporter<V,T> - Interface in org.cg.eventbus.stream
 
isBrokerUp(int) - Method in class org.cg.eventbus.EventBusManager
 
isEventBusUp() - Method in class org.cg.eventbus.EventBusManager
 

K

KEY_DECODER - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
KEY_SERIALIZER_CLASS - Static variable in interface org.cg.eventbus.IProducer
 

L

launch() - Method in class org.cg.eventbus.consumer.SymmetricDispatcher
launch processor thread N topic, each topic -> M stream -> M thread
LEADER_ACK - Static variable in class org.cg.eventbus.producer.AbstractEventProducer
 
LOG - Static variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 

M

ManagerConfigurator - Class in org.cg.eventbus.producer.manager
 
ManagerConfigurator() - Constructor for class org.cg.eventbus.producer.manager.ManagerConfigurator
 
Message - Class in org.cg.eventbus.message
 
Message(String, long, byte[], byte[], int) - Constructor for class org.cg.eventbus.message.Message
 
Message(String, long, byte[], byte[]) - Constructor for class org.cg.eventbus.message.Message
 
MessageHandler<T> - Interface in org.cg.eventbus.message
 
MessageParser<V> - Class in org.cg.eventbus.parser
 
MessageParser(Configuration) - Constructor for class org.cg.eventbus.parser.MessageParser
 

N

needCommit() - Method in class org.cg.eventbus.policy.CommitPolicy
 
needCommit(Message) - Method in class org.cg.eventbus.policy.CommitPolicy
 
needCommit() - Method in class org.cg.eventbus.policy.StrictCommitPolicy
 
needCommit(Message) - Method in class org.cg.eventbus.policy.StrictCommitPolicy
 
nextMessage() - Method in class org.cg.eventbus.stream.Fetcher
 
NO_ACK - Static variable in class org.cg.eventbus.producer.AbstractEventProducer
 
NO_SUCH_BROKER - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
NO_SUCH_TOPIC - Static variable in interface org.cg.eventbus.consumer.IConsumer
 

O

onCompletion(ICallback.Response, Exception) - Method in interface org.cg.eventbus.ICallback
 
org.cg.eventbus - package org.cg.eventbus
 
org.cg.eventbus.consumer - package org.cg.eventbus.consumer
 
org.cg.eventbus.consumer.bytestream - package org.cg.eventbus.consumer.bytestream
 
org.cg.eventbus.hook - package org.cg.eventbus.hook
 
org.cg.eventbus.message - package org.cg.eventbus.message
 
org.cg.eventbus.parser - package org.cg.eventbus.parser
 
org.cg.eventbus.policy - package org.cg.eventbus.policy
 
org.cg.eventbus.producer - package org.cg.eventbus.producer
 
org.cg.eventbus.producer.manager - package org.cg.eventbus.producer.manager
 
org.cg.eventbus.stream - package org.cg.eventbus.stream
 

P

parser(Message) - Method in class org.cg.eventbus.parser.MessageParser
 
parserConfig - Variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
PARTITION_CLASS - Static variable in interface org.cg.eventbus.IProducer
 
pieceDone() - Method in interface org.cg.eventbus.policy.IPolicy
 
pingServer(String) - Static method in class org.cg.eventbus.EventBusManager
 
policy - Variable in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
poll() - Method in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
POOL_SIZE - Static variable in class org.cg.eventbus.producer.EventProducerPool
 
PooledEventProducerFactory<K,V> - Class in org.cg.eventbus.producer
 
PooledEventProducerFactory(Class<? extends AbstractEventProducer>, String) - Constructor for class org.cg.eventbus.producer.PooledEventProducerFactory
 
PooledEventProducerFactory(Class<? extends AbstractEventProducer>, Configuration) - Constructor for class org.cg.eventbus.producer.PooledEventProducerFactory
 
postProcess(K, V) - Method in interface org.cg.eventbus.IEventListener
 
preWork(V) - Method in interface org.cg.eventbus.stream.IReporter
 
PRO_TYPE - Static variable in interface org.cg.eventbus.IProducer
 
PRO_TYPE_ASYNC - Static variable in class org.cg.eventbus.producer.AbstractEventProducer
 
process(K, V) - Method in interface org.cg.eventbus.IEventListener
 
PRODUCER_TOPIC - Static variable in interface org.cg.eventbus.IProducer
 
ProducerConfigurator - Class in org.cg.eventbus.producer
 
ProducerConfigurator() - Constructor for class org.cg.eventbus.producer.ProducerConfigurator
 

Q

QUIT_ON_ERROR - Static variable in class org.cg.eventbus.producer.AbstractEventProducer
 

R

read() - Method in class org.cg.eventbus.consumer.bytestream.GenericFetcher
 
RECOVERY_FILE_PATH - Static variable in interface org.cg.eventbus.IProducer
 
REPLICAS_ACK - Static variable in class org.cg.eventbus.producer.AbstractEventProducer
 
report(V) - Method in interface org.cg.eventbus.stream.IReporter
 
REQUEST_REQUIRED_ACKS - Static variable in interface org.cg.eventbus.IProducer
 
returnProducer(String, AbstractEventProducer) - Method in class org.cg.eventbus.producer.manager.BaseManager
 
run() - Method in class org.cg.eventbus.consumer.bytestream.Dispatcher
 
run() - Method in class org.cg.eventbus.hook.FetcherHook
 
run() - Method in class org.cg.eventbus.stream.Dispatcher
 

S

send(V, ICallback) - Method in interface org.cg.eventbus.IProducer
 
send(List<V>, ICallback) - Method in interface org.cg.eventbus.IProducer
 
send(K, V, ICallback) - Method in interface org.cg.eventbus.IProducer
 
send(List<K>, List<V>, ICallback) - Method in interface org.cg.eventbus.IProducer
 
send(V, ICallback) - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
send(List<V>, ICallback) - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
send(K, V, ICallback) - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
send(List<K>, List<V>, ICallback) - Method in class org.cg.eventbus.producer.AbstractEventProducer
 
send(V) - Method in class org.cg.eventbus.producer.manager.BaseManager
 
serialize(String, T) - Method in class org.cg.eventbus.AvroSerializer
 
setConfig(Configuration) - Method in class org.cg.eventbus.consumer.bytestream.ConsumerConfigFactory
 
setHost(String) - Method in class org.cg.eventbus.EventBusManager.Connection
 
setOffset(long) - Method in class org.cg.eventbus.ICallback.Response
 
setPartition(int) - Method in class org.cg.eventbus.ICallback.Response
 
setPort(int) - Method in class org.cg.eventbus.EventBusManager.Connection
 
setTopic(String) - Method in class org.cg.eventbus.ICallback.Response
 
setZookeeperConnection(String) - Method in class org.cg.eventbus.consumer.bytestream.ConsumerConfigFactory
 
shutdown() - Method in class org.cg.eventbus.consumer.SymmetricDispatcher
Shutdown this CONSUMER, set offsets correctly and then shutdown everything
shutdown() - Method in class org.cg.eventbus.EventBusManager
 
SINGLE_TOPIC - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
StrictCommitPolicy - Class in org.cg.eventbus.policy
A very strict commit policy.
StrictCommitPolicy() - Constructor for class org.cg.eventbus.policy.StrictCommitPolicy
 
STRING_SERIALIZER_CLASS - Static variable in interface org.cg.eventbus.IProducer
 
SymmetricDispatcher<K,V> - Class in org.cg.eventbus.consumer
SymmetricDispatcher has one kafka consumer, dispatcher can be launched into multiple processes, kafka should auto balance its consumers therefore it is symmetric.
SymmetricDispatcher(String) - Constructor for class org.cg.eventbus.consumer.SymmetricDispatcher
 
SymmetricDispatcher(Configuration) - Constructor for class org.cg.eventbus.consumer.SymmetricDispatcher
 
SymmetricDispatcher(Properties) - Constructor for class org.cg.eventbus.consumer.SymmetricDispatcher
 

T

TOPIC_LIST - Static variable in interface org.cg.eventbus.IManager
 
TOPIC_PARTITION_NUM - Static variable in interface org.cg.eventbus.IProducer
 
TOPIC_REPLICATION_FACTOR - Static variable in interface org.cg.eventbus.IProducer
 
toString() - Method in class org.cg.eventbus.EventBusManager.Connection
 
toString() - Method in class org.cg.eventbus.ICallback.Response
 
toString() - Method in class org.cg.eventbus.message.Message
 

V

validate(Properties) - Static method in class org.cg.eventbus.consumer.ConsumerConfigrator
mandatory properties are: group.id zookeeper.connect key.decoder value.decoder topics (a comma-separated String list)
validate(Configuration) - Static method in class org.cg.eventbus.producer.manager.ManagerConfigurator
 
validate(Configuration) - Static method in class org.cg.eventbus.producer.ProducerConfigurator
validate required configuration zk.connect: zookeeper connection metadata.broker.list: kafka broker list producer.topic: topic name this producer sending to
VALUE_DECODER - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
VALUE_SERIALIZER_CLASS - Static variable in interface org.cg.eventbus.IProducer
 

W

wrap(AbstractEventProducer<K, V>) - Method in class org.cg.eventbus.producer.PooledEventProducerFactory
 

Z

ZK_CONNECT - Static variable in interface org.cg.eventbus.IEventBus
Kafka only uses ZK in consumer config, the reason we expose this to common configuration is we will optionally auto create the topic in server kick off
ZKCONNECTION_TIMEOUT - Static variable in interface org.cg.eventbus.consumer.IConsumer
 
A B C D E F G H I K L M N O P Q R S T V W Z 

Copyright © 2018 CodeGerm. All rights reserved.