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
19 changes: 9 additions & 10 deletions package-lock.json

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

51 changes: 51 additions & 0 deletions src/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,9 @@ interface IDaprService extends grpc.ServiceDefinition<grpc.UntypedServiceImpleme
publishEvent: IDaprService_IPublishEvent;
invokeBinding: IDaprService_IInvokeBinding;
getSecret: IDaprService_IGetSecret;
registerActorTimer: IDaprService_IRegisterActorTimer;
unregisterActorTimer: IDaprService_IUnregisterActorTimer;
invokeActor: IDaprService_IInvokeActor;
}

interface IDaprService_IInvokeService extends grpc.MethodDefinition<dapr_proto_runtime_v1_dapr_pb.InvokeServiceRequest, dapr_proto_common_v1_common_pb.InvokeResponse> {
Expand Down Expand Up @@ -102,6 +105,33 @@ interface IDaprService_IGetSecret extends grpc.MethodDefinition<dapr_proto_runti
responseSerialize: grpc.serialize<dapr_proto_runtime_v1_dapr_pb.GetSecretResponse>;
responseDeserialize: grpc.deserialize<dapr_proto_runtime_v1_dapr_pb.GetSecretResponse>;
}
interface IDaprService_IRegisterActorTimer extends grpc.MethodDefinition<dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, google_protobuf_empty_pb.Empty> {
path: "/dapr.proto.runtime.v1.Dapr/RegisterActorTimer";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest>;
requestDeserialize: grpc.deserialize<dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest>;
responseSerialize: grpc.serialize<google_protobuf_empty_pb.Empty>;
responseDeserialize: grpc.deserialize<google_protobuf_empty_pb.Empty>;
}
interface IDaprService_IUnregisterActorTimer extends grpc.MethodDefinition<dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, google_protobuf_empty_pb.Empty> {
path: "/dapr.proto.runtime.v1.Dapr/UnregisterActorTimer";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest>;
requestDeserialize: grpc.deserialize<dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest>;
responseSerialize: grpc.serialize<google_protobuf_empty_pb.Empty>;
responseDeserialize: grpc.deserialize<google_protobuf_empty_pb.Empty>;
}
interface IDaprService_IInvokeActor extends grpc.MethodDefinition<dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse> {
path: "/dapr.proto.runtime.v1.Dapr/InvokeActor";
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest>;
requestDeserialize: grpc.deserialize<dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest>;
responseSerialize: grpc.serialize<dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse>;
responseDeserialize: grpc.deserialize<dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse>;
}

export const DaprService: IDaprService;

Expand All @@ -115,6 +145,9 @@ export interface IDaprServer {
publishEvent: grpc.handleUnaryCall<dapr_proto_runtime_v1_dapr_pb.PublishEventRequest, google_protobuf_empty_pb.Empty>;
invokeBinding: grpc.handleUnaryCall<dapr_proto_runtime_v1_dapr_pb.InvokeBindingRequest, dapr_proto_runtime_v1_dapr_pb.InvokeBindingResponse>;
getSecret: grpc.handleUnaryCall<dapr_proto_runtime_v1_dapr_pb.GetSecretRequest, dapr_proto_runtime_v1_dapr_pb.GetSecretResponse>;
registerActorTimer: grpc.handleUnaryCall<dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, google_protobuf_empty_pb.Empty>;
unregisterActorTimer: grpc.handleUnaryCall<dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, google_protobuf_empty_pb.Empty>;
invokeActor: grpc.handleUnaryCall<dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest, dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse>;
}

export interface IDaprClient {
Expand Down Expand Up @@ -145,6 +178,15 @@ export interface IDaprClient {
getSecret(request: dapr_proto_runtime_v1_dapr_pb.GetSecretRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetSecretResponse) => void): grpc.ClientUnaryCall;
getSecret(request: dapr_proto_runtime_v1_dapr_pb.GetSecretRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetSecretResponse) => void): grpc.ClientUnaryCall;
getSecret(request: dapr_proto_runtime_v1_dapr_pb.GetSecretRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetSecretResponse) => void): grpc.ClientUnaryCall;
registerActorTimer(request: dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
registerActorTimer(request: dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
registerActorTimer(request: dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
unregisterActorTimer(request: dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
unregisterActorTimer(request: dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
unregisterActorTimer(request: dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
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<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall;
}

export class DaprClient extends grpc.Client implements IDaprClient {
Expand Down Expand Up @@ -176,4 +218,13 @@ export class DaprClient extends grpc.Client implements IDaprClient {
public getSecret(request: dapr_proto_runtime_v1_dapr_pb.GetSecretRequest, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetSecretResponse) => void): grpc.ClientUnaryCall;
public getSecret(request: dapr_proto_runtime_v1_dapr_pb.GetSecretRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetSecretResponse) => void): grpc.ClientUnaryCall;
public getSecret(request: dapr_proto_runtime_v1_dapr_pb.GetSecretRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.GetSecretResponse) => void): grpc.ClientUnaryCall;
public registerActorTimer(request: dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
public registerActorTimer(request: dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
public registerActorTimer(request: dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
public unregisterActorTimer(request: dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
public unregisterActorTimer(request: dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
public unregisterActorTimer(request: dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: google_protobuf_empty_pb.Empty) => void): grpc.ClientUnaryCall;
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<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse) => void): grpc.ClientUnaryCall;
}
80 changes: 80 additions & 0 deletions src/dapr/proto/runtime/v1/dapr_grpc_pb.js
Original file line number Diff line number Diff line change
Expand Up @@ -111,6 +111,28 @@ function deserialize_dapr_proto_runtime_v1_GetStateResponse(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.GetStateResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_dapr_proto_runtime_v1_InvokeActorRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.InvokeActorRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_dapr_proto_runtime_v1_InvokeActorRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_dapr_proto_runtime_v1_InvokeActorResponse(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.InvokeActorResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_dapr_proto_runtime_v1_InvokeActorResponse(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_dapr_proto_runtime_v1_InvokeBindingRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.InvokeBindingRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.InvokeBindingRequest');
Expand Down Expand Up @@ -155,6 +177,17 @@ function deserialize_dapr_proto_runtime_v1_PublishEventRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.PublishEventRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_dapr_proto_runtime_v1_RegisterActorTimerRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.RegisterActorTimerRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_dapr_proto_runtime_v1_RegisterActorTimerRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_dapr_proto_runtime_v1_SaveStateRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.SaveStateRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.SaveStateRequest');
Expand All @@ -166,6 +199,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_UnregisterActorTimerRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.UnregisterActorTimerRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_dapr_proto_runtime_v1_UnregisterActorTimerRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_google_protobuf_Empty(arg) {
if (!(arg instanceof google_protobuf_empty_pb.Empty)) {
throw new Error('Expected argument of type google.protobuf.Empty');
Expand Down Expand Up @@ -288,6 +332,42 @@ getSecret: {
responseSerialize: serialize_dapr_proto_runtime_v1_GetSecretResponse,
responseDeserialize: deserialize_dapr_proto_runtime_v1_GetSecretResponse,
},
// Register an actor timer.
registerActorTimer: {
path: '/dapr.proto.runtime.v1.Dapr/RegisterActorTimer',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest,
responseType: google_protobuf_empty_pb.Empty,
requestSerialize: serialize_dapr_proto_runtime_v1_RegisterActorTimerRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_RegisterActorTimerRequest,
responseSerialize: serialize_google_protobuf_Empty,
responseDeserialize: deserialize_google_protobuf_Empty,
},
// Unregister an actor timer.
unregisterActorTimer: {
path: '/dapr.proto.runtime.v1.Dapr/UnregisterActorTimer',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest,
responseType: google_protobuf_empty_pb.Empty,
requestSerialize: serialize_dapr_proto_runtime_v1_UnregisterActorTimerRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_UnregisterActorTimerRequest,
responseSerialize: serialize_google_protobuf_Empty,
responseDeserialize: deserialize_google_protobuf_Empty,
},
// InvokeActor calls a method on an actor.
invokeActor: {
path: '/dapr.proto.runtime.v1.Dapr/InvokeActor',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.InvokeActorRequest,
responseType: dapr_proto_runtime_v1_dapr_pb.InvokeActorResponse,
requestSerialize: serialize_dapr_proto_runtime_v1_InvokeActorRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_InvokeActorRequest,
responseSerialize: serialize_dapr_proto_runtime_v1_InvokeActorResponse,
responseDeserialize: deserialize_dapr_proto_runtime_v1_InvokeActorResponse,
},
};

exports.DaprClient = grpc.makeGenericClientConstructor(DaprService);
Loading