mirror of https://github.com/dapr/go-sdk.git
upgrade protoc from v3.11.2 to v3.14.0 (#141)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
This commit is contained in:
Sky/敖小剑
GitHub
parent
22f00ec23f
commit
e9a069acee
|
|
@ -6,16 +6,16 @@
|
|||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.25.0
|
||||
// protoc v3.11.2
|
||||
// protoc v3.14.0
|
||||
// source: dapr/proto/common/v1/common.proto
|
||||
|
||||
package common
|
||||
|
||||
import (
|
||||
proto "github.com/golang/protobuf/proto"
|
||||
any "github.com/golang/protobuf/ptypes/any"
|
||||
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
||||
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
||||
anypb "google.golang.org/protobuf/types/known/anypb"
|
||||
reflect "reflect"
|
||||
sync "sync"
|
||||
)
|
||||
|
|
@ -276,7 +276,7 @@ type InvokeRequest struct {
|
|||
Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
|
||||
// Required. Bytes value or Protobuf message which caller sent.
|
||||
// Dapr treats Any.value as bytes type if Any.type_url is unset.
|
||||
Data *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
|
||||
Data *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
|
||||
// The type of data content.
|
||||
//
|
||||
// This field is required if data delivers http request body
|
||||
|
|
@ -328,7 +328,7 @@ func (x *InvokeRequest) GetMethod() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *InvokeRequest) GetData() *any.Any {
|
||||
func (x *InvokeRequest) GetData() *anypb.Any {
|
||||
if x != nil {
|
||||
return x.Data
|
||||
}
|
||||
|
|
@ -359,7 +359,7 @@ type InvokeResponse struct {
|
|||
unknownFields protoimpl.UnknownFields
|
||||
|
||||
// Required. The content body of InvokeService response.
|
||||
Data *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
|
||||
Data *anypb.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
|
||||
// Required. The type of data content.
|
||||
ContentType string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
|
||||
}
|
||||
|
|
@ -396,7 +396,7 @@ func (*InvokeResponse) Descriptor() ([]byte, []int) {
|
|||
return file_dapr_proto_common_v1_common_proto_rawDescGZIP(), []int{2}
|
||||
}
|
||||
|
||||
func (x *InvokeResponse) GetData() *any.Any {
|
||||
func (x *InvokeResponse) GetData() *anypb.Any {
|
||||
if x != nil {
|
||||
return x.Data
|
||||
}
|
||||
|
|
@ -730,7 +730,7 @@ var file_dapr_proto_common_v1_common_proto_goTypes = []interface{}{
|
|||
(*StateOptions)(nil), // 8: dapr.proto.common.v1.StateOptions
|
||||
nil, // 9: dapr.proto.common.v1.HTTPExtension.QuerystringEntry
|
||||
nil, // 10: dapr.proto.common.v1.StateItem.MetadataEntry
|
||||
(*any.Any)(nil), // 11: google.protobuf.Any
|
||||
(*anypb.Any)(nil), // 11: google.protobuf.Any
|
||||
}
|
||||
var file_dapr_proto_common_v1_common_proto_depIdxs = []int32{
|
||||
0, // 0: dapr.proto.common.v1.HTTPExtension.verb:type_name -> dapr.proto.common.v1.HTTPExtension.Verb
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.25.0
|
||||
// protoc v3.11.2
|
||||
// protoc v3.14.0
|
||||
// source: dapr/proto/runtime/v1/appcallback.proto
|
||||
|
||||
package runtime
|
||||
|
|
@ -14,9 +14,9 @@ package runtime
|
|||
import (
|
||||
v1 "github.com/dapr/go-sdk/dapr/proto/common/v1"
|
||||
proto "github.com/golang/protobuf/proto"
|
||||
empty "github.com/golang/protobuf/ptypes/empty"
|
||||
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
||||
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
reflect "reflect"
|
||||
sync "sync"
|
||||
)
|
||||
|
|
@ -786,7 +786,7 @@ var file_dapr_proto_runtime_v1_appcallback_proto_goTypes = []interface{}{
|
|||
nil, // 10: dapr.proto.runtime.v1.TopicSubscription.MetadataEntry
|
||||
(*v1.StateItem)(nil), // 11: dapr.proto.common.v1.StateItem
|
||||
(*v1.InvokeRequest)(nil), // 12: dapr.proto.common.v1.InvokeRequest
|
||||
(*empty.Empty)(nil), // 13: google.protobuf.Empty
|
||||
(*emptypb.Empty)(nil), // 13: google.protobuf.Empty
|
||||
(*v1.InvokeResponse)(nil), // 14: dapr.proto.common.v1.InvokeResponse
|
||||
}
|
||||
var file_dapr_proto_runtime_v1_appcallback_proto_depIdxs = []int32{
|
||||
|
|
|
|||
|
|
@ -5,10 +5,10 @@ package runtime
|
|||
import (
|
||||
context "context"
|
||||
v1 "github.com/dapr/go-sdk/dapr/proto/common/v1"
|
||||
empty "github.com/golang/protobuf/ptypes/empty"
|
||||
grpc "google.golang.org/grpc"
|
||||
codes "google.golang.org/grpc/codes"
|
||||
status "google.golang.org/grpc/status"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
)
|
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
|
|
@ -23,11 +23,11 @@ type AppCallbackClient interface {
|
|||
// Invokes service method with InvokeRequest.
|
||||
OnInvoke(ctx context.Context, in *v1.InvokeRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)
|
||||
// Lists all topics subscribed by this app.
|
||||
ListTopicSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
|
||||
ListTopicSubscriptions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
|
||||
// Subscribes events from Pubsub
|
||||
OnTopicEvent(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*TopicEventResponse, error)
|
||||
// Lists all input bindings subscribed by this app.
|
||||
ListInputBindings(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListInputBindingsResponse, error)
|
||||
ListInputBindings(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListInputBindingsResponse, error)
|
||||
// Listens events from the input bindings
|
||||
//
|
||||
// User application can save the states or send the events to the output
|
||||
|
|
@ -52,7 +52,7 @@ func (c *appCallbackClient) OnInvoke(ctx context.Context, in *v1.InvokeRequest,
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *appCallbackClient) ListTopicSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) {
|
||||
func (c *appCallbackClient) ListTopicSubscriptions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) {
|
||||
out := new(ListTopicSubscriptionsResponse)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.AppCallback/ListTopicSubscriptions", in, out, opts...)
|
||||
if err != nil {
|
||||
|
|
@ -70,7 +70,7 @@ func (c *appCallbackClient) OnTopicEvent(ctx context.Context, in *TopicEventRequ
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *appCallbackClient) ListInputBindings(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListInputBindingsResponse, error) {
|
||||
func (c *appCallbackClient) ListInputBindings(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListInputBindingsResponse, error) {
|
||||
out := new(ListInputBindingsResponse)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.AppCallback/ListInputBindings", in, out, opts...)
|
||||
if err != nil {
|
||||
|
|
@ -95,11 +95,11 @@ type AppCallbackServer interface {
|
|||
// Invokes service method with InvokeRequest.
|
||||
OnInvoke(context.Context, *v1.InvokeRequest) (*v1.InvokeResponse, error)
|
||||
// Lists all topics subscribed by this app.
|
||||
ListTopicSubscriptions(context.Context, *empty.Empty) (*ListTopicSubscriptionsResponse, error)
|
||||
ListTopicSubscriptions(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)
|
||||
// Subscribes events from Pubsub
|
||||
OnTopicEvent(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
|
||||
// Lists all input bindings subscribed by this app.
|
||||
ListInputBindings(context.Context, *empty.Empty) (*ListInputBindingsResponse, error)
|
||||
ListInputBindings(context.Context, *emptypb.Empty) (*ListInputBindingsResponse, error)
|
||||
// Listens events from the input bindings
|
||||
//
|
||||
// User application can save the states or send the events to the output
|
||||
|
|
@ -115,13 +115,13 @@ type UnimplementedAppCallbackServer struct {
|
|||
func (UnimplementedAppCallbackServer) OnInvoke(context.Context, *v1.InvokeRequest) (*v1.InvokeResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method OnInvoke not implemented")
|
||||
}
|
||||
func (UnimplementedAppCallbackServer) ListTopicSubscriptions(context.Context, *empty.Empty) (*ListTopicSubscriptionsResponse, error) {
|
||||
func (UnimplementedAppCallbackServer) ListTopicSubscriptions(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListTopicSubscriptions not implemented")
|
||||
}
|
||||
func (UnimplementedAppCallbackServer) OnTopicEvent(context.Context, *TopicEventRequest) (*TopicEventResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method OnTopicEvent not implemented")
|
||||
}
|
||||
func (UnimplementedAppCallbackServer) ListInputBindings(context.Context, *empty.Empty) (*ListInputBindingsResponse, error) {
|
||||
func (UnimplementedAppCallbackServer) ListInputBindings(context.Context, *emptypb.Empty) (*ListInputBindingsResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListInputBindings not implemented")
|
||||
}
|
||||
func (UnimplementedAppCallbackServer) OnBindingEvent(context.Context, *BindingEventRequest) (*BindingEventResponse, error) {
|
||||
|
|
@ -159,7 +159,7 @@ func _AppCallback_OnInvoke_Handler(srv interface{}, ctx context.Context, dec fun
|
|||
}
|
||||
|
||||
func _AppCallback_ListTopicSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -171,7 +171,7 @@ func _AppCallback_ListTopicSubscriptions_Handler(srv interface{}, ctx context.Co
|
|||
FullMethod: "/dapr.proto.runtime.v1.AppCallback/ListTopicSubscriptions",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(AppCallbackServer).ListTopicSubscriptions(ctx, req.(*empty.Empty))
|
||||
return srv.(AppCallbackServer).ListTopicSubscriptions(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
|
@ -195,7 +195,7 @@ func _AppCallback_OnTopicEvent_Handler(srv interface{}, ctx context.Context, dec
|
|||
}
|
||||
|
||||
func _AppCallback_ListInputBindings_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -207,7 +207,7 @@ func _AppCallback_ListInputBindings_Handler(srv interface{}, ctx context.Context
|
|||
FullMethod: "/dapr.proto.runtime.v1.AppCallback/ListInputBindings",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(AppCallbackServer).ListInputBindings(ctx, req.(*empty.Empty))
|
||||
return srv.(AppCallbackServer).ListInputBindings(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.25.0
|
||||
// protoc v3.11.2
|
||||
// protoc v3.14.0
|
||||
// source: dapr/proto/runtime/v1/dapr.proto
|
||||
|
||||
package runtime
|
||||
|
|
@ -14,10 +14,10 @@ package runtime
|
|||
import (
|
||||
v1 "github.com/dapr/go-sdk/dapr/proto/common/v1"
|
||||
proto "github.com/golang/protobuf/proto"
|
||||
any "github.com/golang/protobuf/ptypes/any"
|
||||
empty "github.com/golang/protobuf/ptypes/empty"
|
||||
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
||||
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
||||
anypb "google.golang.org/protobuf/types/known/anypb"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
reflect "reflect"
|
||||
sync "sync"
|
||||
)
|
||||
|
|
@ -1770,9 +1770,9 @@ type TransactionalActorStateOperation struct {
|
|||
sizeCache protoimpl.SizeCache
|
||||
unknownFields protoimpl.UnknownFields
|
||||
|
||||
OperationType string `protobuf:"bytes,1,opt,name=operationType,proto3" json:"operationType,omitempty"`
|
||||
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
|
||||
Value *any.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
|
||||
OperationType string `protobuf:"bytes,1,opt,name=operationType,proto3" json:"operationType,omitempty"`
|
||||
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
|
||||
Value *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
|
||||
}
|
||||
|
||||
func (x *TransactionalActorStateOperation) Reset() {
|
||||
|
|
@ -1821,7 +1821,7 @@ func (x *TransactionalActorStateOperation) GetKey() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *TransactionalActorStateOperation) GetValue() *any.Any {
|
||||
func (x *TransactionalActorStateOperation) GetValue() *anypb.Any {
|
||||
if x != nil {
|
||||
return x.Value
|
||||
}
|
||||
|
|
@ -2762,8 +2762,8 @@ var file_dapr_proto_runtime_v1_dapr_proto_goTypes = []interface{}{
|
|||
(*v1.Etag)(nil), // 50: dapr.proto.common.v1.Etag
|
||||
(*v1.StateOptions)(nil), // 51: dapr.proto.common.v1.StateOptions
|
||||
(*v1.StateItem)(nil), // 52: dapr.proto.common.v1.StateItem
|
||||
(*any.Any)(nil), // 53: google.protobuf.Any
|
||||
(*empty.Empty)(nil), // 54: google.protobuf.Empty
|
||||
(*anypb.Any)(nil), // 53: google.protobuf.Any
|
||||
(*emptypb.Empty)(nil), // 54: google.protobuf.Empty
|
||||
(*v1.InvokeResponse)(nil), // 55: dapr.proto.common.v1.InvokeResponse
|
||||
}
|
||||
var file_dapr_proto_runtime_v1_dapr_proto_depIdxs = []int32{
|
||||
|
|
|
|||
|
|
@ -5,10 +5,10 @@ package runtime
|
|||
import (
|
||||
context "context"
|
||||
v1 "github.com/dapr/go-sdk/dapr/proto/common/v1"
|
||||
empty "github.com/golang/protobuf/ptypes/empty"
|
||||
grpc "google.golang.org/grpc"
|
||||
codes "google.golang.org/grpc/codes"
|
||||
status "google.golang.org/grpc/status"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
)
|
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
|
|
@ -27,15 +27,15 @@ type DaprClient interface {
|
|||
// Gets a bulk of state items for a list of keys
|
||||
GetBulkState(ctx context.Context, in *GetBulkStateRequest, opts ...grpc.CallOption) (*GetBulkStateResponse, error)
|
||||
// Saves the state for a specific key.
|
||||
SaveState(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
SaveState(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Deletes the state for a specific key.
|
||||
DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Deletes a bulk of state items for a list of keys
|
||||
DeleteBulkState(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
DeleteBulkState(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Executes transactions for a specified store
|
||||
ExecuteStateTransaction(ctx context.Context, in *ExecuteStateTransactionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
ExecuteStateTransaction(ctx context.Context, in *ExecuteStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Publishes events to the specific topic.
|
||||
PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Invokes binding data to specific output bindings
|
||||
InvokeBinding(ctx context.Context, in *InvokeBindingRequest, opts ...grpc.CallOption) (*InvokeBindingResponse, error)
|
||||
// Gets secrets from secret stores.
|
||||
|
|
@ -43,23 +43,23 @@ type DaprClient interface {
|
|||
// Gets a bulk of secrets
|
||||
GetBulkSecret(ctx context.Context, in *GetBulkSecretRequest, opts ...grpc.CallOption) (*GetBulkSecretResponse, error)
|
||||
// Register an actor timer.
|
||||
RegisterActorTimer(ctx context.Context, in *RegisterActorTimerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
RegisterActorTimer(ctx context.Context, in *RegisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Unregister an actor timer.
|
||||
UnregisterActorTimer(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
UnregisterActorTimer(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Register an actor reminder.
|
||||
RegisterActorReminder(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
RegisterActorReminder(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Unregister an actor reminder.
|
||||
UnregisterActorReminder(ctx context.Context, in *UnregisterActorReminderRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
UnregisterActorReminder(ctx context.Context, in *UnregisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// Gets the state for a specific actor.
|
||||
GetActorState(ctx context.Context, in *GetActorStateRequest, opts ...grpc.CallOption) (*GetActorStateResponse, error)
|
||||
// Executes state transactions for a specified actor
|
||||
ExecuteActorStateTransaction(ctx context.Context, in *ExecuteActorStateTransactionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
ExecuteActorStateTransaction(ctx context.Context, in *ExecuteActorStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// InvokeActor calls a method on an actor.
|
||||
InvokeActor(ctx context.Context, in *InvokeActorRequest, opts ...grpc.CallOption) (*InvokeActorResponse, error)
|
||||
// Gets metadata of the sidecar
|
||||
GetMetadata(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetMetadataResponse, error)
|
||||
GetMetadata(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMetadataResponse, error)
|
||||
// Sets value in extended metadata of the sidecar
|
||||
SetMetadata(ctx context.Context, in *SetMetadataRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
SetMetadata(ctx context.Context, in *SetMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
}
|
||||
|
||||
type daprClient struct {
|
||||
|
|
@ -97,8 +97,8 @@ func (c *daprClient) GetBulkState(ctx context.Context, in *GetBulkStateRequest,
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) SaveState(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) SaveState(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/SaveState", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -106,8 +106,8 @@ func (c *daprClient) SaveState(ctx context.Context, in *SaveStateRequest, opts .
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/DeleteState", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -115,8 +115,8 @@ func (c *daprClient) DeleteState(ctx context.Context, in *DeleteStateRequest, op
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) DeleteBulkState(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) DeleteBulkState(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/DeleteBulkState", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -124,8 +124,8 @@ func (c *daprClient) DeleteBulkState(ctx context.Context, in *DeleteBulkStateReq
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) ExecuteStateTransaction(ctx context.Context, in *ExecuteStateTransactionRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) ExecuteStateTransaction(ctx context.Context, in *ExecuteStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/ExecuteStateTransaction", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -133,8 +133,8 @@ func (c *daprClient) ExecuteStateTransaction(ctx context.Context, in *ExecuteSta
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/PublishEvent", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -169,8 +169,8 @@ func (c *daprClient) GetBulkSecret(ctx context.Context, in *GetBulkSecretRequest
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) RegisterActorTimer(ctx context.Context, in *RegisterActorTimerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) RegisterActorTimer(ctx context.Context, in *RegisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/RegisterActorTimer", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -178,8 +178,8 @@ func (c *daprClient) RegisterActorTimer(ctx context.Context, in *RegisterActorTi
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) UnregisterActorTimer(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) UnregisterActorTimer(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/UnregisterActorTimer", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -187,8 +187,8 @@ func (c *daprClient) UnregisterActorTimer(ctx context.Context, in *UnregisterAct
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) RegisterActorReminder(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) RegisterActorReminder(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/RegisterActorReminder", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -196,8 +196,8 @@ func (c *daprClient) RegisterActorReminder(ctx context.Context, in *RegisterActo
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) UnregisterActorReminder(ctx context.Context, in *UnregisterActorReminderRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) UnregisterActorReminder(ctx context.Context, in *UnregisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/UnregisterActorReminder", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -214,8 +214,8 @@ func (c *daprClient) GetActorState(ctx context.Context, in *GetActorStateRequest
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) ExecuteActorStateTransaction(ctx context.Context, in *ExecuteActorStateTransactionRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) ExecuteActorStateTransaction(ctx context.Context, in *ExecuteActorStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/ExecuteActorStateTransaction", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -232,7 +232,7 @@ func (c *daprClient) InvokeActor(ctx context.Context, in *InvokeActorRequest, op
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) GetMetadata(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetMetadataResponse, error) {
|
||||
func (c *daprClient) GetMetadata(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMetadataResponse, error) {
|
||||
out := new(GetMetadataResponse)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/GetMetadata", in, out, opts...)
|
||||
if err != nil {
|
||||
|
|
@ -241,8 +241,8 @@ func (c *daprClient) GetMetadata(ctx context.Context, in *empty.Empty, opts ...g
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *daprClient) SetMetadata(ctx context.Context, in *SetMetadataRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *daprClient) SetMetadata(ctx context.Context, in *SetMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/dapr.proto.runtime.v1.Dapr/SetMetadata", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
@ -261,15 +261,15 @@ type DaprServer interface {
|
|||
// Gets a bulk of state items for a list of keys
|
||||
GetBulkState(context.Context, *GetBulkStateRequest) (*GetBulkStateResponse, error)
|
||||
// Saves the state for a specific key.
|
||||
SaveState(context.Context, *SaveStateRequest) (*empty.Empty, error)
|
||||
SaveState(context.Context, *SaveStateRequest) (*emptypb.Empty, error)
|
||||
// Deletes the state for a specific key.
|
||||
DeleteState(context.Context, *DeleteStateRequest) (*empty.Empty, error)
|
||||
DeleteState(context.Context, *DeleteStateRequest) (*emptypb.Empty, error)
|
||||
// Deletes a bulk of state items for a list of keys
|
||||
DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*empty.Empty, error)
|
||||
DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*emptypb.Empty, error)
|
||||
// Executes transactions for a specified store
|
||||
ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*empty.Empty, error)
|
||||
ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*emptypb.Empty, error)
|
||||
// Publishes events to the specific topic.
|
||||
PublishEvent(context.Context, *PublishEventRequest) (*empty.Empty, error)
|
||||
PublishEvent(context.Context, *PublishEventRequest) (*emptypb.Empty, error)
|
||||
// Invokes binding data to specific output bindings
|
||||
InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error)
|
||||
// Gets secrets from secret stores.
|
||||
|
|
@ -277,23 +277,23 @@ type DaprServer interface {
|
|||
// Gets a bulk of secrets
|
||||
GetBulkSecret(context.Context, *GetBulkSecretRequest) (*GetBulkSecretResponse, error)
|
||||
// Register an actor timer.
|
||||
RegisterActorTimer(context.Context, *RegisterActorTimerRequest) (*empty.Empty, error)
|
||||
RegisterActorTimer(context.Context, *RegisterActorTimerRequest) (*emptypb.Empty, error)
|
||||
// Unregister an actor timer.
|
||||
UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*empty.Empty, error)
|
||||
UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*emptypb.Empty, error)
|
||||
// Register an actor reminder.
|
||||
RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*empty.Empty, error)
|
||||
RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*emptypb.Empty, error)
|
||||
// Unregister an actor reminder.
|
||||
UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*empty.Empty, error)
|
||||
UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*emptypb.Empty, error)
|
||||
// Gets the state for a specific actor.
|
||||
GetActorState(context.Context, *GetActorStateRequest) (*GetActorStateResponse, error)
|
||||
// Executes state transactions for a specified actor
|
||||
ExecuteActorStateTransaction(context.Context, *ExecuteActorStateTransactionRequest) (*empty.Empty, error)
|
||||
ExecuteActorStateTransaction(context.Context, *ExecuteActorStateTransactionRequest) (*emptypb.Empty, error)
|
||||
// InvokeActor calls a method on an actor.
|
||||
InvokeActor(context.Context, *InvokeActorRequest) (*InvokeActorResponse, error)
|
||||
// Gets metadata of the sidecar
|
||||
GetMetadata(context.Context, *empty.Empty) (*GetMetadataResponse, error)
|
||||
GetMetadata(context.Context, *emptypb.Empty) (*GetMetadataResponse, error)
|
||||
// Sets value in extended metadata of the sidecar
|
||||
SetMetadata(context.Context, *SetMetadataRequest) (*empty.Empty, error)
|
||||
SetMetadata(context.Context, *SetMetadataRequest) (*emptypb.Empty, error)
|
||||
mustEmbedUnimplementedDaprServer()
|
||||
}
|
||||
|
||||
|
|
@ -310,19 +310,19 @@ func (UnimplementedDaprServer) GetState(context.Context, *GetStateRequest) (*Get
|
|||
func (UnimplementedDaprServer) GetBulkState(context.Context, *GetBulkStateRequest) (*GetBulkStateResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetBulkState not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) SaveState(context.Context, *SaveStateRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) SaveState(context.Context, *SaveStateRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method SaveState not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) DeleteState(context.Context, *DeleteStateRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) DeleteState(context.Context, *DeleteStateRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method DeleteState not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method DeleteBulkState not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ExecuteStateTransaction not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) PublishEvent(context.Context, *PublishEventRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) PublishEvent(context.Context, *PublishEventRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method PublishEvent not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error) {
|
||||
|
|
@ -334,31 +334,31 @@ func (UnimplementedDaprServer) GetSecret(context.Context, *GetSecretRequest) (*G
|
|||
func (UnimplementedDaprServer) GetBulkSecret(context.Context, *GetBulkSecretRequest) (*GetBulkSecretResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetBulkSecret not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) RegisterActorTimer(context.Context, *RegisterActorTimerRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) RegisterActorTimer(context.Context, *RegisterActorTimerRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method RegisterActorTimer not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method UnregisterActorTimer not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method RegisterActorReminder not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method UnregisterActorReminder not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) GetActorState(context.Context, *GetActorStateRequest) (*GetActorStateResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetActorState not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) ExecuteActorStateTransaction(context.Context, *ExecuteActorStateTransactionRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) ExecuteActorStateTransaction(context.Context, *ExecuteActorStateTransactionRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ExecuteActorStateTransaction not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) InvokeActor(context.Context, *InvokeActorRequest) (*InvokeActorResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method InvokeActor not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) GetMetadata(context.Context, *empty.Empty) (*GetMetadataResponse, error) {
|
||||
func (UnimplementedDaprServer) GetMetadata(context.Context, *emptypb.Empty) (*GetMetadataResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetMetadata not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) SetMetadata(context.Context, *SetMetadataRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedDaprServer) SetMetadata(context.Context, *SetMetadataRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method SetMetadata not implemented")
|
||||
}
|
||||
func (UnimplementedDaprServer) mustEmbedUnimplementedDaprServer() {}
|
||||
|
|
@ -699,7 +699,7 @@ func _Dapr_InvokeActor_Handler(srv interface{}, ctx context.Context, dec func(in
|
|||
}
|
||||
|
||||
func _Dapr_GetMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -711,7 +711,7 @@ func _Dapr_GetMetadata_Handler(srv interface{}, ctx context.Context, dec func(in
|
|||
FullMethod: "/dapr.proto.runtime.v1.Dapr/GetMetadata",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(DaprServer).GetMetadata(ctx, req.(*empty.Empty))
|
||||
return srv.(DaprServer).GetMetadata(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue