Enum pliantdb_local::core::networking::DatabaseResponse

pub enum DatabaseResponse {
    Documents(Vec<Document<'static>, Global>),
    TransactionResults(Vec<OperationResult, Global>),
    ViewMappings(Vec<Serialized, Global>),
    ViewMappingsWithDocs(Vec<MappedDocument, Global>),
    ViewReduction(Vec<u8, Global>),
    ViewGroupedReduction(Vec<MappedValue<Vec<u8, Global>, Vec<u8, Global>>, Global>),
    ExecutedTransactions(Vec<Executed<'static>, Global>),
    LastTransactionId(Option<u64>),
    SubscriberCreated {
        subscriber_id: u64,
    },
    MessageReceived {
        subscriber_id: u64,
        topic: String,
        payload: Vec<u8, Global>,
    },
    KvOutput(Output),
}

A response to a DatabaseRequest.

Variants

Documents(Vec<Document<'static>, Global>)

One or more documents.

TransactionResults(Vec<OperationResult, Global>)

Results of DatabaseRequest::ApplyTransaction.

ViewMappings(Vec<Serialized, Global>)

Results of DatabaseRequest::Query when with_docs is false.

ViewMappingsWithDocs(Vec<MappedDocument, Global>)

Results of DatabaseRequest::Query when with_docs is true.

ViewReduction(Vec<u8, Global>)

Result of DatabaseRequest::Reduce when grouped is false.

ViewGroupedReduction(Vec<MappedValue<Vec<u8, Global>, Vec<u8, Global>>, Global>)

Result of DatabaseRequest::Reduce when grouped is true.

ExecutedTransactions(Vec<Executed<'static>, Global>)

Results of DatabaseRequest::ListExecutedTransactions.

LastTransactionId(Option<u64>)

Result of DatabaseRequest::LastTransactionId.

SubscriberCreated

A new PubSub subscriber was created.

Fields of SubscriberCreated

subscriber_id: u64

The unique ID of the subscriber.

MessageReceived

A PubSub message was received.

Fields of MessageReceived

subscriber_id: u64

The ID of the subscriber receiving the message.

topic: String

The topic the payload was received on.

payload: Vec<u8, Global>

The message payload.

KvOutput(Output)

Output from a KeyOperation being executed.

Trait Implementations

impl Clone for DatabaseResponse

pub fn clone(&self) -> DatabaseResponse

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DatabaseResponse

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DatabaseResponse

pub fn deserialize<__D>(
    __deserializer: __D
) -> Result<DatabaseResponse, <__D as Deserializer<'de>>::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for DatabaseResponse

pub fn serialize<__S>(
    &self,
    __serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.