cordis-rs 0.4.2

Runtime-agnostic Rust port of Cordis, the plugin framework at the core of DeepSeek Harness
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

//! Cordis is a context-based plugin framework with scoped dependency injection,
//! lifecycle-owned effects, events, configuration interception, and structured
//! logging.
//!
//! This crate is a Rust port of `@deepseek-ai/cordis` 4.x.  The JavaScript
//! implementation relies heavily on proxies, prototype chains, callable
//! objects, and decorators.  The Rust API keeps the same runtime model while
//! replacing those language features with explicit, typed methods.
//!
//! # Quick start
//!
//! ```
//! use cordis::{plugin_sync, Context, Inject, PluginOutput};
//! use std::sync::atomic::{AtomicUsize, Ordering};
//! use std::sync::Arc;
//!
//! let root = Context::new();
//! let counter = Arc::new(AtomicUsize::new(0));
//! let _counter_effect = root.provide_arc("counter", counter.clone()).unwrap();
//!
//! let greeter = plugin_sync::<(), _>("greeter", Inject::new(["counter"]),
//!     |ctx, _config| {
//!         let counter = ctx.require::<AtomicUsize>("counter")?;
//!         counter.fetch_add(1, Ordering::SeqCst);
//!         Ok(PluginOutput::default())
//!     });
//!
//! let fiber = root.plugin(greeter, ());
//! fiber.try_wait().unwrap();
//! assert_eq!(counter.load(Ordering::SeqCst), 1);
//! fiber.dispose().unwrap();
//! ```

#![forbid(unsafe_code)]
#![warn(missing_docs)]

pub mod context;
pub mod effect;
pub mod error;
pub mod events;
pub mod fiber;
pub mod logger;
pub mod reflect;
pub mod registry;
pub mod service;
pub mod utils;
pub mod value;

pub use context::{Context, ContextMeta, Isolation};
pub use effect::{AsyncDisposer, EffectHandle, EffectMeta};
pub use error::{CordisError, ErrorCode, Result, ValidationError, ValidationIssue};
pub use events::{
    DispatchMode, Event, EventOptions, EventResult, EventValue, EventsService, is_bailed,
};
pub use fiber::{Fiber, FiberState};
pub use logger::{
    C16, C256, Exporter, ExporterConfig, FormatterFn, LogArg, Logger, LoggerIntercept, LoggerLevel,
    LoggerService, LoggerType, Message, color_code, default_format,
};
pub use reflect::{Accessor, Property, ReflectService, ServiceInfo};
pub use registry::{
    Inject, IntoPlugin, Plugin, PluginHandle, PluginKey, PluginOutput, RegistryService,
    RuntimeInfo, plugin_async, plugin_sync,
};
pub use service::{Service, service_async, service_sync};
pub use value::{Config, Value};