Struct StreamEndpoints 

pub struct StreamEndpoints {
    pub status: Option<String>,
    pub events: Option<String>,
    pub metrics: Option<String>,
    pub timeline: Option<String>,
    pub status_fallbacks: Vec<String>,
    pub event_fallbacks: Vec<String>,
    pub metric_fallbacks: Vec<String>,
    pub timeline_fallbacks: Vec<String>,
}

Endpoint configuration for streaming from a job.

Fields

status: Option<String>

Status endpoint.

events: Option<String>

Events endpoint.

metrics: Option<String>

Metrics endpoint.

timeline: Option<String>

Timeline endpoint.

status_fallbacks: Vec<String>

Fallback status endpoints (tried in order if primary fails).

event_fallbacks: Vec<String>

Fallback event endpoints.

metric_fallbacks: Vec<String>

Fallback metrics endpoints.

timeline_fallbacks: Vec<String>

Fallback timeline endpoints.

Implementations

impl StreamEndpoints

pub fn learning(job_id: &str) -> StreamEndpoints

Create endpoints for a generic learning job.

pub fn prompt_learning(job_id: &str) -> StreamEndpoints

Create endpoints for a prompt learning (GEPA) job.

pub fn eval(job_id: &str) -> StreamEndpoints

Create endpoints for an eval job.

pub fn rl(job_id: &str) -> StreamEndpoints

Create endpoints for an RL job.

pub fn sft(job_id: &str) -> StreamEndpoints

Create endpoints for an SFT job.

pub fn graph_optimization(job_id: &str) -> StreamEndpoints

Create endpoints for graph optimization.

pub fn graph_evolve(job_id: &str) -> StreamEndpoints

Create endpoints for graph evolve jobs.

pub fn graphgen(job_id: &str) -> StreamEndpoints

Legacy alias for graph evolve endpoints.

pub fn custom( status: Option<String>, events: Option<String>, metrics: Option<String>, timeline: Option<String>, ) -> StreamEndpoints

Create custom endpoints.

pub fn with_status_fallback( self, endpoint: impl Into<String>, ) -> StreamEndpoints

Add a status fallback endpoint.

pub fn with_event_fallback(self, endpoint: impl Into<String>) -> StreamEndpoints

Add an event fallback endpoint.

pub fn with_metric_fallback( self, endpoint: impl Into<String>, ) -> StreamEndpoints

Add a metrics fallback endpoint.

pub fn with_timeline_fallback( self, endpoint: impl Into<String>, ) -> StreamEndpoints

Add a timeline fallback endpoint.

pub fn events_stream_url(&self) -> Option<String>

Get the SSE stream URL for events.

pub fn all_status_endpoints(&self) -> Vec<&str>

Get all status endpoints to try (primary + fallbacks).

pub fn all_event_endpoints(&self) -> Vec<&str>

Get all event endpoints to try (primary + fallbacks).

pub fn all_metric_endpoints(&self) -> Vec<&str>

Get all metrics endpoints to try (primary + fallbacks).

pub fn all_timeline_endpoints(&self) -> Vec<&str>

Get all timeline endpoints to try (primary + fallbacks).

Trait Implementations

impl Clone for StreamEndpoints

fn clone(&self) -> StreamEndpoints

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamEndpoints

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

Formats the value using the given formatter.

impl Default for StreamEndpoints

fn default() -> StreamEndpoints

Returns the “default value” for a type.