Struct ContextManager 

pub struct ContextManager { /* private fields */ }

The central actor responsible for managing the lifecycle of all contexts.

As an actor, it maintains its own state and processes incoming messages sequentially from a mailbox.

Implementations

impl ContextManager

pub fn get_module( &self, application_id: ApplicationId, ) -> impl ActorFuture<Self, Output = Result<Module>> + 'static

impl ContextManager

Creates a new ContextManager.

Arguments

• datastore - The persistent storage backend.
• node_client - Client for interacting with the underlying Calimero node.
• context_client - The context client facade.
• external_config - Configuration for interacting with external blockchain contracts (e.g., NEAR).
• prometheus_registry - A mutable reference to a Prometheus registry for registering metrics.

pub fn new( datastore: Store, node_client: NodeClient, context_client: ContextClient, external_config: ExternalClientConfig, prometheus_registry: Option<&mut Registry>, ) -> Self

Trait Implementations

impl Actor for ContextManager

Implements the Actor trait for ContextManager, allowing it to run within the Actix framework.

By implementing Actor, ContextManager gains a “Context” (an execution environment) and a mailbox. Messages sent to the manager are queued in its mailbox and processed one at a time in the order they are received, which is the core of the actor model’s safety guarantee for its internal state.

type Context = Context<ContextManager>

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_in_arbiter<F>(wrk: &ArbiterHandle, f: F) -> Addr<Self>

where Self: Actor<Context = Context<Self>>, F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,

Start new actor in arbiter’s thread.

fn create<F>(f: F) -> Addr<Self>

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

Start a new asynchronous actor given a Context.

impl Debug for ContextManager

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

Formats the value using the given formatter.

impl Handler<ContextMessage> for ContextManager

type Result = ()

The type of value that this handler will return.

fn handle( &mut self, msg: ContextMessage, ctx: &mut Self::Context, ) -> Self::Result

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

impl Handler<CreateContextRequest> for ContextManager

type Result = ActorResponse<ContextManager, <CreateContextRequest as Message>::Result>

The type of value that this handler will return.

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

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

impl Handler<DeleteContextRequest> for ContextManager

type Result = ActorResponse<ContextManager, <DeleteContextRequest as Message>::Result>

The type of value that this handler will return.

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

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

impl Handler<ExecuteRequest> for ContextManager

type Result = ActorResponse<ContextManager, <ExecuteRequest as Message>::Result>

The type of value that this handler will return.

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

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

impl Handler<JoinContextRequest> for ContextManager

type Result = Pin<Box<dyn Future<Output = <JoinContextRequest as Message>::Result>>>

The type of value that this handler will return.

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

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

impl Handler<SyncRequest> for ContextManager

type Result = <SyncRequest as Message>::Result

The type of value that this handler will return.

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

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

impl Handler<UpdateApplicationRequest> for ContextManager

type Result = ActorResponse<ContextManager, <UpdateApplicationRequest as Message>::Result>

The type of value that this handler will return.

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

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