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) -> Self

Create endpoints for a generic learning job.

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

Create endpoints for a prompt learning (GEPA) job.

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

Create endpoints for an eval job.

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

Create endpoints for an RL job.

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

Create endpoints for an SFT job.

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

Create endpoints for graph optimization.

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

Create endpoints for graph evolve jobs.

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

Legacy alias for graph evolve endpoints.

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

Create custom endpoints.

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

Add a status fallback endpoint.

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

Add an event fallback endpoint.

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

Add a metrics fallback endpoint.

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

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

Formats the value using the given formatter.

impl Default for StreamEndpoints

fn default() -> Self

Returns the “default value” for a type.