chore(watchers): fix rpc method name

pereslavtsev · Nov 23, 2021 · 7435f21 · 7435f21
1 parent 1d3ca38
commit 7435f21
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 14 deletions.
diff --git a/.npmrc b/.npmrc
@@ -0,0 +1 @@
+@pereslavtsev:registry=https://npm.pkg.github.com
diff --git a/src/services/watchers/watchers.proto b/src/services/watchers/watchers.proto
@@ -11,7 +11,7 @@ service WatchersService {
   rpc UpdateWatcher (UpdateWatcherRequest) returns (Watcher);
   rpc RunWatcher (GetWatcherRequest) returns (RunWatcherResponse);
   rpc PauseWatcher (GetWatcherRequest) returns (PauseWatcherResponse);
-  rpc PauseAll (PauseAllRequest) returns (PauseAllResponse);
+  rpc PauseAllWatchers (PauseAllWatchersRequest) returns (PauseAllWatchersResponse);
   rpc StopWatcher (GetWatcherRequest) returns (StopWatcherResponse);
   rpc SubscribeWatcher(GetWatcherRequest) returns (stream SubscribeWatcherResponse) {}
 }
@@ -47,12 +47,12 @@ message ListWatchersResponse {
   string next_page_token = 2;
 }
 
-message PauseAllRequest {}
+message PauseAllWatchersRequest {}
 
 message RunWatcherResponse {}
 message PauseWatcherResponse {}
 message StopWatcherResponse {}
-message PauseAllResponse {}
+message PauseAllWatchersResponse {}
 
 message GetWatcherRequest {
   string id = 1;

diff --git a/src/services/watchers/watchers.ts b/src/services/watchers/watchers.ts
@@ -38,15 +38,15 @@ export interface ListWatchersResponse {
   nextPageToken: string;
 }
 
-export interface PauseAllRequest {}
+export interface PauseAllWatchersRequest {}
 
 export interface RunWatcherResponse {}
 
 export interface PauseWatcherResponse {}
 
 export interface StopWatcherResponse {}
 
-export interface PauseAllResponse {}
+export interface PauseAllWatchersResponse {}
 
 export interface GetWatcherRequest {
   id: string;
@@ -110,11 +110,11 @@ export interface WatchersServiceClient {
     ...rest: any
   ): Observable<PauseWatcherResponse>;
 
-  pauseAll(
-    request: PauseAllRequest,
+  pauseAllWatchers(
+    request: PauseAllWatchersRequest,
     metadata: Metadata,
     ...rest: any
-  ): Observable<PauseAllResponse>;
+  ): Observable<PauseAllWatchersResponse>;
 
   stopWatcher(
     request: GetWatcherRequest,
@@ -175,14 +175,14 @@ export interface WatchersServiceController {
     | Observable<PauseWatcherResponse>
     | PauseWatcherResponse;
 
-  pauseAll(
-    request: PauseAllRequest,
+  pauseAllWatchers(
+    request: PauseAllWatchersRequest,
     metadata: Metadata,
     ...rest: any
   ):
-    | Promise<PauseAllResponse>
-    | Observable<PauseAllResponse>
-    | PauseAllResponse;
+    | Promise<PauseAllWatchersResponse>
+    | Observable<PauseAllWatchersResponse>
+    | PauseAllWatchersResponse;
 
   stopWatcher(
     request: GetWatcherRequest,
@@ -209,7 +209,7 @@ export function WatchersServiceControllerMethods() {
       'updateWatcher',
       'runWatcher',
       'pauseWatcher',
-      'pauseAll',
+      'pauseAllWatchers',
       'stopWatcher',
       'subscribeWatcher',
     ];
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		@pereslavtsev:registry=https://npm.pkg.github.com