Struct ActorConfig 

pub struct ActorConfig { /* private fields */ }

Per-actor configuration.

Controls settings that vary between actors, such as the mailbox channel capacity. Created automatically by Supervisor::add_actor using global defaults from SupervisorConfig, or customized via ActorBuilder.

Examples

use maiko::{SupervisorConfig, ActorConfig};

let config = ActorConfig::new(&SupervisorConfig::default())
    .with_channel_capacity(512)
    .with_max_events_per_tick(64);

assert_eq!(config.channel_capacity(), 512);
assert_eq!(config.max_events_per_tick(), 64);

With the builder API (see ActorBuilder):

sup.build_actor("writer", |ctx| Writer::new(ctx))
    .channel_capacity(512)
    .topics(&[Topic::Data])
    .build()?;

Implementations

impl ActorConfig

pub fn new(global_config: &SupervisorConfig) -> Self

Create a new config inheriting defaults from the global SupervisorConfig.

pub fn with_channel_capacity(self, channel_capacity: usize) -> Self

Set the actor’s mailbox channel capacity.

This is the number of events that can be queued for this actor before the broker’s overflow policy takes effect.

pub fn channel_capacity(&self) -> usize

Returns the actor’s mailbox channel capacity.

pub fn with_max_events_per_tick(self, max_events: usize) -> Self

Set the maximum number of events processed per tick cycle.

After processing this many events, the actor yields to allow other tasks to run and to call Actor::step.

pub fn max_events_per_tick(&self) -> usize

Returns the maximum number of events processed per tick cycle.

Trait Implementations

impl Clone for ActorConfig

fn clone(&self) -> ActorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActorConfig

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

Formats the value using the given formatter.

impl Default for ActorConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ActorConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for ActorConfig

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 ActorConfig

fn eq(&self, other: &ActorConfig) -> 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 ActorConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for ActorConfig

impl Eq for ActorConfig

impl StructuralPartialEq for ActorConfig