A B C D G H I J L N O P R S T
All Classes All Packages

A

accountName - Variable in class superstream.Superstream

B

brokerConnection - Variable in class superstream.Superstream

C

clientCounters - Variable in class superstream.Superstream

clientID - Variable in class superstream.Superstream

clientReconnectionUpdateSubject - Static variable in class superstream.Consts

clientRegisterSubject - Static variable in class superstream.Consts

clientTypeUpdateSubject - Static variable in class superstream.Consts

close() - Method in class superstream.Superstream

close() - Method in class superstream.SuperstreamDeserializer

close() - Method in class superstream.SuperstreamSerializer

config - Variable in class superstream.Superstream

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

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

Consts - Class in superstream

Consts() - Constructor for class superstream.Consts

ConsumerSchemaID - Variable in class superstream.Superstream

D

descriptor - Variable in class superstream.Superstream

descriptorAsBytes - Variable in class superstream.Superstream

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

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

G

getID() - Method in class superstream.NatsAuthHandler

getJWT() - Method in class superstream.NatsAuthHandler

getTotalBytesAfterReduction() - Method in class superstream.SuperstreamCounters

getTotalBytesBeforeReduction() - Method in class superstream.SuperstreamCounters

getTotalMessagesFailedConsume() - Method in class superstream.SuperstreamCounters

getTotalMessagesFailedProduce() - Method in class superstream.SuperstreamCounters

getTotalMessagesSuccessfullyConsumed() - Method in class superstream.SuperstreamCounters

getTotalMessagesSuccessfullyProduce() - Method in class superstream.SuperstreamCounters

H

handleError(String) - Method in class superstream.Superstream

I

incrementTotalBytesAfterReduction(long) - Method in class superstream.SuperstreamCounters

incrementTotalBytesBeforeReduction(long) - Method in class superstream.SuperstreamCounters

incrementTotalMessagesFailedConsume() - Method in class superstream.SuperstreamCounters

incrementTotalMessagesFailedProduce() - Method in class superstream.SuperstreamCounters

incrementTotalMessagesSuccessfullyConsumed() - Method in class superstream.SuperstreamCounters

incrementTotalMessagesSuccessfullyProduce() - Method in class superstream.SuperstreamCounters

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

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

J

jetstream - Variable in class superstream.Superstream

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

L

learningFactor - Variable in class superstream.Superstream

learningFactorCounter - Variable in class superstream.Superstream

learningRequestSent - Variable in class superstream.Superstream

N

NatsAuthHandler - Class in superstream

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

natsConnectionID - Variable in class superstream.Superstream

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

O

originalDeserializer - Static variable in class superstream.Consts

originalSerializer - Static variable in class superstream.Consts

P

ProducerSchemaID - Variable in class superstream.Superstream

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

R

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

reportClientsUpdate() - Method in class superstream.Superstream

reset() - Method in class superstream.SuperstreamCounters

S

SchemaIDMap - Variable in class superstream.Superstream

sdkVersion - Static variable in class superstream.Consts

sendClientTypeUpdateReq(String) - Method in class superstream.Superstream

sendGetSchemaRequest(String) - Method in class superstream.Superstream

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

sendRegisterSchemaReq() - Method in class superstream.Superstream

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

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

setTotalBytesAfterReduction(long) - Method in class superstream.SuperstreamCounters

setTotalBytesBeforeReduction(long) - Method in class superstream.SuperstreamCounters

setTotalMessagesFailedConsume(int) - Method in class superstream.SuperstreamCounters

setTotalMessagesFailedProduce(int) - Method in class superstream.SuperstreamCounters

setTotalMessagesSuccessfullyConsumed(int) - Method in class superstream.SuperstreamCounters

setTotalMessagesSuccessfullyProduce(int) - Method in class superstream.SuperstreamCounters

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

subscribeToUpdates() - Method in class superstream.Superstream

superstream - package superstream

Superstream - Class in superstream

Superstream(String, String, Integer, String, Map<String, ?>) - Constructor for class superstream.Superstream

superstreamClientsUpdateSubject - Static variable in class superstream.Consts

SuperstreamCounters - Class in superstream

SuperstreamCounters() - Constructor for class superstream.SuperstreamCounters

superstreamDefaultHost - Static variable in class superstream.Consts

superstreamDefaultLearningFactor - Static variable in class superstream.Consts

SuperstreamDeserializer<T> - Class in superstream

SuperstreamDeserializer() - Constructor for class superstream.SuperstreamDeserializer

superstreamErrorSubject - Static variable in class superstream.Consts

superstreamGetSchemaSubject - Static variable in class superstream.Consts

superstreamHostKey - Static variable in class superstream.Consts

superstreamInternalUsername - Static variable in class superstream.Consts

superstreamJwt - Variable in class superstream.Superstream

superstreamLearningFactorKey - Static variable in class superstream.Consts

superstreamLearningSubject - Static variable in class superstream.Consts

superstreamNkey - Variable in class superstream.Superstream

superstreamRegisterSchemaSubject - Static variable in class superstream.Consts

SuperstreamSerializer<T> - Class in superstream

SuperstreamSerializer() - Constructor for class superstream.SuperstreamSerializer

superstreamTokenKey - Static variable in class superstream.Consts

superstreamUpdatesSubject - Static variable in class superstream.Consts

T

TotalBytesAfterReduction - Variable in class superstream.SuperstreamCounters

TotalBytesBeforeReduction - Variable in class superstream.SuperstreamCounters

TotalMessagesFailedConsume - Variable in class superstream.SuperstreamCounters

TotalMessagesFailedProduce - Variable in class superstream.SuperstreamCounters

TotalMessagesSuccessfullyConsumed - Variable in class superstream.SuperstreamCounters

TotalMessagesSuccessfullyProduce - Variable in class superstream.SuperstreamCounters

A B C D G H I J L N O P R S T
All Classes All Packages