DistributedPubSub: make query to count local subscribers for topic pu…

…blic (#6856) * DistributedPubSub: make query to count local subscribers for topic public close #3663 - between this and `Topic`s all local data should be queryable for distributed pub-sub * added `ApiMayChange` attribute --------- Co-authored-by: Gregorius Soedharmo <arkatufus@yahoo.com>
akkadotnet · Jul 27, 2023 · 28bdef6 · 28bdef6
1 parent 588d5d6
commit 28bdef6
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 2 deletions.
diff --git a/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/Internal/TopicMessages.cs b/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/Internal/TopicMessages.cs
@@ -10,6 +10,7 @@
 using System.Collections.Immutable;
 using System.Linq;
 using Akka.Actor;
+using Akka.Annotations;
 using Akka.Event;
 using Akka.Routing;
 
@@ -42,9 +43,10 @@ private Count() { }
     }
 
     /// <summary>
-    /// TBD
+    /// Get all subscribers for a given topic.
     /// </summary>
-    internal sealed class CountSubscribers
+    [ApiMayChange]
+    public sealed class CountSubscribers
     {
         public string Topic { get; }
 

diff --git a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.DotNet.verified.txt b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.DotNet.verified.txt
@@ -318,6 +318,15 @@ namespace Akka.Cluster.Tools.PublishSubscribe
         public override string ToString() { }
     }
 }
+namespace Akka.Cluster.Tools.PublishSubscribe.Internal
+{
+    [Akka.Annotations.ApiMayChangeAttribute()]
+    public sealed class CountSubscribers
+    {
+        public CountSubscribers(string topic) { }
+        public string Topic { get; }
+    }
+}
 namespace Akka.Cluster.Tools.PublishSubscribe.Serialization
 {
     public class DistributedPubSubMessageSerializer : Akka.Serialization.SerializerWithStringManifest

diff --git a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.Net.verified.txt b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.Net.verified.txt
@@ -318,6 +318,15 @@ namespace Akka.Cluster.Tools.PublishSubscribe
         public override string ToString() { }
     }
 }
+namespace Akka.Cluster.Tools.PublishSubscribe.Internal
+{
+    [Akka.Annotations.ApiMayChangeAttribute()]
+    public sealed class CountSubscribers
+    {
+        public CountSubscribers(string topic) { }
+        public string Topic { get; }
+    }
+}
 namespace Akka.Cluster.Tools.PublishSubscribe.Serialization
 {
     public class DistributedPubSubMessageSerializer : Akka.Serialization.SerializerWithStringManifest