Index

A B C D E G H I J L N O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values

A

accountName - Variable in class ai.superstream.Superstream

ai.superstream - package ai.superstream

B

brokerConnection - Variable in class ai.superstream.Superstream

C

clientCounters - Variable in class ai.superstream.Superstream

clientID - Variable in class ai.superstream.Superstream

clientReconnectionUpdateSubject - Static variable in class ai.superstream.Consts

clientRegisterSubject - Static variable in class ai.superstream.Consts

clientTypeUpdateSubject - Static variable in class ai.superstream.Consts

close() - Method in class ai.superstream.Superstream

close() - Method in class ai.superstream.SuperstreamConsumerInterceptor

close() - Method in class ai.superstream.SuperstreamDeserializer

close() - Method in class ai.superstream.SuperstreamProducerInterceptor

close() - Method in class ai.superstream.SuperstreamSerializer

configs - Variable in class ai.superstream.Superstream

configure(Map<String, ?>) - Method in class ai.superstream.SuperstreamConsumerInterceptor

configure(Map<String, ?>) - Method in class ai.superstream.SuperstreamProducerInterceptor

configure(Map<String, ?>, boolean) - Method in class ai.superstream.SuperstreamDeserializer

configure(Map<String, ?>, boolean) - Method in class ai.superstream.SuperstreamSerializer

Consts - Class in ai.superstream

Consts() - Constructor for class ai.superstream.Consts

ConsumerSchemaID - Variable in class ai.superstream.Superstream

convertMap(Map<String, Set<Integer>>) - Static method in class ai.superstream.Superstream

D

descriptor - Variable in class ai.superstream.Superstream

descriptorAsBytes - Variable in class ai.superstream.Superstream

deserialize(String, byte[]) - Method in class ai.superstream.SuperstreamDeserializer

deserialize(String, Headers, byte[]) - Method in class ai.superstream.SuperstreamDeserializer

E

executorService - Variable in class ai.superstream.Superstream

G

getID() - Method in class ai.superstream.NatsAuthHandler

getJWT() - Method in class ai.superstream.NatsAuthHandler

getTotalBytesAfterReduction() - Method in class ai.superstream.SuperstreamCounters

getTotalBytesBeforeReduction() - Method in class ai.superstream.SuperstreamCounters

getTotalMessagesFailedConsume() - Method in class ai.superstream.SuperstreamCounters

getTotalMessagesFailedProduce() - Method in class ai.superstream.SuperstreamCounters

getTotalMessagesSuccessfullyConsumed() - Method in class ai.superstream.SuperstreamCounters

getTotalMessagesSuccessfullyProduce() - Method in class ai.superstream.SuperstreamCounters

H

handleError(String) - Method in class ai.superstream.Superstream

I

incrementTotalBytesAfterReduction(long) - Method in class ai.superstream.SuperstreamCounters

incrementTotalBytesBeforeReduction(long) - Method in class ai.superstream.SuperstreamCounters

incrementTotalMessagesFailedConsume() - Method in class ai.superstream.SuperstreamCounters

incrementTotalMessagesFailedProduce() - Method in class ai.superstream.SuperstreamCounters

incrementTotalMessagesSuccessfullyConsumed() - Method in class ai.superstream.SuperstreamCounters

incrementTotalMessagesSuccessfullyProduce() - Method in class ai.superstream.SuperstreamCounters

init() - Method in class ai.superstream.Superstream

initSuperstreamConfig(Map<String, Object>, String) - Static method in class ai.superstream.Superstream

initSuperstreamProps(Properties, String) - Static method in class ai.superstream.Superstream

J

jetstream - Variable in class ai.superstream.Superstream

jsonToProto(byte[]) - Method in class ai.superstream.Superstream

L

learningFactor - Variable in class ai.superstream.Superstream

learningFactorCounter - Variable in class ai.superstream.Superstream

learningRequestSent - Variable in class ai.superstream.Superstream

N

NatsAuthHandler - Class in ai.superstream

NatsAuthHandler(String, String) - Constructor for class ai.superstream.NatsAuthHandler

natsConnectionID - Variable in class ai.superstream.Superstream

normalizeClientConfig(Map<String, ?>) - Static method in class ai.superstream.Superstream

O

onAcknowledgement(RecordMetadata, Exception) - Method in class ai.superstream.SuperstreamProducerInterceptor

onCommit(Map<TopicPartition, OffsetAndMetadata>) - Method in class ai.superstream.SuperstreamConsumerInterceptor

onConsume(ConsumerRecords<K, V>) - Method in class ai.superstream.SuperstreamConsumerInterceptor

onSend(ProducerRecord<K, V>) - Method in class ai.superstream.SuperstreamProducerInterceptor

originalDeserializer - Static variable in class ai.superstream.Consts

originalSerializer - Static variable in class ai.superstream.Consts

P

ProducerSchemaID - Variable in class ai.superstream.Superstream

propertiesToMap(Properties) - Static method in class ai.superstream.Superstream

protoToJson(byte[], Descriptors.Descriptor) - Method in class ai.superstream.Superstream

R

reductionEnabled - Variable in class ai.superstream.Superstream

registerClient(Map<String, ?>) - Method in class ai.superstream.Superstream

reportClientsUpdate() - Method in class ai.superstream.Superstream

reset() - Method in class ai.superstream.SuperstreamCounters

S

SchemaIDMap - Variable in class ai.superstream.Superstream

sdkVersion - Static variable in class ai.superstream.Consts

sendClientTypeUpdateReq() - Method in class ai.superstream.Superstream

sendGetSchemaRequest(String) - Method in class ai.superstream.Superstream

sendLearningMessage(byte[]) - Method in class ai.superstream.Superstream

sendRegisterSchemaReq() - Method in class ai.superstream.Superstream

serialize(String, Headers, T) - Method in class ai.superstream.SuperstreamSerializer

serialize(String, T) - Method in class ai.superstream.SuperstreamSerializer

setTotalBytesAfterReduction(long) - Method in class ai.superstream.SuperstreamCounters

setTotalBytesBeforeReduction(long) - Method in class ai.superstream.SuperstreamCounters

setTotalMessagesFailedConsume(int) - Method in class ai.superstream.SuperstreamCounters

setTotalMessagesFailedProduce(int) - Method in class ai.superstream.SuperstreamCounters

setTotalMessagesSuccessfullyConsumed(int) - Method in class ai.superstream.SuperstreamCounters

setTotalMessagesSuccessfullyProduce(int) - Method in class ai.superstream.SuperstreamCounters

sign(byte[]) - Method in class ai.superstream.NatsAuthHandler

subscribeToUpdates() - Method in class ai.superstream.Superstream

Superstream - Class in ai.superstream

Superstream(String, String, Integer, Map<String, Object>, Boolean, String) - Constructor for class ai.superstream.Superstream

superstreamClientsUpdateSubject - Static variable in class ai.superstream.Consts

superstreamConnectionKey - Static variable in class ai.superstream.Consts

SuperstreamConsumerInterceptor<K,V> - Class in ai.superstream

SuperstreamConsumerInterceptor() - Constructor for class ai.superstream.SuperstreamConsumerInterceptor

SuperstreamCounters - Class in ai.superstream

SuperstreamCounters() - Constructor for class ai.superstream.SuperstreamCounters

superstreamDefaultLearningFactor - Static variable in class ai.superstream.Consts

superstreamDefaultToken - Static variable in class ai.superstream.Consts

SuperstreamDeserializer<T> - Class in ai.superstream

SuperstreamDeserializer() - Constructor for class ai.superstream.SuperstreamDeserializer

superstreamErrorSubject - Static variable in class ai.superstream.Consts

superstreamGetSchemaSubject - Static variable in class ai.superstream.Consts

superstreamHostKey - Static variable in class ai.superstream.Consts

superstreamInternalUsername - Static variable in class ai.superstream.Consts

superstreamJwt - Variable in class ai.superstream.Superstream

superstreamLearningFactorKey - Static variable in class ai.superstream.Consts

superstreamLearningSubject - Static variable in class ai.superstream.Consts

superstreamNkey - Variable in class ai.superstream.Superstream

SuperstreamProducerInterceptor<K,V> - Class in ai.superstream

SuperstreamProducerInterceptor() - Constructor for class ai.superstream.SuperstreamProducerInterceptor

superstreamReductionEnabledKey - Static variable in class ai.superstream.Consts

superstreamRegisterSchemaSubject - Static variable in class ai.superstream.Consts

SuperstreamSerializer<T> - Class in ai.superstream

SuperstreamSerializer() - Constructor for class ai.superstream.SuperstreamSerializer

superstreamTokenKey - Static variable in class ai.superstream.Consts

superstreamUpdatesSubject - Static variable in class ai.superstream.Consts

T

topicPartitions - Variable in class ai.superstream.Superstream

TotalBytesAfterReduction - Variable in class ai.superstream.SuperstreamCounters

TotalBytesBeforeReduction - Variable in class ai.superstream.SuperstreamCounters

TotalMessagesFailedConsume - Variable in class ai.superstream.SuperstreamCounters

TotalMessagesFailedProduce - Variable in class ai.superstream.SuperstreamCounters

TotalMessagesSuccessfullyConsumed - Variable in class ai.superstream.SuperstreamCounters

TotalMessagesSuccessfullyProduce - Variable in class ai.superstream.SuperstreamCounters

type - Variable in class ai.superstream.Superstream

U

updateTopicPartitions(String, Integer) - Method in class ai.superstream.Superstream

A B C D E G H I J L N O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values