Package io.deephaven.extensions.barrage

Interface BarrageStreamGenerator.Factory<MessageView>

All Known Implementing Classes:
BarrageStreamGeneratorImpl.ArrowFactory, BarrageStreamGeneratorImpl.Factory
Enclosing interface:
BarrageStreamGenerator<MessageView>
public static interface BarrageStreamGenerator.Factory<MessageView>

  • Method Details

    • newGenerator

      BarrageStreamGenerator<MessageView> 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

      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