Module stream_service

Modules

• barrier_complete_response
  Nested message and enum types in BarrierCompleteResponse.
• stream_service_client
  Generated client implementations.
• stream_service_server
  Generated server implementations.
• streaming_control_stream_request
  Nested message and enum types in StreamingControlStreamRequest.
• streaming_control_stream_response
  Nested message and enum types in StreamingControlStreamResponse.

Structs

• BarrierCompleteResponse
• GetMinUncommittedSstIdRequest
• GetMinUncommittedSstIdResponse
• InjectBarrierRequest
• StreamingControlStreamRequest
• StreamingControlStreamResponse
• WaitEpochCommitRequest
• WaitEpochCommitResponse

Type Aliases

• PbBarrierCompleteResponse
  Alias for BarrierCompleteResponse.
• PbGetMinUncommittedSstIdRequest
  Alias for GetMinUncommittedSstIdRequest.
• PbGetMinUncommittedSstIdResponse
  Alias for GetMinUncommittedSstIdResponse.
• PbInjectBarrierRequest
  Alias for InjectBarrierRequest.
• PbStreamingControlStreamRequest
  Alias for StreamingControlStreamRequest.
• PbStreamingControlStreamResponse
  Alias for StreamingControlStreamResponse.
• PbWaitEpochCommitRequest
  Alias for WaitEpochCommitRequest.
• PbWaitEpochCommitResponse
  Alias for WaitEpochCommitResponse.