Enum mmids_core::workflows::WorkflowRequestOperation

source ·

pub enum WorkflowRequestOperation {
    UpdateDefinition {
        new_definition: WorkflowDefinition,
    },
    GetState {
        response_channel: Sender<Option<WorkflowState>>,
    },
    StopWorkflow,
    MediaNotification {
        media: MediaNotification,
    },
}

Expand description

Operations that can be made to an actively running workflow

Variants

`UpdateDefinition`

Fields

new_definition: WorkflowDefinition

Requests the workflow update with a new definition. The workflow will take shape to look exactly as the specified definition has. Any existing steps that aren’t specified will be removed, any new steps will be created, and any steps that stay will reflect the order specified.

`GetState`

Fields

response_channel: Sender<Option<WorkflowState>>

Requests the workflow to return a snapshot of its current state

`StopWorkflow`

Requests the workflow stop operating

`MediaNotification`

Fields

media: MediaNotification

Sends a media notification to this stream

Enum mmids_core::workflows::WorkflowRequestOperation

Variants

UpdateDefinition

Fields

GetState

Fields

StopWorkflow

MediaNotification

Fields

Trait Implementations

impl Debug for WorkflowRequestOperation

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Auto Trait Implementations

impl !RefUnwindSafe for WorkflowRequestOperation

impl Send for WorkflowRequestOperation

impl Sync for WorkflowRequestOperation

impl Unpin for WorkflowRequestOperation

impl !UnwindSafe for WorkflowRequestOperation

Blanket Implementations

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> Downcast for Twhere T: Any,

fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

fn as_any(&self) -> &(dyn Any + 'static)

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

impl<T> DowncastSync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync + 'static>

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

`UpdateDefinition`

`GetState`

`StopWorkflow`

`MediaNotification`

impl<T> Any for Twhere
T: 'static + ?Sized,

impl<T> Borrow<T> for Twhere
T: ?Sized,

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

impl<T> Downcast for Twhere
T: Any,

impl<T> DowncastSync for Twhere
T: Any + Send + Sync,

impl<T, U> Into<U> for Twhere
U: From<T>,

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,