Proto.Actor by Proto.Actor Team

<PackageReference Include="Proto.Actor" Version="0.11.1-alpha.0.44" />

---

API Diff between 0.11.1-alpha.0.44 and 0.3.1-alpha.0.86

263 Additions 38 Removals

Proto

• public static class Actor
• public class ActorContext : IMessageInvoker, IContext, ISenderContext, IInfoContext, IReceiverContext, ISpawnerContext, IStopperContext, ISupervisor
• public class ActorContextExtras
  • public CancellationToken CancellationToken { get; }
• public class ActorSystem
  • public static readonly ActorSystem Default
  • public ActorSystemConfig Config { get; }
  • public ActorSystemExtensions Extensions { get; }
  • public string Id { get; }
  • public CancellationToken Shutdown { get; }
  • public ActorSystem(ActorSystemConfig config)
  • public RootContext NewRoot(MessageHeader headers = null, Func<Sender, Sender>[] middleware)
  • public Task ShutdownAsync()
• public class ActorSystemConfig : IEquatable<ActorSystemConfig>
  • public int DeadLetterThrottleCount { get; set; }
  • public TimeSpan DeadLetterThrottleInterval { get; set; }
  • protected virtual Type EqualityContract { get; }
  • protected ActorSystemConfig(ActorSystemConfig original)
  • public ActorSystemConfig()
  • public static bool op_Equality(ActorSystemConfig r1, ActorSystemConfig r2)
  • public static bool op_Inequality(ActorSystemConfig r1, ActorSystemConfig r2)
  • public static ActorSystemConfig Setup()
  • public virtual ActorSystemConfig <Clone>$()
  • public virtual bool Equals(ActorSystemConfig other)
  • protected virtual bool PrintMembers(StringBuilder builder)
  • public ActorSystemConfig WithDeadLetterThrottleCount(int deadLetterThrottleCount)
  • public ActorSystemConfig WithDeadLetterThrottleInterval(TimeSpan deadLetterThrottleInterval)
• public abstract class AutoReceiveMessage
• public class DeadLetterEvent
  • public MessageHeader Header { get; }
  • public DeadLetterEvent(PID pid, object message, PID sender, MessageHeader header)
• public class DeadLetterException : Exception
  • public DeadLetterException(PID pid)
• public sealed class DeadLetterResponse : IMessage<DeadLetterResponse>, IMessage, IEquatable<DeadLetterResponse>, IDeepCloneable<DeadLetterResponse>, IBufferMessage
  • public const int TargetFieldNumber = 1
  • public static MessageDescriptor Descriptor { get; }
  • public static MessageParser<DeadLetterResponse> Parser { get; }
  • public PID Target { get; set; }
  • public DeadLetterResponse()
  • public DeadLetterResponse(DeadLetterResponse other)
  • public int CalculateSize()
  • public DeadLetterResponse Clone()
  • public bool Equals(DeadLetterResponse other)
  • public void MergeFrom(DeadLetterResponse other)
  • public void MergeFrom(CodedInputStream input)
  • public void WriteTo(CodedOutputStream output)
• public class EventStream<T>
  • public Subscription<T> Subscribe(Action<T> action, IDispatcher dispatcher = null)
  • public Subscription<T> Subscribe(Func<T, Task> action, IDispatcher dispatcher = null)
  • public Subscription<T> Subscribe<TMsg>(Action<TMsg> action, IDispatcher dispatcher = null) where TMsg : T
  • public Subscription<T> Subscribe<TMsg>(ISenderContext context, PID[] pids) where TMsg : T
  • public Subscription<T> Subscribe<TMsg>(Func<TMsg, Task> action, IDispatcher dispatcher = null) where TMsg : T
  • public EventStreamSubscription<T> Subscribe(Action<T> action, IDispatcher dispatcher = null)
  • public EventStreamSubscription<T> Subscribe(Func<T, Task> action, IDispatcher dispatcher = null)
  • public EventStreamSubscription<T> Subscribe<TMsg>(Action<TMsg> action, IDispatcher dispatcher = null) where TMsg : T
  • public EventStreamSubscription<T> Subscribe<TMsg>(Func<TMsg, bool> predicate, Action<TMsg> action, IDispatcher dispatcher = null) where TMsg : T
  • public EventStreamSubscription<T> Subscribe<TMsg>(ISenderContext context, PID[] pids) where TMsg : T
  • public EventStreamSubscription<T> Subscribe<TMsg>(Func<TMsg, Task> action, IDispatcher dispatcher = null) where TMsg : T
  • public void Unsubscribe(Subscription<T> subscription)
  • public void Unsubscribe(EventStreamSubscription<T> subscription)
• public class EventStreamSubscription<T>
  • public Func<T, Task> Action { get; }
  • public IDispatcher Dispatcher { get; }
  • public Guid Id { get; }
  • public EventStreamSubscription(EventStream<T> eventStream, IDispatcher dispatcher, Func<T, Task> action)
  • public void Unsubscribe()
• public static class Extensions
• public interface ISpawnContext
• public static class Log
  • public static ILoggerFactory GetLoggerFactory()
• public class MessageEnvelope : IEquatable<MessageEnvelope>
  • protected virtual Type EqualityContract { get; }
  • protected MessageEnvelope(MessageEnvelope original)
  • public static bool op_Equality(MessageEnvelope r1, MessageEnvelope r2)
  • public static bool op_Inequality(MessageEnvelope r1, MessageEnvelope r2)
  • public virtual MessageEnvelope <Clone>$()
  • public virtual bool Equals(MessageEnvelope other)
  • protected virtual bool PrintMembers(StringBuilder builder)
• public class MessageHeader : IReadOnlyDictionary<string, string>, IEnumerable<KeyValuePair<string, string>>, IEnumerable, IReadOnlyCollection<KeyValuePair<string, string>>, IEquatable<MessageHeader>
  • protected virtual Type EqualityContract { get; }
  • public MessageHeader()
  • protected MessageHeader(MessageHeader original)
  • public static bool op_Equality(MessageHeader r1, MessageHeader r2)
  • public static bool op_Inequality(MessageHeader r1, MessageHeader r2)
  • public virtual MessageHeader <Clone>$()
  • public virtual bool Equals(MessageHeader other)
  • protected virtual bool PrintMembers(StringBuilder builder)
• public static class MurmurHash2
  • public static uint Hash(byte[] data, uint seed)
• public class NullLoggerFactory : ILoggerFactory, IDisposable
• public sealed class PID : ICustomDiagnosticMessage, IMessage, IMessage<PID>, IEquatable<PID>, IDeepCloneable<PID>, IBufferMessage
  • public static PID FromAddress(string address, string id)
  • public string ToShortString()
  • public string ToDiagnosticString()
• public sealed class PoisonPill : IMessage<PoisonPill>, IMessage, IEquatable<PoisonPill>, IDeepCloneable<PoisonPill>, IBufferMessage
  • public static readonly PoisonPill Instance
• public class ProcessRegistry
  • public ActorSystem System { get; }
  • public int ProcessCount { get; }
  • public Process GetLocal(string id)
  • public void RegisterClientResolver(Func<PID, Process> resolver)
• public sealed delegate ProducerWithSystem : MulticastDelegate
  • public ProducerWithSystem(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ActorSystem system, AsyncCallback callback, object object)
  • public virtual IActor EndInvoke(IAsyncResult result)
  • public virtual IActor Invoke(ActorSystem system)
• public sealed class Props : IEquatable<Props>
  • public IList<Func<IContext, IContext>> ContextDecorator { get; }
  • public static readonly Props Empty
  • public ImmutableList<Func<IContext, IContext>> ContextDecorator { get; set; }
  • public Producer Producer { get; }
  • public IList<Func<Receiver, Receiver>> ReceiverMiddleware { get; }
  • public ProducerWithSystem Producer { get; set; }
  • public ImmutableList<Func<Receiver, Receiver>> ReceiverMiddleware { get; set; }
  • public IList<Func<Sender, Sender>> SenderMiddleware { get; }
  • public ImmutableList<Func<Sender, Sender>> SenderMiddleware { get; set; }
  • public static Props FromProducer(ProducerWithSystem producer)
  • public static bool op_Equality(Props r1, Props r2)
  • public static bool op_Inequality(Props r1, Props r2)
  • public Props <Clone>$()
  • public bool Equals(Props other)
  • public Props WithProducer(ProducerWithSystem producer)
• public class RestartStatistics
  • public RestartStatistics(int failureCount, DateTime? lastFailureTime)
  • public RestartStatistics(int failureCount, DateTimeOffset? lastFailureTime)
• public sealed class RootContext : IRootContext, ISpawnerContext, ISenderContext, IInfoContext, IStopperContext, IEquatable<RootContext>
  • public static bool op_Equality(RootContext r1, RootContext r2)
  • public static bool op_Inequality(RootContext r1, RootContext r2)
  • public RootContext <Clone>$()
  • public bool Equals(RootContext other)
• public class Subscription<T>
• public sealed class Terminated : SystemMessage, IMessage<Terminated>, IMessage, IEquatable<Terminated>, IDeepCloneable<Terminated>, IBufferMessage
  • public const int AddressTerminatedFieldNumber = 2
  • public const int WhyFieldNumber = 2
  • public bool AddressTerminated { get; set; }
  • public TerminatedReason Why { get; set; }
  • public static Terminated From(PID who)
  • public static Terminated From(PID who, TerminatedReason why)
• public static class TimeConvert
• public enum TerminatedReason
  • AddressTerminated = 1
  • NotFound = 2
  • Stopped = 0
• public sealed class VoidResponse : IMessage<VoidResponse>, IMessage, IEquatable<VoidResponse>, IDeepCloneable<VoidResponse>
• public static class UtilExtensions
  • public static void Deconstruct<TKey, TValue>(this KeyValuePair<TKey, TValue> self, out TKey key, out TValue value)

Proto.Context

• public class ActorContext : IMessageInvoker, IContext, ISenderContext, IInfoContext, IReceiverContext, ISpawnerContext, IStopperContext, ISupervisor
  • public IActor Actor { get; }
  • public CancellationToken CancellationToken { get; }
  • public CancellationTokenSource CancellationTokenSource { get; }
  • public IImmutableSet<PID> Children { get; }
  • public MessageHeader Headers { get; }
  • public object Message { get; }
  • public PID Parent { get; }
  • public TimeSpan ReceiveTimeout { get; }
  • public PID Self { get; }
  • public PID Sender { get; }
  • public ActorSystem System { get; }
  • public ActorContext(ActorSystem system, Props props, PID parent, PID self)
  • public static ActorContext Setup(ActorSystem system, Props props, PID parent, PID self)
  • public void CancelReceiveTimeout()
  • public void EscalateFailure(Exception reason, object message)
  • public void Forward(PID target)
  • public Task InvokeSystemMessageAsync(object msg)
  • public Task InvokeUserMessageAsync(object msg)
  • public void Poison(PID pid)
  • public Task PoisonAsync(PID pid)
  • public Task Receive(MessageEnvelope envelope)
  • public void ReenterAfter<T>(Task<T> target, Func<Task<T>, Task> action)
  • public void ReenterAfter(Task target, Action action)
  • public void Request(PID target, object message)
  • public void Request(PID target, object message, PID sender)
  • public Task<T> RequestAsync<T>(PID target, object message, TimeSpan timeout)
  • public Task<T> RequestAsync<T>(PID target, object message, CancellationToken cancellationToken)
  • public Task<T> RequestAsync<T>(PID target, object message)
  • public void Respond(object message)
  • public void RestartChildren(Exception reason, PID[] pids)
  • public void ResumeChildren(PID[] pids)
  • public void Send(PID target, object message)
  • public void SetReceiveTimeout(TimeSpan duration)
  • public PID Spawn(Props props)
  • public PID SpawnNamed(Props props, string name)
  • public PID SpawnPrefix(Props props, string prefix)
  • public void Stash()
  • public void Stop(PID pid)
  • public Task StopAsync(PID pid)
  • public void StopChildren(PID[] pids)
  • public void Unwatch(PID pid)
  • public void Watch(PID pid)

Proto.DependencyInjection

• public class DependencyResolver : IDependencyResolver
  • public DependencyResolver(IServiceProvider services)
  • public Props PropsFor<TActor>() where TActor : IActor
  • public Props PropsFor(Type actorType)
• public class DIExtension : IActorSystemExtension<DIExtension>, IActorSystemExtension
  • public IDependencyResolver Resolver { get; }
  • public DIExtension(IDependencyResolver resolver)
• public static class Extensions
  • public static IDependencyResolver DI(this ActorSystem system)
  • public static ActorSystem WithServiceProvider(this ActorSystem actorSystem, IServiceProvider serviceProvider)
• public interface IDependencyResolver
  • Props PropsFor<TActor>() where TActor : IActor
  • Props PropsFor(Type actorType)

Proto.Extensions

• public class ActorSystemExtensions
  • public ActorSystemExtensions(ActorSystem actorSystem)
  • public T Get<T>() where T : IActorSystemExtension
  • public void Register<T>(IActorSystemExtension<T> extension) where T : IActorSystemExtension
• public interface IActorSystemExtension
• public interface IActorSystemExtension<T> : IActorSystemExtension where T : IActorSystemExtension
  • public static int Id

Proto.Interactive

• public static class InteractiveExtensions
  • public static Task ParallelForEach<T>(this IEnumerable<T> self, Func<T, Task> body, int concurrencyLevel = 10)
  • public static Task ParallelForEach<T>(this IAsyncEnumerable<T> self, Func<T, Task> body, int concurrencyLevel = 10)
  • public static Task ParallelForEach<T>(this IEnumerable<T> self, Action<T> body, int concurrencyLevel = 10)

Proto.Logging

• public class NullLoggerFactory : ILoggerFactory, IDisposable
  • public NullLoggerFactory()
  • public void AddProvider(ILoggerProvider provider)
  • public ILogger CreateLogger(string name)
  • public void Dispose()

Proto.Mailbox

• public interface SystemMessage
  • protected SystemMessage()

Proto.Router

• public static class RouterExtensions
  • public static Props NewConsistentHashGroup(this ISenderContext senderContext, Func<object, string> messageHasher, PID[] routees)
  • public static Props NewConsistentHashPool(this ISenderContext senderContext, Props props, int poolSize, Func<string, uint> hash = null, int replicaCount = 100)
  • public static Props NewConsistentHashGroup(this ISenderContext senderContext, Func<string, uint> hash, int replicaCount, Func<object, string> messageHasher, PID[] routees)
  • public static Props NewConsistentHashPool(this ISenderContext senderContext, Props props, int poolSize, Func<string, uint> hash = null, int replicaCount = 100, Func<object, string> messageHasher = null)

Proto.Router.Messages

• public class Routees : IEquatable<Routees>
  • public List<PID> PIDs { get; }
  • protected virtual Type EqualityContract { get; }
  • public List<PID> Pids { get; set; }
  • protected Routees(Routees original)
  • public static bool op_Equality(Routees r1, Routees r2)
  • public static bool op_Inequality(Routees r1, Routees r2)
  • public virtual Routees <Clone>$()
  • public void Deconstruct(out List Pids)
  • public virtual bool Equals(Routees other)
  • protected virtual bool PrintMembers(StringBuilder builder)
• public class RouterAddRoutee : RouterManagementMessage, IEquatable<RouterAddRoutee>
  • public PID PID { get; }
  • public PID Pid { get; set; }
  • protected RouterAddRoutee(RouterAddRoutee original)
  • public static bool op_Equality(RouterAddRoutee r1, RouterAddRoutee r2)
  • public static bool op_Inequality(RouterAddRoutee r1, RouterAddRoutee r2)
  • public void Deconstruct(out PID Pid)
  • public virtual bool Equals(RouterAddRoutee other)
• public class RouterBroadcastMessage : RouterManagementMessage, IEquatable<RouterBroadcastMessage>
  • protected RouterBroadcastMessage(RouterBroadcastMessage original)
  • public static bool op_Equality(RouterBroadcastMessage r1, RouterBroadcastMessage r2)
  • public static bool op_Inequality(RouterBroadcastMessage r1, RouterBroadcastMessage r2)
  • public void Deconstruct(out object Message)
  • public virtual bool Equals(RouterBroadcastMessage other)
• public class RouterGetRoutees : RouterManagementMessage, IEquatable<RouterGetRoutees>
  • protected RouterGetRoutees(RouterGetRoutees original)
  • public static bool op_Equality(RouterGetRoutees r1, RouterGetRoutees r2)
  • public static bool op_Inequality(RouterGetRoutees r1, RouterGetRoutees r2)
  • public virtual bool Equals(RouterGetRoutees other)
• public abstract class RouterManagementMessage : IEquatable<RouterManagementMessage>
  • protected virtual Type EqualityContract { get; }
  • protected RouterManagementMessage(RouterManagementMessage original)
  • public static bool op_Equality(RouterManagementMessage r1, RouterManagementMessage r2)
  • public static bool op_Inequality(RouterManagementMessage r1, RouterManagementMessage r2)
  • public abstract RouterManagementMessage <Clone>$()
  • public virtual bool Equals(RouterManagementMessage other)
  • protected virtual bool PrintMembers(StringBuilder builder)
• public class RouterRemoveRoutee : RouterManagementMessage, IEquatable<RouterRemoveRoutee>
  • public PID PID { get; }
  • public PID Pid { get; set; }
  • protected RouterRemoveRoutee(RouterRemoveRoutee original)
  • public static bool op_Equality(RouterRemoveRoutee r1, RouterRemoveRoutee r2)
  • public static bool op_Inequality(RouterRemoveRoutee r1, RouterRemoveRoutee r2)
  • public void Deconstruct(out PID Pid)
  • public virtual bool Equals(RouterRemoveRoutee other)

Proto.Router.Routers

• public abstract class GroupRouterConfig : RouterConfig, IEquatable<GroupRouterConfig>
  • protected readonly ISenderContext SenderContext
  • public PID[] Routees { get; set; }
  • public ISenderContext SenderContext { get; set; }
  • protected GroupRouterConfig(GroupRouterConfig original)
  • public static bool op_Equality(GroupRouterConfig r1, GroupRouterConfig r2)
  • public static bool op_Inequality(GroupRouterConfig r1, GroupRouterConfig r2)
  • public abstract RouterConfig <Clone>$()
  • public void Deconstruct(out ISenderContext SenderContext, out PID Routees)
  • public virtual bool Equals(GroupRouterConfig other)
• public abstract class RouterConfig : IEquatable<RouterConfig>
  • protected virtual Type EqualityContract { get; }
  • protected RouterConfig(RouterConfig original)
  • public static bool op_Equality(RouterConfig r1, RouterConfig r2)
  • public static bool op_Inequality(RouterConfig r1, RouterConfig r2)
  • public abstract RouterConfig <Clone>$()
  • public virtual bool Equals(RouterConfig other)
  • protected virtual bool PrintMembers(StringBuilder builder)
• public abstract class RouterState
  • protected HashSet<PID> Routees
  • protected ImmutableList<PID> Values
  • protected List<PID> GetValues()
  • protected ImmutableList<PID> GetValues()
  • public virtual void SetRoutees(HashSet<PID> routees)
  • public virtual void SetRoutees(PID[] routees)

Proto.Timers

• public class Scheduler
  • public Scheduler(ISenderContext context)
  • public CancellationTokenSource RequestOnce(TimeSpan delay, PID sender, PID target, object message)
  • public CancellationTokenSource RequestRepeatedly(TimeSpan interval, PID sender, PID target, object message)
  • public CancellationTokenSource RequestRepeatedly(TimeSpan delay, TimeSpan interval, PID target, object message)
  • public CancellationTokenSource SendOnce(TimeSpan delay, PID target, object message)
  • public CancellationTokenSource SendRepeatedly(TimeSpan interval, PID target, object message)
  • public CancellationTokenSource SendRepeatedly(TimeSpan delay, TimeSpan interval, PID target, object message)
• public static class TimerExtensions
  • public static Scheduler Scheduler(this ISenderContext context)

Proto.Utils

• public class AsyncSemaphore
  • public AsyncSemaphore(int maxConcurrency)
  • public void Wait(Func<Task> producer)
  • public Task<T> WaitAsync<T>(Func<Task<T>> producer)
  • public Task WaitAsync(Func<Task> producer)
• public class ConcurrentSet<T>
  • public ConcurrentSet()
  • public void Add(T key)
  • public bool Contains(T key)
  • public void Remove(T key)
  • public T[] ToArray()
  • public bool TryAdd(T key)
• public sealed delegate ShouldThrottle : MulticastDelegate
  • public ShouldThrottle(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual Valve EndInvoke(IAsyncResult result)
  • public virtual Valve Invoke()
• public static class Throttle
  • public enum Valve
  • public static ShouldThrottle Create(int maxEventsInPeriod, TimeSpan period, Action<int> throttledCallBack = null)
  • public static bool IsOpen(this Valve valve)