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 T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

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

pub fn borrow(&self) -> &T

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

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

impl<T> Downcast for T where T: Any,

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

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

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

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

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

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

impl<T> From<T> for T

pub 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 T where U: From<T>,

pub fn into(self) -> U

impl<T> Same<T> for T

type Output = T

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

type Error = Infallible

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

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

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

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

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

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 T where
T: 'static + ?Sized,

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

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

impl<T> Downcast for T where
T: Any,

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

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

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

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

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

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