Struct Agent 

pub struct Agent { /* private fields */ }

Agent is the authoritative agent data boundary. Read RPCs for sessions, turns, turn events, and interactions should use provider-owned control-plane state and should not require a live execution sandbox, pod-level transport, or cached tunnel.

Client for the gestalt.provider.v1.Agent service.

Implementations

impl Agent

pub fn new(channel: Channel) -> Self

Creates a client over an established channel.

pub fn with_timeout(self, timeout: Duration) -> Self

Sets a deadline applied to every unary call; calls that run past it fail with DEADLINE_EXCEEDED. Streaming calls are unaffected.

pub fn with_context(self, context: RequestContext) -> Self

Sets the default request context, injected into outgoing requests that do not carry one.

pub async fn connect() -> Result<Self, GestaltError>

Connects to the agent host service described by the environment.

pub async fn connect_named(name: &str) -> Result<Self, GestaltError>

Connects to the named agent host-service binding.

pub async fn create_session( &mut self, idempotency_key: String, model: String, options: AgentCreateSessionOptions, ) -> Result<AgentSession, GestaltError>

Calls gestalt.provider.v1.Agent.CreateSession.

pub async fn create_session_raw( &mut self, request: CreateAgentProviderSessionRequest, ) -> Result<AgentSession, GestaltError>

Calls gestalt.provider.v1.Agent.CreateSession with the full request and response messages.

pub async fn get_session( &mut self, session_id: String, options: AgentGetSessionOptions, ) -> Result<AgentSession, GestaltError>

Calls gestalt.provider.v1.Agent.GetSession.

pub async fn get_session_raw( &mut self, request: GetAgentProviderSessionRequest, ) -> Result<AgentSession, GestaltError>

Calls gestalt.provider.v1.Agent.GetSession with the full request and response messages.

pub async fn list_sessions( &mut self, options: AgentListSessionsOptions, ) -> Result<Vec<AgentSession>, GestaltError>

Calls gestalt.provider.v1.Agent.ListSessions.

pub async fn list_sessions_raw( &mut self, request: ListAgentProviderSessionsRequest, ) -> Result<ListAgentProviderSessionsResponse, GestaltError>

Calls gestalt.provider.v1.Agent.ListSessions with the full request and response messages.

pub async fn update_session( &mut self, session_id: String, options: AgentUpdateSessionOptions, ) -> Result<AgentSession, GestaltError>

Calls gestalt.provider.v1.Agent.UpdateSession.

pub async fn update_session_raw( &mut self, request: UpdateAgentProviderSessionRequest, ) -> Result<AgentSession, GestaltError>

Calls gestalt.provider.v1.Agent.UpdateSession with the full request and response messages.

pub async fn create_turn( &mut self, session_id: String, idempotency_key: String, model: String, messages: Vec<AgentMessage>, options: AgentCreateTurnOptions, ) -> Result<AgentTurn, GestaltError>

Calls gestalt.provider.v1.Agent.CreateTurn.

pub async fn create_turn_raw( &mut self, request: CreateAgentProviderTurnRequest, ) -> Result<AgentTurn, GestaltError>

Calls gestalt.provider.v1.Agent.CreateTurn with the full request and response messages.

pub async fn get_turn( &mut self, turn_id: String, options: AgentGetTurnOptions, ) -> Result<AgentTurn, GestaltError>

Calls gestalt.provider.v1.Agent.GetTurn.

pub async fn get_turn_raw( &mut self, request: GetAgentProviderTurnRequest, ) -> Result<AgentTurn, GestaltError>

Calls gestalt.provider.v1.Agent.GetTurn with the full request and response messages.

pub async fn list_turns( &mut self, session_id: String, options: AgentListTurnsOptions, ) -> Result<Vec<AgentTurn>, GestaltError>

Calls gestalt.provider.v1.Agent.ListTurns.

pub async fn list_turns_raw( &mut self, request: ListAgentProviderTurnsRequest, ) -> Result<ListAgentProviderTurnsResponse, GestaltError>

Calls gestalt.provider.v1.Agent.ListTurns with the full request and response messages.

pub async fn cancel_turn( &mut self, turn_id: String, options: AgentCancelTurnOptions, ) -> Result<AgentTurn, GestaltError>

Calls gestalt.provider.v1.Agent.CancelTurn.

pub async fn cancel_turn_raw( &mut self, request: CancelAgentProviderTurnRequest, ) -> Result<AgentTurn, GestaltError>

Calls gestalt.provider.v1.Agent.CancelTurn with the full request and response messages.

pub async fn list_turn_events( &mut self, turn_id: String, options: AgentListTurnEventsOptions, ) -> Result<Vec<AgentTurnEvent>, GestaltError>

Calls gestalt.provider.v1.Agent.ListTurnEvents.

pub async fn list_turn_events_raw( &mut self, request: ListAgentProviderTurnEventsRequest, ) -> Result<ListAgentProviderTurnEventsResponse, GestaltError>

Calls gestalt.provider.v1.Agent.ListTurnEvents with the full request and response messages.

pub async fn get_interaction( &mut self, interaction_id: String, ) -> Result<AgentInteraction, GestaltError>

Calls gestalt.provider.v1.Agent.GetInteraction.

pub async fn get_interaction_raw( &mut self, request: GetAgentProviderInteractionRequest, ) -> Result<AgentInteraction, GestaltError>

Calls gestalt.provider.v1.Agent.GetInteraction with the full request and response messages.

pub async fn list_interactions( &mut self, turn_id: String, options: AgentListInteractionsOptions, ) -> Result<Vec<AgentInteraction>, GestaltError>

Calls gestalt.provider.v1.Agent.ListInteractions.

pub async fn list_interactions_raw( &mut self, request: ListAgentProviderInteractionsRequest, ) -> Result<ListAgentProviderInteractionsResponse, GestaltError>

Calls gestalt.provider.v1.Agent.ListInteractions with the full request and response messages.

pub async fn resolve_interaction( &mut self, interaction_id: String, resolution: Option<Map<String, Value>>, options: AgentResolveInteractionOptions, ) -> Result<AgentInteraction, GestaltError>

Calls gestalt.provider.v1.Agent.ResolveInteraction.

pub async fn resolve_interaction_raw( &mut self, request: ResolveAgentProviderInteractionRequest, ) -> Result<AgentInteraction, GestaltError>

Calls gestalt.provider.v1.Agent.ResolveInteraction with the full request and response messages.

pub async fn get_capabilities( &mut self, request: GetAgentProviderCapabilitiesRequest, ) -> Result<AgentProviderCapabilities, GestaltError>

Calls gestalt.provider.v1.Agent.GetCapabilities.