Package io.deephaven.server.arrow

Interface ExchangeRequestHandlerFactory

All Known Implementing Classes:
BarrageSnapshotRequestHandler.BarrageSnapshotRequestHandlerFactory, BarrageSubscriptionRequestHandler.BarrageSubscriptionRequestHandlerFactory
public interface ExchangeRequestHandlerFactory
The ExchangeRequestHandlerFactory is a pluggable component within ArrowFlightUtil that provides a handler for each type of barrage message.

Only one factory is permitted per message type.

Note: this interface is not yet stable.

  • Method Details

    • type

      byte type()
      The type of message that this factory produces a handler for.

      Message types are defined in BarrageMessageType.

      Returns:
      the type of message handled by this factory

    • create

      ArrowFlightUtil.DoExchangeMarshaller.Handler create(ArrowFlightUtil.DoExchangeMarshaller marshaller, io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)
      Creates a handler for a DoExchange message.
      Parameters:
      marshaller - the DoExchangeMarshaller handling the message
      listener - the listener for results of this message
      Returns:
      the Handler for the message