Struct JobStreamer 

pub struct JobStreamer { /* private fields */ }

Job streamer that polls endpoints and dispatches to handlers.

Implementations

impl JobStreamer

pub fn new( base_url: impl Into<String>, api_key: impl Into<String>, job_id: impl Into<String>, ) -> JobStreamer

Create a new job streamer.

pub fn with_endpoints(self, endpoints: StreamEndpoints) -> JobStreamer

Set the stream endpoints.

pub fn with_config(self, config: StreamConfig) -> JobStreamer

Set the stream config.

pub fn with_handler(self, handler: Arc<dyn StreamHandler>) -> JobStreamer

Add a handler.

pub fn add_handler<H>(&mut self, handler: H)

where H: StreamHandler + 'static,

Add a handler (convenience method).

pub async fn poll_status(&mut self) -> Result<Option<Value>, CoreError>

Poll status once.

pub async fn poll_events(&mut self) -> Result<Vec<StreamMessage>, CoreError>

Poll events once.

pub async fn poll_metrics(&mut self) -> Result<Vec<StreamMessage>, CoreError>

Poll metrics once.

pub async fn poll_timeline(&mut self) -> Result<Vec<StreamMessage>, CoreError>

Poll timeline once.

pub async fn stream_until_terminal(&mut self) -> Result<Value, CoreError>

Stream until the job reaches a terminal state.

pub async fn stream_for_duration( &mut self, max_seconds: f64, ) -> Result<Option<Value>, CoreError>

Stream for a maximum duration, returning early if terminal.

pub fn job_id(&self) -> &str

Get the job ID.

pub fn last_event_seq(&self) -> Option<i64>

Get the last event sequence number.

pub fn clear_seen(&mut self)

Clear seen messages (for re-streaming).