Package ai.superstream

Class Superstream

java.lang.Object

ai.superstream.Superstream

public class Superstream
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
String	accountName
io.nats.client.Connection	brokerConnection
SuperstreamCounters	clientCounters
int	clientID
Map<String,?>	config
String	ConsumerSchemaID
com.google.protobuf.Descriptors.Descriptor	descriptor
byte[]	descriptorAsBytes
io.nats.client.JetStream	jetstream
int	learningFactor
int	learningFactorCounter
boolean	learningRequestSent
String	natsConnectionID
String	ProducerSchemaID
Map<String,com.google.protobuf.Descriptors.Descriptor>	SchemaIDMap
String	superstreamJwt
String	superstreamNkey

Constructor Summary

Constructors

Constructor	Description
Superstream(String token, String host, Integer learnfactor, String type, Map<String,?> configs)

Method Summary

Modifier and Type	Method	Description
void	close()
void	handleError(String msg)
static Map<String,Object>	initSuperstreamConfig(Map<String,Object> configs)
static Properties	initSuperstreamProps(Properties properties)
byte[]	jsonToProto(byte[] msgBytes)
static Map<String,Object>	normalizeClientConfig(Map<String,?> javaConfig)
byte[]	protoToJson(byte[] msgBytes, com.google.protobuf.Descriptors.Descriptor desc)
void	registerClient(Map<String,?> configs)
void	reportClientsUpdate()
void	sendClientTypeUpdateReq(String clientType)
void	sendGetSchemaRequest(String schemaID)
void	sendLearningMessage(byte[] msg)
void	sendRegisterSchemaReq()
void	subscribeToUpdates()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

brokerConnection

public io.nats.client.Connection brokerConnection

jetstream

public io.nats.client.JetStream jetstream

superstreamJwt

public String superstreamJwt

superstreamNkey

public String superstreamNkey

descriptorAsBytes

public byte[] descriptorAsBytes

descriptor

public com.google.protobuf.Descriptors.Descriptor descriptor

natsConnectionID

public String natsConnectionID

clientID

public int clientID

accountName

public String accountName

learningFactor

public int learningFactor

learningFactorCounter

public int learningFactorCounter

learningRequestSent

public boolean learningRequestSent

ProducerSchemaID

public String ProducerSchemaID

ConsumerSchemaID

public String ConsumerSchemaID

SchemaIDMap

public Map<String,com.google.protobuf.Descriptors.Descriptor> SchemaIDMap

config

public Map<String,?> config

clientCounters

public SuperstreamCounters clientCounters

Constructor Detail

Superstream

public Superstream(String token,
                   String host,
                   Integer learnfactor,
                   String type,
                   Map<String,?> configs)

Method Detail

close

public void close()

registerClient

public void registerClient(Map<String,?> configs)

sendClientTypeUpdateReq

public void sendClientTypeUpdateReq(String clientType)

subscribeToUpdates

public void subscribeToUpdates()

reportClientsUpdate

public void reportClientsUpdate()

sendLearningMessage

public void sendLearningMessage(byte[] msg)

sendRegisterSchemaReq

public void sendRegisterSchemaReq()

jsonToProto

public byte[] jsonToProto(byte[] msgBytes)
                   throws IOException

Throws:

IOException

protoToJson

public byte[] protoToJson(byte[] msgBytes,
                          com.google.protobuf.Descriptors.Descriptor desc)
                   throws IOException

Throws:

IOException

sendGetSchemaRequest

public void sendGetSchemaRequest(String schemaID)

handleError

public void handleError(String msg)

normalizeClientConfig

public static Map<String,Object> normalizeClientConfig(Map<String,?> javaConfig)

initSuperstreamConfig

public static Map<String,Object> initSuperstreamConfig(Map<String,Object> configs)

initSuperstreamProps

public static Properties initSuperstreamProps(Properties properties)