cognis-core 0.3.1

Foundation traits and types for Cognis: typed Runnable<I, O>, Message, errors, streaming, prompts, output parsers, callbacks. Zero external integrations.
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

//! Resilience and policy wrappers for any `Runnable`.
//!
//! - [`Retry`] — exponential backoff on retryable errors.
//! - [`Fallback`] — switch to a backup runnable on error.
//! - [`Timeout`] — bound per-invocation duration.
//! - [`Cache`] — memoize by an input-derived key.
//!
//! All wrappers are themselves `Runnable`s, so they compose with `Pipe`
//! (and `|`). The fluent shorthand lives on [`crate::RunnableExt`]:
//!
//! ```ignore
//! let resilient = model
//!     .with_max_retries(3)
//!     .with_timeout(Duration::from_secs(30))
//!     .with_fallback(backup_model);
//! ```

pub mod assign;
pub mod batch_processor;
pub mod bind;
pub mod cache;
pub mod configurable;
pub mod fallback;
pub mod listeners;
pub mod middleware;
pub mod retry;
pub mod schema;
pub mod timeout;

pub use assign::{Assign, AssignOutput};
pub use batch_processor::{BatchOptions, BatchProcessor};
pub use bind::Bind;
pub use cache::{Cache, CacheBackend, MemoryCache};
pub use configurable::{ConfigKey, Configurable};
pub use fallback::Fallback;
pub use listeners::{
    fn_listener, BuiltListener, FnListener, Listener, ListenerBuilder, WithListeners,
};
pub use middleware::{
    fn_middleware, FnMiddleware, InspectMiddleware, Middleware, MiddlewareStack, WithMiddleware,
};
pub use retry::{Retry, RetryPolicy};
pub use schema::WithSchema;
pub use timeout::Timeout;