Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

26 changes: 13 additions & 13 deletions src/dapr/proto/common/v1/common_pb.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import * as google_protobuf_any_pb from "google-protobuf/google/protobuf/any_pb"

export class HTTPExtension extends jspb.Message {
getVerb(): HTTPExtension.Verb;
setVerb(value: HTTPExtension.Verb): void;
setVerb(value: HTTPExtension.Verb): HTTPExtension;


getQuerystringMap(): jspb.Map<string, string>;
Expand Down Expand Up @@ -49,22 +49,22 @@ export namespace HTTPExtension {

export class InvokeRequest extends jspb.Message {
getMethod(): string;
setMethod(value: string): void;
setMethod(value: string): InvokeRequest;


hasData(): boolean;
clearData(): void;
getData(): google_protobuf_any_pb.Any | undefined;
setData(value?: google_protobuf_any_pb.Any): void;
setData(value?: google_protobuf_any_pb.Any): InvokeRequest;

getContentType(): string;
setContentType(value: string): void;
setContentType(value: string): InvokeRequest;


hasHttpExtension(): boolean;
clearHttpExtension(): void;
getHttpExtension(): HTTPExtension | undefined;
setHttpExtension(value?: HTTPExtension): void;
setHttpExtension(value?: HTTPExtension): InvokeRequest;


serializeBinary(): Uint8Array;
Expand All @@ -91,10 +91,10 @@ export class InvokeResponse extends jspb.Message {
hasData(): boolean;
clearData(): void;
getData(): google_protobuf_any_pb.Any | undefined;
setData(value?: google_protobuf_any_pb.Any): void;
setData(value?: google_protobuf_any_pb.Any): InvokeResponse;

getContentType(): string;
setContentType(value: string): void;
setContentType(value: string): InvokeResponse;


serializeBinary(): Uint8Array;
Expand All @@ -116,15 +116,15 @@ export namespace InvokeResponse {

export class StateItem extends jspb.Message {
getKey(): string;
setKey(value: string): void;
setKey(value: string): StateItem;

getValue(): Uint8Array | string;
getValue_asU8(): Uint8Array;
getValue_asB64(): string;
setValue(value: Uint8Array | string): void;
setValue(value: Uint8Array | string): StateItem;

getEtag(): string;
setEtag(value: string): void;
setEtag(value: string): StateItem;


getMetadataMap(): jspb.Map<string, string>;
Expand All @@ -134,7 +134,7 @@ export class StateItem extends jspb.Message {
hasOptions(): boolean;
clearOptions(): void;
getOptions(): StateOptions | undefined;
setOptions(value?: StateOptions): void;
setOptions(value?: StateOptions): StateItem;


serializeBinary(): Uint8Array;
Expand All @@ -160,10 +160,10 @@ export namespace StateItem {

export class StateOptions extends jspb.Message {
getConcurrency(): StateOptions.StateConcurrency;
setConcurrency(value: StateOptions.StateConcurrency): void;
setConcurrency(value: StateOptions.StateConcurrency): StateOptions;

getConsistency(): StateOptions.StateConsistency;
setConsistency(value: StateOptions.StateConsistency): void;
setConsistency(value: StateOptions.StateConsistency): StateOptions;


serializeBinary(): Uint8Array;
Expand Down
30 changes: 15 additions & 15 deletions src/dapr/proto/runtime/v1/appcallback_grpc_pb.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -18,45 +18,45 @@ interface IAppCallbackService extends grpc.ServiceDefinition<grpc.UntypedService
}

interface IAppCallbackService_IOnInvoke extends grpc.MethodDefinition<dapr_proto_common_v1_common_pb.InvokeRequest, dapr_proto_common_v1_common_pb.InvokeResponse> {
path: string; // "/dapr.proto.runtime.v1.AppCallback/OnInvoke"
requestStream: boolean; // false
responseStream: boolean; // false
path: "/dapr.proto.runtime.v1.AppCallback/OnInvoke";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<dapr_proto_common_v1_common_pb.InvokeRequest>;
requestDeserialize: grpc.deserialize<dapr_proto_common_v1_common_pb.InvokeRequest>;
responseSerialize: grpc.serialize<dapr_proto_common_v1_common_pb.InvokeResponse>;
responseDeserialize: grpc.deserialize<dapr_proto_common_v1_common_pb.InvokeResponse>;
}
interface IAppCallbackService_IListTopicSubscriptions extends grpc.MethodDefinition<google_protobuf_empty_pb.Empty, dapr_proto_runtime_v1_appcallback_pb.ListTopicSubscriptionsResponse> {
path: string; // "/dapr.proto.runtime.v1.AppCallback/ListTopicSubscriptions"
requestStream: boolean; // false
responseStream: boolean; // false
path: "/dapr.proto.runtime.v1.AppCallback/ListTopicSubscriptions";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<google_protobuf_empty_pb.Empty>;
requestDeserialize: grpc.deserialize<google_protobuf_empty_pb.Empty>;
responseSerialize: grpc.serialize<dapr_proto_runtime_v1_appcallback_pb.ListTopicSubscriptionsResponse>;
responseDeserialize: grpc.deserialize<dapr_proto_runtime_v1_appcallback_pb.ListTopicSubscriptionsResponse>;
}
interface IAppCallbackService_IOnTopicEvent extends grpc.MethodDefinition<dapr_proto_runtime_v1_appcallback_pb.TopicEventRequest, dapr_proto_runtime_v1_appcallback_pb.TopicEventResponse> {
path: string; // "/dapr.proto.runtime.v1.AppCallback/OnTopicEvent"
requestStream: boolean; // false
responseStream: boolean; // false
path: "/dapr.proto.runtime.v1.AppCallback/OnTopicEvent";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<dapr_proto_runtime_v1_appcallback_pb.TopicEventRequest>;
requestDeserialize: grpc.deserialize<dapr_proto_runtime_v1_appcallback_pb.TopicEventRequest>;
responseSerialize: grpc.serialize<dapr_proto_runtime_v1_appcallback_pb.TopicEventResponse>;
responseDeserialize: grpc.deserialize<dapr_proto_runtime_v1_appcallback_pb.TopicEventResponse>;
}
interface IAppCallbackService_IListInputBindings extends grpc.MethodDefinition<google_protobuf_empty_pb.Empty, dapr_proto_runtime_v1_appcallback_pb.ListInputBindingsResponse> {
path: string; // "/dapr.proto.runtime.v1.AppCallback/ListInputBindings"
requestStream: boolean; // false
responseStream: boolean; // false
path: "/dapr.proto.runtime.v1.AppCallback/ListInputBindings";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<google_protobuf_empty_pb.Empty>;
requestDeserialize: grpc.deserialize<google_protobuf_empty_pb.Empty>;
responseSerialize: grpc.serialize<dapr_proto_runtime_v1_appcallback_pb.ListInputBindingsResponse>;
responseDeserialize: grpc.deserialize<dapr_proto_runtime_v1_appcallback_pb.ListInputBindingsResponse>;
}
interface IAppCallbackService_IOnBindingEvent extends grpc.MethodDefinition<dapr_proto_runtime_v1_appcallback_pb.BindingEventRequest, dapr_proto_runtime_v1_appcallback_pb.BindingEventResponse> {
path: string; // "/dapr.proto.runtime.v1.AppCallback/OnBindingEvent"
requestStream: boolean; // false
responseStream: boolean; // false
path: "/dapr.proto.runtime.v1.AppCallback/OnBindingEvent";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<dapr_proto_runtime_v1_appcallback_pb.BindingEventRequest>;
requestDeserialize: grpc.deserialize<dapr_proto_runtime_v1_appcallback_pb.BindingEventRequest>;
responseSerialize: grpc.serialize<dapr_proto_runtime_v1_appcallback_pb.BindingEventResponse>;
Expand Down
49 changes: 30 additions & 19 deletions src/dapr/proto/runtime/v1/appcallback_pb.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -10,30 +10,30 @@ import * as dapr_proto_common_v1_common_pb from "../../../../dapr/proto/common/v

export class TopicEventRequest extends jspb.Message {
getId(): string;
setId(value: string): void;
setId(value: string): TopicEventRequest;

getSource(): string;
setSource(value: string): void;
setSource(value: string): TopicEventRequest;

getType(): string;
setType(value: string): void;
setType(value: string): TopicEventRequest;

getSpecVersion(): string;
setSpecVersion(value: string): void;
setSpecVersion(value: string): TopicEventRequest;

getDataContentType(): string;
setDataContentType(value: string): void;
setDataContentType(value: string): TopicEventRequest;

getData(): Uint8Array | string;
getData_asU8(): Uint8Array;
getData_asB64(): string;
setData(value: Uint8Array | string): void;
setData(value: Uint8Array | string): TopicEventRequest;

getTopic(): string;
setTopic(value: string): void;
setTopic(value: string): TopicEventRequest;

getPubsubName(): string;
setPubsubName(value: string): void;
setPubsubName(value: string): TopicEventRequest;


serializeBinary(): Uint8Array;
Expand All @@ -60,6 +60,9 @@ export namespace TopicEventRequest {
}

export class TopicEventResponse extends jspb.Message {
getStatus(): TopicEventResponse.TopicEventResponseStatus;
setStatus(value: TopicEventResponse.TopicEventResponseStatus): TopicEventResponse;


serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): TopicEventResponse.AsObject;
Expand All @@ -73,17 +76,25 @@ export class TopicEventResponse extends jspb.Message {

export namespace TopicEventResponse {
export type AsObject = {
status: TopicEventResponse.TopicEventResponseStatus,
}

export enum TopicEventResponseStatus {
SUCCESS = 0,
RETRY = 1,
DROP = 2,
}

}

export class BindingEventRequest extends jspb.Message {
getName(): string;
setName(value: string): void;
setName(value: string): BindingEventRequest;

getData(): Uint8Array | string;
getData_asU8(): Uint8Array;
getData_asB64(): string;
setData(value: Uint8Array | string): void;
setData(value: Uint8Array | string): BindingEventRequest;


getMetadataMap(): jspb.Map<string, string>;
Expand Down Expand Up @@ -111,25 +122,25 @@ export namespace BindingEventRequest {

export class BindingEventResponse extends jspb.Message {
getStoreName(): string;
setStoreName(value: string): void;
setStoreName(value: string): BindingEventResponse;

clearStatesList(): void;
getStatesList(): Array<dapr_proto_common_v1_common_pb.StateItem>;
setStatesList(value: Array<dapr_proto_common_v1_common_pb.StateItem>): void;
setStatesList(value: Array<dapr_proto_common_v1_common_pb.StateItem>): BindingEventResponse;
addStates(value?: dapr_proto_common_v1_common_pb.StateItem, index?: number): dapr_proto_common_v1_common_pb.StateItem;

clearToList(): void;
getToList(): Array<string>;
setToList(value: Array<string>): void;
setToList(value: Array<string>): BindingEventResponse;
addTo(value: string, index?: number): string;

getData(): Uint8Array | string;
getData_asU8(): Uint8Array;
getData_asB64(): string;
setData(value: Uint8Array | string): void;
setData(value: Uint8Array | string): BindingEventResponse;

getConcurrency(): BindingEventResponse.BindingEventConcurrency;
setConcurrency(value: BindingEventResponse.BindingEventConcurrency): void;
setConcurrency(value: BindingEventResponse.BindingEventConcurrency): BindingEventResponse;


serializeBinary(): Uint8Array;
Expand Down Expand Up @@ -161,7 +172,7 @@ export namespace BindingEventResponse {
export class ListTopicSubscriptionsResponse extends jspb.Message {
clearSubscriptionsList(): void;
getSubscriptionsList(): Array<TopicSubscription>;
setSubscriptionsList(value: Array<TopicSubscription>): void;
setSubscriptionsList(value: Array<TopicSubscription>): ListTopicSubscriptionsResponse;
addSubscriptions(value?: TopicSubscription, index?: number): TopicSubscription;


Expand All @@ -183,10 +194,10 @@ export namespace ListTopicSubscriptionsResponse {

export class TopicSubscription extends jspb.Message {
getPubsubName(): string;
setPubsubName(value: string): void;
setPubsubName(value: string): TopicSubscription;

getTopic(): string;
setTopic(value: string): void;
setTopic(value: string): TopicSubscription;


getMetadataMap(): jspb.Map<string, string>;
Expand Down Expand Up @@ -215,7 +226,7 @@ export namespace TopicSubscription {
export class ListInputBindingsResponse extends jspb.Message {
clearBindingsList(): void;
getBindingsList(): Array<string>;
setBindingsList(value: Array<string>): void;
setBindingsList(value: Array<string>): ListInputBindingsResponse;
addBindings(value: string, index?: number): string;


Expand Down
41 changes: 40 additions & 1 deletion src/dapr/proto/runtime/v1/appcallback_pb.js
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ goog.exportSymbol('proto.dapr.proto.runtime.v1.ListInputBindingsResponse', null,
goog.exportSymbol('proto.dapr.proto.runtime.v1.ListTopicSubscriptionsResponse', null, global);
goog.exportSymbol('proto.dapr.proto.runtime.v1.TopicEventRequest', null, global);
goog.exportSymbol('proto.dapr.proto.runtime.v1.TopicEventResponse', null, global);
goog.exportSymbol('proto.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus', null, global);
goog.exportSymbol('proto.dapr.proto.runtime.v1.TopicSubscription', null, global);
/**
* Generated by JsPbCodeGenerator.
Expand Down Expand Up @@ -567,7 +568,7 @@ proto.dapr.proto.runtime.v1.TopicEventResponse.prototype.toObject = function(opt
*/
proto.dapr.proto.runtime.v1.TopicEventResponse.toObject = function(includeInstance, msg) {
var f, obj = {

status: jspb.Message.getFieldWithDefault(msg, 1, 0)
};

if (includeInstance) {
Expand Down Expand Up @@ -604,6 +605,10 @@ proto.dapr.proto.runtime.v1.TopicEventResponse.deserializeBinaryFromReader = fun
}
var field = reader.getFieldNumber();
switch (field) {
case 1:
var value = /** @type {!proto.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus} */ (reader.readEnum());
msg.setStatus(value);
break;
default:
reader.skipField();
break;
Expand Down Expand Up @@ -633,6 +638,40 @@ proto.dapr.proto.runtime.v1.TopicEventResponse.prototype.serializeBinary = funct
*/
proto.dapr.proto.runtime.v1.TopicEventResponse.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
f = message.getStatus();
if (f !== 0.0) {
writer.writeEnum(
1,
f
);
}
};


/**
* @enum {number}
*/
proto.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus = {
SUCCESS: 0,
RETRY: 1,
DROP: 2
};

/**
* optional TopicEventResponseStatus status = 1;
* @return {!proto.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus}
*/
proto.dapr.proto.runtime.v1.TopicEventResponse.prototype.getStatus = function() {
return /** @type {!proto.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus} */ (jspb.Message.getFieldWithDefault(this, 1, 0));
};


/**
* @param {!proto.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus} value
* @return {!proto.dapr.proto.runtime.v1.TopicEventResponse} returns this
*/
proto.dapr.proto.runtime.v1.TopicEventResponse.prototype.setStatus = function(value) {
return jspb.Message.setProto3EnumField(this, 1, value);
};


Expand Down
Loading