Struct GraphEvolveJob 

pub struct GraphEvolveJob { /* private fields */ }

High-level Graph Evolve job orchestration.

Implementations

impl GraphEvolveJob

pub fn from_payload( payload: Value, api_key: Option<&str>, base_url: Option<&str>, ) -> Result<Self, CoreError>

Create a job from a payload.

pub fn from_job_id( job_id: &str, api_key: Option<&str>, base_url: Option<&str>, ) -> Result<Self, CoreError>

Reconnect to an existing job by ID.

pub fn job_id(&self) -> Option<&str>

Get the job ID (primary or legacy).

pub fn legacy_job_id(&self) -> Option<&str>

Get the legacy GraphGen job ID, if known.

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

Submit the job and return the backend response.

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

Get current job status.

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

Start a queued job.

pub async fn get_events( &self, since_seq: i64, limit: i64, ) -> Result<Value, CoreError>

Fetch events for the job.

pub async fn get_metrics(&self, query_string: &str) -> Result<Value, CoreError>

Fetch metrics for the job.

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

Download prompt (JSON response).

pub async fn download_graph_txt(&self) -> Result<String, CoreError>

Download redacted graph export.

pub async fn run_inference(&self, payload: Value) -> Result<Value, CoreError>

Run inference using the optimized graph.

pub async fn get_graph_record(&self, payload: Value) -> Result<Value, CoreError>

Fetch a graph record snapshot.

pub async fn cancel(&self, payload: Value) -> Result<Value, CoreError>

Cancel the job.

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

Query workflow state.