Struct ContextBuilder 

pub struct ContextBuilder { /* private fields */ }

Builder for creating Context instances with fluent API

Provides a more ergonomic way to create contexts with various configurations.

Example

use mecha10::context::ContextBuilder;

let ctx = ContextBuilder::new("my-node")
    .with_instance("instance-1")
    .with_redis("redis://localhost:6379")
    .build()
    .await?;

Implementations

impl ContextBuilder

pub fn new(node_id: impl Into<String>) -> Self

Create a new context builder

Arguments

• node_id - Unique identifier for the node

Example

use mecha10::context::ContextBuilder;

let builder = ContextBuilder::new("my-node");

pub fn with_instance(self, instance: impl Into<String>) -> Self

Set an instance name for this context

Allows running multiple instances of the same node with different names. The final node_id becomes “{node_name}/{instance}”.

Example

let builder = ContextBuilder::new("camera")
    .with_instance("left");

pub fn with_redis(self, url: impl Into<String>) -> Self

Set the Redis connection URL

Override the default Redis URL from environment or config.

Example

let builder = ContextBuilder::new("my-node")
    .with_redis("redis://localhost:6379");

pub fn with_state_dir(self, dir: impl Into<PathBuf>) -> Self

Set the state directory for persistent storage

Example

let builder = ContextBuilder::new("my-node")
    .with_state_dir("./data/state");

pub fn with_custom_redis<F>(self, configure: F) -> Self

where F: FnOnce(&mut RedisConfig),

Configure Redis with custom settings

Provides a callback to customize Redis configuration.

Example

let builder = ContextBuilder::new("my-node")
    .with_custom_redis(|cfg| {
        cfg.url = "redis://custom:6379".to_string();
        cfg.max_connections = 20;
        cfg.timeout_ms = 5000;
    });

pub async fn build(self) -> Result<Context>

Build the Context instance

Connects to Redis and initializes the context.

Returns

A configured Context instance

Errors

Returns error if:

• Redis connection fails
• Configuration is invalid

Example

let ctx = ContextBuilder::new("my-node")
    .build()
    .await?;

impl ContextBuilder

pub fn local_dev(node_id: impl Into<String>) -> Self

Create a local development context

Pre-configured for local development:

• Redis at localhost:6379
• State directory at ./data/state
• Relaxed timeouts

Example

let ctx = ContextBuilder::local_dev("my-node")
    .build()
    .await?;

pub fn production(node_id: impl Into<String>) -> Self

Create a production context

Pre-configured for production:

• Redis from environment variable
• State directory from environment or /var/lib/mecha10
• Strict timeouts
• Connection pooling

Example

let ctx = ContextBuilder::production("my-node")
    .build()
    .await?;

pub fn test(node_id: impl Into<String>) -> Self

Create a test context

Pre-configured for testing:

• Redis from TEST_REDIS_URL or localhost:6379
• State directory in temp folder
• Fast timeouts

Example

let ctx = ContextBuilder::test("test-node")
    .build()
    .await?;

Trait Implementations

impl Clone for ContextBuilder

fn clone(&self) -> ContextBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContextBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.