Struct ledb_actix::Storage

pub struct Storage(_);

Storage actor

Implementations

impl Storage

pub fn new<P: AsRef<Path>>(path: P, opts: Options) -> LeResult<Self>

Instantiate new storage actor using path to the database in filesystem

You can create multiple storage adapters using same path, actually all of them will use same storage instance.

pub fn start(self, threads: usize) -> Addr<Self>

Start the actor with number of threads

Trait Implementations

impl Actor for Storage

type Context = SyncContext<Self>

Actor execution context type

fn started(&mut self, ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

fn start(self) -> Addr<Self> where
    Self: Actor<Context = Context<Self>>, 

Start a new asynchronous actor, returning its address.

fn start_default() -> Addr<Self> where
    Self: Actor<Context = Context<Self>> + Default, 

Construct and start a new asynchronous actor, returning its address.

fn start_in_arbiter<F>(arb: &Arbiter, f: F) -> Addr<Self> where
    F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,
    Self: Actor<Context = Context<Self>>, 

Start new actor in arbiter's thread.

fn create<F>(f: F) -> Addr<Self> where
    F: FnOnce(&mut Context<Self>) -> Self,
    Self: Actor<Context = Context<Self>>, 

Start a new asynchronous actor given a Context.

impl Clone for Storage

fn clone(&self) -> Storage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Handler<DeleteMsg> for Storage

type Result = <DeleteMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    DeleteMsg: DeleteMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl Handler<DropCollectionMsg> for Storage

type Result = <DropCollectionMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    DropCollectionMsg: DropCollectionMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl Handler<DropIndexMsg> for Storage

type Result = <DropIndexMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    DropIndexMsg: DropIndexMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl Handler<EnsureCollectionMsg> for Storage

type Result = <EnsureCollectionMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    EnsureCollectionMsg: EnsureCollectionMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl Handler<EnsureIndexMsg> for Storage

type Result = <EnsureIndexMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    EnsureIndexMsg: EnsureIndexMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl<T: DeserializeOwned + Document + 'static> Handler<FindMsg<T>> for Storage

type Result = <FindMsg<T> as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, FindMsg: FindMsg<T>, _: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetCollections> for Storage

type Result = <GetCollections as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, _: GetCollections, _: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetIndexesMsg> for Storage

type Result = <GetIndexesMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    GetIndexesMsg: GetIndexesMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetInfo> for Storage

type Result = <GetInfo as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, _: GetInfo, _: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl<T: DeserializeOwned + Document + 'static> Handler<GetMsg<T>> for Storage

type Result = <GetMsg<T> as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, GetMsg: GetMsg<T>, _: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetStats> for Storage

type Result = <GetStats as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, _: GetStats, _: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl<T: Serialize + Document> Handler<InsertMsg<T>> for Storage

type Result = <InsertMsg<T> as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    InsertMsg: InsertMsg<T>,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl<T: Serialize + Document> Handler<PutMsg<T>> for Storage

type Result = <PutMsg<T> as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, PutMsg: PutMsg<T>, _: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<RemoveMsg> for Storage

type Result = <RemoveMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    RemoveMsg: RemoveMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl Handler<SetIndexesMsg> for Storage

type Result = <SetIndexesMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    SetIndexesMsg: SetIndexesMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl Handler<UpdateMsg> for Storage

type Result = <UpdateMsg as Message>::Result

The type of value that this handler will return.

fn handle(
    &mut self,
    UpdateMsg: UpdateMsg,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl StorageAddrExt<Storage> for Addr<Storage>

fn get_storage_addr<M, T, E>(&self) -> &Addr<Storage> where
    Storage: Handler<M>,
    M: Message<Result = Result<T, E>> + Send,
    T: Send + 'static,
    E: Send + 'static, 

fn send_query<M, T, E>(
    &self,
    msg: M
) -> Pin<Box<dyn Future<Output = Result<T, Either<MailboxError, E>>> + Send>> where
    A: Handler<M> + Send,
    A::Context: ToEnvelope<A, M>,
    M: Message<Result = Result<T, E>> + Send + 'static,
    T: Send + 'static,
    E: Send + 'static, 

Send query and get unwrapped result