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.

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

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