Enum Message 

pub enum Message {
    GetRequest {
        request_id: u64,
        uri: Uri,
        reply_channel: u64,
    },
    InsertRequest {
        request_id: u64,
        uri: Uri,
        id: AtlasId,
        reply_channel: u64,
    },
    RemoveRequest {
        request_id: u64,
        uri: Uri,
        reply_channel: u64,
    },
    LookupRequest {
        request_id: u64,
        pattern: String,
        reply_channel: u64,
    },
    ResponseGet {
        request_id: u64,
        id: AtlasId,
        found: bool,
    },
    ResponseRemove {
        request_id: u64,
        id: AtlasId,
        found: bool,
    },
    ResponseLookup {
        request_id: u64,
        ids: Vec<AtlasId>,
    },
    ResponseOk {
        request_id: u64,
    },
    ResponseError {
        request_id: u64,
        message: String,
    },
}

Atlas protocol message envelope.

Variants

GetRequest

Retrieve a single Atlas entry by URI.

Fields

request_id: u64

Correlation identifier supplied by the client.

uri: Uri

URI for the lookup.

reply_channel: u64

Shared handle for the response channel.

InsertRequest

Insert or update an Atlas entry.

Fields

request_id: u64

Correlation identifier supplied by the client.

uri: Uri

URI to insert.

id: AtlasId

Value to store against the URI.

reply_channel: u64

Shared handle for the response channel.

RemoveRequest

Remove an Atlas entry by URI.

Fields

request_id: u64

Correlation identifier supplied by the client.

uri: Uri

URI for the removal.

reply_channel: u64

Shared handle for the response channel.

LookupRequest

Lookup Atlas entries matching the supplied URI pattern.

Fields

request_id: u64

Correlation identifier supplied by the client.

pattern: String

Pattern used to match stored URIs.

reply_channel: u64

Shared handle for the response channel.

ResponseGet

Response to a get request.

Fields

request_id: u64

Correlation identifier supplied by the client.

id: AtlasId

Stored id, if found.

found: bool

Whether the entry existed.

ResponseRemove

Response to a remove request.

Fields

request_id: u64

Correlation identifier supplied by the client.

id: AtlasId

Removed id, if found.

found: bool

Whether the entry existed.

ResponseLookup

Response to a lookup request.

Fields

request_id: u64

Correlation identifier supplied by the client.

ids: Vec<AtlasId>

Matching Atlas identifiers.

ResponseOk

Empty response acknowledging a request.

Fields

request_id: u64

Correlation identifier supplied by the client.

ResponseError

Error response for a request.

Fields

request_id: u64

Correlation identifier supplied by the client.

message: String

Error message supplied by the Atlas service.

Implementations

impl Message

pub fn request_id(&self) -> u64

Return the request identifier associated with this message.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Message

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for Message

fn eq(&self, other: &Message) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Message

impl StructuralPartialEq for Message