behest 0.4.1

A Rust-native cloud agent runtime with typed tools, pluggable memory, queues, and observability.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

//! Agent runtime kernel.
//!
//! This module provides the core runtime engine for executing AI agents
//! with streaming-first execution, tool calling, session persistence,
//! event-sourced state management, snapshot recovery, compaction,
//! doom-loop detection, and background job processing.

pub mod accumulator;
pub mod agent;
pub mod compaction;
pub mod component;
pub mod component_factory;
pub mod components;
pub mod context;
pub mod doom_loop;
pub mod error;
pub mod event;
pub mod event_store;
pub mod extension;
pub mod extensions;
pub mod factory_registry;
pub mod input;
pub mod invocation;
pub mod lifecycle;
pub mod managed;
pub mod memory;
pub mod policy;
pub mod registry;
pub mod router;
pub mod run;
mod run_loop;
pub mod session_gate;
pub mod snapshot;
pub mod state;
pub mod store;
pub mod stream;
pub mod stream_adapter;
pub mod subscription;
pub mod tool;
pub mod turn;

#[cfg(feature = "redis")]
pub mod session_data_store;

pub use agent::{AgentRuntime, RunOutput};
pub use compaction::{CompactionResult, CompactionService};
pub use component::{AnyComponent, AnyComponentError, Component, ComponentContext};
pub use component_factory::{
    ChatProviderAny, ChatProviderComponent, ChatProviderFactory, EmbeddingProviderAny,
    EmbeddingProviderComponent, EmbeddingProviderFactory, EmptyConfig, WrapperError,
};
pub use components::{
    ComponentError, ContextPipelineComponent, ContextPipelineConfig, MemoryArtifactStoreComponent,
    MemoryEmbeddingStoreComponent, MemoryExecutionStoreComponent, MemoryRunStoreComponent,
    MemorySessionStoreComponent, ProviderHttpComponentConfig, default_factory_registry,
    register_context_pipeline, register_memory_stores, register_providers,
};

#[cfg(feature = "openai")]
pub use components::{OpenAiChatComponent, OpenAiEmbeddingComponent};

#[cfg(feature = "anthropic")]
pub use components::AnthropicChatComponent;
pub use context::ContextPipeline;
pub use doom_loop::{DoomLoopConfig, DoomLoopDetector, DoomLoopType, ToolCallFingerprint};
pub use error::RuntimeError;
pub use event::AgentEvent;
pub use event_store::{
    DynRuntimeEventStore, FailingRuntimeEventStore, MemoryRuntimeEventStore, RuntimeEventStore,
    RuntimeEventStoreError,
};
pub use extension::{ExtensionError, ExtensionPoint};
pub use extensions::Extensions;
pub use factory_registry::{FactoryError, FactoryFn, FactoryRegistry};
pub use input::{
    InputAdmission, InputAdmissionConfig, InputEvent, InputId, InputRecord, InputState,
};
pub use invocation::{
    Control, EmitRequest, EventKind, FileSessionDataStore, InvocationError, InvocationEvent,
    InvocationHandle, InvocationSession, MemorySessionDataStore, RuntimeInvocation,
    SessionDataError, SessionDataStore,
};
pub use lifecycle::ShutdownToken;
pub use managed::{ManagedError, ManagedRuntime};
pub use policy::{CompactionConfig, RuntimePolicy};
pub use registry::{
    ComponentDescriptor, ComponentFactory, ComponentRegistry, ComponentState, RegistryError,
    TypedAnyComponent, TypedFactory,
};
pub use router::ModelRouter;
pub use run::{RunId, RunRequest, RunStatus};
pub use session_gate::{SessionGate, SessionGuard};
pub use snapshot::{FileSnapshotStore, Snapshot, SnapshotStore};
pub use state::RunState;
pub use store::RuntimeStore;
pub use stream::{
    BoxRuntimeEventStream, RuntimeEventEnvelope, RuntimeEventId, RuntimeRoom, RuntimeStreamError,
};
pub use stream_adapter::{
    DynRuntimeStreamAdapter, FailingRuntimeStreamAdapter, MemoryRuntimeStreamAdapter,
    RuntimeStreamAdapter,
};
pub use subscription::{
    RuntimeEventBridge, RuntimeEventBridgeError, RuntimeEventBridgeHandle, RuntimeSubscription,
    RuntimeSubscriptionError, RuntimeSubscriptionHub,
};
pub use tool::ToolRuntime;
pub use turn::{TurnState, TurnTransition};

#[cfg(feature = "redis")]
pub use event_store::redis::RedisRuntimeEventStore;

#[cfg(feature = "redis")]
pub use session_data_store::RedisSessionDataStore;

#[cfg(feature = "redis")]
pub use stream_adapter::redis::RedisRuntimeStreamAdapter;

#[cfg(feature = "sqlx-postgres")]
pub use event_store::postgres::PostgresRuntimeEventStore;

#[cfg(feature = "nats")]
pub use stream_adapter::nats_jetstream::NatsJetStreamStreamAdapter;