Module 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.

DirectReadAck

Signal for server that client has finished direct reading. Server should not send a response to the command.

EndPartitionSession

Signal from server that client has finished reading the partition and all messages have been read. Once a partition has been finished no further messages will ever arrive to that partition. This command is a hint to the client to commit offsets, after which the child partitions will be balanced independently in different reading sessions. Unlike StopPartitionSessionRequest, the client does not have to close the reading session. Client should not send a response to the command.

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 DirectReadAck - client signals it has finished direct reading from the partition node.

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.

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 to 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 client 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.

UpdatePartitionSession

Command from server to notify about a partition session update. Client should not send a response to the command.