Struct BasicHarness 

pub struct BasicHarness<E, P, A, S, T> { /* private fields */ }

Minimal in-process harness implementation.

Implementations

impl BasicHarness<NoopEffectExecutor, DefaultPolicyEngine, AlwaysDenyApprovalBroker, NoopAuditSink, NoopTranscriptStore>

pub fn noop() -> BasicHarness<NoopEffectExecutor, DefaultPolicyEngine, AlwaysDenyApprovalBroker, NoopAuditSink, NoopTranscriptStore>

Constructs a harness that performs no side effects.

impl<E, P, A, S, T> BasicHarness<E, P, A, S, T>

where E: EffectExecutor, P: PolicyEngine, A: ApprovalBroker, S: AuditSink, T: TranscriptStore,

pub fn new( executor: E, policy: P, approval: A, audit: S, transcript: T, ) -> BasicHarness<E, P, A, S, T>

Constructs a harness from its lifecycle components.

pub fn with_config(self, config: HarnessConfig) -> BasicHarness<E, P, A, S, T>

Replaces harness configuration.

pub fn with_noop_redactor(self) -> BasicHarness<E, P, A, S, T>

Uses the default no-op redactor.

pub fn with_redactor( self, redactor: impl Redactor + 'static, ) -> BasicHarness<E, P, A, S, T>

Replaces the output redactor used before observations are returned, audited, or stored in transcripts.

Trait Implementations

impl<E, P, A, S, T> Debug for BasicHarness<E, P, A, S, T>

where E: Debug, P: Debug, A: Debug, S: Debug, T: Debug,

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

Formats the value using the given formatter.

impl<E, P, A, S, T> Harness for BasicHarness<E, P, A, S, T>

where E: EffectExecutor, P: PolicyEngine, A: ApprovalBroker, S: AuditSink, T: TranscriptStore,

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, request: EffectRequest, context: &'life1 RunContext, ) -> Pin<Box<dyn Future<Output = Result<EffectObservation, HarnessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, BasicHarness<E, P, A, S, T>: 'async_trait,

Executes one effect through the harness lifecycle.

fn execute_batch<'life0, 'life1, 'async_trait>( &'life0 self, requests: Vec<EffectRequest>, context: &'life1 RunContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<EffectObservation>, HarnessError>> + Send + 'async_trait>>

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

Executes a batch of effects.