Module stream_direct_read_message 

Nested message and enum types in StreamDirectReadMessage.

Modules

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.

Structs

DirectReadResponse

Messages that have been read directly from the partition node. It’s a response to StreamRead.ReadRequest

FromClient

Client-server message for direct read session. InitRequest - command from client to create and start a direct read session. StartDirectReadPartitionSessionRequest - command from client to create and start a direct read partition session. Client signals it is ready to get data from partition. UpdateTokenRequest - request to update auth token

FromServer

Server-client message for direct read session. InitResponse - correct handshake response. StartDirectReadPartitionSessionResponse - Response to StartDirectReadPartitionSessionRequest. DirectReadResponse - portion of message data. StopDirectReadPartitionSession - command from server to stop a direct read partition session. UpdateTokenResponse - acknowledgment of token update.

InitRequest

Command from client to create and start a direct read session. Server should not send a response to the command.

InitResponse

Response to the handshake.

StartDirectReadPartitionSessionRequest

Command from client to create and start a direct read partition session.

StartDirectReadPartitionSessionResponse

Signal for server that client is ready to receive data for partition.

StopDirectReadPartitionSession

Command from server to stop a direct read partition session. Client should not send a response to the command.