Struct kay::ActorSystem

pub struct ActorSystem {
    pub panic_happened: bool,
    pub shutting_down: bool,
    // some fields omitted
}

Fields

panic_happened: bool

shutting_down: bool

Methods

impl ActorSystem

pub fn new(networking: Networking) -> ActorSystem

pub fn new_mmap_persisted<P: AsRef<Path>>(
    networking: Networking,
    directory: &P
) -> ActorSystem

pub fn new_with_storage(
    networking: Networking,
    storage: Rc<dyn ChunkStorage>
) -> ActorSystem

pub fn register<A: Actor>(&mut self)

pub fn register_dummy<D: 'static>(&mut self)

pub fn register_trait<T: ActorOrActorTrait>(&mut self)

pub fn register_trait_message<M: Message>(&mut self)

pub fn register_implementor<A: Actor, T: ActorOrActorTrait>(&mut self)

pub fn add_handler<A: Actor, M: Message, F: Fn(&M, &mut A, &mut World) -> Fate + 'static>(
    &mut self,
    handler: F,
    critical: bool
)

pub fn add_spawner<A: Actor, M: Message, F: Fn(&M, &mut World) -> A + 'static>(
    &mut self,
    constructor: F,
    critical: bool
)

pub fn send<M: Message>(&mut self, recipient: RawID, message: M)

pub fn id<A: ActorOrActorTrait>(&mut self) -> RawID

pub fn process_all_messages(&mut self)

pub fn world(&mut self) -> World

pub fn networking_connect(&mut self)

pub fn networking_send_and_receive(&mut self)

pub fn networking_finish_turn(&mut self) -> Option<usize>

pub fn networking_machine_id(&self) -> MachineID

pub fn networking_n_turns(&self) -> usize

pub fn networking_debug_all_n_turns(&self) -> HashMap<MachineID, isize>

pub fn get_instance_counts(&self) -> HashMap<String, usize>

pub fn get_message_statistics(&self) -> HashMap<String, usize>

pub fn reset_message_statistics(&mut self)

pub fn get_queue_lengths(&self) -> HashMap<String, usize>

pub fn get_actor_type_id_to_name_mapping(&self) -> HashMap<u16, String>