Struct Supervisor 

pub struct Supervisor { /* private fields */ }

Implementations

impl Supervisor

pub fn context(&self) -> &CallContext

pub fn with_value<T: ContextValue>( &self, value: T, ) -> Result<Self, ContextError>

pub fn exiting(&self, reason: impl Into<String>) -> bool

pub fn abandon(&self) -> bool

impl Supervisor

pub fn publisher<P: Declared>(&self) -> Publisher<P>

Trait Implementations

impl<H: ObserverHost> Attachment<Supervisor> for ObserverAttachment<H>

fn observers(&self) -> Vec<Declaration>

fn quiesce( &self, ) -> Pin<Box<dyn Future<Output = Result<(), ServingError>> + Send + '_>>

impl Caller for Supervisor

fn call(&self, target: Target, request: Box<dyn Any + Send>) -> CallFuture<'_>

impl CarrierContext for Supervisor

Available on crate feature kit only.

const FACILITY: &'static str = "sidecar"

impl Clone for Supervisor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Context for Supervisor

impl Context for Supervisor

fn assign_operations(&self, bytes: &[u8]) -> Result<(), ServingError>

fn with_generation(&self, token: [u8; 32]) -> Self

impl Host for Supervisor

type Error = CallError

type Instance<O: OperationDeclaration> = OperationInstance<O>

async fn publish_on<S: StreamSpec>(&self, row: &S::Row) -> Result<(), CallError>

where S::Row: Message,

fn context(&self) -> &CallContext

fn with_value<T: ContextValue>(&self, value: T) -> Result<Self, ContextError>

async fn submit<O: OperationDeclaration>( &self, request: O::Request, ) -> Result<OperationInstance<O>, CallError>

async fn submit_owned<O: OperationDeclaration>( &self, _: O::Request, _: RequestClaims, ) -> Result<OperationInstance<O>, CallError>

async fn call<O: OperationDeclaration>( &self, request: O::Request, ) -> Result<Response<O::Response>, CallError>

fn call_owned<O>( &self, request: <O as OperationDeclaration>::Request, claims: RequestClaims, ) -> impl Future<Output = Result<Response<<O as OperationDeclaration>::Response>, Self::Error>> + Send

where O: OperationDeclaration,

fn publish<S>( &self, row: &S, ) -> impl Future<Output = Result<(), Self::Error>> + Send

where S: StreamSpec<Row = S> + Message,

impl<C> ObserverCaller<C> for Supervisor

where C: OperationDeclaration,

type Request = <C as OperationDeclaration>::Request

type Response = <C as OperationDeclaration>::Response

type Error = CallError

async fn call( &self, _: &ObserverContext<'_, Self>, request: Self::Request, ) -> Result<Self::Response, Self::Error>

impl ObserverHost for Supervisor

fn bind(_: Arc<ExecutionContext>, supervisor: Supervisor) -> Self