Struct InternalGenericAgentProvider 

pub struct InternalGenericAgentProvider { /* private fields */ }

Implementations

impl InternalGenericAgentProvider

pub fn with_checkpoint_store( self, checkpoint_store: Arc<dyn GenericAgentCheckpointStore>, ) -> Result<Self, AgentProtocolError>

Replaces the process-lifetime checkpoint WAL before this Provider is cloned or bound to a controller.

pub fn with_session_compaction( self, summarizer: Arc<dyn AgentSessionSummarizer>, policy: SessionCompactionPolicy, ) -> Result<Self, AgentProtocolError>

Binds one explicit Session compaction strategy before this Provider is shared. The policy becomes part of the immutable Generic Agent config digest; summaries remain durable Journal facts with their own strategy and version provenance.

pub fn new( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, ) -> Result<Self, AgentProtocolError>

pub fn new_with_session_journal( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, session_journal: Arc<dyn AgentSessionJournalStore>, token_meter: Arc<dyn ModelTokenMeter>, ) -> Result<Self, AgentProtocolError>

pub fn new_with_tools( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, runtime: Arc<dyn AgentToolRuntime>, run_grant: RunToolGrant, ) -> Result<Self, AgentProtocolError>

pub fn new_with_tools_and_session_journal( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, runtime: Arc<dyn AgentToolRuntime>, run_grant: RunToolGrant, session_journal: Arc<dyn AgentSessionJournalStore>, token_meter: Arc<dyn ModelTokenMeter>, ) -> Result<Self, AgentProtocolError>

pub fn new_with_tools_approval_and_session_journal( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, runtime: Arc<dyn AgentToolRuntime>, run_grant: RunToolGrant, approval_bridge: Arc<dyn AgentApprovalBridge>, session_journal: Arc<dyn AgentSessionJournalStore>, token_meter: Arc<dyn ModelTokenMeter>, ) -> Result<Self, AgentProtocolError>

Enables Host-mediated approval while keeping capability issuance out of both the model and the Generic Agent implementation.

pub fn new_with_workflow_and_session_journal( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, runtime: Arc<dyn AgentToolRuntime>, run_grant: RunToolGrant, workflow: Arc<WorkflowExecutionStrategy>, session_journal: Arc<dyn AgentSessionJournalStore>, token_meter: Arc<dyn ModelTokenMeter>, ) -> Result<Self, AgentProtocolError>

Enables explicit complex-workflow selection while retaining one Generic Agent loop and the same guarded Tool Runtime for direct and DAG calls.

pub fn new_with_skills_and_session_journal( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, skills: Arc<SkillRuntime>, session_journal: Arc<dyn AgentSessionJournalStore>, token_meter: Arc<dyn ModelTokenMeter>, ) -> Result<Self, AgentProtocolError>

Enables the independent Skill Context Plane. The catalog must still be bound into each Run before descriptors or loading are visible.

pub fn new_with_tools_approval_skills_and_session_journal( backend: Arc<dyn ModelBackend>, config: GenericAgentConfig, runtime: Arc<dyn AgentToolRuntime>, run_grant: RunToolGrant, approval_bridge: Arc<dyn AgentApprovalBridge>, skills: Arc<SkillRuntime>, session_journal: Arc<dyn AgentSessionJournalStore>, token_meter: Arc<dyn ModelTokenMeter>, ) -> Result<Self, AgentProtocolError>

Composition-root constructor for the ordinary CLI/API Agent: Skill context and guarded Tools remain separate runtimes sharing only the Generic Agent loop.

Trait Implementations

impl AgentProvider for InternalGenericAgentProvider

fn describe(&self) -> AgentDescriptorEnvelope

Describe only capabilities that the implementation actually enforces.

fn start<'life0, 'async_trait>( &'life0 self, request: AgentStartRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentStart, AgentStartError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Idempotently start one immutable AgentStartRequest identity: Run, Session, spec digest, Provider binding, and descriptor digest.

fn command<'life0, 'life1, 'async_trait>( &'life0 self, execution: &'life1 AgentExecutionRef, command: AgentCommandEnvelope, ) -> Pin<Box<dyn Future<Output = Result<ProviderCommandDisposition, AgentProtocolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Apply an idempotent command to an existing run.

fn recover<'life0, 'async_trait>( &'life0 self, request: AgentRecoveryRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentRecovery, AgentProtocolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Recover the Provider-native observation stream for an existing run.

impl Clone for InternalGenericAgentProvider

fn clone(&self) -> InternalGenericAgentProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.