From e3987b7c467284669dfcda3ca34767f0d951a11f Mon Sep 17 00:00:00 2001 From: Deepanshu Agarwal Date: Fri, 13 Oct 2023 13:35:38 +0530 Subject: [PATCH] chore(proto): update protos and point Workflow to beta APIs (#531) * proto updation and beta endpoint for wf http Signed-off-by: Deepanshu Agarwal * lint Signed-off-by: Deepanshu Agarwal --------- Signed-off-by: Deepanshu Agarwal --- scripts/fetch-proto.sh | 2 +- .../Client/HTTPClient/workflow.ts | 14 +- src/proto/dapr/proto/common/v1/common_pb.js | 14 +- .../dapr/proto/internals/v1/apiversion_pb.js | 8 +- .../internals/v1/service_invocation_pb.js | 17 +- .../dapr/proto/internals/v1/status_pb.js | 8 +- .../dapr/proto/operator/v1/operator_pb.js | 8 +- .../dapr/proto/placement/v1/placement.proto | 4 + .../proto/placement/v1/placement_grpc_pb.js | 3 +- .../dapr/proto/placement/v1/placement_pb.d.ts | 6 + .../dapr/proto/placement/v1/placement_pb.js | 79 +- .../dapr/proto/runtime/v1/appcallback_pb.js | 20 +- src/proto/dapr/proto/runtime/v1/dapr.proto | 84 +- .../dapr/proto/runtime/v1/dapr_grpc_pb.d.ts | 119 ++ .../dapr/proto/runtime/v1/dapr_grpc_pb.js | 84 ++ src/proto/dapr/proto/runtime/v1/dapr_pb.d.ts | 108 ++ src/proto/dapr/proto/runtime/v1/dapr_pb.js | 1044 ++++++++++++++++- src/proto/dapr/proto/sentry/v1/sentry.proto | 12 + src/proto/dapr/proto/sentry/v1/sentry_pb.d.ts | 11 + src/proto/dapr/proto/sentry/v1/sentry_pb.js | 51 +- src/proto/google/protobuf/any_pb.js | 8 +- src/proto/google/protobuf/empty_pb.js | 8 +- src/proto/google/protobuf/timestamp_pb.js | 8 +- 23 files changed, 1613 insertions(+), 107 deletions(-) diff --git a/scripts/fetch-proto.sh b/scripts/fetch-proto.sh index c0dd5865..b1ea2553 100755 --- a/scripts/fetch-proto.sh +++ b/scripts/fetch-proto.sh @@ -3,7 +3,7 @@ OS=$(echo `uname`|tr '[:upper:]' '[:lower:]') ARCH=$(uname -m) ORG_NAME="dapr" REPO_NAME="dapr" -BRANCH_NAME="v1.11.0" +BRANCH_NAME="v1.12.0" # Path to store output PATH_ROOT=$(pwd) diff --git a/src/implementation/Client/HTTPClient/workflow.ts b/src/implementation/Client/HTTPClient/workflow.ts index 4cf2d80d..eb6dc906 100644 --- a/src/implementation/Client/HTTPClient/workflow.ts +++ b/src/implementation/Client/HTTPClient/workflow.ts @@ -42,7 +42,7 @@ export default class HTTPClientWorkflow implements IClientWorkflow { try { const result = await this.client.executeWithApiVersion( - "v1.0-alpha1", + "v1.0-beta1", `/workflows/${workflowComponent}/${instanceID}`, { method: "GET" }, ); @@ -97,7 +97,7 @@ export default class HTTPClientWorkflow implements IClientWorkflow { try { await this.client.executeWithApiVersion( - "v1.0-alpha1", + "v1.0-beta1", `/workflows/${workflowComponent}/${workflowName}/start?${queryParams}`, { method: "POST", @@ -139,7 +139,7 @@ export default class HTTPClientWorkflow implements IClientWorkflow { try { await this.client.executeWithApiVersion( - "v1.0-alpha1", + "v1.0-beta1", `/workflows/${workflowComponent}/${instanceId}/raiseEvent/${eventName}`, { method: "POST", @@ -181,11 +181,9 @@ export default class HTTPClientWorkflow implements IClientWorkflow { workflowComponent = workflowComponent ?? HTTPClientWorkflow.DEFAULT_WORKFLOW_COMPONENT; try { - await this.client.executeWithApiVersion( - "v1.0-alpha1", - `/workflows/${workflowComponent}/${instanceId}/${method}`, - { method: "POST" }, - ); + await this.client.executeWithApiVersion("v1.0-beta1", `/workflows/${workflowComponent}/${instanceId}/${method}`, { + method: "POST", + }); } catch (e: any) { this.logger.error(`Error invoking ${method} on workflow instance: ${e.message}`); throw e; diff --git a/src/proto/dapr/proto/common/v1/common_pb.js b/src/proto/dapr/proto/common/v1/common_pb.js index 5831b458..d6c232b1 100644 --- a/src/proto/dapr/proto/common/v1/common_pb.js +++ b/src/proto/dapr/proto/common/v1/common_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); var google_protobuf_any_pb = require('google-protobuf/google/protobuf/any_pb.js'); goog.object.extend(proto, google_protobuf_any_pb); @@ -1278,7 +1284,8 @@ proto.dapr.proto.common.v1.StateItem.prototype.getMetadataMap = function(opt_noL */ proto.dapr.proto.common.v1.StateItem.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; /** @@ -1816,7 +1823,8 @@ proto.dapr.proto.common.v1.ConfigurationItem.prototype.getMetadataMap = function */ proto.dapr.proto.common.v1.ConfigurationItem.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; goog.object.extend(exports, proto.dapr.proto.common.v1); diff --git a/src/proto/dapr/proto/internals/v1/apiversion_pb.js b/src/proto/dapr/proto/internals/v1/apiversion_pb.js index a3e34a30..31dbf02c 100644 --- a/src/proto/dapr/proto/internals/v1/apiversion_pb.js +++ b/src/proto/dapr/proto/internals/v1/apiversion_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); goog.exportSymbol('proto.dapr.proto.internals.v1.APIVersion', null, global); /** diff --git a/src/proto/dapr/proto/internals/v1/service_invocation_pb.js b/src/proto/dapr/proto/internals/v1/service_invocation_pb.js index 853ba867..fc02e78a 100644 --- a/src/proto/dapr/proto/internals/v1/service_invocation_pb.js +++ b/src/proto/dapr/proto/internals/v1/service_invocation_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); var dapr_proto_common_v1_common_pb = require('../../../../dapr/proto/common/v1/common_pb.js'); goog.object.extend(proto, dapr_proto_common_v1_common_pb); @@ -501,7 +507,8 @@ proto.dapr.proto.internals.v1.InternalInvokeRequest.prototype.getMetadataMap = f */ proto.dapr.proto.internals.v1.InternalInvokeRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; /** @@ -784,7 +791,8 @@ proto.dapr.proto.internals.v1.InternalInvokeResponse.prototype.getHeadersMap = f */ proto.dapr.proto.internals.v1.InternalInvokeResponse.prototype.clearHeadersMap = function() { this.getHeadersMap().clear(); - return this;}; + return this; +}; /** @@ -806,7 +814,8 @@ proto.dapr.proto.internals.v1.InternalInvokeResponse.prototype.getTrailersMap = */ proto.dapr.proto.internals.v1.InternalInvokeResponse.prototype.clearTrailersMap = function() { this.getTrailersMap().clear(); - return this;}; + return this; +}; /** diff --git a/src/proto/dapr/proto/internals/v1/status_pb.js b/src/proto/dapr/proto/internals/v1/status_pb.js index e82bc6b0..bb945491 100644 --- a/src/proto/dapr/proto/internals/v1/status_pb.js +++ b/src/proto/dapr/proto/internals/v1/status_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); var google_protobuf_any_pb = require('google-protobuf/google/protobuf/any_pb.js'); goog.object.extend(proto, google_protobuf_any_pb); diff --git a/src/proto/dapr/proto/operator/v1/operator_pb.js b/src/proto/dapr/proto/operator/v1/operator_pb.js index 81a72590..dd3a4db4 100644 --- a/src/proto/dapr/proto/operator/v1/operator_pb.js +++ b/src/proto/dapr/proto/operator/v1/operator_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); var google_protobuf_empty_pb = require('google-protobuf/google/protobuf/empty_pb.js'); goog.object.extend(proto, google_protobuf_empty_pb); diff --git a/src/proto/dapr/proto/placement/v1/placement.proto b/src/proto/dapr/proto/placement/v1/placement.proto index 8d99d53b..91de9a3c 100644 --- a/src/proto/dapr/proto/placement/v1/placement.proto +++ b/src/proto/dapr/proto/placement/v1/placement.proto @@ -19,6 +19,7 @@ option go_package = "github.com/dapr/dapr/pkg/proto/placement/v1;placement"; // Placement service is used to report Dapr runtime host status. service Placement { + // Reports Dapr actor status and retrieves actor placement table. rpc ReportDaprStatus(stream Host) returns (stream PlacementOrder) {} } @@ -45,4 +46,7 @@ message Host { int64 load = 3; repeated string entities = 4; string id = 5; + string pod = 6; + // Version of the Actor APIs supported by the Dapr runtime + uint32 api_level = 7; } diff --git a/src/proto/dapr/proto/placement/v1/placement_grpc_pb.js b/src/proto/dapr/proto/placement/v1/placement_grpc_pb.js index 18b8637b..3bc7ac5d 100644 --- a/src/proto/dapr/proto/placement/v1/placement_grpc_pb.js +++ b/src/proto/dapr/proto/placement/v1/placement_grpc_pb.js @@ -42,7 +42,8 @@ function deserialize_dapr_proto_placement_v1_PlacementOrder(buffer_arg) { // Placement service is used to report Dapr runtime host status. var PlacementService = exports.PlacementService = { - reportDaprStatus: { + // Reports Dapr actor status and retrieves actor placement table. +reportDaprStatus: { path: '/dapr.proto.placement.v1.Placement/ReportDaprStatus', requestStream: true, responseStream: true, diff --git a/src/proto/dapr/proto/placement/v1/placement_pb.d.ts b/src/proto/dapr/proto/placement/v1/placement_pb.d.ts index 96cb2f15..e40cb57c 100644 --- a/src/proto/dapr/proto/placement/v1/placement_pb.d.ts +++ b/src/proto/dapr/proto/placement/v1/placement_pb.d.ts @@ -105,6 +105,10 @@ export class Host extends jspb.Message { addEntities(value: string, index?: number): string; getId(): string; setId(value: string): Host; + getPod(): string; + setPod(value: string): Host; + getApiLevel(): number; + setApiLevel(value: number): Host; serializeBinary(): Uint8Array; toObject(includeInstance?: boolean): Host.AsObject; @@ -123,5 +127,7 @@ export namespace Host { load: number, entitiesList: Array, id: string, + pod: string, + apiLevel: number, } } diff --git a/src/proto/dapr/proto/placement/v1/placement_pb.js b/src/proto/dapr/proto/placement/v1/placement_pb.js index c983eb16..43aa0dcc 100644 --- a/src/proto/dapr/proto/placement/v1/placement_pb.js +++ b/src/proto/dapr/proto/placement/v1/placement_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); goog.exportSymbol('proto.dapr.proto.placement.v1.Host', null, global); goog.exportSymbol('proto.dapr.proto.placement.v1.PlacementOrder', null, global); @@ -426,7 +432,8 @@ proto.dapr.proto.placement.v1.PlacementTables.prototype.getEntriesMap = function */ proto.dapr.proto.placement.v1.PlacementTables.prototype.clearEntriesMap = function() { this.getEntriesMap().clear(); - return this;}; + return this; +}; /** @@ -621,7 +628,8 @@ proto.dapr.proto.placement.v1.PlacementTable.prototype.getHostsMap = function(op */ proto.dapr.proto.placement.v1.PlacementTable.prototype.clearHostsMap = function() { this.getHostsMap().clear(); - return this;}; + return this; +}; /** @@ -680,7 +688,8 @@ proto.dapr.proto.placement.v1.PlacementTable.prototype.getLoadMapMap = function( */ proto.dapr.proto.placement.v1.PlacementTable.prototype.clearLoadMapMap = function() { this.getLoadMapMap().clear(); - return this;}; + return this; +}; /** @@ -744,7 +753,9 @@ proto.dapr.proto.placement.v1.Host.toObject = function(includeInstance, msg) { port: jspb.Message.getFieldWithDefault(msg, 2, 0), load: jspb.Message.getFieldWithDefault(msg, 3, 0), entitiesList: (f = jspb.Message.getRepeatedField(msg, 4)) == null ? undefined : f, - id: jspb.Message.getFieldWithDefault(msg, 5, "") + id: jspb.Message.getFieldWithDefault(msg, 5, ""), + pod: jspb.Message.getFieldWithDefault(msg, 6, ""), + apiLevel: jspb.Message.getFieldWithDefault(msg, 7, 0) }; if (includeInstance) { @@ -801,6 +812,14 @@ proto.dapr.proto.placement.v1.Host.deserializeBinaryFromReader = function(msg, r var value = /** @type {string} */ (reader.readString()); msg.setId(value); break; + case 6: + var value = /** @type {string} */ (reader.readString()); + msg.setPod(value); + break; + case 7: + var value = /** @type {number} */ (reader.readUint32()); + msg.setApiLevel(value); + break; default: reader.skipField(); break; @@ -865,6 +884,20 @@ proto.dapr.proto.placement.v1.Host.serializeBinaryToWriter = function(message, w f ); } + f = message.getPod(); + if (f.length > 0) { + writer.writeString( + 6, + f + ); + } + f = message.getApiLevel(); + if (f !== 0) { + writer.writeUint32( + 7, + f + ); + } }; @@ -977,4 +1010,40 @@ proto.dapr.proto.placement.v1.Host.prototype.setId = function(value) { }; +/** + * optional string pod = 6; + * @return {string} + */ +proto.dapr.proto.placement.v1.Host.prototype.getPod = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 6, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.placement.v1.Host} returns this + */ +proto.dapr.proto.placement.v1.Host.prototype.setPod = function(value) { + return jspb.Message.setProto3StringField(this, 6, value); +}; + + +/** + * optional uint32 api_level = 7; + * @return {number} + */ +proto.dapr.proto.placement.v1.Host.prototype.getApiLevel = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 7, 0)); +}; + + +/** + * @param {number} value + * @return {!proto.dapr.proto.placement.v1.Host} returns this + */ +proto.dapr.proto.placement.v1.Host.prototype.setApiLevel = function(value) { + return jspb.Message.setProto3IntField(this, 7, value); +}; + + goog.object.extend(exports, proto.dapr.proto.placement.v1); diff --git a/src/proto/dapr/proto/runtime/v1/appcallback_pb.js b/src/proto/dapr/proto/runtime/v1/appcallback_pb.js index 916bed5d..d18dbd9b 100644 --- a/src/proto/dapr/proto/runtime/v1/appcallback_pb.js +++ b/src/proto/dapr/proto/runtime/v1/appcallback_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); var google_protobuf_empty_pb = require('google-protobuf/google/protobuf/empty_pb.js'); goog.object.extend(proto, google_protobuf_empty_pb); @@ -1654,7 +1660,8 @@ proto.dapr.proto.runtime.v1.TopicEventBulkRequestEntry.prototype.getMetadataMap */ proto.dapr.proto.runtime.v1.TopicEventBulkRequestEntry.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -1925,7 +1932,8 @@ proto.dapr.proto.runtime.v1.TopicEventBulkRequest.prototype.getMetadataMap = fun */ proto.dapr.proto.runtime.v1.TopicEventBulkRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; /** @@ -2534,7 +2542,8 @@ proto.dapr.proto.runtime.v1.BindingEventRequest.prototype.getMetadataMap = funct */ proto.dapr.proto.runtime.v1.BindingEventRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -3258,7 +3267,8 @@ proto.dapr.proto.runtime.v1.TopicSubscription.prototype.getMetadataMap = functio */ proto.dapr.proto.runtime.v1.TopicSubscription.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; /** diff --git a/src/proto/dapr/proto/runtime/v1/dapr.proto b/src/proto/dapr/proto/runtime/v1/dapr.proto index c6ca4054..eafb5452 100644 --- a/src/proto/dapr/proto/runtime/v1/dapr.proto +++ b/src/proto/dapr/proto/runtime/v1/dapr.proto @@ -169,6 +169,26 @@ service Dapr { // Raise an event to a running workflow instance rpc RaiseEventWorkflowAlpha1 (RaiseEventWorkflowRequest) returns (google.protobuf.Empty) {} + // Starts a new instance of a workflow + rpc StartWorkflowBeta1 (StartWorkflowRequest) returns (StartWorkflowResponse) {} + + // Gets details about a started workflow instance + rpc GetWorkflowBeta1 (GetWorkflowRequest) returns (GetWorkflowResponse) {} + + // Purge Workflow + rpc PurgeWorkflowBeta1 (PurgeWorkflowRequest) returns (google.protobuf.Empty) {} + + // Terminates a running workflow instance + rpc TerminateWorkflowBeta1 (TerminateWorkflowRequest) returns (google.protobuf.Empty) {} + + // Pauses a running workflow instance + rpc PauseWorkflowBeta1 (PauseWorkflowRequest) returns (google.protobuf.Empty) {} + + // Resumes a paused workflow instance + rpc ResumeWorkflowBeta1 (ResumeWorkflowRequest) returns (google.protobuf.Empty) {} + + // Raise an event to a running workflow instance + rpc RaiseEventWorkflowBeta1 (RaiseEventWorkflowRequest) returns (google.protobuf.Empty) {} // Shutdown the sidecar rpc Shutdown (google.protobuf.Empty) returns (google.protobuf.Empty) {} } @@ -542,6 +562,9 @@ message GetActorStateRequest { // GetActorStateResponse is the response conveying the actor's state value. message GetActorStateResponse { bytes data = 1; + + // The metadata which will be sent to app. + map metadata = 2; } // ExecuteActorStateTransactionRequest is the message to execute multiple operations on a specified actor. @@ -580,10 +603,14 @@ message InvokeActorResponse { // GetMetadataResponse is a message that is returned on GetMetadata rpc call message GetMetadataResponse { string id = 1; - repeated ActiveActorsCount active_actors_count = 2; - repeated RegisteredComponents registered_components = 3; - map extended_metadata = 4; - repeated PubsubSubscription subscriptions = 5; + repeated ActiveActorsCount active_actors_count = 2 [json_name = "actors"]; + repeated RegisteredComponents registered_components = 3 [json_name = "components"]; + map extended_metadata = 4 [json_name = "extended"]; + repeated PubsubSubscription subscriptions = 5 [json_name = "subscriptions"]; + repeated MetadataHTTPEndpoint http_endpoints = 6 [json_name = "httpEndpoints"]; + AppConnectionProperties app_connection_properties = 7 [json_name = "appConnectionProperties"]; + string runtime_version = 8 [json_name = "runtimeVersion"]; + repeated string enabled_features = 9 [json_name = "enabledFeatures"]; } message ActiveActorsCount { @@ -598,12 +625,31 @@ message RegisteredComponents { repeated string capabilities = 4; } +message MetadataHTTPEndpoint { + string name = 1 [json_name = "name"]; +} + +message AppConnectionProperties { + int32 port = 1; + string protocol = 2; + string channel_address = 3 [json_name = "channelAddress"]; + int32 max_concurrency = 4 [json_name = "maxConcurrency"]; + AppConnectionHealthProperties health = 5; +} + +message AppConnectionHealthProperties { + string health_check_path = 1 [json_name = "healthCheckPath"]; + string health_probe_interval = 2 [json_name = "healthProbeInterval"]; + string health_probe_timeout = 3 [json_name = "healthProbeTimeout"]; + int32 health_threshold = 4 [json_name = "healthThreshold"]; +} + message PubsubSubscription { - string pubsub_name = 1; - string topic = 2; - map metadata = 3; - PubsubSubscriptionRules rules = 4; - string dead_letter_topic = 5; + string pubsub_name = 1 [json_name = "pubsubname"]; + string topic = 2 [json_name = "topic"]; + map metadata = 3 [json_name = "metadata"]; + PubsubSubscriptionRules rules = 4 [json_name = "rules"]; + string dead_letter_topic = 5 [json_name = "deadLetterTopic"]; } message PubsubSubscriptionRules { @@ -955,7 +1001,7 @@ message DecryptResponse { common.v1.StreamPayload payload = 1; } -// GetWorkflowRequest is the request for GetWorkflowAlpha1. +// GetWorkflowRequest is the request for GetWorkflowBeta1. message GetWorkflowRequest { // ID of the workflow instance to query. string instance_id = 1 [json_name = "instanceID"]; @@ -963,7 +1009,7 @@ message GetWorkflowRequest { string workflow_component = 2 [json_name = "workflowComponent"]; } -// GetWorkflowResponse is the response for GetWorkflowAlpha1. +// GetWorkflowResponse is the response for GetWorkflowBeta1. message GetWorkflowResponse { // ID of the workflow instance. string instance_id = 1 [json_name = "instanceID"]; @@ -979,7 +1025,7 @@ message GetWorkflowResponse { map properties = 6; } -// StartWorkflowRequest is the request for StartWorkflowAlpha1. +// StartWorkflowRequest is the request for StartWorkflowBeta1. message StartWorkflowRequest { // The ID to assign to the started workflow instance. If empty, a random ID is generated. string instance_id = 1 [json_name = "instanceID"]; @@ -993,13 +1039,13 @@ message StartWorkflowRequest { bytes input = 5; } -// StartWorkflowResponse is the response for StartWorkflowAlpha1. +// StartWorkflowResponse is the response for StartWorkflowBeta1. message StartWorkflowResponse { // ID of the started workflow instance. string instance_id = 1 [json_name = "instanceID"]; } -// TerminateWorkflowRequest is the request for TerminateWorkflowAlpha1. +// TerminateWorkflowRequest is the request for TerminateWorkflowBeta1. message TerminateWorkflowRequest { // ID of the workflow instance to terminate. string instance_id = 1 [json_name = "instanceID"]; @@ -1007,7 +1053,7 @@ message TerminateWorkflowRequest { string workflow_component = 2 [json_name = "workflowComponent"]; } -// PauseWorkflowRequest is the request for PauseWorkflowAlpha1. +// PauseWorkflowRequest is the request for PauseWorkflowBeta1. message PauseWorkflowRequest { // ID of the workflow instance to pause. string instance_id = 1 [json_name = "instanceID"]; @@ -1015,7 +1061,7 @@ message PauseWorkflowRequest { string workflow_component = 2 [json_name = "workflowComponent"]; } -// ResumeWorkflowRequest is the request for ResumeWorkflowAlpha1. +// ResumeWorkflowRequest is the request for ResumeWorkflowBeta1. message ResumeWorkflowRequest { // ID of the workflow instance to resume. string instance_id = 1 [json_name = "instanceID"]; @@ -1023,7 +1069,7 @@ message ResumeWorkflowRequest { string workflow_component = 2 [json_name = "workflowComponent"]; } -// RaiseEventWorkflowRequest is the request for RaiseEventWorkflowAlpha1. +// RaiseEventWorkflowRequest is the request for RaiseEventWorkflowBeta1. message RaiseEventWorkflowRequest { // ID of the workflow instance to raise an event for. string instance_id = 1 [json_name = "instanceID"]; @@ -1035,10 +1081,10 @@ message RaiseEventWorkflowRequest { bytes event_data = 4; } -// PurgeWorkflowRequest is the request for PurgeWorkflowAlpha1. +// PurgeWorkflowRequest is the request for PurgeWorkflowBeta1. message PurgeWorkflowRequest { // ID of the workflow instance to purge. string instance_id = 1 [json_name = "instanceID"]; // Name of the workflow component. string workflow_component = 2 [json_name = "workflowComponent"]; -} \ No newline at end of file +} diff --git a/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts b/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts index 1cc956b8..8db7e693 100644 --- a/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts +++ b/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts @@ -59,6 +59,13 @@ interface IDaprService extends grpc.ServiceDefinition; responseDeserialize: grpc.deserialize; } +interface IDaprService_IStartWorkflowBeta1 extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/StartWorkflowBeta1"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} +interface IDaprService_IGetWorkflowBeta1 extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/GetWorkflowBeta1"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} +interface IDaprService_IPurgeWorkflowBeta1 extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/PurgeWorkflowBeta1"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} +interface IDaprService_ITerminateWorkflowBeta1 extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/TerminateWorkflowBeta1"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} +interface IDaprService_IPauseWorkflowBeta1 extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/PauseWorkflowBeta1"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} +interface IDaprService_IResumeWorkflowBeta1 extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/ResumeWorkflowBeta1"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} +interface IDaprService_IRaiseEventWorkflowBeta1 extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/RaiseEventWorkflowBeta1"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} interface IDaprService_IShutdown extends grpc.MethodDefinition { path: "/dapr.proto.runtime.v1.Dapr/Shutdown"; requestStream: false; @@ -545,6 +615,13 @@ export interface IDaprServer extends grpc.UntypedServiceImplementation { pauseWorkflowAlpha1: grpc.handleUnaryCall; resumeWorkflowAlpha1: grpc.handleUnaryCall; raiseEventWorkflowAlpha1: grpc.handleUnaryCall; + startWorkflowBeta1: grpc.handleUnaryCall; + getWorkflowBeta1: grpc.handleUnaryCall; + purgeWorkflowBeta1: grpc.handleUnaryCall; + terminateWorkflowBeta1: grpc.handleUnaryCall; + pauseWorkflowBeta1: grpc.handleUnaryCall; + resumeWorkflowBeta1: grpc.handleUnaryCall; + raiseEventWorkflowBeta1: grpc.handleUnaryCall; shutdown: grpc.handleUnaryCall; } @@ -688,6 +765,27 @@ export interface IDaprClient { raiseEventWorkflowAlpha1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; raiseEventWorkflowAlpha1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; raiseEventWorkflowAlpha1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + startWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.StartWorkflowRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.StartWorkflowResponse) => void): grpc.ClientUnaryCall; + startWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.StartWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.StartWorkflowResponse) => void): grpc.ClientUnaryCall; + startWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.StartWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.StartWorkflowResponse) => void): grpc.ClientUnaryCall; + getWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.GetWorkflowRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetWorkflowResponse) => void): grpc.ClientUnaryCall; + getWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.GetWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetWorkflowResponse) => void): grpc.ClientUnaryCall; + getWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.GetWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetWorkflowResponse) => void): grpc.ClientUnaryCall; + purgeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PurgeWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + purgeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PurgeWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + purgeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PurgeWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + terminateWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.TerminateWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + terminateWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.TerminateWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + terminateWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.TerminateWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + pauseWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PauseWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + pauseWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PauseWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + pauseWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PauseWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + resumeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.ResumeWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + resumeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.ResumeWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + resumeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.ResumeWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + raiseEventWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + raiseEventWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + raiseEventWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; shutdown(request: google_protobuf_empty_pb.Empty, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; shutdown(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; shutdown(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; @@ -832,6 +930,27 @@ export class DaprClient extends grpc.Client implements IDaprClient { public raiseEventWorkflowAlpha1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public raiseEventWorkflowAlpha1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public raiseEventWorkflowAlpha1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public startWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.StartWorkflowRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.StartWorkflowResponse) => void): grpc.ClientUnaryCall; + public startWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.StartWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.StartWorkflowResponse) => void): grpc.ClientUnaryCall; + public startWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.StartWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.StartWorkflowResponse) => void): grpc.ClientUnaryCall; + public getWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.GetWorkflowRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetWorkflowResponse) => void): grpc.ClientUnaryCall; + public getWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.GetWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetWorkflowResponse) => void): grpc.ClientUnaryCall; + public getWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.GetWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetWorkflowResponse) => void): grpc.ClientUnaryCall; + public purgeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PurgeWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public purgeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PurgeWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public purgeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PurgeWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public terminateWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.TerminateWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public terminateWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.TerminateWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public terminateWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.TerminateWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public pauseWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PauseWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public pauseWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PauseWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public pauseWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.PauseWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public resumeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.ResumeWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public resumeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.ResumeWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public resumeWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.ResumeWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public raiseEventWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public raiseEventWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public raiseEventWorkflowBeta1(request: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public shutdown(request: google_protobuf_empty_pb.Empty, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public shutdown(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public shutdown(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; diff --git a/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.js b/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.js index edfd0001..15a2bf77 100644 --- a/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.js +++ b/src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.js @@ -1370,6 +1370,90 @@ raiseEventWorkflowAlpha1: { responseSerialize: serialize_google_protobuf_Empty, responseDeserialize: deserialize_google_protobuf_Empty, }, + // Starts a new instance of a workflow +startWorkflowBeta1: { + path: '/dapr.proto.runtime.v1.Dapr/StartWorkflowBeta1', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.StartWorkflowRequest, + responseType: dapr_proto_runtime_v1_dapr_pb.StartWorkflowResponse, + requestSerialize: serialize_dapr_proto_runtime_v1_StartWorkflowRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_StartWorkflowRequest, + responseSerialize: serialize_dapr_proto_runtime_v1_StartWorkflowResponse, + responseDeserialize: deserialize_dapr_proto_runtime_v1_StartWorkflowResponse, + }, + // Gets details about a started workflow instance +getWorkflowBeta1: { + path: '/dapr.proto.runtime.v1.Dapr/GetWorkflowBeta1', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.GetWorkflowRequest, + responseType: dapr_proto_runtime_v1_dapr_pb.GetWorkflowResponse, + requestSerialize: serialize_dapr_proto_runtime_v1_GetWorkflowRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_GetWorkflowRequest, + responseSerialize: serialize_dapr_proto_runtime_v1_GetWorkflowResponse, + responseDeserialize: deserialize_dapr_proto_runtime_v1_GetWorkflowResponse, + }, + // Purge Workflow +purgeWorkflowBeta1: { + path: '/dapr.proto.runtime.v1.Dapr/PurgeWorkflowBeta1', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.PurgeWorkflowRequest, + responseType: google_protobuf_empty_pb.Empty, + requestSerialize: serialize_dapr_proto_runtime_v1_PurgeWorkflowRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_PurgeWorkflowRequest, + responseSerialize: serialize_google_protobuf_Empty, + responseDeserialize: deserialize_google_protobuf_Empty, + }, + // Terminates a running workflow instance +terminateWorkflowBeta1: { + path: '/dapr.proto.runtime.v1.Dapr/TerminateWorkflowBeta1', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.TerminateWorkflowRequest, + responseType: google_protobuf_empty_pb.Empty, + requestSerialize: serialize_dapr_proto_runtime_v1_TerminateWorkflowRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_TerminateWorkflowRequest, + responseSerialize: serialize_google_protobuf_Empty, + responseDeserialize: deserialize_google_protobuf_Empty, + }, + // Pauses a running workflow instance +pauseWorkflowBeta1: { + path: '/dapr.proto.runtime.v1.Dapr/PauseWorkflowBeta1', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.PauseWorkflowRequest, + responseType: google_protobuf_empty_pb.Empty, + requestSerialize: serialize_dapr_proto_runtime_v1_PauseWorkflowRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_PauseWorkflowRequest, + responseSerialize: serialize_google_protobuf_Empty, + responseDeserialize: deserialize_google_protobuf_Empty, + }, + // Resumes a paused workflow instance +resumeWorkflowBeta1: { + path: '/dapr.proto.runtime.v1.Dapr/ResumeWorkflowBeta1', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.ResumeWorkflowRequest, + responseType: google_protobuf_empty_pb.Empty, + requestSerialize: serialize_dapr_proto_runtime_v1_ResumeWorkflowRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_ResumeWorkflowRequest, + responseSerialize: serialize_google_protobuf_Empty, + responseDeserialize: deserialize_google_protobuf_Empty, + }, + // Raise an event to a running workflow instance +raiseEventWorkflowBeta1: { + path: '/dapr.proto.runtime.v1.Dapr/RaiseEventWorkflowBeta1', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.RaiseEventWorkflowRequest, + responseType: google_protobuf_empty_pb.Empty, + requestSerialize: serialize_dapr_proto_runtime_v1_RaiseEventWorkflowRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_RaiseEventWorkflowRequest, + responseSerialize: serialize_google_protobuf_Empty, + responseDeserialize: deserialize_google_protobuf_Empty, + }, // Shutdown the sidecar shutdown: { path: '/dapr.proto.runtime.v1.Dapr/Shutdown', diff --git a/src/proto/dapr/proto/runtime/v1/dapr_pb.d.ts b/src/proto/dapr/proto/runtime/v1/dapr_pb.d.ts index 3695c3b2..e9411fc7 100644 --- a/src/proto/dapr/proto/runtime/v1/dapr_pb.d.ts +++ b/src/proto/dapr/proto/runtime/v1/dapr_pb.d.ts @@ -945,6 +945,9 @@ export class GetActorStateResponse extends jspb.Message { getData_asB64(): string; setData(value: Uint8Array | string): GetActorStateResponse; + getMetadataMap(): jspb.Map; + clearMetadataMap(): void; + serializeBinary(): Uint8Array; toObject(includeInstance?: boolean): GetActorStateResponse.AsObject; static toObject(includeInstance: boolean, msg: GetActorStateResponse): GetActorStateResponse.AsObject; @@ -958,6 +961,8 @@ export class GetActorStateResponse extends jspb.Message { export namespace GetActorStateResponse { export type AsObject = { data: Uint8Array | string, + + metadataMap: Array<[string, string]>, } } @@ -1099,6 +1104,21 @@ export class GetMetadataResponse extends jspb.Message { getSubscriptionsList(): Array; setSubscriptionsList(value: Array): GetMetadataResponse; addSubscriptions(value?: PubsubSubscription, index?: number): PubsubSubscription; + clearHttpEndpointsList(): void; + getHttpEndpointsList(): Array; + setHttpEndpointsList(value: Array): GetMetadataResponse; + addHttpEndpoints(value?: MetadataHTTPEndpoint, index?: number): MetadataHTTPEndpoint; + + hasAppConnectionProperties(): boolean; + clearAppConnectionProperties(): void; + getAppConnectionProperties(): AppConnectionProperties | undefined; + setAppConnectionProperties(value?: AppConnectionProperties): GetMetadataResponse; + getRuntimeVersion(): string; + setRuntimeVersion(value: string): GetMetadataResponse; + clearEnabledFeaturesList(): void; + getEnabledFeaturesList(): Array; + setEnabledFeaturesList(value: Array): GetMetadataResponse; + addEnabledFeatures(value: string, index?: number): string; serializeBinary(): Uint8Array; toObject(includeInstance?: boolean): GetMetadataResponse.AsObject; @@ -1118,6 +1138,10 @@ export namespace GetMetadataResponse { extendedMetadataMap: Array<[string, string]>, subscriptionsList: Array, + httpEndpointsList: Array, + appConnectionProperties?: AppConnectionProperties.AsObject, + runtimeVersion: string, + enabledFeaturesList: Array, } } @@ -1175,6 +1199,90 @@ export namespace RegisteredComponents { } } +export class MetadataHTTPEndpoint extends jspb.Message { + getName(): string; + setName(value: string): MetadataHTTPEndpoint; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): MetadataHTTPEndpoint.AsObject; + static toObject(includeInstance: boolean, msg: MetadataHTTPEndpoint): MetadataHTTPEndpoint.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: MetadataHTTPEndpoint, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): MetadataHTTPEndpoint; + static deserializeBinaryFromReader(message: MetadataHTTPEndpoint, reader: jspb.BinaryReader): MetadataHTTPEndpoint; +} + +export namespace MetadataHTTPEndpoint { + export type AsObject = { + name: string, + } +} + +export class AppConnectionProperties extends jspb.Message { + getPort(): number; + setPort(value: number): AppConnectionProperties; + getProtocol(): string; + setProtocol(value: string): AppConnectionProperties; + getChannelAddress(): string; + setChannelAddress(value: string): AppConnectionProperties; + getMaxConcurrency(): number; + setMaxConcurrency(value: number): AppConnectionProperties; + + hasHealth(): boolean; + clearHealth(): void; + getHealth(): AppConnectionHealthProperties | undefined; + setHealth(value?: AppConnectionHealthProperties): AppConnectionProperties; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): AppConnectionProperties.AsObject; + static toObject(includeInstance: boolean, msg: AppConnectionProperties): AppConnectionProperties.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: AppConnectionProperties, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): AppConnectionProperties; + static deserializeBinaryFromReader(message: AppConnectionProperties, reader: jspb.BinaryReader): AppConnectionProperties; +} + +export namespace AppConnectionProperties { + export type AsObject = { + port: number, + protocol: string, + channelAddress: string, + maxConcurrency: number, + health?: AppConnectionHealthProperties.AsObject, + } +} + +export class AppConnectionHealthProperties extends jspb.Message { + getHealthCheckPath(): string; + setHealthCheckPath(value: string): AppConnectionHealthProperties; + getHealthProbeInterval(): string; + setHealthProbeInterval(value: string): AppConnectionHealthProperties; + getHealthProbeTimeout(): string; + setHealthProbeTimeout(value: string): AppConnectionHealthProperties; + getHealthThreshold(): number; + setHealthThreshold(value: number): AppConnectionHealthProperties; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): AppConnectionHealthProperties.AsObject; + static toObject(includeInstance: boolean, msg: AppConnectionHealthProperties): AppConnectionHealthProperties.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: AppConnectionHealthProperties, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): AppConnectionHealthProperties; + static deserializeBinaryFromReader(message: AppConnectionHealthProperties, reader: jspb.BinaryReader): AppConnectionHealthProperties; +} + +export namespace AppConnectionHealthProperties { + export type AsObject = { + healthCheckPath: string, + healthProbeInterval: string, + healthProbeTimeout: string, + healthThreshold: number, + } +} + export class PubsubSubscription extends jspb.Message { getPubsubName(): string; setPubsubName(value: string): PubsubSubscription; diff --git a/src/proto/dapr/proto/runtime/v1/dapr_pb.js b/src/proto/dapr/proto/runtime/v1/dapr_pb.js index b56cca9f..eeb8a307 100644 --- a/src/proto/dapr/proto/runtime/v1/dapr_pb.js +++ b/src/proto/dapr/proto/runtime/v1/dapr_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); var google_protobuf_any_pb = require('google-protobuf/google/protobuf/any_pb.js'); goog.object.extend(proto, google_protobuf_any_pb); @@ -24,6 +30,8 @@ goog.object.extend(proto, google_protobuf_timestamp_pb); var dapr_proto_common_v1_common_pb = require('../../../../dapr/proto/common/v1/common_pb.js'); goog.object.extend(proto, dapr_proto_common_v1_common_pb); goog.exportSymbol('proto.dapr.proto.runtime.v1.ActiveActorsCount', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.AppConnectionHealthProperties', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.AppConnectionProperties', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.BulkPublishRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.BulkPublishRequestEntry', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.BulkPublishResponse', null, global); @@ -59,6 +67,7 @@ goog.exportSymbol('proto.dapr.proto.runtime.v1.InvokeActorResponse', null, globa goog.exportSymbol('proto.dapr.proto.runtime.v1.InvokeBindingRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.InvokeBindingResponse', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.InvokeServiceRequest', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.PauseWorkflowRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.PublishEventRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.PubsubSubscription', null, global); @@ -948,6 +957,69 @@ if (goog.DEBUG && !COMPILED) { */ proto.dapr.proto.runtime.v1.RegisteredComponents.displayName = 'proto.dapr.proto.runtime.v1.RegisteredComponents'; } +/** + * Generated by JsPbCodeGenerator. + * @param {Array=} opt_data Optional initial data array, typically from a + * server response, or constructed directly in Javascript. The array is used + * in place and becomes part of the constructed object. It is not cloned. + * If no data is provided, the constructed object will be empty, but still + * valid. + * @extends {jspb.Message} + * @constructor + */ +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.displayName = 'proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint'; +} +/** + * Generated by JsPbCodeGenerator. + * @param {Array=} opt_data Optional initial data array, typically from a + * server response, or constructed directly in Javascript. The array is used + * in place and becomes part of the constructed object. It is not cloned. + * If no data is provided, the constructed object will be empty, but still + * valid. + * @extends {jspb.Message} + * @constructor + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.AppConnectionProperties, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.AppConnectionProperties.displayName = 'proto.dapr.proto.runtime.v1.AppConnectionProperties'; +} +/** + * Generated by JsPbCodeGenerator. + * @param {Array=} opt_data Optional initial data array, typically from a + * server response, or constructed directly in Javascript. The array is used + * in place and becomes part of the constructed object. It is not cloned. + * If no data is provided, the constructed object will be empty, but still + * valid. + * @extends {jspb.Message} + * @constructor + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.AppConnectionHealthProperties, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.displayName = 'proto.dapr.proto.runtime.v1.AppConnectionHealthProperties'; +} /** * Generated by JsPbCodeGenerator. * @param {Array=} opt_data Optional initial data array, typically from a @@ -2252,7 +2324,8 @@ proto.dapr.proto.runtime.v1.GetStateRequest.prototype.getMetadataMap = function( */ proto.dapr.proto.runtime.v1.GetStateRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -2501,7 +2574,8 @@ proto.dapr.proto.runtime.v1.GetBulkStateRequest.prototype.getMetadataMap = funct */ proto.dapr.proto.runtime.v1.GetBulkStateRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -2938,7 +3012,8 @@ proto.dapr.proto.runtime.v1.BulkStateItem.prototype.getMetadataMap = function(op */ proto.dapr.proto.runtime.v1.BulkStateItem.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -3155,7 +3230,8 @@ proto.dapr.proto.runtime.v1.GetStateResponse.prototype.getMetadataMap = function */ proto.dapr.proto.runtime.v1.GetStateResponse.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -3450,7 +3526,8 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.getMetadataMap = functi */ proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -4023,7 +4100,8 @@ proto.dapr.proto.runtime.v1.QueryStateRequest.prototype.getMetadataMap = functio */ proto.dapr.proto.runtime.v1.QueryStateRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -4490,7 +4568,8 @@ proto.dapr.proto.runtime.v1.QueryStateResponse.prototype.getMetadataMap = functi */ proto.dapr.proto.runtime.v1.QueryStateResponse.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -4767,7 +4846,8 @@ proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.getMetadataMap = funct */ proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -5020,7 +5100,8 @@ proto.dapr.proto.runtime.v1.BulkPublishRequest.prototype.getMetadataMap = functi */ proto.dapr.proto.runtime.v1.BulkPublishRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -5267,7 +5348,8 @@ proto.dapr.proto.runtime.v1.BulkPublishRequestEntry.prototype.getMetadataMap = f */ proto.dapr.proto.runtime.v1.BulkPublishRequestEntry.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -5816,7 +5898,8 @@ proto.dapr.proto.runtime.v1.InvokeBindingRequest.prototype.getMetadataMap = func */ proto.dapr.proto.runtime.v1.InvokeBindingRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; /** @@ -6021,7 +6104,8 @@ proto.dapr.proto.runtime.v1.InvokeBindingResponse.prototype.getMetadataMap = fun */ proto.dapr.proto.runtime.v1.InvokeBindingResponse.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -6214,7 +6298,8 @@ proto.dapr.proto.runtime.v1.GetSecretRequest.prototype.getMetadataMap = function */ proto.dapr.proto.runtime.v1.GetSecretRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -6347,7 +6432,8 @@ proto.dapr.proto.runtime.v1.GetSecretResponse.prototype.getDataMap = function(op */ proto.dapr.proto.runtime.v1.GetSecretResponse.prototype.clearDataMap = function() { this.getDataMap().clear(); - return this;}; + return this; +}; @@ -6510,7 +6596,8 @@ proto.dapr.proto.runtime.v1.GetBulkSecretRequest.prototype.getMetadataMap = func */ proto.dapr.proto.runtime.v1.GetBulkSecretRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -6643,7 +6730,8 @@ proto.dapr.proto.runtime.v1.SecretResponse.prototype.getSecretsMap = function(op */ proto.dapr.proto.runtime.v1.SecretResponse.prototype.clearSecretsMap = function() { this.getSecretsMap().clear(); - return this;}; + return this; +}; @@ -6776,7 +6864,8 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.getDataMap = functio */ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.clearDataMap = function() { this.getDataMap().clear(); - return this;}; + return this; +}; @@ -7180,7 +7269,8 @@ proto.dapr.proto.runtime.v1.ExecuteStateTransactionRequest.prototype.getMetadata */ proto.dapr.proto.runtime.v1.ExecuteStateTransactionRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -8703,7 +8793,8 @@ proto.dapr.proto.runtime.v1.GetActorStateResponse.prototype.toObject = function( */ proto.dapr.proto.runtime.v1.GetActorStateResponse.toObject = function(includeInstance, msg) { var f, obj = { - data: msg.getData_asB64() + data: msg.getData_asB64(), + metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : [] }; if (includeInstance) { @@ -8744,6 +8835,12 @@ proto.dapr.proto.runtime.v1.GetActorStateResponse.deserializeBinaryFromReader = var value = /** @type {!Uint8Array} */ (reader.readBytes()); msg.setData(value); break; + case 2: + var value = msg.getMetadataMap(); + reader.readMessage(value, function(message, reader) { + jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readString, null, "", ""); + }); + break; default: reader.skipField(); break; @@ -8780,6 +8877,10 @@ proto.dapr.proto.runtime.v1.GetActorStateResponse.serializeBinaryToWriter = func f ); } + f = message.getMetadataMap(true); + if (f && f.getLength() > 0) { + f.serializeBinary(2, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString); + } }; @@ -8825,6 +8926,29 @@ proto.dapr.proto.runtime.v1.GetActorStateResponse.prototype.setData = function(v }; +/** + * map metadata = 2; + * @param {boolean=} opt_noLazyCreate Do not create the map if + * empty, instead returning `undefined` + * @return {!jspb.Map} + */ +proto.dapr.proto.runtime.v1.GetActorStateResponse.prototype.getMetadataMap = function(opt_noLazyCreate) { + return /** @type {!jspb.Map} */ ( + jspb.Message.getMapField(this, 2, opt_noLazyCreate, + null)); +}; + + +/** + * Clears values from the map. The map will be non-null. + * @return {!proto.dapr.proto.runtime.v1.GetActorStateResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetActorStateResponse.prototype.clearMetadataMap = function() { + this.getMetadataMap().clear(); + return this; +}; + + /** * List of repeated fields within this message type. @@ -9286,7 +9410,8 @@ proto.dapr.proto.runtime.v1.TransactionalActorStateOperation.prototype.getMetada */ proto.dapr.proto.runtime.v1.TransactionalActorStateOperation.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -9563,7 +9688,8 @@ proto.dapr.proto.runtime.v1.InvokeActorRequest.prototype.getMetadataMap = functi */ proto.dapr.proto.runtime.v1.InvokeActorRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -9726,7 +9852,7 @@ proto.dapr.proto.runtime.v1.InvokeActorResponse.prototype.setData = function(val * @private {!Array} * @const */ -proto.dapr.proto.runtime.v1.GetMetadataResponse.repeatedFields_ = [2,3,5]; +proto.dapr.proto.runtime.v1.GetMetadataResponse.repeatedFields_ = [2,3,5,6,9]; @@ -9766,7 +9892,12 @@ proto.dapr.proto.runtime.v1.GetMetadataResponse.toObject = function(includeInsta proto.dapr.proto.runtime.v1.RegisteredComponents.toObject, includeInstance), extendedMetadataMap: (f = msg.getExtendedMetadataMap()) ? f.toObject(includeInstance, undefined) : [], subscriptionsList: jspb.Message.toObjectList(msg.getSubscriptionsList(), - proto.dapr.proto.runtime.v1.PubsubSubscription.toObject, includeInstance) + proto.dapr.proto.runtime.v1.PubsubSubscription.toObject, includeInstance), + httpEndpointsList: jspb.Message.toObjectList(msg.getHttpEndpointsList(), + proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.toObject, includeInstance), + appConnectionProperties: (f = msg.getAppConnectionProperties()) && proto.dapr.proto.runtime.v1.AppConnectionProperties.toObject(includeInstance, f), + runtimeVersion: jspb.Message.getFieldWithDefault(msg, 8, ""), + enabledFeaturesList: (f = jspb.Message.getRepeatedField(msg, 9)) == null ? undefined : f }; if (includeInstance) { @@ -9828,6 +9959,24 @@ proto.dapr.proto.runtime.v1.GetMetadataResponse.deserializeBinaryFromReader = fu reader.readMessage(value,proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinaryFromReader); msg.addSubscriptions(value); break; + case 6: + var value = new proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint; + reader.readMessage(value,proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.deserializeBinaryFromReader); + msg.addHttpEndpoints(value); + break; + case 7: + var value = new proto.dapr.proto.runtime.v1.AppConnectionProperties; + reader.readMessage(value,proto.dapr.proto.runtime.v1.AppConnectionProperties.deserializeBinaryFromReader); + msg.setAppConnectionProperties(value); + break; + case 8: + var value = /** @type {string} */ (reader.readString()); + msg.setRuntimeVersion(value); + break; + case 9: + var value = /** @type {string} */ (reader.readString()); + msg.addEnabledFeatures(value); + break; default: reader.skipField(); break; @@ -9892,6 +10041,36 @@ proto.dapr.proto.runtime.v1.GetMetadataResponse.serializeBinaryToWriter = functi proto.dapr.proto.runtime.v1.PubsubSubscription.serializeBinaryToWriter ); } + f = message.getHttpEndpointsList(); + if (f.length > 0) { + writer.writeRepeatedMessage( + 6, + f, + proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.serializeBinaryToWriter + ); + } + f = message.getAppConnectionProperties(); + if (f != null) { + writer.writeMessage( + 7, + f, + proto.dapr.proto.runtime.v1.AppConnectionProperties.serializeBinaryToWriter + ); + } + f = message.getRuntimeVersion(); + if (f.length > 0) { + writer.writeString( + 8, + f + ); + } + f = message.getEnabledFeaturesList(); + if (f.length > 0) { + writer.writeRepeatedString( + 9, + f + ); + } }; @@ -10008,7 +10187,8 @@ proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getExtendedMetadataMap */ proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.clearExtendedMetadataMap = function() { this.getExtendedMetadataMap().clear(); - return this;}; + return this; +}; /** @@ -10049,6 +10229,136 @@ proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.clearSubscriptionsList }; +/** + * repeated MetadataHTTPEndpoint http_endpoints = 6; + * @return {!Array} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getHttpEndpointsList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint, 6)); +}; + + +/** + * @param {!Array} value + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this +*/ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.setHttpEndpointsList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 6, value); +}; + + +/** + * @param {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint=} opt_value + * @param {number=} opt_index + * @return {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.addHttpEndpoints = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 6, opt_value, proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.clearHttpEndpointsList = function() { + return this.setHttpEndpointsList([]); +}; + + +/** + * optional AppConnectionProperties app_connection_properties = 7; + * @return {?proto.dapr.proto.runtime.v1.AppConnectionProperties} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getAppConnectionProperties = function() { + return /** @type{?proto.dapr.proto.runtime.v1.AppConnectionProperties} */ ( + jspb.Message.getWrapperField(this, proto.dapr.proto.runtime.v1.AppConnectionProperties, 7)); +}; + + +/** + * @param {?proto.dapr.proto.runtime.v1.AppConnectionProperties|undefined} value + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this +*/ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.setAppConnectionProperties = function(value) { + return jspb.Message.setWrapperField(this, 7, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.clearAppConnectionProperties = function() { + return this.setAppConnectionProperties(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.hasAppConnectionProperties = function() { + return jspb.Message.getField(this, 7) != null; +}; + + +/** + * optional string runtime_version = 8; + * @return {string} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getRuntimeVersion = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 8, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.setRuntimeVersion = function(value) { + return jspb.Message.setProto3StringField(this, 8, value); +}; + + +/** + * repeated string enabled_features = 9; + * @return {!Array} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getEnabledFeaturesList = function() { + return /** @type {!Array} */ (jspb.Message.getRepeatedField(this, 9)); +}; + + +/** + * @param {!Array} value + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.setEnabledFeaturesList = function(value) { + return jspb.Message.setField(this, 9, value || []); +}; + + +/** + * @param {string} value + * @param {number=} opt_index + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.addEnabledFeatures = function(value, opt_index) { + return jspb.Message.addToRepeatedField(this, 9, value, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.clearEnabledFeaturesList = function() { + return this.setEnabledFeaturesList([]); +}; + + @@ -10471,8 +10781,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.dapr.proto.runtime.v1.PubsubSubscription.prototype.toObject = function(opt_includeInstance) { - return proto.dapr.proto.runtime.v1.PubsubSubscription.toObject(opt_includeInstance, this); +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.toObject(opt_includeInstance, this); }; @@ -10481,17 +10791,13 @@ proto.dapr.proto.runtime.v1.PubsubSubscription.prototype.toObject = function(opt * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.dapr.proto.runtime.v1.PubsubSubscription} msg The msg instance to transform. + * @param {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.PubsubSubscription.toObject = function(includeInstance, msg) { +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.toObject = function(includeInstance, msg) { var f, obj = { - pubsubName: jspb.Message.getFieldWithDefault(msg, 1, ""), - topic: jspb.Message.getFieldWithDefault(msg, 2, ""), - metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : [], - rules: (f = msg.getRules()) && proto.dapr.proto.runtime.v1.PubsubSubscriptionRules.toObject(includeInstance, f), - deadLetterTopic: jspb.Message.getFieldWithDefault(msg, 5, "") + name: jspb.Message.getFieldWithDefault(msg, 1, "") }; if (includeInstance) { @@ -10505,23 +10811,23 @@ proto.dapr.proto.runtime.v1.PubsubSubscription.toObject = function(includeInstan /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.dapr.proto.runtime.v1.PubsubSubscription} + * @return {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint} */ -proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinary = function(bytes) { +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.dapr.proto.runtime.v1.PubsubSubscription; - return proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinaryFromReader(msg, reader); + var msg = new proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint; + return proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.dapr.proto.runtime.v1.PubsubSubscription} msg The message object to deserialize into. + * @param {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.dapr.proto.runtime.v1.PubsubSubscription} + * @return {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint} */ -proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinaryFromReader = function(msg, reader) { +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -10530,13 +10836,638 @@ proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinaryFromReader = fun switch (field) { case 1: var value = /** @type {string} */ (reader.readString()); - msg.setPubsubName(value); + msg.setName(value); break; - case 2: - var value = /** @type {string} */ (reader.readString()); - msg.setTopic(value); + default: + reader.skipField(); break; - case 3: + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getName(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } +}; + + +/** + * optional string name = 1; + * @return {string} + */ +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.prototype.getName = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint} returns this + */ +proto.dapr.proto.runtime.v1.MetadataHTTPEndpoint.prototype.setName = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + + + + +if (jspb.Message.GENERATE_TO_OBJECT) { +/** + * Creates an object representation of this proto. + * Field names that are reserved in JavaScript and will be renamed to pb_name. + * Optional fields that are not set will be set to undefined. + * To access a reserved field use, foo.pb_, eg, foo.pb_default. + * For the list of reserved names please see: + * net/proto2/compiler/js/internal/generator.cc#kKeyword. + * @param {boolean=} opt_includeInstance Deprecated. whether to include the + * JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @return {!Object} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.AppConnectionProperties.toObject(opt_includeInstance, this); +}; + + +/** + * Static version of the {@see toObject} method. + * @param {boolean|undefined} includeInstance Deprecated. Whether to include + * the JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @param {!proto.dapr.proto.runtime.v1.AppConnectionProperties} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.toObject = function(includeInstance, msg) { + var f, obj = { + port: jspb.Message.getFieldWithDefault(msg, 1, 0), + protocol: jspb.Message.getFieldWithDefault(msg, 2, ""), + channelAddress: jspb.Message.getFieldWithDefault(msg, 3, ""), + maxConcurrency: jspb.Message.getFieldWithDefault(msg, 4, 0), + health: (f = msg.getHealth()) && proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.toObject(includeInstance, f) + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; +}; +} + + +/** + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.AppConnectionProperties; + return proto.dapr.proto.runtime.v1.AppConnectionProperties.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.dapr.proto.runtime.v1.AppConnectionProperties} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + case 1: + var value = /** @type {number} */ (reader.readInt32()); + msg.setPort(value); + break; + case 2: + var value = /** @type {string} */ (reader.readString()); + msg.setProtocol(value); + break; + case 3: + var value = /** @type {string} */ (reader.readString()); + msg.setChannelAddress(value); + break; + case 4: + var value = /** @type {number} */ (reader.readInt32()); + msg.setMaxConcurrency(value); + break; + case 5: + var value = new proto.dapr.proto.runtime.v1.AppConnectionHealthProperties; + reader.readMessage(value,proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.deserializeBinaryFromReader); + msg.setHealth(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.AppConnectionProperties.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.dapr.proto.runtime.v1.AppConnectionProperties} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getPort(); + if (f !== 0) { + writer.writeInt32( + 1, + f + ); + } + f = message.getProtocol(); + if (f.length > 0) { + writer.writeString( + 2, + f + ); + } + f = message.getChannelAddress(); + if (f.length > 0) { + writer.writeString( + 3, + f + ); + } + f = message.getMaxConcurrency(); + if (f !== 0) { + writer.writeInt32( + 4, + f + ); + } + f = message.getHealth(); + if (f != null) { + writer.writeMessage( + 5, + f, + proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.serializeBinaryToWriter + ); + } +}; + + +/** + * optional int32 port = 1; + * @return {number} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.getPort = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0)); +}; + + +/** + * @param {number} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.setPort = function(value) { + return jspb.Message.setProto3IntField(this, 1, value); +}; + + +/** + * optional string protocol = 2; + * @return {string} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.getProtocol = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.setProtocol = function(value) { + return jspb.Message.setProto3StringField(this, 2, value); +}; + + +/** + * optional string channel_address = 3; + * @return {string} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.getChannelAddress = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.setChannelAddress = function(value) { + return jspb.Message.setProto3StringField(this, 3, value); +}; + + +/** + * optional int32 max_concurrency = 4; + * @return {number} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.getMaxConcurrency = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 4, 0)); +}; + + +/** + * @param {number} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.setMaxConcurrency = function(value) { + return jspb.Message.setProto3IntField(this, 4, value); +}; + + +/** + * optional AppConnectionHealthProperties health = 5; + * @return {?proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.getHealth = function() { + return /** @type{?proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} */ ( + jspb.Message.getWrapperField(this, proto.dapr.proto.runtime.v1.AppConnectionHealthProperties, 5)); +}; + + +/** + * @param {?proto.dapr.proto.runtime.v1.AppConnectionHealthProperties|undefined} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} returns this +*/ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.setHealth = function(value) { + return jspb.Message.setWrapperField(this, 5, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.dapr.proto.runtime.v1.AppConnectionProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.clearHealth = function() { + return this.setHealth(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.dapr.proto.runtime.v1.AppConnectionProperties.prototype.hasHealth = function() { + return jspb.Message.getField(this, 5) != null; +}; + + + + + +if (jspb.Message.GENERATE_TO_OBJECT) { +/** + * Creates an object representation of this proto. + * Field names that are reserved in JavaScript and will be renamed to pb_name. + * Optional fields that are not set will be set to undefined. + * To access a reserved field use, foo.pb_, eg, foo.pb_default. + * For the list of reserved names please see: + * net/proto2/compiler/js/internal/generator.cc#kKeyword. + * @param {boolean=} opt_includeInstance Deprecated. whether to include the + * JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @return {!Object} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.toObject(opt_includeInstance, this); +}; + + +/** + * Static version of the {@see toObject} method. + * @param {boolean|undefined} includeInstance Deprecated. Whether to include + * the JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @param {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.toObject = function(includeInstance, msg) { + var f, obj = { + healthCheckPath: jspb.Message.getFieldWithDefault(msg, 1, ""), + healthProbeInterval: jspb.Message.getFieldWithDefault(msg, 2, ""), + healthProbeTimeout: jspb.Message.getFieldWithDefault(msg, 3, ""), + healthThreshold: jspb.Message.getFieldWithDefault(msg, 4, 0) + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; +}; +} + + +/** + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.AppConnectionHealthProperties; + return proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + case 1: + var value = /** @type {string} */ (reader.readString()); + msg.setHealthCheckPath(value); + break; + case 2: + var value = /** @type {string} */ (reader.readString()); + msg.setHealthProbeInterval(value); + break; + case 3: + var value = /** @type {string} */ (reader.readString()); + msg.setHealthProbeTimeout(value); + break; + case 4: + var value = /** @type {number} */ (reader.readInt32()); + msg.setHealthThreshold(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getHealthCheckPath(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getHealthProbeInterval(); + if (f.length > 0) { + writer.writeString( + 2, + f + ); + } + f = message.getHealthProbeTimeout(); + if (f.length > 0) { + writer.writeString( + 3, + f + ); + } + f = message.getHealthThreshold(); + if (f !== 0) { + writer.writeInt32( + 4, + f + ); + } +}; + + +/** + * optional string health_check_path = 1; + * @return {string} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.getHealthCheckPath = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.setHealthCheckPath = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * optional string health_probe_interval = 2; + * @return {string} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.getHealthProbeInterval = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.setHealthProbeInterval = function(value) { + return jspb.Message.setProto3StringField(this, 2, value); +}; + + +/** + * optional string health_probe_timeout = 3; + * @return {string} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.getHealthProbeTimeout = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.setHealthProbeTimeout = function(value) { + return jspb.Message.setProto3StringField(this, 3, value); +}; + + +/** + * optional int32 health_threshold = 4; + * @return {number} + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.getHealthThreshold = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 4, 0)); +}; + + +/** + * @param {number} value + * @return {!proto.dapr.proto.runtime.v1.AppConnectionHealthProperties} returns this + */ +proto.dapr.proto.runtime.v1.AppConnectionHealthProperties.prototype.setHealthThreshold = function(value) { + return jspb.Message.setProto3IntField(this, 4, value); +}; + + + + + +if (jspb.Message.GENERATE_TO_OBJECT) { +/** + * Creates an object representation of this proto. + * Field names that are reserved in JavaScript and will be renamed to pb_name. + * Optional fields that are not set will be set to undefined. + * To access a reserved field use, foo.pb_, eg, foo.pb_default. + * For the list of reserved names please see: + * net/proto2/compiler/js/internal/generator.cc#kKeyword. + * @param {boolean=} opt_includeInstance Deprecated. whether to include the + * JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @return {!Object} + */ +proto.dapr.proto.runtime.v1.PubsubSubscription.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.PubsubSubscription.toObject(opt_includeInstance, this); +}; + + +/** + * Static version of the {@see toObject} method. + * @param {boolean|undefined} includeInstance Deprecated. Whether to include + * the JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @param {!proto.dapr.proto.runtime.v1.PubsubSubscription} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.PubsubSubscription.toObject = function(includeInstance, msg) { + var f, obj = { + pubsubName: jspb.Message.getFieldWithDefault(msg, 1, ""), + topic: jspb.Message.getFieldWithDefault(msg, 2, ""), + metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : [], + rules: (f = msg.getRules()) && proto.dapr.proto.runtime.v1.PubsubSubscriptionRules.toObject(includeInstance, f), + deadLetterTopic: jspb.Message.getFieldWithDefault(msg, 5, "") + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; +}; +} + + +/** + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.dapr.proto.runtime.v1.PubsubSubscription} + */ +proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.PubsubSubscription; + return proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.dapr.proto.runtime.v1.PubsubSubscription} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.PubsubSubscription} + */ +proto.dapr.proto.runtime.v1.PubsubSubscription.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + case 1: + var value = /** @type {string} */ (reader.readString()); + msg.setPubsubName(value); + break; + case 2: + var value = /** @type {string} */ (reader.readString()); + msg.setTopic(value); + break; + case 3: var value = msg.getMetadataMap(); reader.readMessage(value, function(message, reader) { jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readString, null, "", ""); @@ -10671,7 +11602,8 @@ proto.dapr.proto.runtime.v1.PubsubSubscription.prototype.getMetadataMap = functi */ proto.dapr.proto.runtime.v1.PubsubSubscription.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; /** @@ -11425,7 +12357,8 @@ proto.dapr.proto.runtime.v1.GetConfigurationRequest.prototype.getMetadataMap = f */ proto.dapr.proto.runtime.v1.GetConfigurationRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -11558,7 +12491,8 @@ proto.dapr.proto.runtime.v1.GetConfigurationResponse.prototype.getItemsMap = fun */ proto.dapr.proto.runtime.v1.GetConfigurationResponse.prototype.clearItemsMap = function() { this.getItemsMap().clear(); - return this;}; + return this; +}; @@ -11777,7 +12711,8 @@ proto.dapr.proto.runtime.v1.SubscribeConfigurationRequest.prototype.getMetadataM */ proto.dapr.proto.runtime.v1.SubscribeConfigurationRequest.prototype.clearMetadataMap = function() { this.getMetadataMap().clear(); - return this;}; + return this; +}; @@ -12100,7 +13035,8 @@ proto.dapr.proto.runtime.v1.SubscribeConfigurationResponse.prototype.getItemsMap */ proto.dapr.proto.runtime.v1.SubscribeConfigurationResponse.prototype.clearItemsMap = function() { this.getItemsMap().clear(); - return this;}; + return this; +}; @@ -17995,7 +18931,8 @@ proto.dapr.proto.runtime.v1.GetWorkflowResponse.prototype.getPropertiesMap = fun */ proto.dapr.proto.runtime.v1.GetWorkflowResponse.prototype.clearPropertiesMap = function() { this.getPropertiesMap().clear(); - return this;}; + return this; +}; @@ -18230,7 +19167,8 @@ proto.dapr.proto.runtime.v1.StartWorkflowRequest.prototype.getOptionsMap = funct */ proto.dapr.proto.runtime.v1.StartWorkflowRequest.prototype.clearOptionsMap = function() { this.getOptionsMap().clear(); - return this;}; + return this; +}; /** diff --git a/src/proto/dapr/proto/sentry/v1/sentry.proto b/src/proto/dapr/proto/sentry/v1/sentry.proto index 3f1ff283..49be6342 100644 --- a/src/proto/dapr/proto/sentry/v1/sentry.proto +++ b/src/proto/dapr/proto/sentry/v1/sentry.proto @@ -28,12 +28,24 @@ service CA { } message SignCertificateRequest { + enum TokenValidator { + // Not specified - use the default value. + UNKNOWN = 0; + // Insecure validator (default on self-hosted). + INSECURE = 1; + // Kubernetes validator (default on Kubernetes). + KUBERNETES = 2; + // JWKS validator. + JWKS = 3; + } string id = 1; string token = 2; string trust_domain = 3; string namespace = 4; // A PEM-encoded x509 CSR. bytes certificate_signing_request = 5; + // Name of the validator to use, if not the default for the environemtn. + TokenValidator token_validator = 6; } message SignCertificateResponse { diff --git a/src/proto/dapr/proto/sentry/v1/sentry_pb.d.ts b/src/proto/dapr/proto/sentry/v1/sentry_pb.d.ts index d8cb5494..f514dec3 100644 --- a/src/proto/dapr/proto/sentry/v1/sentry_pb.d.ts +++ b/src/proto/dapr/proto/sentry/v1/sentry_pb.d.ts @@ -20,6 +20,8 @@ export class SignCertificateRequest extends jspb.Message { getCertificateSigningRequest_asU8(): Uint8Array; getCertificateSigningRequest_asB64(): string; setCertificateSigningRequest(value: Uint8Array | string): SignCertificateRequest; + getTokenValidator(): SignCertificateRequest.TokenValidator; + setTokenValidator(value: SignCertificateRequest.TokenValidator): SignCertificateRequest; serializeBinary(): Uint8Array; toObject(includeInstance?: boolean): SignCertificateRequest.AsObject; @@ -38,7 +40,16 @@ export namespace SignCertificateRequest { trustDomain: string, namespace: string, certificateSigningRequest: Uint8Array | string, + tokenValidator: SignCertificateRequest.TokenValidator, } + + export enum TokenValidator { + UNKNOWN = 0, + INSECURE = 1, + KUBERNETES = 2, + JWKS = 3, + } + } export class SignCertificateResponse extends jspb.Message { diff --git a/src/proto/dapr/proto/sentry/v1/sentry_pb.js b/src/proto/dapr/proto/sentry/v1/sentry_pb.js index 33a9091c..8d52a41f 100644 --- a/src/proto/dapr/proto/sentry/v1/sentry_pb.js +++ b/src/proto/dapr/proto/sentry/v1/sentry_pb.js @@ -13,11 +13,18 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); var google_protobuf_timestamp_pb = require('google-protobuf/google/protobuf/timestamp_pb.js'); goog.object.extend(proto, google_protobuf_timestamp_pb); goog.exportSymbol('proto.dapr.proto.sentry.v1.SignCertificateRequest', null, global); +goog.exportSymbol('proto.dapr.proto.sentry.v1.SignCertificateRequest.TokenValidator', null, global); goog.exportSymbol('proto.dapr.proto.sentry.v1.SignCertificateResponse', null, global); /** * Generated by JsPbCodeGenerator. @@ -97,7 +104,8 @@ proto.dapr.proto.sentry.v1.SignCertificateRequest.toObject = function(includeIns token: jspb.Message.getFieldWithDefault(msg, 2, ""), trustDomain: jspb.Message.getFieldWithDefault(msg, 3, ""), namespace: jspb.Message.getFieldWithDefault(msg, 4, ""), - certificateSigningRequest: msg.getCertificateSigningRequest_asB64() + certificateSigningRequest: msg.getCertificateSigningRequest_asB64(), + tokenValidator: jspb.Message.getFieldWithDefault(msg, 6, 0) }; if (includeInstance) { @@ -154,6 +162,10 @@ proto.dapr.proto.sentry.v1.SignCertificateRequest.deserializeBinaryFromReader = var value = /** @type {!Uint8Array} */ (reader.readBytes()); msg.setCertificateSigningRequest(value); break; + case 6: + var value = /** @type {!proto.dapr.proto.sentry.v1.SignCertificateRequest.TokenValidator} */ (reader.readEnum()); + msg.setTokenValidator(value); + break; default: reader.skipField(); break; @@ -218,9 +230,26 @@ proto.dapr.proto.sentry.v1.SignCertificateRequest.serializeBinaryToWriter = func f ); } + f = message.getTokenValidator(); + if (f !== 0.0) { + writer.writeEnum( + 6, + f + ); + } }; +/** + * @enum {number} + */ +proto.dapr.proto.sentry.v1.SignCertificateRequest.TokenValidator = { + UNKNOWN: 0, + INSECURE: 1, + KUBERNETES: 2, + JWKS: 3 +}; + /** * optional string id = 1; * @return {string} @@ -335,6 +364,24 @@ proto.dapr.proto.sentry.v1.SignCertificateRequest.prototype.setCertificateSignin }; +/** + * optional TokenValidator token_validator = 6; + * @return {!proto.dapr.proto.sentry.v1.SignCertificateRequest.TokenValidator} + */ +proto.dapr.proto.sentry.v1.SignCertificateRequest.prototype.getTokenValidator = function() { + return /** @type {!proto.dapr.proto.sentry.v1.SignCertificateRequest.TokenValidator} */ (jspb.Message.getFieldWithDefault(this, 6, 0)); +}; + + +/** + * @param {!proto.dapr.proto.sentry.v1.SignCertificateRequest.TokenValidator} value + * @return {!proto.dapr.proto.sentry.v1.SignCertificateRequest} returns this + */ +proto.dapr.proto.sentry.v1.SignCertificateRequest.prototype.setTokenValidator = function(value) { + return jspb.Message.setProto3EnumField(this, 6, value); +}; + + /** * List of repeated fields within this message type. diff --git a/src/proto/google/protobuf/any_pb.js b/src/proto/google/protobuf/any_pb.js index c32e01f6..c9799fca 100644 --- a/src/proto/google/protobuf/any_pb.js +++ b/src/proto/google/protobuf/any_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); goog.exportSymbol('proto.google.protobuf.Any', null, global); /** diff --git a/src/proto/google/protobuf/empty_pb.js b/src/proto/google/protobuf/empty_pb.js index 52428f70..8cabbd24 100644 --- a/src/proto/google/protobuf/empty_pb.js +++ b/src/proto/google/protobuf/empty_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); goog.exportSymbol('proto.google.protobuf.Empty', null, global); /** diff --git a/src/proto/google/protobuf/timestamp_pb.js b/src/proto/google/protobuf/timestamp_pb.js index 9cf8e7f2..88db5c81 100644 --- a/src/proto/google/protobuf/timestamp_pb.js +++ b/src/proto/google/protobuf/timestamp_pb.js @@ -13,7 +13,13 @@ var jspb = require('google-protobuf'); var goog = jspb; -var global = (function() { return this || window || global || self || Function('return this')(); }).call(null); +var global = + (typeof globalThis !== 'undefined' && globalThis) || + (typeof window !== 'undefined' && window) || + (typeof global !== 'undefined' && global) || + (typeof self !== 'undefined' && self) || + (function () { return this; }).call(null) || + Function('return this')(); goog.exportSymbol('proto.google.protobuf.Timestamp', null, global); /**