Module ydb_grpc::generated::ydb::topic::stream_read_message

Nested message and enum types in StreamReadMessage.

Modules

• commit_offset_request
  Nested message and enum types in CommitOffsetRequest.
• commit_offset_response
  Nested message and enum types in CommitOffsetResponse.
• from_client
  Nested message and enum types in FromClient.
• from_server
  Nested message and enum types in FromServer.
• init_request
  Nested message and enum types in InitRequest.
• read_response
  Nested message and enum types in ReadResponse.

Structs

• CommitOffsetRequest
  Signal for server that client processed some read data.
• CommitOffsetResponse
  Acknowledgement for commits.
• FromClient
  Client-server message for read session. Contains one of: InitRequest - handshake request. ReadRequest - request for data. CommitOffsetRequest - request for commit of some read data. PartitionSessionStatusRequest - request for session status UpdateTokenRequest - request to update auth token StartPartitionSessionResponse - Response to StreamReadServerMessage.StartPartitionSessionRequest. Client signals it is ready to get data from partition. StopPartitionSessionResponse - Response to StreamReadServerMessage.StopPartitionSessionRequest. Client signals it has finished working with partition. Mandatory for graceful stop, optional otherwise.
• FromServer
  Server-client message for read session. Contains one of: InitResponse - handshake response from server. ReadResponse - portion of data. CommitOffsetResponse - acknowledgment for commit. PartitionSessionStatusResponse - server response with partition session status. UpdateTokenResponse - acknowledgment of token update. StartPartitionSessionRequest - command from server to create a partition session. StopPartitionSessionRequest - command from server to destroy a partition session.
• InitRequest
  Handshake request.
• InitResponse
  Handshake response.
• PartitionSession
  Within a StreamRead session delivered messages are separated by partition. Reads from a single partition are represented by a partition session.
• PartitionSessionStatusRequest
• PartitionSessionStatusResponse
  Response for status request.
• ReadRequest
  Message that represents client readiness for receiving more data.
• ReadResponse
  Data read.
• StartPartitionSessionRequest
  Command from server to create and start a partition session. Client must respond with StartPartitionSessionResponse when ready to receive data from this partition.
• StartPartitionSessionResponse
  Signal for server that cient is ready to recive data for partition.
• StopPartitionSessionRequest
  Command from server to stop and destroy concrete partition session.
• StopPartitionSessionResponse
  Signal for server that client finished working with this partition. Must be sent only after corresponding StopPartitionSessionRequest from server. Server will give this partition to other read session only after StopPartitionSessionResponse signal.