Class PhobosActorRefProvider

Used to instrument an Akka.NET ActorSystem with monitoring instrumentation.

Inheritance
System.Object
Phobos.Actor.Impl.WrappedActorRefProvider
PhobosActorRefProvider
PhobosRemoteActorRefProvider
Implements
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
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
System.String systemName
Settings settings
EventStream eventStream

Properties

AskTracingFilter

INTERNAL API

Declaration
protected virtual FilteringEngine AskTracingFilter { get; }
Property Value
Type Description
Phobos.Actor.Instrumentation.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
System.Diagnostics.Metrics.Meter
Overrides
Phobos.Actor.Impl.WrappedActorRefProvider.Monitor

Tracer

Declaration
public override Tracer Tracer { get; protected set; }
Property Value
Type Description
OpenTelemetry.Trace.Tracer
Overrides
Phobos.Actor.Impl.WrappedActorRefProvider.Tracer

Methods

ActorOf(ActorSystemImpl, Props, IInternalActorRef, ActorPath, Boolean, Deploy, Boolean, Boolean)

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
Props props
Akka.Actor.IInternalActorRef supervisor
ActorPath path
System.Boolean systemService
Deploy deploy
System.Boolean lookupDeploy
System.Boolean async
Returns
Type Description
Akka.Actor.IInternalActorRef
Overrides
Phobos.Actor.Impl.WrappedActorRefProvider.ActorOf(Akka.Actor.Internal.ActorSystemImpl, Akka.Actor.Props, Akka.Actor.IInternalActorRef, Akka.Actor.ActorPath, System.Boolean, Akka.Actor.Deploy, System.Boolean, System.Boolean)

CreateFutureRef<T>(TaskCompletionSource<T>)

Declaration
public override FutureActorRef<T> CreateFutureRef<T>(TaskCompletionSource<T> tcs)
Parameters
Type Name Description
System.Threading.Tasks.TaskCompletionSource<T> tcs
Returns
Type Description
FutureActorRef<T>
Type Parameters
Name Description
T
Overrides
Phobos.Actor.Impl.WrappedActorRefProvider.CreateFutureRef<T>(System.Threading.Tasks.TaskCompletionSource<T>)

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
Phobos.Actor.Impl.WrappedActorRefProvider.CreateLog(Akka.Actor.IActorRefProvider, Akka.Event.EventStream)

CreateUnderlying(String, Settings, EventStream)

Declaration
protected override IActorRefProvider CreateUnderlying(string systemName, Settings settings, EventStream eventStream)
Parameters
Type Name Description
System.String systemName
Settings settings
EventStream eventStream
Returns
Type Description
IActorRefProvider
Overrides
Phobos.Actor.Impl.WrappedActorRefProvider.CreateUnderlying(System.String, Akka.Actor.Settings, Akka.Event.EventStream)

Init(ActorSystemImpl)

Declaration
public override void Init(ActorSystemImpl system)
Parameters
Type Name Description
ActorSystemImpl system
Overrides
Phobos.Actor.Impl.WrappedActorRefProvider.Init(Akka.Actor.Internal.ActorSystemImpl)

LocalDeploy(ActorSystemImpl, Props, IInternalActorRef, ActorPath, Boolean, Deploy, Boolean, Boolean)

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
Akka.Actor.IInternalActorRef supervisor
ActorPath path
System.Boolean systemService
Deploy deploy
System.Boolean lookupDeploy
System.Boolean async
Returns
Type Description
Akka.Actor.IInternalActorRef

Implements