Functions — github.com/DavidBM/acteur-rs

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

Functions169 in github.com/DavidBM/acteur-rs

⨍ Functions 169◇ Types & classes 55

↓ 19 callersMethodclone

(&self)

src/actors/manager.rs:233

↓ 16 callersMethodclone

(&self)

src/services/manager.rs:278

↓ 8 callersMethodsend

(&mut self, message: M)

src/actors/proxy.rs:58

↓ 7 callersMethodwait_until_stopped

Waits until all actors are stopped. If you call "system.stop()" this method will wait untill all actor have consumed all messages before returning.

src/facade.rs:237

↓ 6 callersMethodis_empty

(&self)

src/actors/manager.rs:143

↓ 5 callersMethodclone

(&self)

src/facade.rs:264

↓ 5 callersMethodclone

(&self)

src/system_director.rs:129

↓ 5 callersMethodclone

(&self)

src/services/director.rs:161

↓ 5 callersMethodsend

(&self, message: M)

src/services/director.rs:91

↓ 4 callersMethodstop

Send an stop message to all actors in the system. Actors will process all the enqued messages before stop

src/facade.rs:213

↓ 3 callersMethoddeliver

(&mut self, manager: &mut ActorProxy<A>)

src/actors/envelope.rs:100

↓ 3 callersFunctiondispatch

( service: &'a Arc<S>, system_facade: &'a Arc<ServiceAssistant<S>>, mut envelope: Box<dyn ServiceE

src/services/manager.rs:243

↓ 3 callersMethoddispatch

(&mut self, actor: &mut A, assistant: &ActorAssistant<A>)

src/actors/envelope.rs:49

↓ 3 callersMethodsend

( &self, actor_id: A::Id, message: M, )

src/actors/director.rs:78

↓ 2 callersMethodclone

(&self)

src/actors/assistant.rs:194

↓ 2 callersMethoddispatch

( &mut self, service: &Self::Service, system: &ServiceAssistant<Self::Service>, )

src/services/envelope.rs:43

↓ 2 callersMethodend

(&self)

src/actors/manager.rs:76

↓ 2 callersMethodis_ready_to_be_removed

A manager is ready to be removed only if there are no more messages pending to be delivered, has no active actors and it is flagged to be ended.

src/actors/manager.rs:111

↓ 2 callersMethodregister

(&self)

src/services/broker.rs:25

↓ 2 callersMethodset_system

(&mut self, system_director: SystemDirector)

src/actors/director.rs:45

↓ 1 callersFunctionactor_loop

( id: A::Id, sender: Sender<ActorProxyCommand<A>>, receiver: Receiver<ActorProxyCommand<A>>, a

src/actors/proxy.rs:116

↓ 1 callersFunctionactor_manager_loop

( receiver: Receiver<ActorManagerProxyCommand<A>>, actors: Arc<DashMap<A::Id, ActorProxy<A>>>, act

src/actors/manager.rs:148

↓ 1 callersMethodcall

( &mut self, message: M, responder: Sender<<A as Respond<M>>::Response>, )

src/actors/proxy.rs:74

↓ 1 callersMethodclone

(&self)

src/services/system_facade.rs:161

↓ 1 callersMethodend

(&self)

src/services/manager.rs:145

↓ 1 callersMethodend

(&self)

src/actors/proxy.rs:108

↓ 1 callersMethodget_actor_id

(&self)

src/actors/envelope.rs:96

↓ 1 callersMethodget_blocking_actor_entry

Returns the Entry of the actorProxy in the general HashMap, making not possible to send any messages until the Entry is droped.

src/actors/manager.rs:139

↓ 1 callersMethodget_blocking_manager_entry

(&self, id: TypeId)

src/services/director.rs:151

↓ 1 callersMethodget_blocking_manager_entry

(&self, id: TypeId)

src/actors/director.rs:168

↓ 1 callersMethodget_inbox_length

(&self)

src/actors/proxy.rs:97

↓ 1 callersMethodget_last_sent_message_time

(&self)

src/actors/proxy.rs:93

↓ 1 callersMethodget_next_sender_index

(&self)

src/services/manager.rs:129

↓ 1 callersMethodget_report

(&self)

src/actors/proxy.rs:101

↓ 1 callersMethodget_sender

(&self)

src/services/manager.rs:120

↓ 1 callersMethodget_sender_as_any

(&mut self)

src/services/manager.rs:260

↓ 1 callersMethodget_sender_as_any

(&self)

src/actors/manager.rs:261

↓ 1 callersMethodget_type_id

(&self)

src/actors/manager.rs:119

↓ 1 callersFunctionprocess_dispatch_all_command

( mut command: Box<dyn ManagerEnvelope<Actor = A>>, actors: &'a Arc<DashMap<A::Id, ActorProxy<A>>>, )

src/actors/manager.rs:223

↓ 1 callersFunctionprocess_dispatch_command

( mut command: Box<dyn ManagerEnvelope<Actor = A>>, actors: &'a Arc<DashMap<A::Id, ActorProxy<A>>>,

src/actors/manager.rs:190

↓ 1 callersFunctionprocess_end_actor_command

( actor_id: A::Id, actors: &'a Arc<DashMap<A::Id, ActorProxy<A>>>, )

src/actors/manager.rs:181

↓ 1 callersMethodpublish

Allows to publish messages for Services to receive. In order for the mesage to be received by a service, the service must register itself for that mes

src/facade.rs:247

↓ 1 callersMethodpublish_sync

Same as publish method, but sync version

src/facade.rs:252

↓ 1 callersMethodsend

(&mut self, message: M, system_director: &ServicesDirector)

src/services/broker.rs:73

↓ 1 callersFunctionservice_loop

( receiver: Receiver<ServiceManagerCommand<S>>, sender: Sender<ServiceManagerCommand<S>>, service:

src/services/manager.rs:157

↓ 1 callersMethodsignal_actor_removed

(&self)

src/actors/manager.rs:84

↓ 1 callersMethodsignal_manager_removed

(&self)

src/services/director.rs:134

↓ 1 callersMethodsignal_manager_removed

(&self)

src/actors/director.rs:151

↓ 1 callersFunctionstart

()

examples/count_with_generic_type.rs:12

↓ 1 callersMethodstop

(&self)

src/services/director.rs:143

↓ 1 callersMethodstop

Enqueues a end command in the Actor messages queue. The actor will consume all mesages before ending. Keep in mind that event is an actor is stopped,

src/actors/assistant.rs:171

↓ 1 callersMethodstop_system

Send an stop message to all actors in the system. Actors will process all the enqued messages before stop

src/actors/assistant.rs:184

Methodactivate

(id: Self::Id, _: &ActorAssistant<Self>)

examples/count_with_generic_type.rs:46

Methodactivate

(id: Self::Id, _: &ActorAssistant<Self>)

examples/respond_to_message.rs:14

Methodactivate

(_: Self::Id, _: &ActorAssistant<Self>)

examples/actor_without_id.rs:26

Methodactivate

(_: Self::Id, _: &ActorAssistant<Self>)

examples/basic.rs:13

Methodactivate

(id: Self::Id, _: &ActorAssistant<Self>)

examples/http/src/main.rs:14

Methodcall

TODO: Create a proper return type without &str

src/services/director.rs:102

Methodcall

( &self, actor_id: A::Id, message: M, // TODO: Create a proper return type wit

src/actors/director.rs:105

Methodcall_actor

As send_to_actor method, it sends a message to an actor with an ID but this one wait for a response from the actor. This method will execute the [Res

src/facade.rs:147

Methodcall_actor

( &self, actor_id: A::Id, message: M, )

src/system_director.rs:82

Methodcall_actor

Sends a message to the Actor with the specified Id and waits the actor's response . If the Actor is not loaded, it will load the actor before, calling

src/services/system_facade.rs:114

Methodcall_actor

Sends a message to the Actor with the specified Id and waits the actor's response . If the Actor is not loaded, it will load the actor before, calling

src/actors/assistant.rs:143

Methodcall_actor_sync

Same as `call_actor` method, but sync version.

src/facade.rs:158

Methodcall_service

As send_to_service method, it sends a message to a Service but this one wait for a response from the actor. This method will execute the [Serve::hand

src/facade.rs:196

Methodcall_service

( &self, message: M, )

src/system_director.rs:97

Methodcall_service

Sends a message to a Service and waits for its response. If the Service is not loaded, it will load the service before, calling its method `initialize

src/services/system_facade.rs:135

Methodcall_service

Sends a message to a Service and waits for its response. If the Service is not loaded, it will load the service before, calling its method `initialize

src/actors/assistant.rs:162

Methodcall_service_sync

Same as `call_service` method, but sync version.

src/facade.rs:204

Methodcreate_manager

(&self)

src/services/director.rs:123

Methodcreate_manager

(&self)

src/actors/director.rs:136

Methoddeactivate

This method will be called when the framework decided to unload the actor. The concrete algorithms to decide that can change in the future. As for now

src/actors/actor.rs:60

Methoddeactivate

(&mut self)

examples/count_with_generic_type.rs:54

Methoddeactivate

(&mut self)

examples/respond_to_message.rs:22

src/services/service.rs:94

Methoddispatch_service

(&mut self, service: &S, system: &ServiceAssistant<S>)

src/services/envelope.rs:31

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/facade.rs:258

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/services/system_facade.rs:171

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/services/broker.rs:93

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/actors/assistant.rs:204

Methodget_id

Returns the Actor's Id defined by the [`Actor`](./trait.Actor.html) Trait

src/actors/assistant.rs:178

Methodget_mamager

(&self)

src/services/director.rs:61

Methodget_or_create_manager_sender

Ensures that there is a manager for that type and returns a sender to it

src/services/director.rs:76

Methodget_or_create_manager_sender

Ensures that there is a manager for that type and returns a sender to it

src/actors/director.rs:56

Methodget_sender

(&self)

src/actors/manager.rs:115

src/system_director.rs:119

Methodget_statistics

TODO: Implement

src/services/manager.rs:271

Methodget_statistics

(&self)

src/actors/director.rs:172

Methodget_statistics

(&self)

src/actors/manager.rs:123

Methodget_type_id

(&self)

src/services/manager.rs:263

Methodhandle

(&mut self, message: TestMessage, assistant: &ActorAssistant<TestActor<T>>)

examples/count_with_generic_type.rs:64

Methodhandle

(&self, message: EmployeeSalaryChange, _: &ServiceAssistant<Self>)

examples/stateless_service.rs:23

Methodhandle

(&self, message: EmployeeHired, _: &ServiceAssistant<Self>)

examples/statefull_service.rs:31

Methodhandle

(&self, message: EmployeeSalaryChange, _: &ServiceAssistant<Self>)

examples/publish_subscribe.rs:30

Methodhandle

( &mut self, message: SalaryChanged, assistant: &ActorAssistant<Employee>, )

examples/respond_to_message.rs:34

Methodhandle

(&mut self, message: SalaryChanged, _: &ActorAssistant<Employee>)

examples/actor_without_id.rs:38

Methodhandle

(&mut self, message: SalaryChanged, _: &ActorAssistant<Employee>)

examples/basic.rs:25

Methodhandle

If your struct can be cloned, you can respond with yourself.

examples/http/src/main.rs:33

next →1–100 of 169, ranked by callers