Add restarting persistent subscriptions

src/EventStore.Client.Common/protos/operations.proto

@@ -11,6 +11,7 @@ service Operations {
 	rpc MergeIndexes (Empty) returns (Empty);
 	rpc ResignNode (Empty) returns (Empty);
 	rpc SetNodePriority (SetNodePriorityReq) returns (Empty);
+	rpc RestartPersistentSubscriptions (Empty) returns (Empty);
 }
 
 message StartScavengeReq {

src/EventStore.Client.Operations/EventStoreOperationsClient.Admin.cs

@@ -59,5 +59,17 @@ public partial class EventStoreOperationsClient {
 			await _client.SetNodePriorityAsync(new SetNodePriorityReq {Priority = nodePriority},
 				EventStoreCallOptions.Create(Settings, Settings.OperationOptions, userCredentials, cancellationToken));
 		}
+
+		/// <summary>
+		/// Restart persistent subscriptions
+		/// </summary>
+		/// <param name="userCredentials"></param>
+		/// <param name="cancellationToken"></param>
+		/// <returns></returns>
+		public async Task RestartPersistentSubscriptions(UserCredentials? userCredentials = null,
+			CancellationToken cancellationToken = default) {
+			await _client.RestartPersistentSubscriptionsAsync(EmptyResult,
+				EventStoreCallOptions.Create(Settings, Settings.OperationOptions, userCredentials, cancellationToken));
+		}
 	}
 }

test/EventStore.Client.Operations.Tests/admin.cs

@@ -10,43 +10,23 @@ public class admin : IClassFixture<admin.Fixture> {
 		}
 
 		[Fact]
-		public async Task shutdown_does_not_throw() {
-			await _fixture.Client.ShutdownAsync(userCredentials: TestCredentials.Root);
-		}
-
-		[Fact]
-		public async Task shutdown_without_credentials_throws() {
-			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.ShutdownAsync());
-		}
-
-		[Fact]
-		public async Task set_node_priority_does_not_throw() {
-			await _fixture.Client.SetNodePriorityAsync(1000, TestCredentials.Root);
-		}
-
-		[Fact]
-		public async Task set_node_priority_without_credentials_throws() {
-			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.SetNodePriorityAsync(1000));
-		}
-
-		[Fact]
-		public async Task resign_node_does_not_throw() {
-			await _fixture.Client.ResignNodeAsync(TestCredentials.Root);
+		public async Task merge_indexes_does_not_throw() {
+			await _fixture.Client.MergeIndexesAsync(TestCredentials.Root);
 		}
 
 		[Fact]
-		public async Task resign_node_without_credentials_throws() {
-			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.ResignNodeAsync());
+		public async Task merge_indexes_without_credentials_throws() {
+			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.MergeIndexesAsync());
 		}
-
+		
 		[Fact]
-		public async Task merge_indexes_does_not_throw() {
-			await _fixture.Client.MergeIndexesAsync(TestCredentials.Root);
+		public async Task restart_persistent_subscriptions_does_not_throw() {
+			await _fixture.Client.RestartPersistentSubscriptions(TestCredentials.Root);
 		}
 
 		[Fact]
-		public async Task merge_indexes_without_credentials_throws() {
-			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.MergeIndexesAsync());
+		public async Task restart_persistent_subscriptions_without_credentials_throws() {
+			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.RestartPersistentSubscriptions());
 		}
 
 		public class Fixture : EventStoreClientFixture {

test/EventStore.Client.Operations.Tests/admin_resign_node.cs

@@ -0,0 +1,27 @@
+using System.Threading.Tasks;
+using Xunit;
+
+namespace EventStore.Client {
+	public class admin_resign_node : IClassFixture<admin_resign_node.Fixture> {
+		private readonly Fixture _fixture;
+
+		public admin_resign_node(Fixture fixture) {
+			_fixture = fixture;
+		}
+
+		[Fact]
+		public async Task resign_node_does_not_throw() {
+			await _fixture.Client.ResignNodeAsync(TestCredentials.Root);
+		}
+
+		[Fact]
+		public async Task resign_node_without_credentials_throws() {
+			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.ResignNodeAsync());
+		}
+
+		public class Fixture : EventStoreClientFixture {
+			protected override Task Given() => Task.CompletedTask;
+			protected override Task When() => Task.CompletedTask;
+		}
+	}
+}

test/EventStore.Client.Operations.Tests/admin_shutdown_node.cs

@@ -0,0 +1,27 @@
+using System.Threading.Tasks;
+using Xunit;
+
+namespace EventStore.Client {
+	public class admin_shutdown_node : IClassFixture<admin_shutdown_node.Fixture> {
+		private readonly Fixture _fixture;
+
+		public admin_shutdown_node(Fixture fixture) {
+			_fixture = fixture;
+		}
+
+		[Fact]
+		public async Task shutdown_does_not_throw() {
+			await _fixture.Client.ShutdownAsync(userCredentials: TestCredentials.Root);
+		}
+
+		[Fact]
+		public async Task shutdown_without_credentials_throws() {
+			await Assert.ThrowsAsync<AccessDeniedException>(() => _fixture.Client.ShutdownAsync());
+		}
+
+		public class Fixture : EventStoreClientFixture {
+			protected override Task Given() => Task.CompletedTask;
+			protected override Task When() => Task.CompletedTask;
+		}
+	}
+}