MCPcopy Create free account

hub / github.com/DavidBM/acteur-rs / functions

Functions169 in github.com/DavidBM/acteur-rs

Methodinitialize
(_: &ServiceAssistant<Self>)
examples/stateless_service.rs:10
Methodinitialize
(_: &ServiceAssistant<Self>)
examples/statefull_service.rs:13
Methodinitialize
(system: &ServiceAssistant<Self>)
examples/publish_subscribe.rs:10
Functionmain
()
examples/count_with_generic_type.rs:8
Functionmain
()
examples/stateless_service.rs:28
Functionmain
()
examples/statefull_service.rs:36
Functionmain
()
examples/publish_subscribe.rs:37
Functionmain
()
examples/respond_to_message.rs:59
Functionmain
()
examples/actor_without_id.rs:43
Functionmain
()
examples/basic.rs:30
Functionmain
()
examples/http/src/main.rs:52
Methodnew
Initializes the system. After this, you can send messages using the send method.
src/facade.rs:33
Methodnew
()
src/system_director.rs:22
Methodnew
(message: M, responder: Sender<<S as Serve<M>>::Response>)
src/services/envelope.rs:62
Methodnew
( system_director: SystemDirector, broker: MessageBroker, )
src/services/system_facade.rs:53
Methodnew
()
src/services/director.rs:35
Methodnew
( director: ServicesDirector, system_director: SystemDirector, broker: MessageBroker,
src/services/manager.rs:47
Methodnew
(system_director: ServicesDirector)
src/services/broker.rs:18
Methodnew
(message: M)
src/actors/envelope.rs:39
Methodnew
( system_director: SystemDirector, actors_director: ActorsDirector, actor_id: A::Id,
src/actors/assistant.rs:85
Methodnew
(configuration: ActorsDirectorConfiguration)
src/actors/director.rs:35
Methodnew
( actors_director: ActorsDirector, system_director: SystemDirector, innactivity_durati
src/actors/manager.rs:44
Methodnew
( system_director: SystemDirector, actors_director: ActorsDirector, manager: ActorsMan
src/actors/proxy.rs:31
Methodnew_for_service
(message: M)
src/services/envelope.rs:20
Methodpoll
(self: Pin<&mut Self>, cx: &mut Context)
src/services/director.rs:183
Methodpoll
(self: Pin<&mut Self>, cx: &mut Context)
src/actors/director.rs:194
Methodpreload
(&self)
src/services/director.rs:87
Methodpreload_service
Ensures a service is loaded and running. It ensures that all Service's subscriptions are performed
src/facade.rs:222
Methodpreload_service
(&self)
src/system_director.rs:104
Methodpreload_service_sync
Same as `preload_service` but sync version
src/facade.rs:227
Methodpublish
(&self, message: M)
src/system_director.rs:123
Methodpublish
(&self, message: M)
src/services/director.rs:155
Methodpublish
(&self, message: M)
src/services/broker.rs:42
Methodremove_actor
(&self, actor_id: A::Id)
src/actors/manager.rs:133
Methodschedule_send_to_actor
Same as `send_to_actor` but it delays the message sending
src/facade.rs:66
Methodschedule_send_to_actor
( &self, actor_id: A::Id, duration: std::time::Duration, message: M, )
src/system_director.rs:56
Methodschedule_send_to_actor
Schedules to sends a message to the Actor with the specified Id. If the Actor is not loaded, it will load the actor before, calling its method `activa
src/services/system_facade.rs:89
Methodschedule_send_to_actor
Schedules to sends a message to the Actor with the specified Id. If the Actor is not loaded, it will load the actor before, calling its method `activa
src/actors/assistant.rs:118
Methodschedule_send_to_actor_sync
Same as `schedule_send_to_actor` method, but sync version.
src/facade.rs:78
Methodschedule_send_to_all_actors
Same as `send_to_all_actors` but it delays the message sending
src/facade.rs:114
Methodschedule_send_to_all_actors
( &self, duration: std::time::Duration, message: M, )
src/system_director.rs:73
Methodschedule_send_to_all_actors
Schedules to sends a message to all actor of a type, independently of the ID. It will only send messages to actors already in Ram (already loaded)
src/services/system_facade.rs:102
Methodschedule_send_to_all_actors
Schedules to sends a message to all actors independently of the ID. It will only send messages to actors already in Ram (already loaded)
src/actors/assistant.rs:131
Methodschedule_send_to_all_actors_sync
Same as `schedule_send_to_all_actors` method, but sync version.
src/facade.rs:125
Methodsend_to_actor
Sends a message to an actor with an ID. This method will execute the [Receive::handle](./trait.Receive.html) implemented for that Message and Actor.
src/facade.rs:46
Methodsend_to_actor
( &self, actor_id: A::Id, message: M, )
src/system_director.rs:48
Methodsend_to_actor
Sends a message to the Actor with the specified Id. If the Actor is not loaded, it will load the actor before, calling its method `activate`
src/services/system_facade.rs:66
Methodsend_to_actor
Sends a message to the Actor with the specified Id. If the Actor is not loaded, it will load the actor before, calling its method `activate`
src/actors/assistant.rs:99
Methodsend_to_actor_sync
Same as `send_to_actor` method, but sync version.
src/facade.rs:57
Methodsend_to_all
( &self, message: M, )
src/actors/director.rs:92
Methodsend_to_all_actors
Sends a message to all actors of a type independently of their ID This method will execute the [Receive::handle](./trait.Receive.html) implemented fo
src/facade.rs:96
Methodsend_to_all_actors
( &self, message: M, )
src/system_director.rs:66
Methodsend_to_all_actors
Sends a message to all actors of a type, independently of the ID. It will only send messages to actors already in Ram (already loaded)
src/services/system_facade.rs:78
Methodsend_to_all_actors
Sends a message to all actors independently of the ID. It will only send messages to actors already in Ram (already loaded)
src/actors/assistant.rs:109
Methodsend_to_all_actors_sync
Same as `send_to_all_actors` method, but sync version.
src/facade.rs:106
Methodsend_to_service
Sends a message to a Service. This method will execute the [Listen::handle](./trait.Listen.html) implemented for that Message and Service. If the Se
src/facade.rs:173
Methodsend_to_service
( &self, message: M, )
src/system_director.rs:90
Methodsend_to_service
Sends a message to a Service. If the Service is not loaded, it will load the service before, calling its method `initialize`
src/services/system_facade.rs:126
Methodsend_to_service
Sends a message to a Service. If the Service is not loaded, it will load the service before, calling its method `initialize`
src/actors/assistant.rs:153
Methodsend_to_service_sync
Same as `send_to_service` method, but sync version.
src/facade.rs:181
Methodset_system
(&mut self, system_director: SystemDirector)
src/services/director.rs:51
Methodstop
(&self)
src/system_director.rs:115
Methodstop
(&self)
src/actors/director.rs:160
Methodstop_actor
(&self, actor_id: A::Id)
src/actors/director.rs:124
Methodstop_system
Send an stop message to all actors in the system. Actors will process all the enqued messages before stop
src/services/system_facade.rs:144
Methodsubscribe
(&self)
src/services/system_facade.rs:152
Methodwait_until_stopped
(&self)
src/system_director.rs:108
Methodwait_until_stopped
(&self)
src/services/director.rs:119
Methodwait_until_stopped
(&self)
src/actors/director.rs:132
← previous101–169 of 169, ranked by callers