Trait Operation 

pub trait Operation:
    OperationDeclaration<Request = Self>
    + Portable
    + Streams
    + Dependent
    + Clone
    + Send
    + 'static {
    type Error: Error + Send + Sync + 'static;

    // Required method
    fn run(
        self,
        context: Context<'_, Self>,
    ) -> impl Future<Output = Result<Response<Self::Response>, Self::Error>> + Send;

    // Provided method
    fn classify(_error: &Self::Error) -> FailureKind { ... }
}

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn run( self, context: Context<'_, Self>, ) -> impl Future<Output = Result<Response<Self::Response>, Self::Error>> + Send

Provided Methods

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".

Implementations on Foreign Types

impl Operation for AbandonFile

type Error = Error

async fn run( self, context: Context<'_, AbandonFile>, ) -> Result<Response<FileProgress>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for AppendFile

type Error = Error

async fn run( self, context: Context<'_, AppendFile>, ) -> Result<Response<FileProducer>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for Cancel

Available on crate feature runtime only.

type Error = Error

async fn run( self, context: Context<'_, Cancel>, ) -> Result<Response<InstanceState>, Error>

impl Operation for CaptureFile

type Error = Error

async fn run( self, context: Context<'_, CaptureFile>, ) -> Result<Response<FileReference>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for Catalog

Available on crate feature runtime only.

type Error = Error

async fn run( self, context: Context<'_, Catalog>, ) -> Result<Response<CatalogPage>, Error>

impl Operation for CreateFile

type Error = Error

async fn run( self, context: Context<'_, CreateFile>, ) -> Result<Response<FileProducer>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for DeleteFile

type Error = Error

async fn run( self, context: Context<'_, DeleteFile>, ) -> Result<Response<StagedFile>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for FinishFile

type Error = Error

async fn run( self, context: Context<'_, FinishFile>, ) -> Result<Response<FileReference>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for FollowFile

type Error = Error

async fn run( self, context: Context<'_, FollowFile>, ) -> Result<Response<FileCompletion>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for FollowObjects

type Error = Error

async fn run( self, context: Context<'_, FollowObjects>, ) -> Result<Response<StorageCursor>, Error>

impl Operation for FollowProduction

type Error = Error

async fn run( self, context: Context<'_, FollowProduction>, ) -> Result<Response<FileProgress>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for FollowRecords

type Error = Error

async fn run( self, context: Context<'_, FollowRecords>, ) -> Result<Response<StorageCursor>, Error>

impl Operation for FollowStream

type Error = Error

async fn run( self, context: Context<'_, FollowStream>, ) -> Result<Response<StorageCursor>, Error>

impl Operation for HashFile

type Error = Error

async fn run( self, context: Context<'_, HashFile>, ) -> Result<Response<FileHash>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for ListDirectory

type Error = Error

async fn run( self, context: Context<'_, ListDirectory>, ) -> Result<Response<DirectoryCompletion>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for Publish

Available on crate feature runtime only.

type Error = Error

async fn run( self, context: Context<'_, Publish>, ) -> Result<Response<()>, <Publish as Operation>::Error>

impl Operation for Query

type Error = Error

async fn run( self, context: Context<'_, Query>, ) -> Result<Response<QueryCompletion>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for ReadFile

type Error = Error

async fn run( self, context: Context<'_, ReadFile>, ) -> Result<Response<FileCompletion>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for ResumeFile

type Error = Error

async fn run( self, context: Context<'_, ResumeFile>, ) -> Result<Response<FileProducer>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for Status

Available on crate feature runtime only.

type Error = Error

async fn run( self, context: Context<'_, Status>, ) -> Result<Response<InstanceState>, Error>

impl Operation for StorageStatus

type Error = Error

async fn run( self, context: Context<'_, StorageStatus>, ) -> Result<Response<StorageInfo>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for Watch

Available on crate feature runtime only.

type Error = Error

async fn run( self, context: Context<'_, Watch>, ) -> Result<Response<InstanceState>, Error>

impl Operation for WatchDirectory

type Error = Error

async fn run( self, context: Context<'_, WatchDirectory>, ) -> Result<Response<DirectoryCompletion>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for WriteFile

type Error = Error

async fn run( self, context: Context<'_, WriteFile>, ) -> Result<Response<FileReference>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for WriteObjects

type Error = Error

async fn run( self, context: Context<'_, WriteObjects>, ) -> Result<Response<WriteCompletion>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for WriteRecords

type Error = Error

async fn run( self, context: Context<'_, WriteRecords>, ) -> Result<Response<WriteCompletion>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for WriteSchema

type Error = Error

async fn run( self, context: Context<'_, WriteSchema>, ) -> Result<Response<StorageCursor>, Error>

fn classify(error: &Error) -> FailureKind

impl Operation for WriteStreams

type Error = Error

async fn run( self, context: Context<'_, WriteStreams>, ) -> Result<Response<WriteCompletion>, Error>

fn classify(error: &Error) -> FailureKind

Implementors