Skip to main content

Operation

harmos_runtime::operations

Trait Operation 

Source 
pub trait Operation:
    Sized
    + Send
    + 'static {
    type Declaration: OperationDeclaration;
    type Resources: Send + Sync + 'static;
    type Error: Error + Send + Sync + 'static;
    type Context<'a>: Send;
    type Endpoints: EndpointSet;

    // Required methods
    fn initialize<'ctx>(
        resources: Arc<Self::Resources>,
        context: Self::Context<'ctx>,
    ) -> impl Future<Output = Result<Self, Self::Error>> + Send;
    fn run<'ctx>(
        &mut self,
        context: Self::Context<'ctx>,
        request: &mut Self::Declaration,
        endpoints: &mut Self::Endpoints,
    ) -> impl Future<Output = Result<Response<<Self::Declaration as OperationDeclaration>::Response>, Self::Error>> + Send;

    // Provided methods
    fn stop(&mut self) -> impl Future<Output = Result<(), Self::Error>> + Send { ... }
    fn cleanup(
        &mut self,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send { ... }
    fn transferred(&self) -> bool { ... }
    fn classify(_error: &Self::Error) -> FailureKind { ... }
}

Required Associated Types§

Source

type Declaration: OperationDeclaration

Source

type Resources: Send + Sync + 'static

Source

type Error: Error + Send + Sync + 'static

Source

type Context<'a>: Send

Source

type Endpoints: EndpointSet

Required Methods§

Source

fn initialize<'ctx>( resources: Arc<Self::Resources>, context: Self::Context<'ctx>, ) -> impl Future<Output = Result<Self, Self::Error>> + Send

Source

fn run<'ctx>( &mut self, context: Self::Context<'ctx>, request: &mut Self::Declaration, endpoints: &mut Self::Endpoints, ) -> impl Future<Output = Result<Response<<Self::Declaration as OperationDeclaration>::Response>, Self::Error>> + Send

Provided Methods§

Source

fn stop(&mut self) -> impl Future<Output = Result<(), Self::Error>> + Send

Source

fn cleanup(&mut self) -> impl Future<Output = Result<(), Self::Error>> + Send

Source

fn transferred(&self) -> bool

Source

fn classify(_error: &Self::Error) -> FailureKind

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§