Add projection manager method to get partition state and result.

EventStore · Dec 5, 2015 · 367f2f3 · 367f2f3
1 parent 0b6da4a
commit 367f2f3
Show file tree

Hide file tree

Showing 2 changed files with 56 additions and 1 deletion.
diff --git a/src/EventStore.ClientAPI/Projections/ProjectionsClient.cs b/src/EventStore.ClientAPI/Projections/ProjectionsClient.cs
@@ -117,6 +117,21 @@ public Task<string> GetState(IPEndPoint endPoint, string name, UserCredentials u
             return SendGet(endPoint.ToHttpUrl("/projection/{0}/state", name), userCredentials, HttpStatusCode.OK);
         }
 
+        public Task<string> GetPartitionStateAsync(IPEndPoint endPoint, string name, string partition, UserCredentials userCredentials = null)
+        {
+            return SendGet(endPoint.ToHttpUrl("/projection/{0}/state?partition={1}", name, partition), userCredentials, HttpStatusCode.OK);
+        }
+
+        public Task<string> GetResult(IPEndPoint endPoint, string name, UserCredentials userCredentials = null)
+        {
+            return SendGet(endPoint.ToHttpUrl("/projection/{0}/result", name), userCredentials, HttpStatusCode.OK);
+        }
+
+        public Task<string> GetPartitionResultAsync(IPEndPoint endPoint, string name, string partition, UserCredentials userCredentials = null)
+        {
+            return SendGet(endPoint.ToHttpUrl("/projection/{0}/result?partition={1}", name, partition), userCredentials, HttpStatusCode.OK);
+        }
+
         public Task<string> GetStatistics(IPEndPoint endPoint, string name, UserCredentials userCredentials = null)
         {
             return SendGet(endPoint.ToHttpUrl("/projection/{0}/statistics", name), userCredentials, HttpStatusCode.OK);

diff --git a/src/EventStore.ClientAPI/Projections/ProjectionsManager.cs b/src/EventStore.ClientAPI/Projections/ProjectionsManager.cs
@@ -192,6 +192,46 @@ public Task<string> GetStateAsync(string name, UserCredentials userCredentials =
             return _client.GetState(_httpEndPoint, name, userCredentials);
         }
 
+        /// <summary>
+        /// Asynchronously gets the state of a projection for a specified partition.
+        /// </summary>
+        /// <param name="name">The name of the projection.</param>
+        /// <param name="partitionId">The id of the partition.</param>
+        /// <param name="userCredentials">Credentials for the operation.</param>
+        /// <returns>String of JSON containing projection state.</returns>
+        public Task<string> GetPartitionStateAsync(string name, string partitionId, UserCredentials userCredentials = null)
+        {
+            Ensure.NotNullOrEmpty(name, "name");
+            Ensure.NotNullOrEmpty(partitionId, "partitionId");
+            return _client.GetPartitionStateAsync(_httpEndPoint, name, partitionId, userCredentials);
+        }
+
+        /// <summary>
+        /// Asynchronously gets the state of a projection.
+        /// </summary>
+        /// <param name="name">The name of the projection.</param>
+        /// <param name="userCredentials">Credentials for the operation.</param>
+        /// <returns>String of JSON containing projection state.</returns>
+        public Task<string> GetResultAsync(string name, UserCredentials userCredentials = null)
+        {
+            Ensure.NotNullOrEmpty(name, "name");
+            return _client.GetState(_httpEndPoint, name, userCredentials);
+        }
+
+        /// <summary>
+        /// Asynchronously gets the state of a projection for a specified partition.
+        /// </summary>
+        /// <param name="name">The name of the projection.</param>
+        /// <param name="partitionId">The id of the partition.</param>
+        /// <param name="userCredentials">Credentials for the operation.</param>
+        /// <returns>String of JSON containing projection state.</returns>
+        public Task<string> GetPartitionResultAsync(string name, string partitionId, UserCredentials userCredentials = null)
+        {
+            Ensure.NotNullOrEmpty(name, "name");
+            Ensure.NotNullOrEmpty(partitionId, "partitionId");
+            return _client.GetPartitionStateAsync(_httpEndPoint, name, partitionId, userCredentials);
+        }
+
         /// <summary>
         /// Asynchronously gets the statistics of a projection.
         /// </summary>
@@ -242,4 +282,4 @@ public Task DeleteAsync(string name, UserCredentials userCredentials = null)
             return _client.Delete(_httpEndPoint, name, userCredentials);
         }
     }
-}
+}