Struct JobContext 

pub struct JobContext { /* private fields */ }

Context passed to a job blueprint factory for one materialized generation.

Implementations

impl JobContext

pub fn name(&self) -> &str

pub fn job_id(&self) -> JobId

pub fn generation(&self) -> u64

pub fn kill_switch(&self) -> SharedKillSwitch

pub fn instrumentation_registry(&self) -> &StreamInstrumentationRegistry

pub fn drain_flow<T: Send + 'static>(&self) -> Flow<T, T, SharedKillSwitch>

Return a flow backed by the agent-owned shared kill switch.

Graph factories should wire this flow into the job path when graceful drain is supported.

pub fn control(&self) -> JobControl

Trait Implementations

impl Clone for JobContext

fn clone(&self) -> JobContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobContext

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

Formats the value using the given formatter.