Struct CellstateClient 

pub struct CellstateClient {
    http: Client,
    base_url: Url,
    api_key: SecretString,
    response_format: ResponseFormat,
}

Fields

http: Client

base_url: Url

api_key: SecretString

response_format: ResponseFormat

Implementations

impl CellstateClient

pub fn new(base_url: &str, api_key: &str) -> Result<Self>

Create a new client pointing at the given API base URL.

Arguments

• base_url: Full URL to the CELLSTATE API (e.g., "https://cst.batterypack.dev")
• api_key: API key for authentication (e.g., "cst_...")

Errors

Returns Error::InvalidUrl if base_url cannot be parsed.

pub fn from_env() -> Result<Self>

Create a client from environment variables.

Reads CELLSTATE_API_URL (or CELLSTATE_BASE_URL) and CELLSTATE_API_KEY.

Errors

Returns Error::InvalidUrl if the URL env var is missing or invalid.

fn url(&self, path: &str) -> Result<Url>

Build the full URL for an API path.

pub fn with_response_format(self, response_format: ResponseFormat) -> Self

Returns a cloned client configured to request the given response format.

pub fn set_response_format(&mut self, response_format: ResponseFormat)

Set the preferred response format for this client.

fn auth(&self, builder: RequestBuilder) -> RequestBuilder

Attach authentication and common headers to a request.

fn is_msgpack_content_type(content_type: &str) -> bool

async fn parse_response<T>(&self, response: Response) -> Result<T>

where T: DeserializeOwned,

async fn send(&self, builder: RequestBuilder) -> Result<Response>

Execute a request and handle error responses.

pub async fn create_trajectory( &self, request: &CreateTrajectoryRequest, ) -> Result<TrajectoryResponse>

Create a new trajectory.

pub async fn get_trajectory( &self, id: TrajectoryId, ) -> Result<TrajectoryResponse>

Get a trajectory by ID.

pub async fn list_trajectories( &self, params: &ListParams, ) -> Result<ListResponse<TrajectoryResponse>>

List trajectories with optional pagination.

pub async fn update_trajectory( &self, id: TrajectoryId, request: &UpdateTrajectoryRequest, ) -> Result<TrajectoryResponse>

Update a trajectory.

pub async fn delete_trajectory(&self, id: TrajectoryId) -> Result<()>

Delete a trajectory.

pub async fn create_scope( &self, request: &CreateScopeRequest, ) -> Result<ScopeResponse>

Create a new scope.

pub async fn get_scope(&self, id: ScopeId) -> Result<ScopeResponse>

Get a scope by ID.

pub async fn list_scopes( &self, params: &ListParams, ) -> Result<ListResponse<ScopeResponse>>

List scopes with optional pagination.

pub async fn update_scope( &self, id: ScopeId, request: &UpdateScopeRequest, ) -> Result<ScopeResponse>

Update a scope.

pub async fn delete_scope(&self, id: ScopeId) -> Result<()>

Delete a scope.

pub async fn create_artifact( &self, request: &CreateArtifactRequest, ) -> Result<ArtifactResponse>

Create a new artifact.

pub async fn get_artifact(&self, id: ArtifactId) -> Result<ArtifactResponse>

Get an artifact by ID.

pub async fn list_artifacts( &self, params: &ListParams, ) -> Result<ListResponse<ArtifactResponse>>

List artifacts with optional pagination.

pub async fn update_artifact( &self, id: ArtifactId, request: &UpdateArtifactRequest, ) -> Result<ArtifactResponse>

Update an artifact.

pub async fn delete_artifact(&self, id: ArtifactId) -> Result<()>

Delete an artifact.

pub async fn create_note( &self, request: &CreateNoteRequest, ) -> Result<NoteResponse>

Create a new note.

pub async fn get_note(&self, id: NoteId) -> Result<NoteResponse>

Get a note by ID.

pub async fn list_notes( &self, params: &ListParams, ) -> Result<ListResponse<NoteResponse>>

List notes with optional pagination.

pub async fn update_note( &self, id: NoteId, request: &UpdateNoteRequest, ) -> Result<NoteResponse>

Update a note.

pub async fn delete_note(&self, id: NoteId) -> Result<()>

Delete a note.

pub async fn create_turn( &self, request: &CreateTurnRequest, ) -> Result<TurnResponse>

Create a new turn.

pub async fn get_turn(&self, id: TurnId) -> Result<TurnResponse>

Get a turn by ID.

pub async fn list_turns( &self, params: &ListParams, ) -> Result<ListResponse<TurnResponse>>

List turns with optional pagination.

pub async fn create_agent( &self, request: &CreateAgentRequest, ) -> Result<AgentResponse>

Create a new agent.

pub async fn get_agent(&self, id: AgentId) -> Result<AgentResponse>

Get an agent by ID.

pub async fn list_agents( &self, params: &ListParams, ) -> Result<ListResponse<AgentResponse>>

List agents with optional pagination.

pub async fn commit_memory( &self, request: &CommitMemoryRequest, ) -> Result<CommitMemoryResponse>

Commit a memory interaction (PCP memory commit).

pub async fn recall(&self, request: &RecallRequest) -> Result<RecallResponse>

Recall previous interactions for a trajectory.

pub async fn assemble_context( &self, request: &AssembleContextRequest, ) -> Result<AssembleContextResponse>

Assemble a context window for a scope.

pub async fn health(&self) -> Result<bool>

Check API health.

Returns Ok(true) if the API is healthy, Ok(false) if it returns a non-success status, or Err on connection failure.

Trait Implementations

impl Clone for CellstateClient

fn clone(&self) -> CellstateClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CellstateClient

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

Formats the value using the given formatter.