Class PhobosClusterActorRefProvider
Akka.Cluster implementation of PhobosActorRefProvider
Inheritance
System.Object
Phobos.Actor.Impl.WrappedActorRefProvider
PhobosClusterActorRefProvider
Implements
Akka.Cluster.IClusterActorRefProvider
Akka.Remote.IRemoteActorRefProvider
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.Cluster
Assembly: Phobos.Actor.Cluster.dll
Syntax
public class PhobosClusterActorRefProvider : PhobosRemoteActorRefProvider, IPhobosActorRefProvider, IClusterActorRefProvider, IRemoteActorRefProvider, IActorRefProvider
Constructors
PhobosClusterActorRefProvider(String, Settings, EventStream)
Declaration
public PhobosClusterActorRefProvider(string systemName, Settings settings, EventStream eventStream)
Parameters
Type | Name | Description |
---|---|---|
System.String | systemName | |
Settings | settings | |
EventStream | eventStream |
Properties
AskTracingFilter
Overridden so we can make sure that Ask{T}
operations from inside the Akka.Cluster.Sharding infrastructure
don't produce spans by default.
Declaration
protected override FilteringEngine AskTracingFilter { get; }
Property Value
Type | Description |
---|---|
Phobos.Actor.Instrumentation.FilteringEngine |
Overrides
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
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 |
---|---|---|
System.String | systemName | |
Settings | settings | |
EventStream | eventStream |
Returns
Type | Description |
---|---|
IActorRefProvider |
Overrides
Init(ActorSystemImpl)
Declaration
public override void Init(ActorSystemImpl system)
Parameters
Type | Name | Description |
---|---|---|
ActorSystemImpl | system |
Overrides
Implements
Akka.Cluster.IClusterActorRefProvider
Akka.Remote.IRemoteActorRefProvider