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<R: Send + Sync + 'static, H: ObserverHost<R>> Attachment<Supervisor> for ObserverAttachment<R, H>

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

fn resources(&self) -> Arc<dyn Any + Send + Sync>

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

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

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

impl Host for Supervisor

type Error = CallError

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

fn context(&self) -> &CallContext

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

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

async fn submit_with_resources<O: OperationDeclaration<Response = ()>, R: Send + Sync + 'static>( &self, _: O, _: Arc<R>, ) -> Result<OperationInstance<O>, CallError>

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

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

where S::Row: Message,

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

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

impl<R: Sync, C> ObserverCaller<R, C> for Supervisor

where C: OperationDeclaration,

type Request = C

type Response = <C as OperationDeclaration>::Response

type Error = CallError

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

impl<R> ObserverHost<R> for Supervisor

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