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
4 changes: 2 additions & 2 deletions examples/typescript/app.ts
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@ var client = new dapr_grpc.DaprClient(
var event = new dapr_pb.PublishEventRequest();
event.setTopic('sith');
event.setPubsubName('pubsub');
event.setDataContentType('text/plain');
event.getMetadataMap().set('key', 'value');

const data = Buffer.from('lala');
event.setData(data);
Expand Down Expand Up @@ -108,5 +110,3 @@ client.saveState(stateReq, (err, res) => {
});
}
});


24 changes: 12 additions & 12 deletions package-lock.json

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

2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
},
"devDependencies": {
"eslint": "^7.9.0",
"grpc-tools": "^1.9.1",
"grpc-tools": "^1.10.0",
"grpc_tools_node_protoc_ts": "^4.1.5"
}
}
2 changes: 2 additions & 0 deletions src/dapr/proto/common/v1/common_pb.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@
* @public
*/
// GENERATED CODE -- DO NOT EDIT!
/* eslint-disable */
// @ts-nocheck

var jspb = require('google-protobuf');
var goog = jspb;
Expand Down
2 changes: 2 additions & 0 deletions src/dapr/proto/runtime/v1/appcallback_pb.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@
* @public
*/
// GENERATED CODE -- DO NOT EDIT!
/* eslint-disable */
// @ts-nocheck

var jspb = require('google-protobuf');
var goog = jspb;
Expand Down
86 changes: 86 additions & 0 deletions src/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts

Large diffs are not rendered by default.

138 changes: 138 additions & 0 deletions src/dapr/proto/runtime/v1/dapr_grpc_pb.js
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
'use strict';
var grpc = require('grpc');
var dapr_proto_runtime_v1_dapr_pb = require('../../../../dapr/proto/runtime/v1/dapr_pb.js');
var google_protobuf_any_pb = require('google-protobuf/google/protobuf/any_pb.js');
var google_protobuf_empty_pb = require('google-protobuf/google/protobuf/empty_pb.js');
var dapr_proto_common_v1_common_pb = require('../../../../dapr/proto/common/v1/common_pb.js');

Expand All @@ -34,6 +35,17 @@ function deserialize_dapr_proto_runtime_v1_DeleteStateRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

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

function deserialize_dapr_proto_runtime_v1_ExecuteActorStateTransactionRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.ExecuteActorStateTransactionRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_dapr_proto_runtime_v1_ExecuteStateTransactionRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.ExecuteStateTransactionRequest');
Expand All @@ -45,6 +57,50 @@ function deserialize_dapr_proto_runtime_v1_ExecuteStateTransactionRequest(buffer
return dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

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

function deserialize_dapr_proto_runtime_v1_GetActorStateRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.GetActorStateRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

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

function deserialize_dapr_proto_runtime_v1_GetActorStateResponse(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.GetActorStateResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

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

function deserialize_dapr_proto_runtime_v1_GetBulkSecretRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.GetBulkSecretRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

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

function deserialize_dapr_proto_runtime_v1_GetBulkSecretResponse(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.GetBulkSecretResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_dapr_proto_runtime_v1_GetBulkStateRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetBulkStateRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.GetBulkStateRequest');
Expand Down Expand Up @@ -177,6 +233,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_RegisterActorReminderRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.RegisterActorReminderRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.RegisterActorReminderRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_dapr_proto_runtime_v1_RegisterActorReminderRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.RegisterActorReminderRequest.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');
Expand All @@ -199,6 +266,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_UnregisterActorReminderRequest(arg) {
if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.UnregisterActorReminderRequest)) {
throw new Error('Expected argument of type dapr.proto.runtime.v1.UnregisterActorReminderRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest(buffer_arg) {
return dapr_proto_runtime_v1_dapr_pb.UnregisterActorReminderRequest.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');
Expand Down Expand Up @@ -332,6 +410,18 @@ getSecret: {
responseSerialize: serialize_dapr_proto_runtime_v1_GetSecretResponse,
responseDeserialize: deserialize_dapr_proto_runtime_v1_GetSecretResponse,
},
// Gets a bulk of secrets
getBulkSecret: {
path: '/dapr.proto.runtime.v1.Dapr/GetBulkSecret',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.GetBulkSecretRequest,
responseType: dapr_proto_runtime_v1_dapr_pb.GetBulkSecretResponse,
requestSerialize: serialize_dapr_proto_runtime_v1_GetBulkSecretRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_GetBulkSecretRequest,
responseSerialize: serialize_dapr_proto_runtime_v1_GetBulkSecretResponse,
responseDeserialize: deserialize_dapr_proto_runtime_v1_GetBulkSecretResponse,
},
// Register an actor timer.
registerActorTimer: {
path: '/dapr.proto.runtime.v1.Dapr/RegisterActorTimer',
Expand All @@ -356,6 +446,54 @@ unregisterActorTimer: {
responseSerialize: serialize_google_protobuf_Empty,
responseDeserialize: deserialize_google_protobuf_Empty,
},
// Register an actor reminder.
registerActorReminder: {
path: '/dapr.proto.runtime.v1.Dapr/RegisterActorReminder',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.RegisterActorReminderRequest,
responseType: google_protobuf_empty_pb.Empty,
requestSerialize: serialize_dapr_proto_runtime_v1_RegisterActorReminderRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_RegisterActorReminderRequest,
responseSerialize: serialize_google_protobuf_Empty,
responseDeserialize: deserialize_google_protobuf_Empty,
},
// Unregister an actor reminder.
unregisterActorReminder: {
path: '/dapr.proto.runtime.v1.Dapr/UnregisterActorReminder',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.UnregisterActorReminderRequest,
responseType: google_protobuf_empty_pb.Empty,
requestSerialize: serialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest,
responseSerialize: serialize_google_protobuf_Empty,
responseDeserialize: deserialize_google_protobuf_Empty,
},
// Gets the state for a specific actor.
getActorState: {
path: '/dapr.proto.runtime.v1.Dapr/GetActorState',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.GetActorStateRequest,
responseType: dapr_proto_runtime_v1_dapr_pb.GetActorStateResponse,
requestSerialize: serialize_dapr_proto_runtime_v1_GetActorStateRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_GetActorStateRequest,
responseSerialize: serialize_dapr_proto_runtime_v1_GetActorStateResponse,
responseDeserialize: deserialize_dapr_proto_runtime_v1_GetActorStateResponse,
},
// Executes state transactions for a specified actor
executeActorStateTransaction: {
path: '/dapr.proto.runtime.v1.Dapr/ExecuteActorStateTransaction',
requestStream: false,
responseStream: false,
requestType: dapr_proto_runtime_v1_dapr_pb.ExecuteActorStateTransactionRequest,
responseType: google_protobuf_empty_pb.Empty,
requestSerialize: serialize_dapr_proto_runtime_v1_ExecuteActorStateTransactionRequest,
requestDeserialize: deserialize_dapr_proto_runtime_v1_ExecuteActorStateTransactionRequest,
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',
Expand Down
Loading