Enum 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

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.

Fields

§new_definition: WorkflowDefinition

§

GetState

Requests the workflow to return a snapshot of its current state

Fields

§response_channel: Sender<Option<WorkflowState>>

§

StopWorkflow

Requests the workflow stop operating

§

MediaNotification

Sends a media notification to this stream

Fields

§media: MediaNotification

Enum WorkflowRequestOperationCopy item path

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 !Freeze for WorkflowRequestOperation

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>) -> Box<dyn Any>

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

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 + Sync + Send>

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> Same for T

type Output = T

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<V, T> VZip<V> for Twhere V: MultiLane<T>,

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>

Enum WorkflowRequestOperation

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>,