pe-core 0.1.0

Core types for Potential Expectations — messages, channels, state, traits
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

//! # pe-core — Core types for Potential Expectations
//!
//! Zero internal dependencies. Every other crate in the workspace depends on this.
//! Contains: messages, channels, state traits, node traits, error types, agent types.

pub mod agent;
pub mod boundaries;
pub mod channel;
pub mod channel_store;
pub mod circuit_breaker;
pub mod cognitive;
pub mod cognitive_budget;
pub mod cognitive_memory;
pub mod cognitive_signal;
pub mod error;
pub mod fallback_provider;
pub mod formatter;
pub mod internal_tool;
pub mod lobe;
pub mod lobe_cache;
pub mod lobe_node;
pub mod lobe_registry;

pub mod llm;
pub mod message;
pub mod middleware_stack;
pub mod mock_provider;
pub mod node;
pub mod openai_formatter;
pub mod phase_store;
pub mod provider_middleware;
pub mod reducers;
pub mod retry_middleware;
pub mod scope;
pub mod self_model;
pub mod state;
pub mod synthesizer;
pub mod timeout_middleware;
pub mod token;
pub mod types;
pub mod validation;
#[macro_use]
pub mod macros;

// Re-export primary types at crate root
pub use agent::Agent;
pub use channel::Channel;
pub use channel_store::{ChannelId, ChannelStore};
pub use cognitive::{
    CognitiveArchitecture, CognitiveState, CognitiveStateUpdate, CognitiveStream, SynthesisStrategy,
};
pub use cognitive_budget::{BudgetTracker, CognitiveBudget};
pub use cognitive_memory::{
    MeditateConfig, MeditateResult, MemoryConfig, NoteCategory, WorkingNote,
};
pub use cognitive_signal::CognitiveSignal;
pub use error::PeError;
pub use formatter::MessageFormatter;
pub use internal_tool::{InternalTool, InternalToolRegistry};
pub use llm::{LlmProvider, LlmResponse, StreamChunk, StreamFuture, ToolSchema};
pub use lobe::{
    Lobe, LobeActivation, LobeBudget, LobeContext, LobeFuture, LobeInput, LobeInspectionEntry,
    LobeInspectionEntryKind, LobeInspectionRequest, LobeInspectionResult, LobeOutput,
    LobeOutputFormat, LobeRuntimeServiceFactory, LobeRuntimeServices,
};
pub use lobe_cache::LobeCache;
pub use lobe_node::LobeNode;
pub use lobe_registry::LobeRegistry;
pub use message::*;
pub use mock_provider::MockProvider;
pub use node::{
    ActivationReason, ConvergenceSignal, HumanInput, InterruptRequest, NodeContext, NodeFn,
    NodeFuture, NodeObserver, NodeResult, ToolObserver,
};
pub use openai_formatter::OpenAiFormatter;
pub use phase_store::{PhaseStateStore, PhaseStoreError};
pub use reducers::add_messages;
pub use scope::ExecutionScope;
pub use self_model::{FailureRecord, NegativeKnowledge, SelfModel, Severity};
pub use state::{CoreState, CoreStateUpdate, State, StateUpdate};
pub use synthesizer::{
    IntegrateSynthesizer, SynthesisResult, Synthesizer, VoteSynthesizer, WeightedSynthesizer,
};
pub use token::{CharTokenCounter, TokenCounter, TrimStrategy, trim_messages};
pub use types::{AgentCapability, AgentMatrix, BuilderMode, END, ExecutionBudget, NodeId, START};
pub use validation::{ExecutionMetrics, WriteRecord};

// Middleware types
pub use circuit_breaker::CircuitBreaker;
pub use fallback_provider::FallbackProvider;
pub use middleware_stack::MiddlewareStack;
pub use provider_middleware::ProviderMiddleware;
pub use retry_middleware::RetryMiddleware;
pub use timeout_middleware::TimeoutMiddleware;