diff --git a/googleapis b/googleapis index faa3bda..ae73675 160000 --- a/googleapis +++ b/googleapis @@ -1 +1 @@ -Subproject commit faa3bdad6e01e6a012727f96f79d1576156b3227 +Subproject commit ae73675c503a14affb9fd3dcc347e8e398f9a9a4 diff --git a/manager/v1/manager.pb.go b/manager/v1/manager.pb.go index 85bcf0b..2a1c883 100644 --- a/manager/v1/manager.pb.go +++ b/manager/v1/manager.pb.go @@ -1,15 +1,15 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.28.1 -// protoc v3.21.12 +// protoc-gen-go v1.31.0 +// protoc v3.12.4 // source: proto/vatz/manager/v1/manager.proto package v1 import ( + _struct "github.com/golang/protobuf/ptypes/struct" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" - structpb "google.golang.org/protobuf/types/known/structpb" reflect "reflect" sync "sync" ) @@ -132,11 +132,11 @@ type InitRequest struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` - Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` - Version float32 `protobuf:"fixed32,4,opt,name=version,proto3" json:"version,omitempty"` // version >< revision 때문에 정확한 타입지정이 필요 - Option *structpb.Struct `protobuf:"bytes,5,opt,name=option,proto3" json:"option,omitempty"` // mapType 변환 + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` + Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` + Version float32 `protobuf:"fixed32,4,opt,name=version,proto3" json:"version,omitempty"` // version >< revision 때문에 정확한 타입지정이 필요 + Option *_struct.Struct `protobuf:"bytes,5,opt,name=option,proto3" json:"option,omitempty"` // mapType 변환 } func (x *InitRequest) Reset() { @@ -199,7 +199,7 @@ func (x *InitRequest) GetVersion() float32 { return 0 } -func (x *InitRequest) GetOption() *structpb.Struct { +func (x *InitRequest) GetOption() *_struct.Struct { if x != nil { return x.Option } @@ -211,8 +211,8 @@ type InitResponse struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Result CommandStatus `protobuf:"varint,1,opt,name=result,proto3,enum=vatz.manager.CommandStatus" json:"result,omitempty"` - Metadata *structpb.Struct `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` + Result CommandStatus `protobuf:"varint,1,opt,name=result,proto3,enum=vatz.manager.CommandStatus" json:"result,omitempty"` + Metadata *_struct.Struct `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` } func (x *InitResponse) Reset() { @@ -254,7 +254,7 @@ func (x *InitResponse) GetResult() CommandStatus { return CommandStatus_SUCCESS } -func (x *InitResponse) GetMetadata() *structpb.Struct { +func (x *InitResponse) GetMetadata() *_struct.Struct { if x != nil { return x.Metadata } @@ -266,7 +266,7 @@ type VerifyRequest struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Options *structpb.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"` + Options *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"` } func (x *VerifyRequest) Reset() { @@ -301,7 +301,7 @@ func (*VerifyRequest) Descriptor() ([]byte, []int) { return file_proto_vatz_manager_v1_manager_proto_rawDescGZIP(), []int{2} } -func (x *VerifyRequest) GetOptions() *structpb.Struct { +func (x *VerifyRequest) GetOptions() *_struct.Struct { if x != nil { return x.Options } @@ -360,7 +360,7 @@ type EndRequest struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Metadata *structpb.Struct `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` + Metadata *_struct.Struct `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` } func (x *EndRequest) Reset() { @@ -395,7 +395,7 @@ func (*EndRequest) Descriptor() ([]byte, []int) { return file_proto_vatz_manager_v1_manager_proto_rawDescGZIP(), []int{4} } -func (x *EndRequest) GetMetadata() *structpb.Struct { +func (x *EndRequest) GetMetadata() *_struct.Struct { if x != nil { return x.Metadata } @@ -455,9 +455,9 @@ type ExecuteRequest struct { unknownFields protoimpl.UnknownFields // is_required: true - TargetInfo *structpb.Struct `protobuf:"bytes,1,opt,name=target_info,json=targetInfo,proto3" json:"target_info,omitempty"` + TargetInfo *_struct.Struct `protobuf:"bytes,1,opt,name=target_info,json=targetInfo,proto3" json:"target_info,omitempty"` // is_required: true - Command *structpb.Struct `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"` + Command *_struct.Struct `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"` } func (x *ExecuteRequest) Reset() { @@ -492,14 +492,14 @@ func (*ExecuteRequest) Descriptor() ([]byte, []int) { return file_proto_vatz_manager_v1_manager_proto_rawDescGZIP(), []int{6} } -func (x *ExecuteRequest) GetTargetInfo() *structpb.Struct { +func (x *ExecuteRequest) GetTargetInfo() *_struct.Struct { if x != nil { return x.TargetInfo } return nil } -func (x *ExecuteRequest) GetCommand() *structpb.Struct { +func (x *ExecuteRequest) GetCommand() *_struct.Struct { if x != nil { return x.Command } @@ -514,7 +514,7 @@ type ExecuteResponse struct { State ExecuteResponse_State `protobuf:"varint,1,opt,name=state,proto3,enum=vatz.manager.ExecuteResponse_State" json:"state,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` - Options *structpb.Struct `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"` + Options *_struct.Struct `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"` } func (x *ExecuteResponse) Reset() { @@ -570,7 +570,7 @@ func (x *ExecuteResponse) GetProtocol() string { return "" } -func (x *ExecuteResponse) GetOptions() *structpb.Struct { +func (x *ExecuteResponse) GetOptions() *_struct.Struct { if x != nil { return x.Options } @@ -778,7 +778,7 @@ var file_proto_vatz_manager_v1_manager_proto_goTypes = []interface{}{ (*ExecuteResponse)(nil), // 9: vatz.manager.ExecuteResponse (*UpdateRequest)(nil), // 10: vatz.manager.UpdateRequest (*UpdateResponse)(nil), // 11: vatz.manager.UpdateResponse - (*structpb.Struct)(nil), // 12: google.protobuf.Struct + (*_struct.Struct)(nil), // 12: google.protobuf.Struct } var file_proto_vatz_manager_v1_manager_proto_depIdxs = []int32{ 12, // 0: vatz.manager.InitRequest.option:type_name -> google.protobuf.Struct diff --git a/manager/v1/manager_grpc.pb.go b/manager/v1/manager_grpc.pb.go index fcae72c..32a064d 100644 --- a/manager/v1/manager_grpc.pb.go +++ b/manager/v1/manager_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 -// - protoc v3.21.12 +// - protoc-gen-go-grpc v1.3.0 +// - protoc v3.12.4 // source: proto/vatz/manager/v1/manager.proto package v1 @@ -18,6 +18,14 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Manager_Init_FullMethodName = "/vatz.manager.Manager/Init" + Manager_Verify_FullMethodName = "/vatz.manager.Manager/Verify" + Manager_End_FullMethodName = "/vatz.manager.Manager/End" + Manager_Execute_FullMethodName = "/vatz.manager.Manager/Execute" + Manager_UpdateConfig_FullMethodName = "/vatz.manager.Manager/UpdateConfig" +) + // ManagerClient is the client API for Manager service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -39,7 +47,7 @@ func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient { func (c *managerClient) Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error) { out := new(InitResponse) - err := c.cc.Invoke(ctx, "/vatz.manager.Manager/Init", in, out, opts...) + err := c.cc.Invoke(ctx, Manager_Init_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -48,7 +56,7 @@ func (c *managerClient) Init(ctx context.Context, in *InitRequest, opts ...grpc. func (c *managerClient) Verify(ctx context.Context, in *VerifyRequest, opts ...grpc.CallOption) (*VerifyInfo, error) { out := new(VerifyInfo) - err := c.cc.Invoke(ctx, "/vatz.manager.Manager/Verify", in, out, opts...) + err := c.cc.Invoke(ctx, Manager_Verify_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -57,7 +65,7 @@ func (c *managerClient) Verify(ctx context.Context, in *VerifyRequest, opts ...g func (c *managerClient) End(ctx context.Context, in *EndRequest, opts ...grpc.CallOption) (*EndResponse, error) { out := new(EndResponse) - err := c.cc.Invoke(ctx, "/vatz.manager.Manager/End", in, out, opts...) + err := c.cc.Invoke(ctx, Manager_End_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -66,7 +74,7 @@ func (c *managerClient) End(ctx context.Context, in *EndRequest, opts ...grpc.Ca func (c *managerClient) Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) { out := new(ExecuteResponse) - err := c.cc.Invoke(ctx, "/vatz.manager.Manager/Execute", in, out, opts...) + err := c.cc.Invoke(ctx, Manager_Execute_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -75,7 +83,7 @@ func (c *managerClient) Execute(ctx context.Context, in *ExecuteRequest, opts .. func (c *managerClient) UpdateConfig(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) { out := new(UpdateResponse) - err := c.cc.Invoke(ctx, "/vatz.manager.Manager/UpdateConfig", in, out, opts...) + err := c.cc.Invoke(ctx, Manager_UpdateConfig_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -136,7 +144,7 @@ func _Manager_Init_Handler(srv interface{}, ctx context.Context, dec func(interf } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.manager.Manager/Init", + FullMethod: Manager_Init_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagerServer).Init(ctx, req.(*InitRequest)) @@ -154,7 +162,7 @@ func _Manager_Verify_Handler(srv interface{}, ctx context.Context, dec func(inte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.manager.Manager/Verify", + FullMethod: Manager_Verify_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagerServer).Verify(ctx, req.(*VerifyRequest)) @@ -172,7 +180,7 @@ func _Manager_End_Handler(srv interface{}, ctx context.Context, dec func(interfa } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.manager.Manager/End", + FullMethod: Manager_End_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagerServer).End(ctx, req.(*EndRequest)) @@ -190,7 +198,7 @@ func _Manager_Execute_Handler(srv interface{}, ctx context.Context, dec func(int } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.manager.Manager/Execute", + FullMethod: Manager_Execute_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagerServer).Execute(ctx, req.(*ExecuteRequest)) @@ -208,7 +216,7 @@ func _Manager_UpdateConfig_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.manager.Manager/UpdateConfig", + FullMethod: Manager_UpdateConfig_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagerServer).UpdateConfig(ctx, req.(*UpdateRequest)) diff --git a/plugin/v1/plugin.pb.go b/plugin/v1/plugin.pb.go index e802d47..73fc4eb 100644 --- a/plugin/v1/plugin.pb.go +++ b/plugin/v1/plugin.pb.go @@ -1,16 +1,16 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.28.1 -// protoc v3.21.12 +// protoc-gen-go v1.31.0 +// protoc v3.12.4 // source: proto/vatz/plugin/v1/plugin.proto package v1 import ( + empty "github.com/golang/protobuf/ptypes/empty" + _struct "github.com/golang/protobuf/ptypes/struct" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" - emptypb "google.golang.org/protobuf/types/known/emptypb" - structpb "google.golang.org/protobuf/types/known/structpb" reflect "reflect" sync "sync" ) @@ -187,9 +187,9 @@ type ExecuteRequest struct { unknownFields protoimpl.UnknownFields // is_required: True - ExecuteInfo *structpb.Struct `protobuf:"bytes,1,opt,name=execute_info,json=executeInfo,proto3" json:"execute_info,omitempty"` + ExecuteInfo *_struct.Struct `protobuf:"bytes,1,opt,name=execute_info,json=executeInfo,proto3" json:"execute_info,omitempty"` // is_required: True - Options *structpb.Struct `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` + Options *_struct.Struct `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` } func (x *ExecuteRequest) Reset() { @@ -224,14 +224,14 @@ func (*ExecuteRequest) Descriptor() ([]byte, []int) { return file_proto_vatz_plugin_v1_plugin_proto_rawDescGZIP(), []int{0} } -func (x *ExecuteRequest) GetExecuteInfo() *structpb.Struct { +func (x *ExecuteRequest) GetExecuteInfo() *_struct.Struct { if x != nil { return x.ExecuteInfo } return nil } -func (x *ExecuteRequest) GetOptions() *structpb.Struct { +func (x *ExecuteRequest) GetOptions() *_struct.Struct { if x != nil { return x.Options } @@ -245,7 +245,7 @@ type ExecuteResponse struct { State STATE `protobuf:"varint,1,opt,name=state,proto3,enum=vatz.plugin.STATE" json:"state,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` - // Deprecated: Do not use. + // Deprecated: Marked as deprecated in proto/vatz/plugin/v1/plugin.proto. AlertType []ALERT_TYPE `protobuf:"varint,3,rep,packed,name=alert_type,json=alertType,proto3,enum=vatz.plugin.ALERT_TYPE" json:"alert_type,omitempty"` Severity SEVERITY `protobuf:"varint,4,opt,name=severity,proto3,enum=vatz.plugin.SEVERITY" json:"severity,omitempty"` ResourceType string `protobuf:"bytes,5,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"` @@ -297,7 +297,7 @@ func (x *ExecuteResponse) GetMessage() string { return "" } -// Deprecated: Do not use. +// Deprecated: Marked as deprecated in proto/vatz/plugin/v1/plugin.proto. func (x *ExecuteResponse) GetAlertType() []ALERT_TYPE { if x != nil { return x.AlertType @@ -324,7 +324,7 @@ type CollectorVerifyInfo struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Options *structpb.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"` + Options *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"` } func (x *CollectorVerifyInfo) Reset() { @@ -359,7 +359,7 @@ func (*CollectorVerifyInfo) Descriptor() ([]byte, []int) { return file_proto_vatz_plugin_v1_plugin_proto_rawDescGZIP(), []int{2} } -func (x *CollectorVerifyInfo) GetOptions() *structpb.Struct { +func (x *CollectorVerifyInfo) GetOptions() *_struct.Struct { if x != nil { return x.Options } @@ -500,8 +500,8 @@ var file_proto_vatz_plugin_v1_plugin_proto_goTypes = []interface{}{ (*ExecuteResponse)(nil), // 4: vatz.plugin.ExecuteResponse (*CollectorVerifyInfo)(nil), // 5: vatz.plugin.CollectorVerifyInfo (*VerifyInfo)(nil), // 6: vatz.plugin.VerifyInfo - (*structpb.Struct)(nil), // 7: google.protobuf.Struct - (*emptypb.Empty)(nil), // 8: google.protobuf.Empty + (*_struct.Struct)(nil), // 7: google.protobuf.Struct + (*empty.Empty)(nil), // 8: google.protobuf.Empty } var file_proto_vatz_plugin_v1_plugin_proto_depIdxs = []int32{ 7, // 0: vatz.plugin.ExecuteRequest.execute_info:type_name -> google.protobuf.Struct diff --git a/plugin/v1/plugin_grpc.pb.go b/plugin/v1/plugin_grpc.pb.go index 019509f..dddf869 100644 --- a/plugin/v1/plugin_grpc.pb.go +++ b/plugin/v1/plugin_grpc.pb.go @@ -1,17 +1,17 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 -// - protoc v3.21.12 +// - protoc-gen-go-grpc v1.3.0 +// - protoc v3.12.4 // source: proto/vatz/plugin/v1/plugin.proto package v1 import ( context "context" + 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 @@ -19,11 +19,16 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Plugin_Verify_FullMethodName = "/vatz.plugin.Plugin/verify" + Plugin_Execute_FullMethodName = "/vatz.plugin.Plugin/execute" +) + // PluginClient is the client API for Plugin service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type PluginClient interface { - Verify(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VerifyInfo, error) + Verify(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VerifyInfo, error) Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) } @@ -35,9 +40,9 @@ func NewPluginClient(cc grpc.ClientConnInterface) PluginClient { return &pluginClient{cc} } -func (c *pluginClient) Verify(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VerifyInfo, error) { +func (c *pluginClient) Verify(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VerifyInfo, error) { out := new(VerifyInfo) - err := c.cc.Invoke(ctx, "/vatz.plugin.Plugin/verify", in, out, opts...) + err := c.cc.Invoke(ctx, Plugin_Verify_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -46,7 +51,7 @@ func (c *pluginClient) Verify(ctx context.Context, in *emptypb.Empty, opts ...gr func (c *pluginClient) Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) { out := new(ExecuteResponse) - err := c.cc.Invoke(ctx, "/vatz.plugin.Plugin/execute", in, out, opts...) + err := c.cc.Invoke(ctx, Plugin_Execute_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -57,7 +62,7 @@ func (c *pluginClient) Execute(ctx context.Context, in *ExecuteRequest, opts ... // All implementations must embed UnimplementedPluginServer // for forward compatibility type PluginServer interface { - Verify(context.Context, *emptypb.Empty) (*VerifyInfo, error) + Verify(context.Context, *empty.Empty) (*VerifyInfo, error) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) mustEmbedUnimplementedPluginServer() } @@ -66,7 +71,7 @@ type PluginServer interface { type UnimplementedPluginServer struct { } -func (UnimplementedPluginServer) Verify(context.Context, *emptypb.Empty) (*VerifyInfo, error) { +func (UnimplementedPluginServer) Verify(context.Context, *empty.Empty) (*VerifyInfo, error) { return nil, status.Errorf(codes.Unimplemented, "method Verify not implemented") } func (UnimplementedPluginServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) { @@ -86,7 +91,7 @@ func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer) { } func _Plugin_Verify_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(emptypb.Empty) + in := new(empty.Empty) if err := dec(in); err != nil { return nil, err } @@ -95,10 +100,10 @@ func _Plugin_Verify_Handler(srv interface{}, ctx context.Context, dec func(inter } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.plugin.Plugin/verify", + FullMethod: Plugin_Verify_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(PluginServer).Verify(ctx, req.(*emptypb.Empty)) + return srv.(PluginServer).Verify(ctx, req.(*empty.Empty)) } return interceptor(ctx, in, info, handler) } @@ -113,7 +118,7 @@ func _Plugin_Execute_Handler(srv interface{}, ctx context.Context, dec func(inte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.plugin.Plugin/execute", + FullMethod: Plugin_Execute_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PluginServer).Execute(ctx, req.(*ExecuteRequest)) diff --git a/rpc/v1/rpc.pb.go b/rpc/v1/rpc.pb.go index 28e85f1..2eb933c 100644 --- a/rpc/v1/rpc.pb.go +++ b/rpc/v1/rpc.pb.go @@ -1,17 +1,17 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.28.1 -// protoc v3.21.12 +// protoc-gen-go v1.31.0 +// protoc v3.12.4 // source: proto/vatz/rpc/v1/rpc.proto package v1 import ( + _ "github.com/golang/protobuf/protoc-gen-go/descriptor" + empty "github.com/golang/protobuf/ptypes/empty" _ "google.golang.org/genproto/googleapis/api/annotations" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" - _ "google.golang.org/protobuf/types/descriptorpb" - emptypb "google.golang.org/protobuf/types/known/emptypb" reflect "reflect" sync "sync" ) @@ -234,7 +234,7 @@ var file_proto_vatz_rpc_v1_rpc_proto_goTypes = []interface{}{ (Status)(0), // 0: vatz.rpc.Status (*PluginStatusResponse)(nil), // 1: vatz.rpc.PluginStatusResponse (*PluginStatus)(nil), // 2: vatz.rpc.PluginStatus - (*emptypb.Empty)(nil), // 3: google.protobuf.Empty + (*empty.Empty)(nil), // 3: google.protobuf.Empty } var file_proto_vatz_rpc_v1_rpc_proto_depIdxs = []int32{ 0, // 0: vatz.rpc.PluginStatusResponse.status:type_name -> vatz.rpc.Status diff --git a/rpc/v1/rpc_grpc.pb.go b/rpc/v1/rpc_grpc.pb.go index 3f48184..50560b6 100644 --- a/rpc/v1/rpc_grpc.pb.go +++ b/rpc/v1/rpc_grpc.pb.go @@ -1,17 +1,17 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 -// - protoc v3.21.12 +// - protoc-gen-go-grpc v1.3.0 +// - protoc v3.12.4 // source: proto/vatz/rpc/v1/rpc.proto package v1 import ( context "context" + 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 @@ -19,11 +19,15 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + VatzRPC_PluginStatus_FullMethodName = "/vatz.rpc.VatzRPC/PluginStatus" +) + // VatzRPCClient is the client API for VatzRPC service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type VatzRPCClient interface { - PluginStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PluginStatusResponse, error) + PluginStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PluginStatusResponse, error) } type vatzRPCClient struct { @@ -34,9 +38,9 @@ func NewVatzRPCClient(cc grpc.ClientConnInterface) VatzRPCClient { return &vatzRPCClient{cc} } -func (c *vatzRPCClient) PluginStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PluginStatusResponse, error) { +func (c *vatzRPCClient) PluginStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PluginStatusResponse, error) { out := new(PluginStatusResponse) - err := c.cc.Invoke(ctx, "/vatz.rpc.VatzRPC/PluginStatus", in, out, opts...) + err := c.cc.Invoke(ctx, VatzRPC_PluginStatus_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -47,7 +51,7 @@ func (c *vatzRPCClient) PluginStatus(ctx context.Context, in *emptypb.Empty, opt // All implementations must embed UnimplementedVatzRPCServer // for forward compatibility type VatzRPCServer interface { - PluginStatus(context.Context, *emptypb.Empty) (*PluginStatusResponse, error) + PluginStatus(context.Context, *empty.Empty) (*PluginStatusResponse, error) mustEmbedUnimplementedVatzRPCServer() } @@ -55,7 +59,7 @@ type VatzRPCServer interface { type UnimplementedVatzRPCServer struct { } -func (UnimplementedVatzRPCServer) PluginStatus(context.Context, *emptypb.Empty) (*PluginStatusResponse, error) { +func (UnimplementedVatzRPCServer) PluginStatus(context.Context, *empty.Empty) (*PluginStatusResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method PluginStatus not implemented") } func (UnimplementedVatzRPCServer) mustEmbedUnimplementedVatzRPCServer() {} @@ -72,7 +76,7 @@ func RegisterVatzRPCServer(s grpc.ServiceRegistrar, srv VatzRPCServer) { } func _VatzRPC_PluginStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(emptypb.Empty) + in := new(empty.Empty) if err := dec(in); err != nil { return nil, err } @@ -81,10 +85,10 @@ func _VatzRPC_PluginStatus_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/vatz.rpc.VatzRPC/PluginStatus", + FullMethod: VatzRPC_PluginStatus_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(VatzRPCServer).PluginStatus(ctx, req.(*emptypb.Empty)) + return srv.(VatzRPCServer).PluginStatus(ctx, req.(*empty.Empty)) } return interceptor(ctx, in, info, handler) }