Proto.Actor by Proto.Actor Team

<PackageReference Include="Proto.Actor" Version="0.33.1-alpha.0.5" />

---

API Diff between 0.33.1-alpha.0.5 and 0.22.1-alpha.0.24

129 Additions 42 Removals

Proto

• public abstract class ActorContextDecorator : IContext, ISenderContext, IInfoContext, IContextStore, ISystemContext, IReceiverContext, ISpawnerContext, IStopperContext
  • public void Apply(CapturedContext capturedContext)
  • public CapturedContext Capture()
  • public void ReenterAfterCancellation(CancellationToken cancellationToken, Action onCancelled)
  • public virtual PID SpawnNamed(Props props, string name)
  • public virtual PID SpawnNamed(Props props, string name, Action<IContext> callback = null)
• public sealed class ActorContextExtras : IDisposable
  • public void Dispose()
• public class ActorLoggingContext : ActorContextDecorator
  • public ActorLoggingContext(IContext context, ILogger logger, LogLevel logLevel = 1, LogLevel infrastructureLogLevel = 6, LogLevel exceptionLogLevel = 4)
• public static class ActorLoggingContextExtensions
  • public static Props WithLoggingContextDecorator(this Props props, ILogger logger, LogLevel logLevel = 1, LogLevel infrastructureLogLevel = 6, LogLevel exceptionLogLevel = 4)
• public sealed class ActorSystem : IAsyncDisposable
  • public const string Client = "$client"
  • public const string NoHost = "nonhost"
  • public Stopper Stopper { get; }
  • public Props ConfigureSystemProps(string name, Props props)
  • public ValueTask DisposeAsync()
  • public Task ShutdownAsync()
  • public void SetClientAddress()
  • public Task ShutdownAsync(string reason = "")
• public class ActorSystemConfig : IEquatable<ActorSystemConfig>
  • public TimeSpan ActorRequestTimeout { get; set; }
  • public Func<string, Props, Props> ConfigureSystemProps { get; set; }
  • public bool DeadLetterResponseLogging { get; set; }
  • public IMetricsProvider[] MetricsProviders { get; set; }
  • public bool MetricsEnabled { get; set; }
  • public ActorSystemConfig WithActorRequestTimeout(TimeSpan timeout)
  • public ActorSystemConfig WithConfigureSystemProps(Func<string, Props, Props> configureSystemProps)
  • public ActorSystemConfig WithDeadLetterResponseLogging(bool enabled)
  • public ActorSystemConfig WithMetricsProviders(IMetricsProvider[] providers)
  • public ActorSystemConfig WithMetrics(bool enabled = true)
• public class CapturedContext : IEquatable<CapturedContext>
  • public IContext Context { get; set; }
  • protected virtual Type EqualityContract { get; }
  • public MessageEnvelope MessageEnvelope { get; set; }
  • public CapturedContext(MessageEnvelope MessageEnvelope, IContext Context)
  • protected CapturedContext(CapturedContext original)
  • public static bool op_Equality(CapturedContext left, CapturedContext right)
  • public static bool op_Inequality(CapturedContext left, CapturedContext right)
  • public virtual CapturedContext <Clone>$()
  • public void Apply()
  • public void Deconstruct(out MessageEnvelope MessageEnvelope, out IContext Context)
  • public virtual bool Equals(CapturedContext other)
  • protected virtual bool PrintMembers(StringBuilder builder)
  • public Task Receive()
• public class Continuation : SystemMessage, InfrastructureMessage
  • public IActor Actor { get; }
  • public Continuation(Func<Task> fun, object message)
  • public Continuation(Func<Task> fun, object message, IActor actor)
• public interface IContext : ISenderContext, IInfoContext, IContextStore, ISystemContext, IReceiverContext, ISpawnerContext, IStopperContext
  • void Apply(CapturedContext capturedContext)
  • CapturedContext Capture()
  • void ReenterAfterCancellation(CancellationToken cancellationToken, Action onCancelled)
• public interface InfrastructureMessage
• public interface ISpawnerContext : ISystemContext
  • PID SpawnNamed(Props props, string name)
  • PID SpawnNamed(Props props, string name, Action<IContext> callback = null)
• public static class MetricsExtensions
  • public static Task<T> Observe<T>(this IHistogramMetric histogram, Func<Task<T>> factory, string[] labels)
  • public static Task Observe(this IHistogramMetric histogram, Func<Task> factory, string[] labels)
  • public static Task<T> Observe<T>(this Histogram<double> histogram, Func<Task<T>> factory, KeyValuePair<string, object>[] tags)
  • public static Task Observe(this Histogram<double> histogram, Func<Task> factory, KeyValuePair<string, object>[] tags)
• public class ProcessRegistry
  • public IEnumerable<PID> Find(Func<string, bool> predicate)
  • public IEnumerable<PID> Find(string pattern)
  • public void RegisterClientResolver(Func<PID, Process> resolver)
  • public IEnumerable<PID> SearchByName(string name)
• public sealed delegate ProducerWithSystemAndContext : MulticastDelegate
  • public ProducerWithSystemAndContext(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ActorSystem system, IContext context, AsyncCallback callback, object object)
  • public virtual IActor EndInvoke(IAsyncResult result)
  • public virtual IActor Invoke(ActorSystem system, IContext context)
• public sealed class Props : IEquatable<Props>
  • public ImmutableList<Action<IContext>> OnInit { get; set; }
  • public ProducerWithSystem Producer { get; set; }
  • public ProducerWithSystemAndContext Producer { get; set; }
  • public static PID DefaultSpawner(ActorSystem system, string name, Props props, PID parent)
  • public static PID DefaultSpawner(ActorSystem system, string name, Props props, PID parent, Action<IContext> callback)
  • public Props WithOnInit(Action<IContext>[] callback)
  • public Props WithProducer(ProducerWithSystemAndContext producer)
• public sealed class RootContext : IRootContext, ISpawnerContext, ISystemContext, ISenderContext, IInfoContext, IContextStore, IStopperContext, IEquatable<RootContext>
  • public PID SpawnNamed(Props props, string name)
  • public PID SpawnNamed(Props props, string name, Action<IContext> callback = null)
• public abstract class RootContextDecorator : IRootContext, ISpawnerContext, ISystemContext, ISenderContext, IInfoContext, IContextStore, IStopperContext
  • public virtual PID SpawnNamed(Props props, string name)
  • public virtual PID SpawnNamed(Props props, string name, Action<IContext> callback = null)
• public static class SenderContextExtensions
  • public static void RequestReenter<T>(this IContext self, PID target, object message, Func<Task<T>, Task> callback, CancellationToken ct)
• public sealed delegate Spawner : MulticastDelegate
  • public virtual IAsyncResult BeginInvoke(ActorSystem system, string id, Props props, PID parent, AsyncCallback callback, object object)
  • public virtual IAsyncResult BeginInvoke(ActorSystem system, string id, Props props, PID parent, Action<IContext> callback, AsyncCallback __callback, object object)
  • public virtual PID Invoke(ActorSystem system, string id, Props props, PID parent)
  • public virtual PID Invoke(ActorSystem system, string id, Props props, PID parent, Action<IContext> callback = null)
• public static class SpawnerContextExtensions
  • public static PID SpawnPrefix(this ISpawnerContext self, Props props, string prefix, Action<IContext> callback)
• public class Stopper
  • public string StoppedReason { get; }
  • public CancellationToken Token { get; }
  • public Stopper()
  • public void Stop(string reason = "")
• public static class SystemContext
  • public static PID SpawnNamedSystem(this RootContext self, Props props, string name)
• public static class UtilExtensions
  • public static void CheckFailFast(this Exception reason)

Proto.Context

• public class ActorContext : IMessageInvoker, IContext, ISenderContext, IInfoContext, IContextStore, ISystemContext, IReceiverContext, ISpawnerContext, IStopperContext, ISupervisor
  • public void Apply(CapturedContext capturedContext)
  • public CapturedContext Capture()
  • public void ReenterAfterCancellation(CancellationToken token, Action onCancelled)
  • public PID SpawnNamed(Props props, string name)
  • public PID SpawnNamed(Props props, string name, Action<IContext> callback = null)
• public class DeadlineContextDecorator : ActorContextDecorator
  • public DeadlineContextDecorator(IContext context, TimeSpan deadline, ILogger logger)
• public static class DeadlineContextExtensions
  • public static Props WithDeadlineDecorator(this Props props, TimeSpan deadline, ILogger logger)

Proto.DependencyInjection

• public class DependencyResolver : IDependencyResolver
  • public Props PropsFor<TActor>(object[] args) where TActor : IActor
• public interface IDependencyResolver
  • Props PropsFor<TActor>(object[] args) where TActor : IActor

Proto.Extensions

• public class ActorSystemExtensions
  • public T GetRequired<T>(string notFoundMessage = null) where T : IActorSystemExtension

Proto.Logging

• public class InstanceLogger : IActorSystemExtension<InstanceLogger>, IActorSystemExtension
  • public void LogDebug(string template)
  • public void LogDebug<T>(string template, T arg)
  • public void LogDebug<T, T2>(string template, T arg, T2 arg2)
  • public void LogDebug<T, T2, T3>(string template, T arg, T2 arg2, T3 arg3)

Proto.Mailbox

• public class LockingUnboundedMailboxQueue : IMailboxQueue
  • public bool HasMessages { get; }
  • public int Length { get; }
  • public LockingUnboundedMailboxQueue(int initialCapacity)
  • public object Pop()
  • public void Push(object message)

Proto.Metrics

• public static class ActorMetrics
  • public readonly ICountMetric ActorFailureCount
  • public readonly IGaugeMetric ActorMailboxLength
  • public readonly IHistogramMetric ActorMessageReceiveHistogram
  • public readonly ICountMetric ActorRestartedCount
  • public readonly ICountMetric ActorSpawnCount
  • public readonly ICountMetric ActorStoppedCount
  • public readonly ICountMetric DeadletterCount
  • public readonly ICountMetric FuturesCompletedCount
  • public readonly ICountMetric FuturesStartedCount
  • public readonly ICountMetric FuturesTimedOutCount
  • public readonly IHistogramMetric ThreadPoolLatencyHistogram
  • public ActorMetrics(ProtoMetrics metrics)
  • public static readonly Counter<long> ActorFailureCount
  • public static readonly Histogram<long> ActorMailboxLength
  • public static readonly Histogram<double> ActorMessageReceiveDuration
  • public static readonly Counter<long> ActorRestartedCount
  • public static readonly Counter<long> ActorSpawnCount
  • public static readonly Counter<long> ActorStoppedCount
  • public static readonly Counter<long> DeadletterCount
  • public static readonly Counter<long> FuturesCompletedCount
  • public static readonly Counter<long> FuturesStartedCount
  • public static readonly Counter<long> FuturesTimedOutCount
  • public static readonly Histogram<double> ThreadPoolLatency
• public class ObservableGaugeWrapper<T> where T : struct
  • public ObservableGaugeWrapper()
  • public void AddObserver(Func<IEnumerable<Measurement<T>>> observer)
  • public IEnumerable<Measurement<T>> Observe()
  • public void RemoveObserver(Func<IEnumerable<Measurement<T>>> observer)
• public class ProtoMetrics
  • public readonly bool IsNoop
  • public ProtoMetrics(IMetricsProvider[] configurators)
  • public ICountMetric CreateCount(string name, string description, LabelName[] labelNames)
  • public IGaugeMetric CreateGauge(string name, string description, LabelName[] labelNames)
  • public IHistogramMetric CreateHistogram(string name, string description, LabelName[] labelNames)
  • public T Get<T>()
  • public void Register<T>(T instance)
  • public static Meter Meter
  • public const string MeterName = "Proto.Actor"
  • public readonly bool Enabled
  • public ProtoMetrics(bool enabled)

Proto.Router

• public class HashRing
• public class HashRing<T>
  • public int Count { get; }
  • public HashRing(IEnumerable<T> nodes, Func<T, string> getKey, Func<string, uint> hash, int replicaCount)
  • public void Add(T[] added)
  • public HashRing<T> Clone()
  • public T GetNode(string key)
  • public void Remove(ISet<T> nodes)
  • public void Remove(T node)

Proto.Utils

• public static class Retry
  • public static Task<T> Try<T>(Func<Task<T>> body, int retryCount = 10, int backoffMilliSeconds = 100, Action<int, Exception> onError = null, Action<Exception> onFailed = null)
  • public static Task Try(Func<Task> body, int retryCount = 10, int backoffMilliSeconds = 100, Action<int, Exception> onError = null, Action<Exception> onFailed = null, bool ignoreFailure = false)
  • public class RetriesExhaustedException : Exception
  • public const int Forever = 0
  • public static Task<T> Try<T>(Func<Task<T>> body, int retryCount = 10, int backoffMilliSeconds = 100, int maxBackoffMilliseconds = 5000, Action<int, Exception> onError = null, Action<Exception> onFailed = null)
  • public static Task Try(Func<Task> body, int retryCount = 10, int backoffMilliSeconds = 100, int maxBackoffMilliseconds = 5000, Action<int, Exception> onError = null, Action<Exception> onFailed = null, bool ignoreFailure = false)
  • public static Task<T> TryUntil<T>(Func<Task<T>> body, Func<T, bool> condition, int retryCount = 10, int backoffMilliSeconds = 100, int maxBackoffMilliseconds = 5000, Action<int, Exception> onError = null, Action<Exception> onFailed = null)
  • public static Task<T> TryUntilNotNull<T>(Func<Task<T>> body, int retryCount = 10, int backoffMilliSeconds = 100, int maxBackoffMilliseconds = 5000, Action<int, Exception> onError = null, Action<Exception> onFailed = null)
• public static class TaskExtensions
  • public static Task<TResult> WithTimeout<TResult>(this Task<TResult> task, TimeSpan timeout)
  • public static Task<bool> WaitUpTo(this Task task, TimeSpan timeout, CancellationToken? ct = default)
  • public static Task<ValueTuple<bool, TResult>> WaitUpTo<TResult>(this Task<TResult> task, TimeSpan timeout, CancellationToken? ct = default)
  • public static Task<TResult> WithTimeout<TResult>(this Task<TResult> task, TimeSpan timeout, CancellationToken? ct = default)