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
static interface	Superstream.CompressionUpdateCallback
class	Superstream.JsonToProtoResult

Field Summary

Fields

Modifier and Type	Field	Description
String	accountName
io.nats.client.Connection	brokerConnection
Boolean	canStart
final SuperstreamCounters	clientCounters
String	clientHash
Boolean	compressionEnabled
Map<String,Object>	configs
String	ConsumerSchemaID
com.google.protobuf.Descriptors.Descriptor	descriptor
byte[]	descriptorAsBytes
ExecutorService	executorService
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
Boolean	superstreamReady
Map<String,Set<Integer>>	topicPartitions
String	type

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
static Map<String,Integer[]>	convertMap(Map<String,Set<Integer>> topicPartitions)
void	handleError(String msg)
void	init()
static Map<String,Object>	initSuperstreamConfig(Map<String,Object> configs, String type)
static Properties	initSuperstreamProps(Properties properties, String type)
Superstream.JsonToProtoResult	jsonToProto(byte[] msgBytes)
static Map<String,Object>	normalizeClientConfig(Map<String,?> javaConfig)
static Map<String,Object>	propertiesToMap(Properties properties)
byte[]	protoToJson(byte[] msgBytes, com.google.protobuf.Descriptors.Descriptor desc)
void	registerClient(Map<String,?> configs)
void	reportClientsUpdate()
void	sendClientTypeUpdateReq()
void	sendGetSchemaRequest(String schemaID)
void	sendLearningMessage(byte[] msg)
void	sendRegisterSchemaReq()
void	setCompressionUpdateCallback(Superstream.CompressionUpdateCallback callback)
void	subscribeToUpdates()
void	updateClientCounters(Consumer<SuperstreamCounters> updateFunction)
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

clientHash

public String clientHash

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,Object> configs

clientCounters

public final SuperstreamCounters clientCounters

type

public String type

reductionEnabled

public Boolean reductionEnabled

topicPartitions

public Map<String,Set<Integer>> topicPartitions

executorService

public ExecutorService executorService

superstreamReady

public Boolean superstreamReady

canStart

public Boolean canStart

compressionEnabled

public Boolean compressionEnabled

Constructor Details

Superstream

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

Superstream

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

Method Details

init

public void init()

close

public void close()

setCompressionUpdateCallback

public void setCompressionUpdateCallback(Superstream.CompressionUpdateCallback callback)

updateClientCounters

public void updateClientCounters(Consumer<SuperstreamCounters> updateFunction)

registerClient

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

sendClientTypeUpdateReq

public void sendClientTypeUpdateReq()

subscribeToUpdates

public void subscribeToUpdates()

reportClientsUpdate

public void reportClientsUpdate()

convertMap

public static Map<String,Integer[]> convertMap(Map<String,Set<Integer>> topicPartitions)

sendLearningMessage

public void sendLearningMessage(byte[] msg)

sendRegisterSchemaReq

public void sendRegisterSchemaReq()

jsonToProto

public Superstream.JsonToProtoResult jsonToProto(byte[] msgBytes)
                                          throws Exception

Throws:

Exception

protoToJson

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

Throws:

Exception

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,
 String type)

initSuperstreamProps

public static Properties initSuperstreamProps(Properties properties,
 String type)

propertiesToMap

public static Map<String,Object> propertiesToMap(Properties properties)

updateTopicPartitions

public void updateTopicPartitions(String topic,
 Integer partition)