Struct Client

Source

pub struct Client {
    pub auth: AuthClient,
    pub core: CoreClient,
    /* private fields */
}

Fields§

§auth: AuthClient§core: CoreClient

Implementations§

Source §

impl Client

Source

pub fn new(config: ClientConfig) -> Result<Self>

Source

pub fn advanced(&self) -> &AdvancedClient

Raw low-level control-plane surface. Every operation takes a free-form serializable payload and returns raw JSON — the same ops that used to be flattened onto Client directly (those flat delegates are now deprecated in favour of this namespace). The ~24 typed helpers (remember, recall, handoff, …) stay on Client.

Source

pub fn run_scope(&self, run_id: impl Into<String>) -> RunScope

Run-scope sugar: set the client’s ambient run id (the same mechanism that auto-injects run_id into every operation with a run_id field) and restore the previous run id when the returned RunScope guard drops. For explicit reflection at the end of the scope, call RunScope::end_with_reflect instead of letting the guard drop (no async work happens in Drop).

{
    let _scope = client.run_scope("ticket-4711");
    client.remember(RememberBuilder::new("...").build()).await?;
} // previous run id restored here

Source §

impl Client

Source

pub async fn remember(&self, options: RememberOptions) -> Result<Value>

Source

pub async fn recall(&self, options: RecallOptions) -> Result<Value>

Source

pub async fn get_context(&self, options: GetContextOptions) -> Result<Value>

Source

pub async fn archive(&self, options: ArchiveOptions) -> Result<Value>

Source

pub async fn archive_block(&self, options: ArchiveOptions) -> Result<Value>

Source

pub async fn dereference(&self, options: DereferenceOptions) -> Result<Value>

Source

pub async fn memory_health(&self, options: MemoryHealthOptions) -> Result<Value>

Source

pub async fn diagnose(&self, options: DiagnoseOptions) -> Result<Value>

Source

pub async fn reflect(&self, options: ReflectOptions) -> Result<Value>

Source

pub async fn forget(&self, options: ForgetOptions) -> Result<Value>

Source

pub async fn checkpoint(&self, options: CheckpointOptions) -> Result<Value>

Source

pub async fn register_agent( &self, options: RegisterAgentOptions, ) -> Result<Value>

Source

pub async fn list_agents(&self, options: ListAgentsOptions) -> Result<Value>

Source

pub async fn record_outcome( &self, options: RecordOutcomeOptions, ) -> Result<Value>

Source

pub async fn learned(&self, options: LearnedOptions) -> Result<Value>

Source

pub async fn optimize_prompt( &self, options: OptimizePromptOptions, ) -> Result<Value>

Phase 2.4: generate a challenger prompt version from accumulated lessons and outcome stats. The server never auto-activates unless auto_activate=true explicitly; by default the challenger surfaces via the champion/challenger evaluator (Phase 1.1) with ready_for_promotion=true once it outperforms the active version.

Source

pub async fn optimize_skill( &self, options: OptimizeSkillOptions, ) -> Result<Value>

Phase 2.4: skill-version analogue of optimize_prompt.

Source

pub async fn circuit_break(&self, options: CircuitBreakOptions) -> Result<Value>

Phase 1.5: atomic anti-loop reset. Snapshots working memory to LTM as a loop_detected lesson, clears working memory, resets the drift monitor state, and emits a CIRCUIT_BROKEN event. Customers should invoke this after observing signals.repeated == true (or stagnant / drifting) on a recall response.

Source

pub async fn record_step_outcome( &self, options: RecordStepOutcomeOptions, ) -> Result<Value>

Source

pub async fn surface_strategies( &self, options: SurfaceStrategiesOptions, ) -> Result<Value>

Source

pub async fn handoff(&self, options: HandoffOptions) -> Result<Value>

Hand a task off to another agent.

With await_verdict = true, polls (2s interval) for a feedback entry referencing the new handoff_id and returns the verdict (“approve” | “request_changes” | “block” | “acknowledge”) as Value::String — or Value::Null when timeout_s (default 30) elapses without a verdict. Without it, returns the handoff response as before.

Source

pub async fn receive_handoffs( &self, options: ReceiveHandoffsOptions, ) -> Result<Vec<ReceivedHandoff>>

Receiver-side handoff inbox.

Implemented client-side over query with entry_types = ["handoff"] (evidence only, no LLM synthesis) and filtered to evidence whose metadata addresses to_agent_id == agent_id. Each match is returned as a ReceivedHandoff wrapper around the raw evidence item.

Source

pub async fn feedback(&self, options: FeedbackOptions) -> Result<Value>

Source §