Struct SlopServer 

pub struct SlopServer { /* private fields */ }

SLOP server provider.

Manages node registrations, connections, and message routing. Thread-safe — can be shared across threads via Clone (it wraps Arc).

Example

use slop_ai::SlopServer;
use serde_json::json;

let mut slop = SlopServer::new("my-app", "My App");
slop.register("status", json!({"type": "status", "props": {"healthy": true}}));
assert_eq!(slop.version(), 1);

Implementations

impl SlopServer

pub fn new(id: impl Into<String>, name: impl Into<String>) -> Self

Create a new SLOP server with the given provider ID and name.

pub fn tree(&self) -> SlopNode

Current state tree.

pub fn version(&self) -> u64

Current version number.

pub fn register(&self, path: impl Into<String>, descriptor: Value)

Register a static node descriptor at path.

pub fn register_fn<F>(&self, path: impl Into<String>, f: F)

where F: Fn() -> Value + Send + Sync + 'static,

Register a descriptor function re-evaluated on refresh().

pub fn action<F>( &self, path: impl Into<String>, name: impl Into<String>, handler: F, )

where F: Fn(&Value) -> Result<Option<Value>> + Send + Sync + 'static,

Register an action handler at path/name.

pub fn action_with<F>( &self, path: impl Into<String>, name: impl Into<String>, handler: F, options: ActionOptions, )

where F: Fn(&Value) -> Result<Option<Value>> + Send + Sync + 'static,

Register an action handler with metadata (label, dangerous, etc.).

pub fn unregister(&self, path: &str)

Remove the registration at path.

pub fn scope(&self, prefix: impl Into<String>) -> ScopedServer

Return a scoped server that prefixes all paths.

pub fn refresh(&self)

Re-evaluate all dynamic registrations, diff, and broadcast patches.

pub fn handle_connection(&self, conn: Arc<dyn Connection>)

Handle a new consumer connection.

pub fn emit_event(&self, name: &str, data: Option<Value>)

Emit an event to all connected consumers.

pub fn handle_message(&self, conn: &Arc<dyn Connection>, msg: &Value)

Process an incoming message from a consumer.

pub fn handle_disconnect(&self, conn: &Arc<dyn Connection>)

Handle a consumer disconnect.

pub fn on_change<F: Fn() + Send + Sync + 'static>(&self, callback: F)

Register a callback fired after each tree change.

pub fn stop(&self)

Close all connections and clean up.

Trait Implementations

impl Clone for SlopServer

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.