From 16e906fe4660f5572632e5c643d002dbe8a01683 Mon Sep 17 00:00:00 2001 From: Nghia Tran Date: Wed, 27 Jan 2021 23:36:31 -0800 Subject: [PATCH] Update proto from 1.0.0-RC.3 --- package-lock.json | 8 +- src/dapr/proto/common/v1/common_pb.d.ts | 30 +- src/dapr/proto/common/v1/common_pb.js | 195 ++- src/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts | 51 + src/dapr/proto/runtime/v1/dapr_grpc_pb.js | 69 + src/dapr/proto/runtime/v1/dapr_pb.d.ts | 181 ++- src/dapr/proto/runtime/v1/dapr_pb.js | 1522 +++++++++++++++++-- 7 files changed, 1903 insertions(+), 153 deletions(-) diff --git a/package-lock.json b/package-lock.json index 3e3ee2aa..a17be439 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,6 +1,6 @@ { "name": "dapr-client", - "version": "0.8.0-preview01", + "version": "0.9.0-preview01", "lockfileVersion": 1, "requires": true, "dependencies": { @@ -3433,9 +3433,9 @@ } }, "uglify-js": { - "version": "3.12.1", - "resolved": "https://registry.npmjs.org/uglify-js/-/uglify-js-3.12.1.tgz", - "integrity": "sha512-o8lHP20KjIiQe5b/67Rh68xEGRrc2SRsCuuoYclXXoC74AfSRGblU1HKzJWH3HxPZ+Ort85fWHpSX7KwBUC9CQ==", + "version": "3.12.5", + "resolved": "https://registry.npmjs.org/uglify-js/-/uglify-js-3.12.5.tgz", + "integrity": "sha512-SgpgScL4T7Hj/w/GexjnBHi3Ien9WS1Rpfg5y91WXMj9SY997ZCQU76mH4TpLwwfmMvoOU8wiaRkIf6NaH3mtg==", "dev": true, "optional": true }, diff --git a/src/dapr/proto/common/v1/common_pb.d.ts b/src/dapr/proto/common/v1/common_pb.d.ts index 19ad2127..58cbb226 100644 --- a/src/dapr/proto/common/v1/common_pb.d.ts +++ b/src/dapr/proto/common/v1/common_pb.d.ts @@ -123,8 +123,11 @@ export class StateItem extends jspb.Message { getValue_asB64(): string; setValue(value: Uint8Array | string): StateItem; - getEtag(): string; - setEtag(value: string): StateItem; + + hasEtag(): boolean; + clearEtag(): void; + getEtag(): Etag | undefined; + setEtag(value?: Etag): StateItem; getMetadataMap(): jspb.Map; @@ -151,13 +154,34 @@ export namespace StateItem { export type AsObject = { key: string, value: Uint8Array | string, - etag: string, + etag?: Etag.AsObject, metadataMap: Array<[string, string]>, options?: StateOptions.AsObject, } } +export class Etag extends jspb.Message { + getValue(): string; + setValue(value: string): Etag; + + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): Etag.AsObject; + static toObject(includeInstance: boolean, msg: Etag): Etag.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: Etag, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): Etag; + static deserializeBinaryFromReader(message: Etag, reader: jspb.BinaryReader): Etag; +} + +export namespace Etag { + export type AsObject = { + value: string, + } +} + export class StateOptions extends jspb.Message { getConcurrency(): StateOptions.StateConcurrency; setConcurrency(value: StateOptions.StateConcurrency): StateOptions; diff --git a/src/dapr/proto/common/v1/common_pb.js b/src/dapr/proto/common/v1/common_pb.js index e4378812..11d93026 100644 --- a/src/dapr/proto/common/v1/common_pb.js +++ b/src/dapr/proto/common/v1/common_pb.js @@ -16,6 +16,7 @@ var global = Function('return this')(); var google_protobuf_any_pb = require('google-protobuf/google/protobuf/any_pb.js'); goog.object.extend(proto, google_protobuf_any_pb); +goog.exportSymbol('proto.dapr.proto.common.v1.Etag', null, global); goog.exportSymbol('proto.dapr.proto.common.v1.HTTPExtension', null, global); goog.exportSymbol('proto.dapr.proto.common.v1.HTTPExtension.Verb', null, global); goog.exportSymbol('proto.dapr.proto.common.v1.InvokeRequest', null, global); @@ -108,6 +109,27 @@ if (goog.DEBUG && !COMPILED) { */ proto.dapr.proto.common.v1.StateItem.displayName = 'proto.dapr.proto.common.v1.StateItem'; } +/** + * 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.common.v1.Etag = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.common.v1.Etag, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.common.v1.Etag.displayName = 'proto.dapr.proto.common.v1.Etag'; +} /** * Generated by JsPbCodeGenerator. * @param {Array=} opt_data Optional initial data array, typically from a @@ -784,7 +806,7 @@ proto.dapr.proto.common.v1.StateItem.toObject = function(includeInstance, msg) { var f, obj = { key: jspb.Message.getFieldWithDefault(msg, 1, ""), value: msg.getValue_asB64(), - etag: jspb.Message.getFieldWithDefault(msg, 3, ""), + etag: (f = msg.getEtag()) && proto.dapr.proto.common.v1.Etag.toObject(includeInstance, f), metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : [], options: (f = msg.getOptions()) && proto.dapr.proto.common.v1.StateOptions.toObject(includeInstance, f) }; @@ -832,7 +854,8 @@ proto.dapr.proto.common.v1.StateItem.deserializeBinaryFromReader = function(msg, msg.setValue(value); break; case 3: - var value = /** @type {string} */ (reader.readString()); + var value = new proto.dapr.proto.common.v1.Etag; + reader.readMessage(value,proto.dapr.proto.common.v1.Etag.deserializeBinaryFromReader); msg.setEtag(value); break; case 4: @@ -890,10 +913,11 @@ proto.dapr.proto.common.v1.StateItem.serializeBinaryToWriter = function(message, ); } f = message.getEtag(); - if (f.length > 0) { - writer.writeString( + if (f != null) { + writer.writeMessage( 3, - f + f, + proto.dapr.proto.common.v1.Etag.serializeBinaryToWriter ); } f = message.getMetadataMap(true); @@ -972,20 +996,39 @@ proto.dapr.proto.common.v1.StateItem.prototype.setValue = function(value) { /** - * optional string etag = 3; - * @return {string} + * optional Etag etag = 3; + * @return {?proto.dapr.proto.common.v1.Etag} */ proto.dapr.proto.common.v1.StateItem.prototype.getEtag = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, "")); + return /** @type{?proto.dapr.proto.common.v1.Etag} */ ( + jspb.Message.getWrapperField(this, proto.dapr.proto.common.v1.Etag, 3)); }; /** - * @param {string} value + * @param {?proto.dapr.proto.common.v1.Etag|undefined} value * @return {!proto.dapr.proto.common.v1.StateItem} returns this - */ +*/ proto.dapr.proto.common.v1.StateItem.prototype.setEtag = function(value) { - return jspb.Message.setProto3StringField(this, 3, value); + return jspb.Message.setWrapperField(this, 3, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.dapr.proto.common.v1.StateItem} returns this + */ +proto.dapr.proto.common.v1.StateItem.prototype.clearEtag = function() { + return this.setEtag(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.dapr.proto.common.v1.StateItem.prototype.hasEtag = function() { + return jspb.Message.getField(this, 3) != null; }; @@ -1051,6 +1094,136 @@ proto.dapr.proto.common.v1.StateItem.prototype.hasOptions = function() { +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.common.v1.Etag.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.common.v1.Etag.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.common.v1.Etag} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.common.v1.Etag.toObject = function(includeInstance, msg) { + var f, obj = { + value: jspb.Message.getFieldWithDefault(msg, 1, "") + }; + + 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.common.v1.Etag} + */ +proto.dapr.proto.common.v1.Etag.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.common.v1.Etag; + return proto.dapr.proto.common.v1.Etag.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.dapr.proto.common.v1.Etag} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.common.v1.Etag} + */ +proto.dapr.proto.common.v1.Etag.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.setValue(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.dapr.proto.common.v1.Etag.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.common.v1.Etag.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.common.v1.Etag} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.common.v1.Etag.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getValue(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } +}; + + +/** + * optional string value = 1; + * @return {string} + */ +proto.dapr.proto.common.v1.Etag.prototype.getValue = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.common.v1.Etag} returns this + */ +proto.dapr.proto.common.v1.Etag.prototype.setValue = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + + + + if (jspb.Message.GENERATE_TO_OBJECT) { /** * Creates an object representation of this proto. diff --git a/src/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts b/src/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts index 084003b0..1e330025 100644 --- a/src/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts +++ b/src/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts @@ -16,6 +16,7 @@ interface IDaprService extends grpc.ServiceDefinition { @@ -75,6 +78,15 @@ interface IDaprService_IDeleteState extends grpc.MethodDefinition; responseDeserialize: grpc.deserialize; } +interface IDaprService_IDeleteBulkState extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/DeleteBulkState"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} interface IDaprService_IExecuteStateTransaction extends grpc.MethodDefinition { path: "/dapr.proto.runtime.v1.Dapr/ExecuteStateTransaction"; requestStream: false; @@ -183,6 +195,24 @@ interface IDaprService_IInvokeActor extends grpc.MethodDefinition; responseDeserialize: grpc.deserialize; } +interface IDaprService_IGetMetadata extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/GetMetadata"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} +interface IDaprService_ISetMetadata extends grpc.MethodDefinition { + path: "/dapr.proto.runtime.v1.Dapr/SetMetadata"; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} export const DaprService: IDaprService; @@ -192,6 +222,7 @@ export interface IDaprServer { getBulkState: grpc.handleUnaryCall; saveState: grpc.handleUnaryCall; deleteState: grpc.handleUnaryCall; + deleteBulkState: grpc.handleUnaryCall; executeStateTransaction: grpc.handleUnaryCall; publishEvent: grpc.handleUnaryCall; invokeBinding: grpc.handleUnaryCall; @@ -204,6 +235,8 @@ export interface IDaprServer { getActorState: grpc.handleUnaryCall; executeActorStateTransaction: grpc.handleUnaryCall; invokeActor: grpc.handleUnaryCall; + getMetadata: grpc.handleUnaryCall; + setMetadata: grpc.handleUnaryCall; } export interface IDaprClient { @@ -222,6 +255,9 @@ export interface IDaprClient { deleteState(request: dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; deleteState(request: dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; deleteState(request: dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + deleteBulkState(request: dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + deleteBulkState(request: dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + deleteBulkState(request: dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; executeStateTransaction(request: dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; executeStateTransaction(request: dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; executeStateTransaction(request: dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; @@ -258,6 +294,12 @@ export interface IDaprClient { invokeActor(request: dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall; invokeActor(request: dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall; invokeActor(request: dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall; + getMetadata(request: google_protobuf_empty_pb.Empty, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse) => void): grpc.ClientUnaryCall; + getMetadata(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse) => void): grpc.ClientUnaryCall; + getMetadata(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse) => void): grpc.ClientUnaryCall; + setMetadata(request: dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + setMetadata(request: dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + setMetadata(request: dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; } export class DaprClient extends grpc.Client implements IDaprClient { @@ -277,6 +319,9 @@ export class DaprClient extends grpc.Client implements IDaprClient { public deleteState(request: dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public deleteState(request: dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public deleteState(request: dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public deleteBulkState(request: dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public deleteBulkState(request: dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public deleteBulkState(request: dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public executeStateTransaction(request: dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public executeStateTransaction(request: dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; public executeStateTransaction(request: dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; @@ -313,4 +358,10 @@ export class DaprClient extends grpc.Client implements IDaprClient { public invokeActor(request: dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall; public invokeActor(request: dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall; public invokeActor(request: dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall; + public getMetadata(request: google_protobuf_empty_pb.Empty, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse) => void): grpc.ClientUnaryCall; + public getMetadata(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse) => void): grpc.ClientUnaryCall; + public getMetadata(request: google_protobuf_empty_pb.Empty, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse) => void): grpc.ClientUnaryCall; + public setMetadata(request: dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public setMetadata(request: dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; + public setMetadata(request: dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest, metadata: grpc.Metadata, options: Partial, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall; } diff --git a/src/dapr/proto/runtime/v1/dapr_grpc_pb.js b/src/dapr/proto/runtime/v1/dapr_grpc_pb.js index 1c5d2c02..5bb1140d 100644 --- a/src/dapr/proto/runtime/v1/dapr_grpc_pb.js +++ b/src/dapr/proto/runtime/v1/dapr_grpc_pb.js @@ -24,6 +24,17 @@ function deserialize_dapr_proto_common_v1_InvokeResponse(buffer_arg) { return dapr_proto_common_v1_common_pb.InvokeResponse.deserializeBinary(new Uint8Array(buffer_arg)); } +function serialize_dapr_proto_runtime_v1_DeleteBulkStateRequest(arg) { + if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest)) { + throw new Error('Expected argument of type dapr.proto.runtime.v1.DeleteBulkStateRequest'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_dapr_proto_runtime_v1_DeleteBulkStateRequest(buffer_arg) { + return dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest.deserializeBinary(new Uint8Array(buffer_arg)); +} + function serialize_dapr_proto_runtime_v1_DeleteStateRequest(arg) { if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest)) { throw new Error('Expected argument of type dapr.proto.runtime.v1.DeleteStateRequest'); @@ -123,6 +134,17 @@ function deserialize_dapr_proto_runtime_v1_GetBulkStateResponse(buffer_arg) { return dapr_proto_runtime_v1_dapr_pb.GetBulkStateResponse.deserializeBinary(new Uint8Array(buffer_arg)); } +function serialize_dapr_proto_runtime_v1_GetMetadataResponse(arg) { + if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse)) { + throw new Error('Expected argument of type dapr.proto.runtime.v1.GetMetadataResponse'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_dapr_proto_runtime_v1_GetMetadataResponse(buffer_arg) { + return dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse.deserializeBinary(new Uint8Array(buffer_arg)); +} + function serialize_dapr_proto_runtime_v1_GetSecretRequest(arg) { if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetSecretRequest)) { throw new Error('Expected argument of type dapr.proto.runtime.v1.GetSecretRequest'); @@ -266,6 +288,17 @@ function deserialize_dapr_proto_runtime_v1_SaveStateRequest(buffer_arg) { return dapr_proto_runtime_v1_dapr_pb.SaveStateRequest.deserializeBinary(new Uint8Array(buffer_arg)); } +function serialize_dapr_proto_runtime_v1_SetMetadataRequest(arg) { + if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest)) { + throw new Error('Expected argument of type dapr.proto.runtime.v1.SetMetadataRequest'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_dapr_proto_runtime_v1_SetMetadataRequest(buffer_arg) { + return dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest.deserializeBinary(new Uint8Array(buffer_arg)); +} + function serialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest(arg) { if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.UnregisterActorReminderRequest)) { throw new Error('Expected argument of type dapr.proto.runtime.v1.UnregisterActorReminderRequest'); @@ -362,6 +395,18 @@ deleteState: { responseSerialize: serialize_google_protobuf_Empty, responseDeserialize: deserialize_google_protobuf_Empty, }, + // Deletes a bulk of state items for a list of keys +deleteBulkState: { + path: '/dapr.proto.runtime.v1.Dapr/DeleteBulkState', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.DeleteBulkStateRequest, + responseType: google_protobuf_empty_pb.Empty, + requestSerialize: serialize_dapr_proto_runtime_v1_DeleteBulkStateRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_DeleteBulkStateRequest, + responseSerialize: serialize_google_protobuf_Empty, + responseDeserialize: deserialize_google_protobuf_Empty, + }, // Executes transactions for a specified store executeStateTransaction: { path: '/dapr.proto.runtime.v1.Dapr/ExecuteStateTransaction', @@ -506,6 +551,30 @@ invokeActor: { responseSerialize: serialize_dapr_proto_runtime_v1_InvokeActorResponse, responseDeserialize: deserialize_dapr_proto_runtime_v1_InvokeActorResponse, }, + // Gets metadata of the sidecar +getMetadata: { + path: '/dapr.proto.runtime.v1.Dapr/GetMetadata', + requestStream: false, + responseStream: false, + requestType: google_protobuf_empty_pb.Empty, + responseType: dapr_proto_runtime_v1_dapr_pb.GetMetadataResponse, + requestSerialize: serialize_google_protobuf_Empty, + requestDeserialize: deserialize_google_protobuf_Empty, + responseSerialize: serialize_dapr_proto_runtime_v1_GetMetadataResponse, + responseDeserialize: deserialize_dapr_proto_runtime_v1_GetMetadataResponse, + }, + // Sets value in extended metadata of the sidecar +setMetadata: { + path: '/dapr.proto.runtime.v1.Dapr/SetMetadata', + requestStream: false, + responseStream: false, + requestType: dapr_proto_runtime_v1_dapr_pb.SetMetadataRequest, + responseType: google_protobuf_empty_pb.Empty, + requestSerialize: serialize_dapr_proto_runtime_v1_SetMetadataRequest, + requestDeserialize: deserialize_dapr_proto_runtime_v1_SetMetadataRequest, + responseSerialize: serialize_google_protobuf_Empty, + responseDeserialize: deserialize_google_protobuf_Empty, + }, }; exports.DaprClient = grpc.makeGenericClientConstructor(DaprService); diff --git a/src/dapr/proto/runtime/v1/dapr_pb.d.ts b/src/dapr/proto/runtime/v1/dapr_pb.d.ts index c576d240..ee957cfb 100644 --- a/src/dapr/proto/runtime/v1/dapr_pb.d.ts +++ b/src/dapr/proto/runtime/v1/dapr_pb.d.ts @@ -213,8 +213,11 @@ export class DeleteStateRequest extends jspb.Message { getKey(): string; setKey(value: string): DeleteStateRequest; - getEtag(): string; - setEtag(value: string): DeleteStateRequest; + + hasEtag(): boolean; + clearEtag(): void; + getEtag(): dapr_proto_common_v1_common_pb.Etag | undefined; + setEtag(value?: dapr_proto_common_v1_common_pb.Etag): DeleteStateRequest; hasOptions(): boolean; @@ -241,13 +244,40 @@ export namespace DeleteStateRequest { export type AsObject = { storeName: string, key: string, - etag: string, + etag?: dapr_proto_common_v1_common_pb.Etag.AsObject, options?: dapr_proto_common_v1_common_pb.StateOptions.AsObject, metadataMap: Array<[string, string]>, } } +export class DeleteBulkStateRequest extends jspb.Message { + getStoreName(): string; + setStoreName(value: string): DeleteBulkStateRequest; + + clearStatesList(): void; + getStatesList(): Array; + setStatesList(value: Array): DeleteBulkStateRequest; + addStates(value?: dapr_proto_common_v1_common_pb.StateItem, index?: number): dapr_proto_common_v1_common_pb.StateItem; + + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): DeleteBulkStateRequest.AsObject; + static toObject(includeInstance: boolean, msg: DeleteBulkStateRequest): DeleteBulkStateRequest.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: DeleteBulkStateRequest, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): DeleteBulkStateRequest; + static deserializeBinaryFromReader(message: DeleteBulkStateRequest, reader: jspb.BinaryReader): DeleteBulkStateRequest; +} + +export namespace DeleteBulkStateRequest { + export type AsObject = { + storeName: string, + statesList: Array, + } +} + export class SaveStateRequest extends jspb.Message { getStoreName(): string; setStoreName(value: string): SaveStateRequest; @@ -463,9 +493,32 @@ export namespace GetBulkSecretRequest { } } +export class SecretResponse extends jspb.Message { + + getSecretsMap(): jspb.Map; + clearSecretsMap(): void; + + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): SecretResponse.AsObject; + static toObject(includeInstance: boolean, msg: SecretResponse): SecretResponse.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: SecretResponse, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): SecretResponse; + static deserializeBinaryFromReader(message: SecretResponse, reader: jspb.BinaryReader): SecretResponse; +} + +export namespace SecretResponse { + export type AsObject = { + + secretsMap: Array<[string, string]>, + } +} + export class GetBulkSecretResponse extends jspb.Message { - getDataMap(): jspb.Map; + getDataMap(): jspb.Map; clearDataMap(): void; @@ -482,7 +535,7 @@ export class GetBulkSecretResponse extends jspb.Message { export namespace GetBulkSecretResponse { export type AsObject = { - dataMap: Array<[string, string]>, + dataMap: Array<[string, SecretResponse.AsObject]>, } } @@ -867,3 +920,121 @@ export namespace InvokeActorResponse { data: Uint8Array | string, } } + +export class GetMetadataResponse extends jspb.Message { + getId(): string; + setId(value: string): GetMetadataResponse; + + clearActiveActorsCountList(): void; + getActiveActorsCountList(): Array; + setActiveActorsCountList(value: Array): GetMetadataResponse; + addActiveActorsCount(value?: ActiveActorsCount, index?: number): ActiveActorsCount; + + clearRegisteredComponentsList(): void; + getRegisteredComponentsList(): Array; + setRegisteredComponentsList(value: Array): GetMetadataResponse; + addRegisteredComponents(value?: RegisteredComponents, index?: number): RegisteredComponents; + + + getExtendedMetadataMap(): jspb.Map; + clearExtendedMetadataMap(): void; + + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): GetMetadataResponse.AsObject; + static toObject(includeInstance: boolean, msg: GetMetadataResponse): GetMetadataResponse.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: GetMetadataResponse, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): GetMetadataResponse; + static deserializeBinaryFromReader(message: GetMetadataResponse, reader: jspb.BinaryReader): GetMetadataResponse; +} + +export namespace GetMetadataResponse { + export type AsObject = { + id: string, + activeActorsCountList: Array, + registeredComponentsList: Array, + + extendedMetadataMap: Array<[string, string]>, + } +} + +export class ActiveActorsCount extends jspb.Message { + getType(): string; + setType(value: string): ActiveActorsCount; + + getCount(): number; + setCount(value: number): ActiveActorsCount; + + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): ActiveActorsCount.AsObject; + static toObject(includeInstance: boolean, msg: ActiveActorsCount): ActiveActorsCount.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: ActiveActorsCount, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): ActiveActorsCount; + static deserializeBinaryFromReader(message: ActiveActorsCount, reader: jspb.BinaryReader): ActiveActorsCount; +} + +export namespace ActiveActorsCount { + export type AsObject = { + type: string, + count: number, + } +} + +export class RegisteredComponents extends jspb.Message { + getName(): string; + setName(value: string): RegisteredComponents; + + getType(): string; + setType(value: string): RegisteredComponents; + + getVersion(): string; + setVersion(value: string): RegisteredComponents; + + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): RegisteredComponents.AsObject; + static toObject(includeInstance: boolean, msg: RegisteredComponents): RegisteredComponents.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: RegisteredComponents, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): RegisteredComponents; + static deserializeBinaryFromReader(message: RegisteredComponents, reader: jspb.BinaryReader): RegisteredComponents; +} + +export namespace RegisteredComponents { + export type AsObject = { + name: string, + type: string, + version: string, + } +} + +export class SetMetadataRequest extends jspb.Message { + getKey(): string; + setKey(value: string): SetMetadataRequest; + + getValue(): string; + setValue(value: string): SetMetadataRequest; + + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): SetMetadataRequest.AsObject; + static toObject(includeInstance: boolean, msg: SetMetadataRequest): SetMetadataRequest.AsObject; + static extensions: {[key: number]: jspb.ExtensionFieldInfo}; + static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; + static serializeBinaryToWriter(message: SetMetadataRequest, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): SetMetadataRequest; + static deserializeBinaryFromReader(message: SetMetadataRequest, reader: jspb.BinaryReader): SetMetadataRequest; +} + +export namespace SetMetadataRequest { + export type AsObject = { + key: string, + value: string, + } +} diff --git a/src/dapr/proto/runtime/v1/dapr_pb.js b/src/dapr/proto/runtime/v1/dapr_pb.js index 5d7cab56..7f200bf5 100644 --- a/src/dapr/proto/runtime/v1/dapr_pb.js +++ b/src/dapr/proto/runtime/v1/dapr_pb.js @@ -20,7 +20,9 @@ var google_protobuf_empty_pb = require('google-protobuf/google/protobuf/empty_pb goog.object.extend(proto, google_protobuf_empty_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.BulkStateItem', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.DeleteBulkStateRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.DeleteStateRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.ExecuteActorStateTransactionRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.ExecuteStateTransactionRequest', null, global); @@ -30,6 +32,7 @@ goog.exportSymbol('proto.dapr.proto.runtime.v1.GetBulkSecretRequest', null, glob goog.exportSymbol('proto.dapr.proto.runtime.v1.GetBulkSecretResponse', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.GetBulkStateRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.GetBulkStateResponse', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.GetMetadataResponse', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.GetSecretRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.GetSecretResponse', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.GetStateRequest', null, global); @@ -42,7 +45,10 @@ goog.exportSymbol('proto.dapr.proto.runtime.v1.InvokeServiceRequest', null, glob goog.exportSymbol('proto.dapr.proto.runtime.v1.PublishEventRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.RegisterActorReminderRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.RegisterActorTimerRequest', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.RegisteredComponents', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.SaveStateRequest', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.SecretResponse', null, global); +goog.exportSymbol('proto.dapr.proto.runtime.v1.SetMetadataRequest', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.TransactionalActorStateOperation', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.TransactionalStateOperation', null, global); goog.exportSymbol('proto.dapr.proto.runtime.v1.UnregisterActorReminderRequest', null, global); @@ -194,6 +200,27 @@ if (goog.DEBUG && !COMPILED) { */ proto.dapr.proto.runtime.v1.DeleteStateRequest.displayName = 'proto.dapr.proto.runtime.v1.DeleteStateRequest'; } +/** + * 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.DeleteBulkStateRequest = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.repeatedFields_, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.DeleteBulkStateRequest, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.displayName = 'proto.dapr.proto.runtime.v1.DeleteBulkStateRequest'; +} /** * Generated by JsPbCodeGenerator. * @param {Array=} opt_data Optional initial data array, typically from a @@ -341,6 +368,27 @@ if (goog.DEBUG && !COMPILED) { */ proto.dapr.proto.runtime.v1.GetBulkSecretRequest.displayName = 'proto.dapr.proto.runtime.v1.GetBulkSecretRequest'; } +/** + * 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.SecretResponse = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.SecretResponse, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.SecretResponse.displayName = 'proto.dapr.proto.runtime.v1.SecretResponse'; +} /** * Generated by JsPbCodeGenerator. * @param {Array=} opt_data Optional initial data array, typically from a @@ -614,6 +662,90 @@ if (goog.DEBUG && !COMPILED) { */ proto.dapr.proto.runtime.v1.InvokeActorResponse.displayName = 'proto.dapr.proto.runtime.v1.InvokeActorResponse'; } +/** + * 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.GetMetadataResponse = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, proto.dapr.proto.runtime.v1.GetMetadataResponse.repeatedFields_, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.GetMetadataResponse, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.GetMetadataResponse.displayName = 'proto.dapr.proto.runtime.v1.GetMetadataResponse'; +} +/** + * 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.ActiveActorsCount = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.ActiveActorsCount, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.ActiveActorsCount.displayName = 'proto.dapr.proto.runtime.v1.ActiveActorsCount'; +} +/** + * 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.RegisteredComponents = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.RegisteredComponents, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + 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.SetMetadataRequest = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.dapr.proto.runtime.v1.SetMetadataRequest, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.dapr.proto.runtime.v1.SetMetadataRequest.displayName = 'proto.dapr.proto.runtime.v1.SetMetadataRequest'; +} @@ -1955,7 +2087,7 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.toObject = function(includeInstan var f, obj = { storeName: jspb.Message.getFieldWithDefault(msg, 1, ""), key: jspb.Message.getFieldWithDefault(msg, 2, ""), - etag: jspb.Message.getFieldWithDefault(msg, 3, ""), + etag: (f = msg.getEtag()) && dapr_proto_common_v1_common_pb.Etag.toObject(includeInstance, f), options: (f = msg.getOptions()) && dapr_proto_common_v1_common_pb.StateOptions.toObject(includeInstance, f), metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : [] }; @@ -2003,7 +2135,8 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.deserializeBinaryFromReader = fun msg.setKey(value); break; case 3: - var value = /** @type {string} */ (reader.readString()); + var value = new dapr_proto_common_v1_common_pb.Etag; + reader.readMessage(value,dapr_proto_common_v1_common_pb.Etag.deserializeBinaryFromReader); msg.setEtag(value); break; case 4: @@ -2061,10 +2194,11 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.serializeBinaryToWriter = functio ); } f = message.getEtag(); - if (f.length > 0) { - writer.writeString( + if (f != null) { + writer.writeMessage( 3, - f + f, + dapr_proto_common_v1_common_pb.Etag.serializeBinaryToWriter ); } f = message.getOptions(); @@ -2119,20 +2253,39 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.setKey = function(value /** - * optional string etag = 3; - * @return {string} + * optional dapr.proto.common.v1.Etag etag = 3; + * @return {?proto.dapr.proto.common.v1.Etag} */ proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.getEtag = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, "")); + return /** @type{?proto.dapr.proto.common.v1.Etag} */ ( + jspb.Message.getWrapperField(this, dapr_proto_common_v1_common_pb.Etag, 3)); }; /** - * @param {string} value + * @param {?proto.dapr.proto.common.v1.Etag|undefined} value * @return {!proto.dapr.proto.runtime.v1.DeleteStateRequest} returns this - */ +*/ proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.setEtag = function(value) { - return jspb.Message.setProto3StringField(this, 3, value); + return jspb.Message.setWrapperField(this, 3, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.dapr.proto.runtime.v1.DeleteStateRequest} returns this + */ +proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.clearEtag = function() { + return this.setEtag(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.hasEtag = function() { + return jspb.Message.getField(this, 3) != null; }; @@ -2201,7 +2354,7 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.clearMetadataMap = func * @private {!Array} * @const */ -proto.dapr.proto.runtime.v1.SaveStateRequest.repeatedFields_ = [2]; +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.repeatedFields_ = [2]; @@ -2218,8 +2371,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.toObject = function(opt_includeInstance) { - return proto.dapr.proto.runtime.v1.SaveStateRequest.toObject(opt_includeInstance, this); +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.toObject(opt_includeInstance, this); }; @@ -2228,11 +2381,11 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.toObject = function(opt_i * @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.SaveStateRequest} msg The msg instance to transform. + * @param {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.SaveStateRequest.toObject = function(includeInstance, msg) { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.toObject = function(includeInstance, msg) { var f, obj = { storeName: jspb.Message.getFieldWithDefault(msg, 1, ""), statesList: jspb.Message.toObjectList(msg.getStatesList(), @@ -2250,23 +2403,23 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.toObject = function(includeInstance /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} + * @return {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} */ -proto.dapr.proto.runtime.v1.SaveStateRequest.deserializeBinary = function(bytes) { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.dapr.proto.runtime.v1.SaveStateRequest; - return proto.dapr.proto.runtime.v1.SaveStateRequest.deserializeBinaryFromReader(msg, reader); + var msg = new proto.dapr.proto.runtime.v1.DeleteBulkStateRequest; + return proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.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.SaveStateRequest} msg The message object to deserialize into. + * @param {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} + * @return {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} */ -proto.dapr.proto.runtime.v1.SaveStateRequest.deserializeBinaryFromReader = function(msg, reader) { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -2295,9 +2448,9 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.deserializeBinaryFromReader = funct * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.serializeBinary = function() { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.dapr.proto.runtime.v1.SaveStateRequest.serializeBinaryToWriter(this, writer); + proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -2305,11 +2458,11 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.serializeBinary = functio /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.dapr.proto.runtime.v1.SaveStateRequest} message + * @param {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.SaveStateRequest.serializeBinaryToWriter = function(message, writer) { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.serializeBinaryToWriter = function(message, writer) { var f = undefined; f = message.getStoreName(); if (f.length > 0) { @@ -2333,16 +2486,16 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.serializeBinaryToWriter = function( * optional string store_name = 1; * @return {string} */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.getStoreName = function() { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.getStoreName = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); }; /** * @param {string} value - * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} returns this + * @return {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} returns this */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.setStoreName = function(value) { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.setStoreName = function(value) { return jspb.Message.setProto3StringField(this, 1, value); }; @@ -2351,7 +2504,7 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.setStoreName = function(v * repeated dapr.proto.common.v1.StateItem states = 2; * @return {!Array} */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.getStatesList = function() { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.getStatesList = function() { return /** @type{!Array} */ ( jspb.Message.getRepeatedWrapperField(this, dapr_proto_common_v1_common_pb.StateItem, 2)); }; @@ -2359,9 +2512,9 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.getStatesList = function( /** * @param {!Array} value - * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} returns this + * @return {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} returns this */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.setStatesList = function(value) { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.setStatesList = function(value) { return jspb.Message.setRepeatedWrapperField(this, 2, value); }; @@ -2371,21 +2524,28 @@ proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.setStatesList = function( * @param {number=} opt_index * @return {!proto.dapr.proto.common.v1.StateItem} */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.addStates = function(opt_value, opt_index) { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.addStates = function(opt_value, opt_index) { return jspb.Message.addToRepeatedWrapperField(this, 2, opt_value, proto.dapr.proto.common.v1.StateItem, opt_index); }; /** * Clears the list making it empty but non-null. - * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} returns this + * @return {!proto.dapr.proto.runtime.v1.DeleteBulkStateRequest} returns this */ -proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.clearStatesList = function() { +proto.dapr.proto.runtime.v1.DeleteBulkStateRequest.prototype.clearStatesList = function() { return this.setStatesList([]); }; +/** + * List of repeated fields within this message type. + * @private {!Array} + * @const + */ +proto.dapr.proto.runtime.v1.SaveStateRequest.repeatedFields_ = [2]; + if (jspb.Message.GENERATE_TO_OBJECT) { @@ -2401,8 +2561,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.toObject = function(opt_includeInstance) { - return proto.dapr.proto.runtime.v1.PublishEventRequest.toObject(opt_includeInstance, this); +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.SaveStateRequest.toObject(opt_includeInstance, this); }; @@ -2411,17 +2571,15 @@ proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.toObject = function(op * @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.PublishEventRequest} msg The msg instance to transform. + * @param {!proto.dapr.proto.runtime.v1.SaveStateRequest} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.PublishEventRequest.toObject = function(includeInstance, msg) { +proto.dapr.proto.runtime.v1.SaveStateRequest.toObject = function(includeInstance, msg) { var f, obj = { - pubsubName: jspb.Message.getFieldWithDefault(msg, 1, ""), - topic: jspb.Message.getFieldWithDefault(msg, 2, ""), - data: msg.getData_asB64(), - dataContentType: jspb.Message.getFieldWithDefault(msg, 4, ""), - metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : [] + storeName: jspb.Message.getFieldWithDefault(msg, 1, ""), + statesList: jspb.Message.toObjectList(msg.getStatesList(), + dapr_proto_common_v1_common_pb.StateItem.toObject, includeInstance) }; if (includeInstance) { @@ -2435,23 +2593,23 @@ proto.dapr.proto.runtime.v1.PublishEventRequest.toObject = function(includeInsta /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.dapr.proto.runtime.v1.PublishEventRequest} + * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} */ -proto.dapr.proto.runtime.v1.PublishEventRequest.deserializeBinary = function(bytes) { +proto.dapr.proto.runtime.v1.SaveStateRequest.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.dapr.proto.runtime.v1.PublishEventRequest; - return proto.dapr.proto.runtime.v1.PublishEventRequest.deserializeBinaryFromReader(msg, reader); + var msg = new proto.dapr.proto.runtime.v1.SaveStateRequest; + return proto.dapr.proto.runtime.v1.SaveStateRequest.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.PublishEventRequest} msg The message object to deserialize into. + * @param {!proto.dapr.proto.runtime.v1.SaveStateRequest} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.dapr.proto.runtime.v1.PublishEventRequest} + * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} */ -proto.dapr.proto.runtime.v1.PublishEventRequest.deserializeBinaryFromReader = function(msg, reader) { +proto.dapr.proto.runtime.v1.SaveStateRequest.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -2460,25 +2618,12 @@ proto.dapr.proto.runtime.v1.PublishEventRequest.deserializeBinaryFromReader = fu switch (field) { case 1: var value = /** @type {string} */ (reader.readString()); - msg.setPubsubName(value); + msg.setStoreName(value); break; case 2: - var value = /** @type {string} */ (reader.readString()); - msg.setTopic(value); - break; - case 3: - var value = /** @type {!Uint8Array} */ (reader.readBytes()); - msg.setData(value); - break; - case 4: - var value = /** @type {string} */ (reader.readString()); - msg.setDataContentType(value); - break; - case 5: - var value = msg.getMetadataMap(); - reader.readMessage(value, function(message, reader) { - jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readString, null, "", ""); - }); + var value = new dapr_proto_common_v1_common_pb.StateItem; + reader.readMessage(value,dapr_proto_common_v1_common_pb.StateItem.deserializeBinaryFromReader); + msg.addStates(value); break; default: reader.skipField(); @@ -2493,9 +2638,9 @@ proto.dapr.proto.runtime.v1.PublishEventRequest.deserializeBinaryFromReader = fu * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.serializeBinary = function() { +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.dapr.proto.runtime.v1.PublishEventRequest.serializeBinaryToWriter(this, writer); + proto.dapr.proto.runtime.v1.SaveStateRequest.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -2503,49 +2648,247 @@ proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.serializeBinary = func /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.dapr.proto.runtime.v1.PublishEventRequest} message + * @param {!proto.dapr.proto.runtime.v1.SaveStateRequest} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.PublishEventRequest.serializeBinaryToWriter = function(message, writer) { +proto.dapr.proto.runtime.v1.SaveStateRequest.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getPubsubName(); + f = message.getStoreName(); if (f.length > 0) { writer.writeString( 1, f ); } - f = message.getTopic(); + f = message.getStatesList(); if (f.length > 0) { - writer.writeString( + writer.writeRepeatedMessage( 2, - f - ); - } - f = message.getData_asU8(); - if (f.length > 0) { - writer.writeBytes( - 3, - f - ); - } - f = message.getDataContentType(); - if (f.length > 0) { - writer.writeString( - 4, - f + f, + dapr_proto_common_v1_common_pb.StateItem.serializeBinaryToWriter ); } - f = message.getMetadataMap(true); - if (f && f.getLength() > 0) { - f.serializeBinary(5, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString); - } }; /** - * optional string pubsub_name = 1; + * optional string store_name = 1; + * @return {string} + */ +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.getStoreName = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} returns this + */ +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.setStoreName = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * repeated dapr.proto.common.v1.StateItem states = 2; + * @return {!Array} + */ +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.getStatesList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, dapr_proto_common_v1_common_pb.StateItem, 2)); +}; + + +/** + * @param {!Array} value + * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} returns this +*/ +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.setStatesList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 2, value); +}; + + +/** + * @param {!proto.dapr.proto.common.v1.StateItem=} opt_value + * @param {number=} opt_index + * @return {!proto.dapr.proto.common.v1.StateItem} + */ +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.addStates = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 2, opt_value, proto.dapr.proto.common.v1.StateItem, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.dapr.proto.runtime.v1.SaveStateRequest} returns this + */ +proto.dapr.proto.runtime.v1.SaveStateRequest.prototype.clearStatesList = function() { + return this.setStatesList([]); +}; + + + + + +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.PublishEventRequest.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.PublishEventRequest.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.PublishEventRequest} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.PublishEventRequest.toObject = function(includeInstance, msg) { + var f, obj = { + pubsubName: jspb.Message.getFieldWithDefault(msg, 1, ""), + topic: jspb.Message.getFieldWithDefault(msg, 2, ""), + data: msg.getData_asB64(), + dataContentType: jspb.Message.getFieldWithDefault(msg, 4, ""), + metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : [] + }; + + 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.PublishEventRequest} + */ +proto.dapr.proto.runtime.v1.PublishEventRequest.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.PublishEventRequest; + return proto.dapr.proto.runtime.v1.PublishEventRequest.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.PublishEventRequest} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.PublishEventRequest} + */ +proto.dapr.proto.runtime.v1.PublishEventRequest.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 = /** @type {!Uint8Array} */ (reader.readBytes()); + msg.setData(value); + break; + case 4: + var value = /** @type {string} */ (reader.readString()); + msg.setDataContentType(value); + break; + case 5: + 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; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.PublishEventRequest.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.PublishEventRequest} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.PublishEventRequest.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getPubsubName(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getTopic(); + if (f.length > 0) { + writer.writeString( + 2, + f + ); + } + f = message.getData_asU8(); + if (f.length > 0) { + writer.writeBytes( + 3, + f + ); + } + f = message.getDataContentType(); + if (f.length > 0) { + writer.writeString( + 4, + f + ); + } + f = message.getMetadataMap(true); + if (f && f.getLength() > 0) { + f.serializeBinary(5, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString); + } +}; + + +/** + * optional string pubsub_name = 1; * @return {string} */ proto.dapr.proto.runtime.v1.PublishEventRequest.prototype.getPubsubName = function() { @@ -3601,8 +3944,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.toObject = function(opt_includeInstance) { - return proto.dapr.proto.runtime.v1.GetBulkSecretResponse.toObject(opt_includeInstance, this); +proto.dapr.proto.runtime.v1.SecretResponse.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.SecretResponse.toObject(opt_includeInstance, this); }; @@ -3611,13 +3954,13 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.toObject = function( * @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.GetBulkSecretResponse} msg The msg instance to transform. + * @param {!proto.dapr.proto.runtime.v1.SecretResponse} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.toObject = function(includeInstance, msg) { +proto.dapr.proto.runtime.v1.SecretResponse.toObject = function(includeInstance, msg) { var f, obj = { - dataMap: (f = msg.getDataMap()) ? f.toObject(includeInstance, undefined) : [] + secretsMap: (f = msg.getSecretsMap()) ? f.toObject(includeInstance, undefined) : [] }; if (includeInstance) { @@ -3631,23 +3974,23 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.toObject = function(includeIns /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} + * @return {!proto.dapr.proto.runtime.v1.SecretResponse} */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.deserializeBinary = function(bytes) { +proto.dapr.proto.runtime.v1.SecretResponse.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.dapr.proto.runtime.v1.GetBulkSecretResponse; - return proto.dapr.proto.runtime.v1.GetBulkSecretResponse.deserializeBinaryFromReader(msg, reader); + var msg = new proto.dapr.proto.runtime.v1.SecretResponse; + return proto.dapr.proto.runtime.v1.SecretResponse.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.GetBulkSecretResponse} msg The message object to deserialize into. + * @param {!proto.dapr.proto.runtime.v1.SecretResponse} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} + * @return {!proto.dapr.proto.runtime.v1.SecretResponse} */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.deserializeBinaryFromReader = function(msg, reader) { +proto.dapr.proto.runtime.v1.SecretResponse.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -3655,7 +3998,7 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.deserializeBinaryFromReader = var field = reader.getFieldNumber(); switch (field) { case 1: - var value = msg.getDataMap(); + var value = msg.getSecretsMap(); reader.readMessage(value, function(message, reader) { jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readString, null, "", ""); }); @@ -3673,9 +4016,9 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.deserializeBinaryFromReader = * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.serializeBinary = function() { +proto.dapr.proto.runtime.v1.SecretResponse.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.dapr.proto.runtime.v1.GetBulkSecretResponse.serializeBinaryToWriter(this, writer); + proto.dapr.proto.runtime.v1.SecretResponse.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -3683,13 +4026,13 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.serializeBinary = fu /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} message + * @param {!proto.dapr.proto.runtime.v1.SecretResponse} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.serializeBinaryToWriter = function(message, writer) { +proto.dapr.proto.runtime.v1.SecretResponse.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getDataMap(true); + f = message.getSecretsMap(true); if (f && f.getLength() > 0) { f.serializeBinary(1, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString); } @@ -3697,12 +4040,12 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.serializeBinaryToWriter = func /** - * map data = 1; + * map secrets = 1; * @param {boolean=} opt_noLazyCreate Do not create the map if * empty, instead returning `undefined` * @return {!jspb.Map} */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.getDataMap = function(opt_noLazyCreate) { +proto.dapr.proto.runtime.v1.SecretResponse.prototype.getSecretsMap = function(opt_noLazyCreate) { return /** @type {!jspb.Map} */ ( jspb.Message.getMapField(this, 1, opt_noLazyCreate, null)); @@ -3711,10 +4054,10 @@ proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.getDataMap = functio /** * Clears values from the map. The map will be non-null. - * @return {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} returns this + * @return {!proto.dapr.proto.runtime.v1.SecretResponse} returns this */ -proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.clearDataMap = function() { - this.getDataMap().clear(); +proto.dapr.proto.runtime.v1.SecretResponse.prototype.clearSecretsMap = function() { + this.getSecretsMap().clear(); return this;}; @@ -3734,8 +4077,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.dapr.proto.runtime.v1.TransactionalStateOperation.prototype.toObject = function(opt_includeInstance) { - return proto.dapr.proto.runtime.v1.TransactionalStateOperation.toObject(opt_includeInstance, this); +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.GetBulkSecretResponse.toObject(opt_includeInstance, this); }; @@ -3744,14 +4087,13 @@ proto.dapr.proto.runtime.v1.TransactionalStateOperation.prototype.toObject = fun * @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.TransactionalStateOperation} msg The msg instance to transform. + * @param {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.dapr.proto.runtime.v1.TransactionalStateOperation.toObject = function(includeInstance, msg) { +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.toObject = function(includeInstance, msg) { var f, obj = { - operationtype: jspb.Message.getFieldWithDefault(msg, 1, ""), - request: (f = msg.getRequest()) && dapr_proto_common_v1_common_pb.StateItem.toObject(includeInstance, f) + dataMap: (f = msg.getDataMap()) ? f.toObject(includeInstance, proto.dapr.proto.runtime.v1.SecretResponse.toObject) : [] }; if (includeInstance) { @@ -3765,13 +4107,147 @@ proto.dapr.proto.runtime.v1.TransactionalStateOperation.toObject = function(incl /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.dapr.proto.runtime.v1.TransactionalStateOperation} + * @return {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} */ -proto.dapr.proto.runtime.v1.TransactionalStateOperation.deserializeBinary = function(bytes) { +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.dapr.proto.runtime.v1.TransactionalStateOperation; - return proto.dapr.proto.runtime.v1.TransactionalStateOperation.deserializeBinaryFromReader(msg, reader); -}; + var msg = new proto.dapr.proto.runtime.v1.GetBulkSecretResponse; + return proto.dapr.proto.runtime.v1.GetBulkSecretResponse.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.GetBulkSecretResponse} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} + */ +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + case 1: + var value = msg.getDataMap(); + reader.readMessage(value, function(message, reader) { + jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readMessage, proto.dapr.proto.runtime.v1.SecretResponse.deserializeBinaryFromReader, "", new proto.dapr.proto.runtime.v1.SecretResponse()); + }); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.GetBulkSecretResponse.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.GetBulkSecretResponse} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getDataMap(true); + if (f && f.getLength() > 0) { + f.serializeBinary(1, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeMessage, proto.dapr.proto.runtime.v1.SecretResponse.serializeBinaryToWriter); + } +}; + + +/** + * map data = 1; + * @param {boolean=} opt_noLazyCreate Do not create the map if + * empty, instead returning `undefined` + * @return {!jspb.Map} + */ +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.getDataMap = function(opt_noLazyCreate) { + return /** @type {!jspb.Map} */ ( + jspb.Message.getMapField(this, 1, opt_noLazyCreate, + proto.dapr.proto.runtime.v1.SecretResponse)); +}; + + +/** + * Clears values from the map. The map will be non-null. + * @return {!proto.dapr.proto.runtime.v1.GetBulkSecretResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetBulkSecretResponse.prototype.clearDataMap = function() { + this.getDataMap().clear(); + return this;}; + + + + + +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.TransactionalStateOperation.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.TransactionalStateOperation.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.TransactionalStateOperation} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.TransactionalStateOperation.toObject = function(includeInstance, msg) { + var f, obj = { + operationtype: jspb.Message.getFieldWithDefault(msg, 1, ""), + request: (f = msg.getRequest()) && dapr_proto_common_v1_common_pb.StateItem.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.TransactionalStateOperation} + */ +proto.dapr.proto.runtime.v1.TransactionalStateOperation.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.TransactionalStateOperation; + return proto.dapr.proto.runtime.v1.TransactionalStateOperation.deserializeBinaryFromReader(msg, reader); +}; /** @@ -6313,4 +6789,790 @@ proto.dapr.proto.runtime.v1.InvokeActorResponse.prototype.setData = function(val }; + +/** + * List of repeated fields within this message type. + * @private {!Array} + * @const + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.repeatedFields_ = [2,3]; + + + +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.GetMetadataResponse.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.GetMetadataResponse.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.GetMetadataResponse} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.toObject = function(includeInstance, msg) { + var f, obj = { + id: jspb.Message.getFieldWithDefault(msg, 1, ""), + activeActorsCountList: jspb.Message.toObjectList(msg.getActiveActorsCountList(), + proto.dapr.proto.runtime.v1.ActiveActorsCount.toObject, includeInstance), + registeredComponentsList: jspb.Message.toObjectList(msg.getRegisteredComponentsList(), + proto.dapr.proto.runtime.v1.RegisteredComponents.toObject, includeInstance), + extendedMetadataMap: (f = msg.getExtendedMetadataMap()) ? f.toObject(includeInstance, undefined) : [] + }; + + 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.GetMetadataResponse} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.GetMetadataResponse; + return proto.dapr.proto.runtime.v1.GetMetadataResponse.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.GetMetadataResponse} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.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.setId(value); + break; + case 2: + var value = new proto.dapr.proto.runtime.v1.ActiveActorsCount; + reader.readMessage(value,proto.dapr.proto.runtime.v1.ActiveActorsCount.deserializeBinaryFromReader); + msg.addActiveActorsCount(value); + break; + case 3: + var value = new proto.dapr.proto.runtime.v1.RegisteredComponents; + reader.readMessage(value,proto.dapr.proto.runtime.v1.RegisteredComponents.deserializeBinaryFromReader); + msg.addRegisteredComponents(value); + break; + case 4: + var value = msg.getExtendedMetadataMap(); + 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; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.GetMetadataResponse.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.GetMetadataResponse} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getId(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getActiveActorsCountList(); + if (f.length > 0) { + writer.writeRepeatedMessage( + 2, + f, + proto.dapr.proto.runtime.v1.ActiveActorsCount.serializeBinaryToWriter + ); + } + f = message.getRegisteredComponentsList(); + if (f.length > 0) { + writer.writeRepeatedMessage( + 3, + f, + proto.dapr.proto.runtime.v1.RegisteredComponents.serializeBinaryToWriter + ); + } + f = message.getExtendedMetadataMap(true); + if (f && f.getLength() > 0) { + f.serializeBinary(4, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString); + } +}; + + +/** + * optional string id = 1; + * @return {string} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getId = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.setId = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * repeated ActiveActorsCount active_actors_count = 2; + * @return {!Array} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getActiveActorsCountList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, proto.dapr.proto.runtime.v1.ActiveActorsCount, 2)); +}; + + +/** + * @param {!Array} value + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this +*/ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.setActiveActorsCountList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 2, value); +}; + + +/** + * @param {!proto.dapr.proto.runtime.v1.ActiveActorsCount=} opt_value + * @param {number=} opt_index + * @return {!proto.dapr.proto.runtime.v1.ActiveActorsCount} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.addActiveActorsCount = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 2, opt_value, proto.dapr.proto.runtime.v1.ActiveActorsCount, 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.clearActiveActorsCountList = function() { + return this.setActiveActorsCountList([]); +}; + + +/** + * repeated RegisteredComponents registered_components = 3; + * @return {!Array} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getRegisteredComponentsList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, proto.dapr.proto.runtime.v1.RegisteredComponents, 3)); +}; + + +/** + * @param {!Array} value + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this +*/ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.setRegisteredComponentsList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 3, value); +}; + + +/** + * @param {!proto.dapr.proto.runtime.v1.RegisteredComponents=} opt_value + * @param {number=} opt_index + * @return {!proto.dapr.proto.runtime.v1.RegisteredComponents} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.addRegisteredComponents = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 3, opt_value, proto.dapr.proto.runtime.v1.RegisteredComponents, 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.clearRegisteredComponentsList = function() { + return this.setRegisteredComponentsList([]); +}; + + +/** + * map extended_metadata = 4; + * @param {boolean=} opt_noLazyCreate Do not create the map if + * empty, instead returning `undefined` + * @return {!jspb.Map} + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.getExtendedMetadataMap = function(opt_noLazyCreate) { + return /** @type {!jspb.Map} */ ( + jspb.Message.getMapField(this, 4, opt_noLazyCreate, + null)); +}; + + +/** + * Clears values from the map. The map will be non-null. + * @return {!proto.dapr.proto.runtime.v1.GetMetadataResponse} returns this + */ +proto.dapr.proto.runtime.v1.GetMetadataResponse.prototype.clearExtendedMetadataMap = function() { + this.getExtendedMetadataMap().clear(); + return this;}; + + + + + +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.ActiveActorsCount.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.ActiveActorsCount.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.ActiveActorsCount} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.toObject = function(includeInstance, msg) { + var f, obj = { + type: jspb.Message.getFieldWithDefault(msg, 1, ""), + count: jspb.Message.getFieldWithDefault(msg, 2, 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.ActiveActorsCount} + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.ActiveActorsCount; + return proto.dapr.proto.runtime.v1.ActiveActorsCount.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.ActiveActorsCount} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.ActiveActorsCount} + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.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.setType(value); + break; + case 2: + var value = /** @type {number} */ (reader.readInt32()); + msg.setCount(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.ActiveActorsCount.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.ActiveActorsCount.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.ActiveActorsCount} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getType(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getCount(); + if (f !== 0) { + writer.writeInt32( + 2, + f + ); + } +}; + + +/** + * optional string type = 1; + * @return {string} + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.prototype.getType = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.ActiveActorsCount} returns this + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.prototype.setType = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * optional int32 count = 2; + * @return {number} + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.prototype.getCount = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 2, 0)); +}; + + +/** + * @param {number} value + * @return {!proto.dapr.proto.runtime.v1.ActiveActorsCount} returns this + */ +proto.dapr.proto.runtime.v1.ActiveActorsCount.prototype.setCount = function(value) { + return jspb.Message.setProto3IntField(this, 2, 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.RegisteredComponents.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.RegisteredComponents.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.RegisteredComponents} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.toObject = function(includeInstance, msg) { + var f, obj = { + name: jspb.Message.getFieldWithDefault(msg, 1, ""), + type: jspb.Message.getFieldWithDefault(msg, 2, ""), + version: jspb.Message.getFieldWithDefault(msg, 3, "") + }; + + 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.RegisteredComponents} + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.RegisteredComponents; + return proto.dapr.proto.runtime.v1.RegisteredComponents.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.RegisteredComponents} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.RegisteredComponents} + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.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.setName(value); + break; + case 2: + var value = /** @type {string} */ (reader.readString()); + msg.setType(value); + break; + case 3: + var value = /** @type {string} */ (reader.readString()); + msg.setVersion(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.RegisteredComponents.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.RegisteredComponents.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.RegisteredComponents} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getName(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getType(); + if (f.length > 0) { + writer.writeString( + 2, + f + ); + } + f = message.getVersion(); + if (f.length > 0) { + writer.writeString( + 3, + f + ); + } +}; + + +/** + * optional string name = 1; + * @return {string} + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.prototype.getName = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.RegisteredComponents} returns this + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.prototype.setName = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * optional string type = 2; + * @return {string} + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.prototype.getType = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.RegisteredComponents} returns this + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.prototype.setType = function(value) { + return jspb.Message.setProto3StringField(this, 2, value); +}; + + +/** + * optional string version = 3; + * @return {string} + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.prototype.getVersion = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.RegisteredComponents} returns this + */ +proto.dapr.proto.runtime.v1.RegisteredComponents.prototype.setVersion = function(value) { + return jspb.Message.setProto3StringField(this, 3, 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.SetMetadataRequest.prototype.toObject = function(opt_includeInstance) { + return proto.dapr.proto.runtime.v1.SetMetadataRequest.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.SetMetadataRequest} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.toObject = function(includeInstance, msg) { + var f, obj = { + key: jspb.Message.getFieldWithDefault(msg, 1, ""), + value: jspb.Message.getFieldWithDefault(msg, 2, "") + }; + + 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.SetMetadataRequest} + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.dapr.proto.runtime.v1.SetMetadataRequest; + return proto.dapr.proto.runtime.v1.SetMetadataRequest.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.SetMetadataRequest} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.dapr.proto.runtime.v1.SetMetadataRequest} + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.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.setKey(value); + break; + case 2: + var value = /** @type {string} */ (reader.readString()); + msg.setValue(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.SetMetadataRequest.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.dapr.proto.runtime.v1.SetMetadataRequest.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.SetMetadataRequest} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getKey(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getValue(); + if (f.length > 0) { + writer.writeString( + 2, + f + ); + } +}; + + +/** + * optional string key = 1; + * @return {string} + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.prototype.getKey = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.SetMetadataRequest} returns this + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.prototype.setKey = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * optional string value = 2; + * @return {string} + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.prototype.getValue = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); +}; + + +/** + * @param {string} value + * @return {!proto.dapr.proto.runtime.v1.SetMetadataRequest} returns this + */ +proto.dapr.proto.runtime.v1.SetMetadataRequest.prototype.setValue = function(value) { + return jspb.Message.setProto3StringField(this, 2, value); +}; + + goog.object.extend(exports, proto.dapr.proto.runtime.v1);