Class PhobosActorRefProvider
Used to instrument an Akka.NET ActorSystem with monitoring instrumentation.
Inherited Members
Namespace: Phobos.Actor
Assembly: Phobos.Actor.dll
Syntax
public class PhobosActorRefProvider : WrappedActorRefProvider, IActorRefProvider, IPhobosActorRefProvider
Constructors
PhobosActorRefProvider(string, Settings, EventStream)
Declaration
public PhobosActorRefProvider(string systemName, Settings settings, EventStream eventStream)
Parameters
| Type | Name | Description |
|---|---|---|
| string | systemName | |
| Settings | settings | |
| EventStream | eventStream |
Properties
AskTracingFilter
INTERNAL API
Declaration
protected virtual FilteringEngine AskTracingFilter { get; }
Property Value
| Type | Description |
|---|---|
| FilteringEngine |
Remarks
Needs to be overrideable so implementations such as Akka.Cluster can enable additional noise-cancelling
around Ask{T} operations.
Monitor
Declaration
public override Meter Monitor { get; protected set; }
Property Value
| Type | Description |
|---|---|
| Meter |
Overrides
Tracer
Declaration
public override Tracer Tracer { get; protected set; }
Property Value
| Type | Description |
|---|---|
| Tracer |
Overrides
Methods
ActorOf(ActorSystemImpl, Props, IInternalActorRef, ActorPath, bool, Deploy, bool, bool)
Actor factory with create-only semantics: will create an actor as
described by props with the given supervisor and path (may be different
in case of remote supervision). If systemService is true, deployment is
bypassed (local-only). If a value fordeploy is passed in, it should be
regarded as taking precedence over the nominally applicable settings,
but it should be overridable from external configuration; the lookup of
the latter can be suppressed by setting "lookupDeploy" to "false".
Declaration
public override IInternalActorRef ActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor, ActorPath path, bool systemService, Deploy deploy, bool lookupDeploy, bool async)
Parameters
| Type | Name | Description |
|---|---|---|
| ActorSystemImpl | system | TBD |
| Props | props | TBD |
| IInternalActorRef | supervisor | TBD |
| ActorPath | path | TBD |
| bool | systemService | TBD |
| Deploy | deploy | TBD |
| bool | lookupDeploy | TBD |
| bool | async | TBD |
Returns
| Type | Description |
|---|---|
| IInternalActorRef | TBD |
Overrides
CreateFutureRef<T>(TaskCompletionSource<T>)
Automatically generates a FutureActorRef<T> with a temporary path.
Declaration
public override FutureActorRef<T> CreateFutureRef<T>(TaskCompletionSource<T> tcs)
Parameters
| Type | Name | Description |
|---|---|---|
| TaskCompletionSource<T> | tcs | A typed TaskCompletionSource<TResult> |
Returns
| Type | Description |
|---|---|
| FutureActorRef<T> | A new, single-use FutureActorRef<T> instance. |
Type Parameters
| Name | Description |
|---|---|
| T | The type of output this FutureActorRef<T> expects. |
Overrides
Remarks
CreateLog(IActorRefProvider, EventStream)
Declaration
protected override ILoggingAdapter CreateLog(IActorRefProvider underlying, EventStream stream = null)
Parameters
| Type | Name | Description |
|---|---|---|
| IActorRefProvider | underlying | |
| EventStream | stream |
Returns
| Type | Description |
|---|---|
| ILoggingAdapter |
Overrides
CreateUnderlying(string, Settings, EventStream)
Declaration
protected override IActorRefProvider CreateUnderlying(string systemName, Settings settings, EventStream eventStream)
Parameters
| Type | Name | Description |
|---|---|---|
| string | systemName | |
| Settings | settings | |
| EventStream | eventStream |
Returns
| Type | Description |
|---|---|
| IActorRefProvider |
Overrides
Init(ActorSystemImpl)
Initialization of an ActorRefProvider happens in two steps: first construction of the object with settings, eventStream, etc. and then—when the ActorSystem is constructed—the second phase during which actors may be created (e.g. the guardians).
Declaration
public override void Init(ActorSystemImpl system)
Parameters
| Type | Name | Description |
|---|---|---|
| ActorSystemImpl | system | TBD |
Overrides
LocalDeploy(ActorSystemImpl, Props, IInternalActorRef, ActorPath, bool, Deploy, bool, bool)
Declaration
protected IInternalActorRef LocalDeploy(ActorSystemImpl system, Props props, IInternalActorRef supervisor, ActorPath path, bool systemService, Deploy deploy, bool lookupDeploy, bool async)
Parameters
| Type | Name | Description |
|---|---|---|
| ActorSystemImpl | system | |
| Props | props | |
| IInternalActorRef | supervisor | |
| ActorPath | path | |
| bool | systemService | |
| Deploy | deploy | |
| bool | lookupDeploy | |
| bool | async |
Returns
| Type | Description |
|---|---|
| IInternalActorRef |