Enum Request

pub enum Request {
    Create {
        flow_id: u64,
        plan: TypedPlan,
        sink_id: GlobalId,
        sink_sender: UnboundedSender<Batch>,
        source_ids: Vec<GlobalId>,
        src_recvs: Vec<Receiver<Batch>>,
        expire_after: Option<i64>,
        or_replace: bool,
        create_if_not_exists: bool,
        err_collector: ErrCollector,
    },
    Remove {
        flow_id: u64,
    },
    RunAvail {
        now: i64,
        blocking: bool,
    },
    ContainTask {
        flow_id: u64,
    },
    Shutdown,
    QueryStateSize,
    QueryLastExecTimeMap,
}

Variants

Create

Fields

flow_id: u64

plan: TypedPlan

sink_id: GlobalId

sink_sender: UnboundedSender<Batch>

source_ids: Vec<GlobalId>

src_recvs: Vec<Receiver<Batch>>

expire_after: Option<i64>

or_replace: bool

create_if_not_exists: bool

err_collector: ErrCollector

Remove

Fields

flow_id: u64

RunAvail

Trigger the worker to run, useful after input buffer is full

Fields

now: i64

blocking: bool

ContainTask

Fields

flow_id: u64

Shutdown

QueryStateSize

QueryLastExecTimeMap

Implementations

impl Request

pub fn is_create(&self) -> bool

Returns true if this is a Request::Create, otherwise false

pub fn as_create_mut( &mut self, ) -> Option<(&mut u64, &mut TypedPlan, &mut GlobalId, &mut UnboundedSender<Batch>, &mut Vec<GlobalId>, &mut Vec<Receiver<Batch>>, &mut Option<i64>, &mut bool, &mut bool, &mut ErrCollector)>

Optionally returns mutable references to the inner fields if this is a Request::Create, otherwise None

pub fn as_create( &self, ) -> Option<(&u64, &TypedPlan, &GlobalId, &UnboundedSender<Batch>, &Vec<GlobalId>, &Vec<Receiver<Batch>>, &Option<i64>, &bool, &bool, &ErrCollector)>

Optionally returns references to the inner fields if this is a Request::Create, otherwise None

pub fn into_create( self, ) -> Result<(u64, TypedPlan, GlobalId, UnboundedSender<Batch>, Vec<GlobalId>, Vec<Receiver<Batch>>, Option<i64>, bool, bool, ErrCollector), Self>

Returns the inner fields if this is a Request::Create, otherwise returns back the enum in the Err case of the result

pub fn is_remove(&self) -> bool

Returns true if this is a Request::Remove, otherwise false

pub fn as_remove_mut(&mut self) -> Option<&mut u64>

Optionally returns mutable references to the inner fields if this is a Request::Remove, otherwise None

pub fn as_remove(&self) -> Option<&u64>

Optionally returns references to the inner fields if this is a Request::Remove, otherwise None

pub fn into_remove(self) -> Result<u64, Self>

Returns the inner fields if this is a Request::Remove, otherwise returns back the enum in the Err case of the result

pub fn is_run_avail(&self) -> bool

Returns true if this is a Request::RunAvail, otherwise false

pub fn as_run_avail_mut(&mut self) -> Option<(&mut i64, &mut bool)>

Optionally returns mutable references to the inner fields if this is a Request::RunAvail, otherwise None

pub fn as_run_avail(&self) -> Option<(&i64, &bool)>

Optionally returns references to the inner fields if this is a Request::RunAvail, otherwise None

pub fn into_run_avail(self) -> Result<(i64, bool), Self>

Returns the inner fields if this is a Request::RunAvail, otherwise returns back the enum in the Err case of the result

pub fn is_contain_task(&self) -> bool

Returns true if this is a Request::ContainTask, otherwise false

pub fn as_contain_task_mut(&mut self) -> Option<&mut u64>

Optionally returns mutable references to the inner fields if this is a Request::ContainTask, otherwise None

pub fn as_contain_task(&self) -> Option<&u64>

Optionally returns references to the inner fields if this is a Request::ContainTask, otherwise None

pub fn into_contain_task(self) -> Result<u64, Self>

Returns the inner fields if this is a Request::ContainTask, otherwise returns back the enum in the Err case of the result

pub fn is_shutdown(&self) -> bool

Returns true if this is a Request::Shutdown, otherwise false

pub fn is_query_state_size(&self) -> bool

Returns true if this is a Request::QueryStateSize, otherwise false

pub fn is_query_last_exec_time_map(&self) -> bool

Returns true if this is a Request::QueryLastExecTimeMap, otherwise false

Trait Implementations

impl Debug for Request

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

Formats the value using the given formatter.