Struct SupervisorConfig 

pub struct SupervisorConfig { /* private fields */ }

Runtime configuration for the supervisor and actors.

Controls channel buffer sizes and event batching behavior. Use the builder pattern to customize, or use Default for sensible defaults.

Examples

use maiko::SupervisorConfig;

let config = SupervisorConfig::default()
    .with_broker_channel_capacity(512)          // Larger broker buffer
    .with_default_actor_channel_capacity(256)   // Larger actor mailboxes
    .with_default_max_events_per_tick(20);       // Process more events per cycle

Implementations

impl SupervisorConfig

pub fn with_broker_channel_capacity(self, capacity: usize) -> Self

Set the per-actor channel capacity for stage 1 (actor to broker).

pub fn broker_channel_capacity(&self) -> usize

Returns the per-actor channel capacity for stage 1 (actor to broker).

pub fn with_default_max_events_per_tick(self, limit: usize) -> Self

Set the default maximum events processed per tick cycle for new actors.

This controls batching behavior in the actor event loop. After processing this many events, the actor yields to allow other tasks to run and to call Actor::step.

Trade-offs:

• Lower values (1-5): Better fairness, more responsive step(), higher overhead
• Higher values (50-100): Better throughput, potential starvation of step()

pub fn default_max_events_per_tick(&self) -> usize

Returns the default maximum events processed per tick.

pub fn with_monitoring_channel_capacity(self, capacity: usize) -> Self

Set the buffer size for the monitoring event channel.

pub fn monitoring_channel_capacity(&self) -> usize

Returns the monitoring event channel capacity.

pub fn with_default_actor_channel_capacity(self, capacity: usize) -> Self

Set the default mailbox channel capacity for new actors (stage 2).

pub fn default_actor_channel_capacity(&self) -> usize

Returns the default mailbox channel capacity for new actors.

Trait Implementations

impl Clone for SupervisorConfig

fn clone(&self) -> SupervisorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SupervisorConfig

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

Formats the value using the given formatter.

impl Default for SupervisorConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SupervisorConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for SupervisorConfig

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for SupervisorConfig

fn eq(&self, other: &SupervisorConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SupervisorConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for SupervisorConfig

impl StructuralPartialEq for SupervisorConfig