From 11145914a5fddd1ada06b6a3b938c27b401f7025 Mon Sep 17 00:00:00 2001 From: Shivam Kumar Date: Tue, 30 May 2023 16:32:51 +0530 Subject: [PATCH] updating config API to use v1 endpoint (#496) * updating config API to use v1 endpoint Signed-off-by: Shivam Kumar * using latest runtime rc Signed-off-by: Shivam Kumar --------- Signed-off-by: Shivam Kumar --- .github/workflows/test-e2e.yml | 2 +- src/implementation/Client/GRPCClient/configuration.ts | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/.github/workflows/test-e2e.yml b/.github/workflows/test-e2e.yml index bb2f96c8..576300c9 100644 --- a/.github/workflows/test-e2e.yml +++ b/.github/workflows/test-e2e.yml @@ -36,7 +36,7 @@ jobs: env: GOVER: 1.19 DAPR_CLI_VER: 1.10.0 - DAPR_RUNTIME_VER: 1.10.0 + DAPR_RUNTIME_VER: 1.11.0-rc.5 DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/master/install/install.sh DAPR_CLI_REF: "" DAPR_REF: "" diff --git a/src/implementation/Client/GRPCClient/configuration.ts b/src/implementation/Client/GRPCClient/configuration.ts index 729c4008..932b9fb0 100644 --- a/src/implementation/Client/GRPCClient/configuration.ts +++ b/src/implementation/Client/GRPCClient/configuration.ts @@ -56,7 +56,7 @@ export default class GRPCClientConfiguration implements IClientConfiguration { const client = await this.client.getClient(); return new Promise((resolve, reject) => { - client.getConfigurationAlpha1(msg, metadata, (err, res: GetConfigurationResponse) => { + client.getConfiguration(msg, metadata, (err, res: GetConfigurationResponse) => { if (err) { return reject(err); } @@ -122,7 +122,7 @@ export default class GRPCClientConfiguration implements IClientConfiguration { // and will stay open as long as the client is open // we will thus create a set with our listeners so we don't // break on multi listeners - const stream = client.subscribeConfigurationAlpha1(msg, metadata); + const stream = client.subscribeConfiguration(msg, metadata); let streamId: string; stream.on("data", async (data: SubscribeConfigurationResponse) => { @@ -149,7 +149,7 @@ export default class GRPCClientConfiguration implements IClientConfiguration { req.setStoreName(storeName); req.setId(streamId); - client.unsubscribeConfigurationAlpha1(req, (err, res: UnsubscribeConfigurationResponse) => { + client.unsubscribeConfiguration(req, (err, res: UnsubscribeConfigurationResponse) => { if (err || !res.getOk()) { return reject(res.getMessage()); }