pe_core/
lib.rs

1//! # pe-core — Core types for Potential Expectations
2//!
3//! Zero internal dependencies. Every other crate in the workspace depends on this.
4//! Contains: messages, channels, state traits, node traits, error types, agent types.
5
6pub mod agent;
7pub mod boundaries;
8pub mod channel;
9pub mod channel_store;
10pub mod circuit_breaker;
11pub mod cognitive;
12pub mod cognitive_budget;
13pub mod cognitive_memory;
14pub mod cognitive_signal;
15pub mod error;
16pub mod fallback_provider;
17pub mod formatter;
18pub mod internal_tool;
19pub mod lobe;
20pub mod lobe_cache;
21pub mod lobe_node;
22pub mod lobe_registry;
23
24pub mod llm;
25pub mod message;
26pub mod middleware_stack;
27pub mod mock_provider;
28pub mod node;
29pub mod openai_formatter;
30pub mod phase_store;
31pub mod provider_middleware;
32pub mod reducers;
33pub mod retry_middleware;
34pub mod scope;
35pub mod self_model;
36pub mod state;
37pub mod synthesizer;
38pub mod timeout_middleware;
39pub mod token;
40pub mod types;
41pub mod validation;
42#[macro_use]
43pub mod macros;
44
45// Re-export primary types at crate root
46pub use agent::Agent;
47pub use channel::Channel;
48pub use channel_store::{ChannelId, ChannelStore};
49pub use cognitive::{
50    CognitiveArchitecture, CognitiveState, CognitiveStateUpdate, CognitiveStream, SynthesisStrategy,
51};
52pub use cognitive_budget::{BudgetTracker, CognitiveBudget};
53pub use cognitive_memory::{
54    MeditateConfig, MeditateResult, MemoryConfig, NoteCategory, WorkingNote,
55};
56pub use cognitive_signal::CognitiveSignal;
57pub use error::PeError;
58pub use formatter::MessageFormatter;
59pub use internal_tool::{InternalTool, InternalToolRegistry};
60pub use llm::{LlmProvider, LlmResponse, StreamChunk, StreamFuture, ToolSchema};
61pub use lobe::{
62    Lobe, LobeActivation, LobeBudget, LobeContext, LobeFuture, LobeInput, LobeInspectionEntry,
63    LobeInspectionEntryKind, LobeInspectionRequest, LobeInspectionResult, LobeOutput,
64    LobeOutputFormat, LobeRuntimeServiceFactory, LobeRuntimeServices,
65};
66pub use lobe_cache::LobeCache;
67pub use lobe_node::LobeNode;
68pub use lobe_registry::LobeRegistry;
69pub use message::*;
70pub use mock_provider::MockProvider;
71pub use node::{
72    ActivationReason, ConvergenceSignal, HumanInput, InterruptRequest, NodeContext, NodeFn,
73    NodeFuture, NodeObserver, NodeResult, ToolObserver,
74};
75pub use openai_formatter::OpenAiFormatter;
76pub use phase_store::{PhaseStateStore, PhaseStoreError};
77pub use reducers::add_messages;
78pub use scope::ExecutionScope;
79pub use self_model::{FailureRecord, NegativeKnowledge, SelfModel, Severity};
80pub use state::{CoreState, CoreStateUpdate, State, StateUpdate};
81pub use synthesizer::{
82    IntegrateSynthesizer, SynthesisResult, Synthesizer, VoteSynthesizer, WeightedSynthesizer,
83};
84pub use token::{CharTokenCounter, TokenCounter, TrimStrategy, trim_messages};
85pub use types::{AgentCapability, AgentMatrix, BuilderMode, END, ExecutionBudget, NodeId, START};
86pub use validation::{ExecutionMetrics, WriteRecord};
87
88// Middleware types
89pub use circuit_breaker::CircuitBreaker;
90pub use fallback_provider::FallbackProvider;
91pub use middleware_stack::MiddlewareStack;
92pub use provider_middleware::ProviderMiddleware;
93pub use retry_middleware::RetryMiddleware;
94pub use timeout_middleware::TimeoutMiddleware;
pe_core/lib.rs

pe_core/
lib.rs
