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 1.4.1-alpha.0.6

59 Additions 60 Removals

Proto

• public abstract class ActorContextDecorator : IContext, ISenderContext, IInfoContext, IContextStore, ISystemContext, IReceiverContext, ISpawnerContext, IStopperContext
  • public void ReenterAfter(Task target, Action<Task> action)
  • public void ReenterAfter<T>(Task<T> target, Action<Task<T>> action)
  • public void ReenterAfter(Task target, Func<Task, Task> action)
  • public virtual void Stash()
• public sealed class ActorContextExtras : IDisposable
  • public Stack<object> Stash { get; }
  • public TypeDictionary<object, ActorContextExtras> Store { get; }
• public static class ActorLoggingContextExtensions
  • public static IRootContext WithLoggingContext(this IRootContext context, ILogger logger)
• public sealed class ActorSystem : IAsyncDisposable
  • public Process DeadLetter { get; }
  • public DiagnosticsStore Diagnostics { get; }
  • public DeadLetterProcess DeadLetter { get; }
  • public IRootContext Root { get; }
  • public RootContext Root { get; }
  • public string StoppedReason { get; }
  • public Stopper Stopper { get; }
  • public Props ConfigureProps(Props props)
  • public Props ConfigureSystemProps(string name, Props props)
  • public IRootContext NewRoot(MessageHeader headers = null, Func<Sender, Sender>[] middleware)
  • public RootContext NewRoot(MessageHeader headers = null, Func<Sender, Sender>[] middleware)
• public class ActorSystemConfig : IEquatable<ActorSystemConfig>
  • public Func<Process, Process> ConfigureProcess { get; set; }
  • public Func<RootContext, IRootContext> ConfigureRootContext { get; set; }
  • public LogLevel DiagnosticsLogLevel { get; set; }
  • public ActorSystemConfig WithConfigureProcess(Func<Process, Process> configureProcess)
  • public ActorSystemConfig WithConfigureRootContext(Func<RootContext, IRootContext> configureContext)
  • public ActorSystemConfig WithDiagnosticsLogLevel(LogLevel diagnosticsLogLevel)
• public static class ActorSystemConfigExtensions
  • public static ActorSystemConfig WithDeveloperReceiveLogging(this ActorSystemConfig self, TimeSpan receiveDeadline, LogLevel logLevel = 4)
• public static class CancellationTokens
  • public static CancellationToken FromSeconds(TimeSpan duration)
• public interface IContext : ISenderContext, IInfoContext, IContextStore, ISystemContext, IReceiverContext, ISpawnerContext, IStopperContext
  • void ReenterAfter(Task target, Action<Task> action)
  • void ReenterAfter<T>(Task<T> target, Action<Task<T>> action)
  • void ReenterAfter(Task target, Func<Task, Task> action)
  • void Stash()
• public interface IRootContext : ISpawnerContext, ISystemContext, ISenderContext, IInfoContext, IContextStore, IStopperContext
  • IRootContext WithSenderMiddleware(Func<Sender, Sender>[] middleware)
• public class MessageBatch : IEquatable<MessageBatch>
  • protected virtual Type EqualityContract { get; }
  • public IReadOnlyCollection<object> Messages { get; set; }
  • public MessageBatch(IReadOnlyCollection<object> Messages)
  • protected MessageBatch(MessageBatch original)
  • public static bool op_Equality(MessageBatch left, MessageBatch right)
  • public static bool op_Inequality(MessageBatch left, MessageBatch right)
  • public virtual MessageBatch <Clone>$()
  • public void Deconstruct(out IReadOnlyCollection Messages)
  • public virtual bool Equals(MessageBatch other)
  • protected virtual bool PrintMembers(StringBuilder builder)
• public class MessageEnvelope : IEquatable<MessageEnvelope>
  • public static MessageEnvelope WithSender(object message, PID sender)
  • public string GetTypeName()
• public sealed class PID : ICustomDiagnosticMessage, IMessage, IMessage<PID>, IEquatable<PID>, IDeepCloneable<PID>, IBufferMessage
  • public void SendSystemMessage(ActorSystem system, object sys)
• public abstract class Process
  • protected ActorSystem System { get; }
• public sealed class Props : IEquatable<Props>
  • public Func<IContext, IContext> ContextDecoratorChain { get; set; }
  • public Receiver ReceiverMiddlewareChain { get; set; }
  • public Sender SenderMiddlewareChain { get; set; }
  • public TimeSpan StartDeadline { get; set; }
  • public static PID SystemSpawner(ActorSystem system, string name, Props props, PID parent, Action<IContext> callback)
  • public Props WithStartDeadline(TimeSpan deadline)
• public sealed class RootContext : IRootContext, ISpawnerContext, ISystemContext, ISenderContext, IInfoContext, IContextStore, IStopperContext, IEquatable<RootContext>
  • public IRootContext WithHeaders(MessageHeader headers)
  • public IRootContext WithSenderMiddleware(Func<Sender, Sender>[] middleware)
  • public RootContext WithHeaders(MessageHeader headers)
  • public RootContext WithSenderMiddleware(Func<Sender, Sender>[] middleware)
• public abstract class RootContextDecorator : IRootContext, ISpawnerContext, ISystemContext, ISenderContext, IInfoContext, IContextStore, IStopperContext
  • public virtual void Request(PID target, object message, PID sender)
  • public virtual void Request(PID target, object message, PID sender)
  • public IRootContext WithSenderMiddleware(Func<Sender, Sender>[] middleware)
• public class RootLoggingContext : RootContextDecorator
• public static class SpawnerContextExtensions
  • public static PID Spawn(this ISpawnerContext self, Props props, 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 IRootContext self, Props props, string name)
  • public static PID SpawnNamedSystem(this RootContext self, Props props, string name)
• public static class UtilExtensions
  • public static Process Configure(this Process self)
  • public static Func<T, T> Wrap<T>(this Func<T, T> self, Func<T, T> outer)

Proto.Channels

• public static class ChannelPublisher
  • public static PID StartNew<T>(IRootContext context, Channel<T> channel, string name)
• public class ChannelPublisherActor<T> : IActor
  • public ChannelPublisherActor()
  • public Task ReceiveAsync(IContext context)
• public static class ChannelSubscriber
  • public static PID StartNew<T>(IRootContext context, PID publisher, Channel<T> channel)
• public class ChannelSubscriberActor<T> : IActor
  • public ChannelSubscriberActor(PID publisher, Channel<T> channel)
  • public Task ReceiveAsync(IContext context)

Proto.Context

• public class ActorContext : IMessageInvoker, IContext, ISenderContext, IInfoContext, IContextStore, ISystemContext, IReceiverContext, ISpawnerContext, IStopperContext, ISupervisor
  • public ValueTask InvokeSystemMessageAsync(SystemMessage msg)
  • public ValueTask InvokeSystemMessageAsync(object msg)
  • public void ReenterAfter(Task target, Action<Task> action)
  • public void ReenterAfter<T>(Task<T> target, Action<Task<T>> action)
  • public void ReenterAfter(Task target, Func<Task, Task> action)
  • public void Stash()
• public class PassivationContextDecorator : ActorContextDecorator
• public static class PassivationContextExtensions
• public class StartupDeadlineContextDecorator : ActorContextDecorator
• public static class StartupDeadlineContextExtensions

Proto.Diagnostics

• public class DiagnosticsEntry : IEquatable<DiagnosticsEntry>
• public class DiagnosticsStore
• public interface IDiagnosticsProvider
• public interface IDiagnosticsTypeName

Proto.Extensions

• public class ActorSystemExtensions
  • public IEnumerable<IActorSystemExtension> GetAll()
• public static class TypeExtensions

Proto.Future

• public sealed class SharedFutureProcess : Process, IDisposable
  • public void Stop()

Proto.Mailbox

• public static class BoundedMailbox
  • public static IMailbox Create(int size, BoundedChannelFullMode fullMode, IMailboxStatistics[] stats)
• public class BoundedMailboxQueue : IMailboxQueue
  • public BoundedMailboxQueue(int size, BoundedChannelFullMode fullMode = 0)
  • public BoundedMailboxQueue(int size)
• public sealed class DefaultMailbox : IMailbox
  • public void Execute()
• public interface IMessageInvoker
  • ValueTask InvokeSystemMessageAsync(SystemMessage msg)
  • ValueTask InvokeSystemMessageAsync(object msg)

Proto.Router

• public class RouterActor : IActor
  • public RouterActor(RouterConfig config, RouterState routerState, RouterStartNotification startNotification)
  • public RouterActor(RouterConfig config, RouterState routerState, AutoResetEvent wg)

Proto.Router.Messages

• public class RouterAddRoutee : RouterManagementMessage, IEquatable<RouterAddRoutee>
  • public virtual RouterAddRoutee <Clone>$()
• public class RouterBroadcastMessage : RouterManagementMessage, IEquatable<RouterBroadcastMessage>
  • public virtual RouterBroadcastMessage <Clone>$()
• public class RouterGetRoutees : RouterManagementMessage, IEquatable<RouterGetRoutees>
  • public virtual RouterGetRoutees <Clone>$()
• public class RouterRemoveRoutee : RouterManagementMessage, IEquatable<RouterRemoveRoutee>
  • public virtual RouterRemoveRoutee <Clone>$()

Proto.Router.Routers

• public abstract class GroupRouterConfig : RouterConfig, IEquatable<GroupRouterConfig>
  • public abstract GroupRouterConfig <Clone>$()
  • public abstract RouterConfig <Clone>$()
• public class RouterStartFailedException : Exception
• public class RouterStartNotification

Proto.Utils

• public class TypeDictionary<TValue, TNamespace>
  • public TypeDictionary(int initialSize = 100, double growthFactor = 2)
  • public void Add<TKey>(TValue value)
  • public TValue Get<TKey>()
  • public void Remove<TKey>()