Enum pliantdb::local::core::networking::DatabaseRequest[−][src]

pub enum DatabaseRequest {
Show variants    Get {
        collection: CollectionName,
        id: u64,
    },
    GetMultiple {
        collection: CollectionName,
        ids: Vec<u64, Global>,
    },
    Query {
        view: ViewName,
        key: Option<QueryKey<Vec<u8, Global>>>,
        access_policy: AccessPolicy,
        with_docs: bool,
    },
    Reduce {
        view: ViewName,
        key: Option<QueryKey<Vec<u8, Global>>>,
        access_policy: AccessPolicy,
        grouped: bool,
    },
    ApplyTransaction {
        transaction: Transaction<'static>,
    },
    ListExecutedTransactions {
        starting_id: Option<u64>,
        result_limit: Option<usize>,
    },
    LastTransactionId,
    CreateSubscriber,
    Publish {
        topic: String,
        payload: Vec<u8, Global>,
    },
    PublishToAll {
        topics: Vec<String, Global>,
        payload: Vec<u8, Global>,
    },
    SubscribeTo {
        subscriber_id: u64,
        topic: String,
    },
    UnsubscribeFrom {
        subscriber_id: u64,
        topic: String,
    },
    UnregisterSubscriber {
        subscriber_id: u64,
    },
    ExecuteKeyOperation(KeyOperation),
}

A database-related request.

Variants

Retrieve a single document.

collection: CollectionName

The collection of the document.

The id of the document.

GetMultiple

Retrieve multiple documents.

collection: CollectionName

The collection of the documents.

ids: Vec<u64, Global>

The ids of the documents.

Queries a view.

view: ViewName

The name of the view.

key: Option<QueryKey<Vec<u8, Global>>>

The filter for the view.

access_policy: AccessPolicy

The access policy for the query.

with_docs: bool

Reduces a view.

view: ViewName

The name of the view.

key: Option<QueryKey<Vec<u8, Global>>>

The filter for the view.

access_policy: AccessPolicy

The access policy for the query.

grouped: bool

Whether to return a single value or values grouped by unique key. If true, DatabaseResponse::ViewGroupedReduction will be returned. If false, DatabaseResponse::ViewReduction is returned.

ApplyTransaction

Applies a transaction.

transaction: Transaction<'static>

The trasnaction to apply.

ListExecutedTransactions

Lists executed transactions.

starting_id: Option<u64>

The starting transaction id.

result_limit: Option<usize>

The maximum number of results.

LastTransactionId

Queries the last transaction id.

CreateSubscriber

Creates a PubSub Subscriber

Publishes payload to all subscribers of topic.

topic: String

The topics to publish to.

payload: Vec<u8, Global>

The payload to publish.

PublishToAll

Publishes payload to all subscribers of all topics.

topics: Vec<String, Global>

The topics to publish to.

payload: Vec<u8, Global>

The payload to publish.

SubscribeTo

Subscribes subscriber_id to messages for topic.

subscriber_id: u64

topic: String

The topic to subscribe to.

UnsubscribeFrom

Unsubscribes subscriber_id from messages for topic.

subscriber_id: u64

topic: String

The topic to unsubscribe from.

UnregisterSubscriber

Unregisters the subscriber.

subscriber_id: u64

ExecuteKeyOperation(KeyOperation)

Excutes a key-value store operation.

Trait Implementations

Auto Trait Implementations

Blanket Implementations

The type for initializers.

Should always be Self

The resulting type after obtaining ownership.

The type returned in the event of a conversion error.

The type returned in the event of a conversion error.

Enum pliantdb::local::core::networking::DatabaseRequest⎘[−][src]

Variants

Fields of Get

Fields of GetMultiple

Fields of Query

Fields of Reduce

Fields of ApplyTransaction

Fields of ListExecutedTransactions

Fields of Publish

Fields of PublishToAll

Fields of SubscribeTo

Fields of UnsubscribeFrom

Fields of UnregisterSubscriber

Trait Implementations

impl Clone for DatabaseRequest[src]

pub fn clone(&self) -> DatabaseRequest[src]

pub fn clone_from(&mut self, source: &Self)1.0.0[src]

impl Debug for DatabaseRequest[src]

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

impl<'de> Deserialize<'de> for DatabaseRequest[src]

pub fn deserialize<__D>( __deserializer: __D) -> Result<DatabaseRequest, <__D as Deserializer<'de>>::Error> where __D: Deserializer<'de>, [src]

impl Serialize for DatabaseRequest[src]

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

Auto Trait Implementations

impl RefUnwindSafe for DatabaseRequest

impl Send for DatabaseRequest

impl Sync for DatabaseRequest

impl Unpin for DatabaseRequest

impl UnwindSafe for DatabaseRequest

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

impl<T> Conv for T

pub fn conv<T>(self) -> T where Self: Into<T>,

impl<T> Conv for T

pub fn conv<T>(self) -> T where Self: Into<T>,

impl<T> DeserializeOwned for T where T: for<'de> Deserialize<'de>, [src]

impl<T> FmtForward for T

pub fn fmt_binary(self) -> FmtBinary<Self> where Self: Binary,

pub fn fmt_display(self) -> FmtDisplay<Self> where Self: Display,

pub fn fmt_lower_exp(self) -> FmtLowerExp<Self> where Self: LowerExp,

pub fn fmt_lower_hex(self) -> FmtLowerHex<Self> where Self: LowerHex,

pub fn fmt_octal(self) -> FmtOctal<Self> where Self: Octal,

pub fn fmt_pointer(self) -> FmtPointer<Self> where Self: Pointer,

pub fn fmt_upper_exp(self) -> FmtUpperExp<Self> where Self: UpperExp,

pub fn fmt_upper_hex(self) -> FmtUpperHex<Self> where Self: UpperHex,

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

impl<T> Instrument for T[src]

pub fn instrument(self, span: Span) -> Instrumented<Self>[src]

pub fn in_current_span(self) -> Instrumented<Self>[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

pub fn into(self) -> U[src]

impl<T> Pipe for T where T: ?Sized,

pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R

pub fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where R: 'a,

pub fn pipe_ref_mut<'a, R>( &'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R where R: 'a,

pub fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

pub fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R) -> R where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

pub fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

pub fn pipe_as_mut<'a, U, R>( &'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

pub fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

pub fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

impl<T> Pipe for T

pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R

impl<T> PipeAsRef for T

pub fn pipe_as_ref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: AsRef<T>, T: 'a, R: 'a,

pub fn pipe_as_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where Self: AsMut<T>, T: 'a, R: 'a,

impl<T> PipeBorrow for T

pub fn pipe_borrow<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: Borrow<T>, T: 'a, R: 'a,

pub fn pipe_borrow_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where Self: BorrowMut<T>, T: 'a, R: 'a,

impl<T> PipeDeref for T

pub fn pipe_deref<'a, R>( &'a self, func: impl FnOnce(&'a Self::Target) -> R) -> R where Self: Deref, R: 'a,

pub fn pipe_deref_mut<'a, R>( &'a mut self, func: impl FnOnce(&'a mut Self::Target) -> R) -> R where Self: DerefMut, R: 'a,

impl<T> PipeRef for T

pub fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where R: 'a,

Enum pliantdb::local::core::networking::DatabaseRequest[−][src]

`impl Clone for DatabaseRequest`[src]

`pub fn clone(&self) -> DatabaseRequest`[src]

`pub fn clone_from(&mut self, source: &Self)`1.0.0 [src]

`impl Debug for DatabaseRequest`[src]

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

`impl<'de> Deserialize<'de> for DatabaseRequest`[src]

`pub fn deserialize<D>( deserializer: D ) -> Result<DatabaseRequest, <D as Deserializer<'de>>::Error> where __D: Deserializer<'de>,` [src]

`impl Serialize for DatabaseRequest`[src]

`pub fn serialize<S>( &self, serializer: S ) -> Result<<S as Serializer>::Ok, <S as Serializer>::Error> where S: Serializer,` [src]

`impl RefUnwindSafe for DatabaseRequest`

`impl Send for DatabaseRequest`

`impl Sync for DatabaseRequest`

`impl Unpin for DatabaseRequest`

`impl UnwindSafe for DatabaseRequest`

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> Conv for T`

`pub fn conv<T>(self) -> T where Self: Into<T>,`

`impl<T> Conv for T`

`pub fn conv<T>(self) -> T where Self: Into<T>,`

`impl<T> DeserializeOwned for T where T: for<'de> Deserialize<'de>,` [src]

`impl<T> FmtForward for T`

`pub fn fmt_binary(self) -> FmtBinary<Self> where Self: Binary,`

`pub fn fmt_display(self) -> FmtDisplay<Self> where Self: Display,`

`pub fn fmt_lower_exp(self) -> FmtLowerExp<Self> where Self: LowerExp,`

`pub fn fmt_lower_hex(self) -> FmtLowerHex<Self> where Self: LowerHex,`

`pub fn fmt_octal(self) -> FmtOctal<Self> where Self: Octal,`

`pub fn fmt_pointer(self) -> FmtPointer<Self> where Self: Pointer,`

`pub fn fmt_upper_exp(self) -> FmtUpperExp<Self> where Self: UpperExp,`

`pub fn fmt_upper_hex(self) -> FmtUpperHex<Self> where Self: UpperHex,`

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T> Instrument for T`[src]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src]

`pub fn in_current_span(self) -> Instrumented<Self>`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T> Pipe for T where T: ?Sized,`

`pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R`

`pub fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where R: 'a,`

`pub fn pipe_ref_mut<'a, R>( &'a mut self, func: impl FnOnce(&'a mut Self) -> R ) -> R where R: 'a,`

`pub fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,`

`pub fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R ) -> R where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,`

`pub fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,`

`pub fn pipe_as_mut<'a, U, R>( &'a mut self, func: impl FnOnce(&'a mut U) -> R ) -> R where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,`

`pub fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,`

`pub fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R ) -> R where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,`

`impl<T> Pipe for T`

`pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R`

`impl<T> PipeAsRef for T`

`pub fn pipe_as_ref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: AsRef<T>, T: 'a, R: 'a,`

`pub fn pipe_as_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R ) -> R where Self: AsMut<T>, T: 'a, R: 'a,`

`impl<T> PipeBorrow for T`

`pub fn pipe_borrow<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: Borrow<T>, T: 'a, R: 'a,`

`pub fn pipe_borrow_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R ) -> R where Self: BorrowMut<T>, T: 'a, R: 'a,`

`impl<T> PipeDeref for T`

`pub fn pipe_deref<'a, R>( &'a self, func: impl FnOnce(&'a Self::Target) -> R ) -> R where Self: Deref, R: 'a,`

`pub fn pipe_deref_mut<'a, R>( &'a mut self, func: impl FnOnce(&'a mut Self::Target) -> R ) -> R where Self: DerefMut, R: 'a,`

`impl<T> PipeRef for T`

`pub fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where R: 'a,`

`pub fn pipe_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R where R: 'a,`

`impl<T> Pointable for T`

`pub const ALIGN: usize`

`type Init = T`

`pub unsafe fn init(init: <T as Pointable>::Init) -> usize`

`pub unsafe fn deref<'a>(ptr: usize) -> &'a T`

`pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T`

`pub unsafe fn drop(ptr: usize)`

`impl<T> Same<T> for T`

`type Output = T`

`impl<T> Tap for T`

`pub fn tap(self, func: impl FnOnce(&Self)) -> Self`

`pub fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self`

`pub fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self where Self: Borrow<B>, B: ?Sized,`

`pub fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self where Self: BorrowMut<B>, B: ?Sized,`