Struct SessionHistory 

pub struct SessionHistory { /* private fields */ }

Implementations

impl SessionHistory

pub fn open(config: Config) -> Result<Self>

pub fn health(&self) -> Result<(), Error>

pub fn create_session(&self, input: NewSession) -> Result<Session>

pub fn open_session(&self, metadata: SessionMetadata) -> Result<Session>

pub async fn register( &self, input: RegisterSession, ) -> Result<SessionRecord, Error>

pub async fn start( &self, input: StartSession, ) -> Result<Created<SessionRecord>, Error>

pub async fn enqueue_ingress( &self, input: NewIngressSession, ) -> Result<Created<SessionRecord>, Error>

pub async fn list(&self) -> Result<Vec<SessionRecord>, Error>

pub async fn get(&self, id: &str) -> Result<SessionRecord, Error>

pub async fn enqueue( &self, id: &str, input: NewCommand, ) -> Result<Created<SessionCommand>, Error>

pub async fn command_heads(&self) -> Result<Vec<SessionCommand>, Error>

pub async fn claim_command(&self, id: &str) -> Result<SessionCommand, Error>

pub async fn complete_command( &self, id: &str, outcome: CommandOutcome, ) -> Result<SessionCommand, Error>

pub async fn stop(&self, id: &str) -> Result<SessionRecord, Error>

pub async fn stage_object( &self, id: &str, object: NewObject, ) -> Result<String, Error>

pub fn object(&self, id: &str, pending_id: &str) -> Result<StoredObject, Error>

pub async fn checkpoint( &self, id: &str, input: Checkpoint, ) -> Result<SessionRecord, Error>

pub async fn request_ingress( &self, id: &str, input: Checkpoint, ) -> Result<SessionRecord, Error>

pub async fn start_ingress( &self, id: &str, input: StartIngress, ) -> Result<SessionRecord, Error>

pub async fn complete_ingress( &self, id: &str, input: ExpectedVersion, ) -> Result<SessionRecord, Error>

pub async fn fail_ingress( &self, id: &str, input: IngressFailure, ) -> Result<SessionRecord, Error>

pub async fn retry_ingress( &self, id: &str, input: RetryIngress, ) -> Result<SessionRecord, Error>

pub async fn release_interrupted_ingress(&self) -> Result<Vec<String>, Error>

pub async fn complete( &self, id: &str, input: Checkpoint, ) -> Result<SessionRecord, Error>

pub async fn record_completion( &self, input: RecordCompletion, ) -> Result<(), Error>

Trait Implementations

impl Clone for SessionHistory

fn clone(&self) -> SessionHistory

Returns a duplicate of the value.

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

Performs copy-assignment from source.