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

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

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