Trait OperationDeclaration 

pub trait OperationDeclaration: Portable {
    type Response: Portable;
    type Input: Direction;
    type Output: Direction;

    const ID: &'static str;
    const VERSION: u32;
    const POLICY: OperationPolicy;
    const DESCRIPTION: &'static str = "";
    const VISIBILITY: Visibility = Visibility::Private;
    const REPLAY: ReplaySafety = ReplaySafety::Unknown;
    const GRPC: Option<Grpc> = None;

    // Provided methods
    fn grant(&self) -> Option<Grant> { ... }
    fn key(&self) -> Option<CacheKey> { ... }
}

Required Associated Constants

const ID: &'static str

const VERSION: u32

const POLICY: OperationPolicy

Provided Associated Constants

const DESCRIPTION: &'static str = ""

const VISIBILITY: Visibility = Visibility::Private

const REPLAY: ReplaySafety = ReplaySafety::Unknown

const GRPC: Option<Grpc> = None

Required Associated Types

type Response: Portable

type Input: Direction

type Output: Direction

Provided Methods

fn grant(&self) -> Option<Grant>

fn key(&self) -> Option<CacheKey>

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors

impl OperationDeclaration for AbandonFile

const ID: &'static str = "storage.abandon_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = FileProgress

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Activation

const VERSION: u32 = 1

const ID: &'static str = ""

const POLICY: OperationPolicy

type Response = ()

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for AppendFile

const ID: &'static str = "storage.append_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = FileProducer

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Cancel

const ID: &'static str = "host.operations.cancel"

const VERSION: u32 = 1

const POLICY: OperationPolicy = crate::operations::host::POLICY

const DESCRIPTION: &'static str = "Request cancellation of an operation instance the caller submitted"

const VISIBILITY: Visibility = Visibility::Shared

const GRPC: Option<Grpc>

type Response = InstanceState

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Catalog

const ID: &'static str = "host.catalog"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const DESCRIPTION: &'static str = "Page live operation contracts or the schemas, streams and objects storage holds durably"

const VISIBILITY: Visibility = Visibility::Shared

const GRPC: Option<Grpc>

type Response = CatalogPage

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Control

const ID: &'static str = "harmos.observe"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = ()

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for CreateFile

const ID: &'static str = "storage.create_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = FileProducer

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for DeleteFile

const ID: &'static str = "storage.delete_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = StagedFile

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for FinishFile

const ID: &'static str = "storage.finish_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = FileReference

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for FollowFile

const ID: &'static str = "storage.follow_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = STREAM_POLICY

const VISIBILITY: Visibility = Visibility::Host

type Response = FileProgress

type Input = NoStream

type Output = Stream<FileBatch>

impl OperationDeclaration for FollowObjects

const ID: &'static str = "storage.follow_objects"

const VERSION: u32 = 1

const POLICY: OperationPolicy = STREAM_POLICY

const VISIBILITY: Visibility = Visibility::Host

type Response = StorageCursor

type Input = NoStream

type Output = Stream<ObjectEntry>

impl OperationDeclaration for FollowRecords

const ID: &'static str = "storage.follow_records"

const VERSION: u32 = 1

const POLICY: OperationPolicy = super::STREAM_POLICY

const VISIBILITY: Visibility = crate::operations::Visibility::Shared

const GRPC: Option<Grpc>

type Response = StorageCursor

type Input = NoStream

type Output = Stream<Followed>

impl OperationDeclaration for FollowStream

const ID: &'static str = "storage.follow_stream"

const VERSION: u32 = 1

const POLICY: OperationPolicy = STREAM_POLICY

const VISIBILITY: Visibility = Visibility::Host

type Response = StorageCursor

type Input = NoStream

type Output = Stream<StoredRow>

impl OperationDeclaration for Initialize

const ID: &'static str = "harmos.initialize"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

type Response = ()

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Publish

const ID: &'static str = "host.publish"

const VERSION: u32 = 1

const POLICY: OperationPolicy = crate::operations::host::POLICY

const VISIBILITY: Visibility = Visibility::Shared

type Response = ()

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Query

const ID: &'static str = "storage.query"

const VERSION: u32 = 1

const POLICY: OperationPolicy = IO_POLICY

const VISIBILITY: Visibility = Visibility::Shared

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

const GRPC: Option<Grpc>

type Response = QueryCompletion

type Input = NoStream

type Output = Stream<QueryOutput>

impl OperationDeclaration for ReadFile

const ID: &'static str = "storage.read_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = IO_POLICY

const VISIBILITY: Visibility = Visibility::Shared

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

const GRPC: Option<Grpc>

type Response = FileCompletion

type Input = NoStream

type Output = Stream<FileBatch>

impl OperationDeclaration for ResumeFile

const ID: &'static str = "storage.resume_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = FileProducer

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Shutdown

const ID: &'static str = "harmos.shutdown"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

type Response = ()

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Status

const ID: &'static str = "host.operations.status"

const VERSION: u32 = 1

const POLICY: OperationPolicy = crate::operations::host::POLICY

const DESCRIPTION: &'static str = "Report the status of an operation instance the caller submitted"

const VISIBILITY: Visibility = Visibility::Shared

const GRPC: Option<Grpc>

type Response = InstanceState

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for StorageStatus

const ID: &'static str = "storage.status"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = StorageInfo

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for Watch

const ID: &'static str = "host.operations.watch"

const VERSION: u32 = 1

const POLICY: OperationPolicy = WATCH_POLICY

const DESCRIPTION: &'static str = "Stream the status changes of an operation instance the caller submitted until it settles"

const VISIBILITY: Visibility = Visibility::Shared

const GRPC: Option<Grpc>

type Response = InstanceState

type Input = NoStream

type Output = Stream<InstanceState>

impl OperationDeclaration for WriteFile

const ID: &'static str = "storage.write_file"

const VERSION: u32 = 1

const POLICY: OperationPolicy = IO_POLICY

const VISIBILITY: Visibility = Visibility::Shared

const REPLAY: ReplaySafety = ReplaySafety::Unknown

const GRPC: Option<Grpc>

type Response = FileReference

type Input = Stream<FileBatch>

type Output = NoStream

impl OperationDeclaration for WriteObjects

const ID: &'static str = "storage.write_objects"

const VERSION: u32 = 1

const POLICY: OperationPolicy = IO_POLICY

const VISIBILITY: Visibility = Visibility::Shared

const REPLAY: ReplaySafety = ReplaySafety::Unknown

const GRPC: Option<Grpc>

type Response = WriteCompletion

type Input = Stream<DataBatch>

type Output = Stream<WriteReceipt>

impl OperationDeclaration for WriteRecords

const ID: &'static str = "storage.write_records"

const VERSION: u32 = 1

const POLICY: OperationPolicy = IO_POLICY

const VISIBILITY: Visibility = Visibility::Shared

const REPLAY: ReplaySafety = ReplaySafety::Unknown

const GRPC: Option<Grpc>

type Response = WriteCompletion

type Input = Stream<DataBatch>

type Output = Stream<WriteReceipt>

impl OperationDeclaration for WriteSchema

const ID: &'static str = "storage.write_schema"

const VERSION: u32 = 1

const POLICY: OperationPolicy = POLICY

const VISIBILITY: Visibility = Visibility::Host

const REPLAY: ReplaySafety = ReplaySafety::Idempotent

type Response = StorageCursor

type Input = NoStream

type Output = NoStream

impl OperationDeclaration for WriteStreams

const ID: &'static str = "storage.write_streams"

const VERSION: u32 = 1

const POLICY: OperationPolicy = IO_POLICY

const VISIBILITY: Visibility = Visibility::Shared

const REPLAY: ReplaySafety = ReplaySafety::Unknown

const GRPC: Option<Grpc>

type Response = WriteCompletion

type Input = Stream<DataBatch>

type Output = Stream<WriteReceipt>

impl<L> OperationDeclaration for Delivery<L>

where L: Listener,

const ID: &'static str = L::CALLBACK

const VERSION: u32 = 1

const POLICY: OperationPolicy = L::POLICY

const VISIBILITY: Visibility = crate::operations::Visibility::Shared

type Response = ()

type Input = NoStream

type Output = NoStream