Package io.deephaven.extensions.barrage

Interface BarrageStreamGenerator.Factory

All Known Implementing Classes:

BarrageStreamGeneratorImpl.ArrowFactory, BarrageStreamGeneratorImpl.Factory

Enclosing interface:

BarrageStreamGenerator

public static interface BarrageStreamGenerator.Factory

Method Summary

Modifier and Type	Method	Description
BarrageStreamGenerator.MessageView	getSchemaView(@NotNull ToIntFunction<com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)	Create a MessageView of the Schema to send as the initial message to a new subscriber.
BarrageStreamGenerator	newGenerator(BarrageMessage message, BarragePerformanceLog.WriteMetricsConsumer metricsConsumer)	Create a StreamGenerator that now owns the BarrageMessage.

Method Details

newGenerator

BarrageStreamGenerator newGenerator(BarrageMessage message,
 BarragePerformanceLog.WriteMetricsConsumer metricsConsumer)

Create a StreamGenerator that now owns the BarrageMessage.

Parameters:

message - the message that contains the update that we would like to propagate

metricsConsumer - a method that can be used to record write metrics

getSchemaView

BarrageStreamGenerator.MessageView getSchemaView(@NotNull
 @NotNull ToIntFunction<com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)

Create a MessageView of the Schema to send as the initial message to a new subscriber.

Parameters:

schemaPayloadWriter - a function that writes schema data to a FlatBufferBuilder and returns the schema offset

Returns:

a MessageView that can be sent to a subscriber