Package ai.superstream

Class Superstream

java.lang.Object

ai.superstream.Superstream

public class Superstream
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Superstream.SuperstreamConsumerInterceptor<K,V>
class	Superstream.SuperstreamProducerInterceptor<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
String	accountName
io.nats.client.Connection	brokerConnection
SuperstreamCounters	clientCounters
int	clientID
Map<String,?>	configs
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
Boolean	reductionEnabled
Map<String,com.google.protobuf.Descriptors.Descriptor>	SchemaIDMap
String	superstreamJwt
String	superstreamNkey
Map<String,Set<Integer>>	topicPartitions
String	type

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
void	handleError(String msg)
void	init()
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()
void	updateTopicPartitions(String topic, Integer partition)

Methods inherited from class java.lang.Object

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

Field Details

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

configs

public Map<String,?> configs

clientCounters

public SuperstreamCounters clientCounters

type

public String type

reductionEnabled

public Boolean reductionEnabled

topicPartitions

public Map<String,Set<Integer>> topicPartitions

Constructor Details

Superstream

public Superstream(String token,
 String host,
 Integer learningFactor,
 String type,
 Map<String,?> configs,
 Boolean enableReduction)

Method Details

init

public void init()

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)

updateTopicPartitions

public void updateTopicPartitions(String topic,
 Integer partition)