Enum eventstore_tcp::adapted::AdaptedMessage
[−]
[src]
pub enum AdaptedMessage<'a> {
HeartbeatRequest,
HeartbeatResponse,
Ping,
Pong,
WriteEvents(WriteEvents<'a>),
WriteEventsCompleted(Result<WriteEventsCompleted, WriteEventsFailure>),
ReadEvent(ReadEvent<'a>),
ReadEventCompleted(Result<ResolvedIndexedEvent<'a>, ReadEventError<'a>>),
ReadStreamEvents(ReadDirection, ReadStreamEvents<'a>),
ReadStreamEventsCompleted(ReadDirection, Result<ReadStreamCompleted<'a>, ReadStreamError<'a>>),
ReadAllEvents(ReadDirection, ReadAllEvents),
ReadAllEventsCompleted(ReadDirection, Result<ReadAllCompleted<'a>, ReadAllError<'a>>),
BadRequest(BadRequestMessage<'a>),
NotHandled(NotHandledInfo<'a>),
Authenticate,
Authenticated,
NotAuthenticated(NotAuthenticatedMessage<'a>),
}Enumeration of converted messages for more oxidized API.
Variants
HeartbeatRequestRequests heartbeat from the other side. Unsure if clients or server sends these.
HeartbeatResponseResponse to a heartbeat request.
PingPing request, similar to heartbeat.
PongPing response.
WriteEvents(WriteEvents<'a>)Append to stream request
WriteEventsCompleted(Result<WriteEventsCompleted, WriteEventsFailure>)Append to stream response, which can fail for a number of reasons
ReadEvent(ReadEvent<'a>)Request to read a single event from a stream
ReadEventCompleted(Result<ResolvedIndexedEvent<'a>, ReadEventError<'a>>)Response to a single event read
ReadStreamEvents(ReadDirection, ReadStreamEvents<'a>)Request to read a stream from a point forward or backward
ReadStreamEventsCompleted(ReadDirection, Result<ReadStreamCompleted<'a>, ReadStreamError<'a>>)Response to a stream read in given direction
ReadAllEvents(ReadDirection, ReadAllEvents)Request to read a stream of all events from a position forward or backward
ReadAllEventsCompleted(ReadDirection, Result<ReadAllCompleted<'a>, ReadAllError<'a>>)Response to a read all in given direction
BadRequest(BadRequestMessage<'a>)Request was not understood. Please open an issue!
NotHandled(NotHandledInfo<'a>)Correlated request was not handled. This is the likely response to requests where
require_master is true, but the connected endpoint is not master and cannot reach it.
AuthenticateRequest to authenticate attached credentials.
AuthenticatedPositive authentication response. The credentials used to Authenticate previously can be
used in successive requests.
NotAuthenticated(NotAuthenticatedMessage<'a>)Negative authentication response, or response to any sent request for which used authentication was not accepted.
Methods
impl<'a> AdaptedMessage<'a>[src]
fn as_raw<'b>(&'b self) -> RawMessage<'b>[−]
Converts the adapted back to raw for encoding.
Trait Implementations
impl<'a> Debug for AdaptedMessage<'a>[src]
impl<'a> PartialEq for AdaptedMessage<'a>[src]
fn eq(&self, __arg_0: &AdaptedMessage<'a>) -> bool[−]
This method tests for self and other values to be equal, and is used by ==. Read more
fn ne(&self, __arg_0: &AdaptedMessage<'a>) -> bool[−]
This method tests for !=.
impl<'a> Clone for AdaptedMessage<'a>[src]
fn clone(&self) -> AdaptedMessage<'a>[−]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0[−]
Performs copy-assignment from source. Read more
impl<'a> From<BadRequestMessage<'a>> for AdaptedMessage<'a>[src]
fn from(m: BadRequestMessage<'a>) -> AdaptedMessage<'a>[−]
Performs the conversion.
impl<'a> From<NotAuthenticatedMessage<'a>> for AdaptedMessage<'a>[src]
fn from(m: NotAuthenticatedMessage<'a>) -> AdaptedMessage<'a>[−]
Performs the conversion.