Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Read stash capacity from actor's mailbox or dispatcher configuration #6323

Merged
merged 1 commit into from
Jan 3, 2023
Merged

Read stash capacity from actor's mailbox or dispatcher configuration #6323

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 13 additions & 6 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Core.verified.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1933,13 +1933,13 @@ namespace Akka.Actor.Internal
{
public abstract class AbstractStash : Akka.Actor.IStash
{
protected AbstractStash(Akka.Actor.IActorContext context, int capacity = 100) { }
protected AbstractStash(Akka.Actor.IActorContext context) { }
public System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> ClearStash() { }
public void Prepend(System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> envelopes) { }
public void Stash() { }
public void Unstash() { }
public void UnstashAll() { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> predicate) { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> filterPredicate) { }
}
public class ActorSystemImpl : Akka.Actor.ExtendedActorSystem
{
Expand Down Expand Up @@ -1988,7 +1988,7 @@ namespace Akka.Actor.Internal
}
public class BoundedStashImpl : Akka.Actor.Internal.AbstractStash
{
public BoundedStashImpl(Akka.Actor.IActorContext context, int capacity = 100) { }
public BoundedStashImpl(Akka.Actor.IActorContext context) { }
}
public class ChildNameReserved : Akka.Actor.Internal.IChildStats
{
Expand Down Expand Up @@ -2486,14 +2486,14 @@ namespace Akka.Dispatch
public static void RunTask(System.Func<System.Threading.Tasks.Task> asyncAction) { }
protected override bool TryExecuteTaskInline(System.Threading.Tasks.Task task, bool taskWasPreviouslyQueued) { }
}
public sealed class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>
public class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedDequeBasedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
public System.TimeSpan PushTimeout { get; }
public override Akka.Dispatch.MessageQueues.IMessageQueue Create(Akka.Actor.IActorRef owner, Akka.Actor.ActorSystem system) { }
}
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
Expand Down Expand Up @@ -2549,6 +2549,8 @@ namespace Akka.Dispatch
public Akka.Configuration.Config DefaultDispatcherConfig { get; }
public Akka.Dispatch.MessageDispatcher DefaultGlobalDispatcher { get; }
public Akka.Dispatch.IDispatcherPrerequisites Prerequisites { get; }
[Akka.Annotations.InternalApiAttribute()]
public static Akka.Configuration.Config GetConfig(Akka.Configuration.Config config, string id, int depth = 0) { }
public bool HasDispatcher(string id) { }
public Akka.Dispatch.MessageDispatcher Lookup(string dispatcherName) { }
public bool RegisterConfigurator(string id, Akka.Dispatch.MessageDispatcherConfigurator configurator) { }
Expand Down Expand Up @@ -2602,6 +2604,10 @@ namespace Akka.Dispatch
public interface IMultipleConsumerSemantics : Akka.Dispatch.ISemantics { }
public interface IProducesMessageQueue<TQueue>
where TQueue : Akka.Dispatch.MessageQueues.IMessageQueue { }
public interface IProducesPushTimeoutSemanticsMailbox
{
System.TimeSpan PushTimeout { get; }
}
public interface IRequiresMessageQueue<T>
where T : Akka.Dispatch.ISemantics { }
public interface IRunnable
Expand Down Expand Up @@ -2635,13 +2641,14 @@ namespace Akka.Dispatch
public static readonly string NoMailboxRequirement;
public Mailboxes(Akka.Actor.ActorSystem system) { }
public Akka.Actor.DeadLetterMailbox DeadLetterMailbox { get; }
public System.Type FromConfig(string path) { }
public Akka.Dispatch.MailboxType GetMailboxType(Akka.Actor.Props props, Akka.Configuration.Config dispatcherConfig) { }
public System.Type GetRequiredType(System.Type actorType) { }
public bool HasRequiredType(System.Type actorType) { }
public Akka.Dispatch.MailboxType Lookup(string id) { }
public Akka.Dispatch.MailboxType LookupByQueueType(System.Type queueType) { }
public bool ProducesMessageQueue(System.Type mailboxType) { }
[Akka.Annotations.InternalApiAttribute()]
public int StashCapacity(string dispatcher, string mailbox) { }
}
public abstract class MessageDispatcher
{
Expand Down
19 changes: 13 additions & 6 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.DotNet.verified.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1935,13 +1935,13 @@ namespace Akka.Actor.Internal
{
public abstract class AbstractStash : Akka.Actor.IStash
{
protected AbstractStash(Akka.Actor.IActorContext context, int capacity = 100) { }
protected AbstractStash(Akka.Actor.IActorContext context) { }
public System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> ClearStash() { }
public void Prepend(System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> envelopes) { }
public void Stash() { }
public void Unstash() { }
public void UnstashAll() { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> predicate) { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> filterPredicate) { }
}
public class ActorSystemImpl : Akka.Actor.ExtendedActorSystem
{
Expand Down Expand Up @@ -1990,7 +1990,7 @@ namespace Akka.Actor.Internal
}
public class BoundedStashImpl : Akka.Actor.Internal.AbstractStash
{
public BoundedStashImpl(Akka.Actor.IActorContext context, int capacity = 100) { }
public BoundedStashImpl(Akka.Actor.IActorContext context) { }
}
public class ChildNameReserved : Akka.Actor.Internal.IChildStats
{
Expand Down Expand Up @@ -2490,14 +2490,14 @@ namespace Akka.Dispatch
public static void RunTask(System.Func<System.Threading.Tasks.Task> asyncAction) { }
protected override bool TryExecuteTaskInline(System.Threading.Tasks.Task task, bool taskWasPreviouslyQueued) { }
}
public sealed class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>
public class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedDequeBasedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
public System.TimeSpan PushTimeout { get; }
public override Akka.Dispatch.MessageQueues.IMessageQueue Create(Akka.Actor.IActorRef owner, Akka.Actor.ActorSystem system) { }
}
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
Expand Down Expand Up @@ -2553,6 +2553,8 @@ namespace Akka.Dispatch
public Akka.Configuration.Config DefaultDispatcherConfig { get; }
public Akka.Dispatch.MessageDispatcher DefaultGlobalDispatcher { get; }
public Akka.Dispatch.IDispatcherPrerequisites Prerequisites { get; }
[Akka.Annotations.InternalApiAttribute()]
public static Akka.Configuration.Config GetConfig(Akka.Configuration.Config config, string id, int depth = 0) { }
public bool HasDispatcher(string id) { }
public Akka.Dispatch.MessageDispatcher Lookup(string dispatcherName) { }
public bool RegisterConfigurator(string id, Akka.Dispatch.MessageDispatcherConfigurator configurator) { }
Expand Down Expand Up @@ -2606,6 +2608,10 @@ namespace Akka.Dispatch
public interface IMultipleConsumerSemantics : Akka.Dispatch.ISemantics { }
public interface IProducesMessageQueue<TQueue>
where TQueue : Akka.Dispatch.MessageQueues.IMessageQueue { }
public interface IProducesPushTimeoutSemanticsMailbox
{
System.TimeSpan PushTimeout { get; }
}
public interface IRequiresMessageQueue<T>
where T : Akka.Dispatch.ISemantics { }
public interface IRunnable : System.Threading.IThreadPoolWorkItem
Expand Down Expand Up @@ -2640,13 +2646,14 @@ namespace Akka.Dispatch
public static readonly string NoMailboxRequirement;
public Mailboxes(Akka.Actor.ActorSystem system) { }
public Akka.Actor.DeadLetterMailbox DeadLetterMailbox { get; }
public System.Type FromConfig(string path) { }
public Akka.Dispatch.MailboxType GetMailboxType(Akka.Actor.Props props, Akka.Configuration.Config dispatcherConfig) { }
public System.Type GetRequiredType(System.Type actorType) { }
public bool HasRequiredType(System.Type actorType) { }
public Akka.Dispatch.MailboxType Lookup(string id) { }
public Akka.Dispatch.MailboxType LookupByQueueType(System.Type queueType) { }
public bool ProducesMessageQueue(System.Type mailboxType) { }
[Akka.Annotations.InternalApiAttribute()]
public int StashCapacity(string dispatcher, string mailbox) { }
}
public abstract class MessageDispatcher
{
Expand Down
19 changes: 13 additions & 6 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Net.verified.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1933,13 +1933,13 @@ namespace Akka.Actor.Internal
{
public abstract class AbstractStash : Akka.Actor.IStash
{
protected AbstractStash(Akka.Actor.IActorContext context, int capacity = 100) { }
protected AbstractStash(Akka.Actor.IActorContext context) { }
public System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> ClearStash() { }
public void Prepend(System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> envelopes) { }
public void Stash() { }
public void Unstash() { }
public void UnstashAll() { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> predicate) { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> filterPredicate) { }
}
public class ActorSystemImpl : Akka.Actor.ExtendedActorSystem
{
Expand Down Expand Up @@ -1988,7 +1988,7 @@ namespace Akka.Actor.Internal
}
public class BoundedStashImpl : Akka.Actor.Internal.AbstractStash
{
public BoundedStashImpl(Akka.Actor.IActorContext context, int capacity = 100) { }
public BoundedStashImpl(Akka.Actor.IActorContext context) { }
}
public class ChildNameReserved : Akka.Actor.Internal.IChildStats
{
Expand Down Expand Up @@ -2486,14 +2486,14 @@ namespace Akka.Dispatch
public static void RunTask(System.Func<System.Threading.Tasks.Task> asyncAction) { }
protected override bool TryExecuteTaskInline(System.Threading.Tasks.Task task, bool taskWasPreviouslyQueued) { }
}
public sealed class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>
public class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedDequeBasedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
public System.TimeSpan PushTimeout { get; }
public override Akka.Dispatch.MessageQueues.IMessageQueue Create(Akka.Actor.IActorRef owner, Akka.Actor.ActorSystem system) { }
}
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
Expand Down Expand Up @@ -2549,6 +2549,8 @@ namespace Akka.Dispatch
public Akka.Configuration.Config DefaultDispatcherConfig { get; }
public Akka.Dispatch.MessageDispatcher DefaultGlobalDispatcher { get; }
public Akka.Dispatch.IDispatcherPrerequisites Prerequisites { get; }
[Akka.Annotations.InternalApiAttribute()]
public static Akka.Configuration.Config GetConfig(Akka.Configuration.Config config, string id, int depth = 0) { }
public bool HasDispatcher(string id) { }
public Akka.Dispatch.MessageDispatcher Lookup(string dispatcherName) { }
public bool RegisterConfigurator(string id, Akka.Dispatch.MessageDispatcherConfigurator configurator) { }
Expand Down Expand Up @@ -2602,6 +2604,10 @@ namespace Akka.Dispatch
public interface IMultipleConsumerSemantics : Akka.Dispatch.ISemantics { }
public interface IProducesMessageQueue<TQueue>
where TQueue : Akka.Dispatch.MessageQueues.IMessageQueue { }
public interface IProducesPushTimeoutSemanticsMailbox
{
System.TimeSpan PushTimeout { get; }
}
public interface IRequiresMessageQueue<T>
where T : Akka.Dispatch.ISemantics { }
public interface IRunnable
Expand Down Expand Up @@ -2635,13 +2641,14 @@ namespace Akka.Dispatch
public static readonly string NoMailboxRequirement;
public Mailboxes(Akka.Actor.ActorSystem system) { }
public Akka.Actor.DeadLetterMailbox DeadLetterMailbox { get; }
public System.Type FromConfig(string path) { }
public Akka.Dispatch.MailboxType GetMailboxType(Akka.Actor.Props props, Akka.Configuration.Config dispatcherConfig) { }
public System.Type GetRequiredType(System.Type actorType) { }
public bool HasRequiredType(System.Type actorType) { }
public Akka.Dispatch.MailboxType Lookup(string id) { }
public Akka.Dispatch.MailboxType LookupByQueueType(System.Type queueType) { }
public bool ProducesMessageQueue(System.Type mailboxType) { }
[Akka.Annotations.InternalApiAttribute()]
public int StashCapacity(string dispatcher, string mailbox) { }
}
public abstract class MessageDispatcher
{
Expand Down
Loading