From e9a069acee7fb1eede1016db058ff737cbadfe60 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sky/=E6=95=96=E5=B0=8F=E5=89=91?= Date: Wed, 10 Feb 2021 05:56:37 +0800 Subject: [PATCH] upgrade protoc from v3.11.2 to v3.14.0 (#141) Co-authored-by: Yaron Schneider --- dapr/proto/common/v1/common.pb.go | 14 +-- dapr/proto/runtime/v1/appcallback.pb.go | 6 +- dapr/proto/runtime/v1/appcallback_grpc.pb.go | 26 ++-- dapr/proto/runtime/v1/dapr.pb.go | 18 +-- dapr/proto/runtime/v1/dapr_grpc.pb.go | 124 +++++++++---------- 5 files changed, 94 insertions(+), 94 deletions(-) diff --git a/dapr/proto/common/v1/common.pb.go b/dapr/proto/common/v1/common.pb.go index d5aa948f..d93ea101 100644 --- a/dapr/proto/common/v1/common.pb.go +++ b/dapr/proto/common/v1/common.pb.go @@ -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 diff --git a/dapr/proto/runtime/v1/appcallback.pb.go b/dapr/proto/runtime/v1/appcallback.pb.go index 8b487504..73cd79fb 100644 --- a/dapr/proto/runtime/v1/appcallback.pb.go +++ b/dapr/proto/runtime/v1/appcallback.pb.go @@ -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{ diff --git a/dapr/proto/runtime/v1/appcallback_grpc.pb.go b/dapr/proto/runtime/v1/appcallback_grpc.pb.go index 9429a43c..a50ffeef 100644 --- a/dapr/proto/runtime/v1/appcallback_grpc.pb.go +++ b/dapr/proto/runtime/v1/appcallback_grpc.pb.go @@ -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) } diff --git a/dapr/proto/runtime/v1/dapr.pb.go b/dapr/proto/runtime/v1/dapr.pb.go index f8fffbf9..c1345885 100644 --- a/dapr/proto/runtime/v1/dapr.pb.go +++ b/dapr/proto/runtime/v1/dapr.pb.go @@ -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{ diff --git a/dapr/proto/runtime/v1/dapr_grpc.pb.go b/dapr/proto/runtime/v1/dapr_grpc.pb.go index 2d1f6d98..90fa8b46 100644 --- a/dapr/proto/runtime/v1/dapr_grpc.pb.go +++ b/dapr/proto/runtime/v1/dapr_grpc.pb.go @@ -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) }