Show / Hide Table of Contents

Class PhobosClusterActorRefProvider

Akka.Cluster implementation of PhobosActorRefProvider

Inheritance
object
WrappedActorRefProvider
PhobosActorRefProvider
PhobosRemoteActorRefProvider
PhobosClusterActorRefProvider
Implements
IPhobosActorRefProvider
IClusterActorRefProvider
IRemoteActorRefProvider
IActorRefProvider
Inherited Members
PhobosRemoteActorRefProvider.Rarp
PhobosRemoteActorRefProvider.RemoteDaemon
PhobosRemoteActorRefProvider.RemoteWatcher
PhobosRemoteActorRefProvider.Transport
PhobosRemoteActorRefProvider.RemoteSettings
PhobosRemoteActorRefProvider.LookUpRemotes(IEnumerable<string>)
PhobosRemoteActorRefProvider.HasAddress(Address)
PhobosRemoteActorRefProvider.ResolveActorRefWithLocalAddress(string, Address)
PhobosRemoteActorRefProvider.InternalResolveActorRef(string)
PhobosRemoteActorRefProvider.UseActorOnNode(RemoteActorRef, Props, Deploy, IInternalActorRef)
PhobosRemoteActorRefProvider.Quarantine(Address, int?)
PhobosActorRefProvider.Tracer
PhobosActorRefProvider.Monitor
PhobosActorRefProvider.CreateFutureRef<T>(TaskCompletionSource<T>)
PhobosActorRefProvider.LocalDeploy(ActorSystemImpl, Props, IInternalActorRef, ActorPath, bool, Deploy, bool, bool)
WrappedActorRefProvider.Initialized
WrappedActorRefProvider.Underlying
WrappedActorRefProvider.Log
WrappedActorRefProvider.RootGuardianAt(Address)
WrappedActorRefProvider.TempPath()
WrappedActorRefProvider.RegisterTempActor(IInternalActorRef, ActorPath)
WrappedActorRefProvider.UnregisterTempActor(ActorPath)
WrappedActorRefProvider.ResolveActorRef(string)
WrappedActorRefProvider.ResolveActorRef(ActorPath)
WrappedActorRefProvider.GetExternalAddressFor(Address)
WrappedActorRefProvider.RootGuardian
WrappedActorRefProvider.Guardian
WrappedActorRefProvider.SystemGuardian
WrappedActorRefProvider.DeadLetters
WrappedActorRefProvider.RootPath
WrappedActorRefProvider.Settings
WrappedActorRefProvider.Deployer
WrappedActorRefProvider.TempContainer
WrappedActorRefProvider.TerminationTask
WrappedActorRefProvider.DefaultAddress
WrappedActorRefProvider.SerializationInformation
WrappedActorRefProvider.IgnoreRef
WrappedActorRefProvider.Filtering
WrappedActorRefProvider.PhobosSettings
WrappedActorRefProvider.PhobosDeployer
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
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
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
FilteringEngine
Overrides
PhobosActorRefProvider.AskTracingFilter

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
PhobosRemoteActorRefProvider.ActorOf(ActorSystemImpl, Props, IInternalActorRef, ActorPath, bool, Deploy, bool, bool)

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
PhobosRemoteActorRefProvider.CreateLog(IActorRefProvider, EventStream)

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
PhobosRemoteActorRefProvider.CreateUnderlying(string, Settings, EventStream)

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
PhobosActorRefProvider.Init(ActorSystemImpl)

Implements

IPhobosActorRefProvider
Akka.Cluster.IClusterActorRefProvider
Akka.Remote.IRemoteActorRefProvider
IActorRefProvider
In this article

Phobos®

APM for Akka.NET Applications

© 2025 Petabridge®

All rights reserved

Product
  • Purchase Phobos
  • Contact Sales
  • Phobos Quick Start Guide
  • Phobos Features
  • API Documentation
  • Release Notes
Resources
  • Akka.NET Documentation
  • Petabridge Blog
  • Akka.NET Support Plans
  • Akka.NET Consulting Services
  • Akka.NET Training
Connect
  • Petabridge Website
  • GitHub
  • Twitter
  • LinkedIn
  • YouTube
  • Contact Us
Privacy Policy
Built with ♥ by Petabridge