diff --git a/build/rpc.json b/build/rpc.json index 9012976..efd7ded 100644 --- a/build/rpc.json +++ b/build/rpc.json @@ -5595,7 +5595,9 @@ "responseMessageName": "FindNodeHTTPCCPoliciesResponse", "code": "rpc findNodeHTTPCCPolicies(FindNodeHTTPCCPoliciesRequest) returns (FindNodeHTTPCCPoliciesResponse);", "doc": "查找节点的HTTP CC策略", - "roles": [], + "roles": [ + "node" + ], "isDeprecated": false }, { @@ -5736,6 +5738,17 @@ "admin" ], "isDeprecated": false + }, + { + "name": "updateNodeActionOrders", + "requestMessageName": "UpdateNodeActionOrdersRequest", + "responseMessageName": "RPCSuccess", + "code": "rpc updateNodeActionOrders(UpdateNodeActionOrdersRequest) returns (RPCSuccess);", + "doc": "设置节点动作排序", + "roles": [ + "admin" + ], + "isDeprecated": false } ], "filename": "service_node_action.proto", @@ -21952,6 +21965,11 @@ "code": "message UpdateNodeAPIConfigRequest {\n\tint64 nodeId = 1;\n\tbytes apiNodeAddrsJSON = 2;\n}", "doc": "修改某个节点的API相关配置" }, + { + "name": "UpdateNodeActionOrdersRequest", + "code": "message UpdateNodeActionOrdersRequest {\n\trepeated int64 nodeActionIds = 1; // 节点动作ID列表\n}", + "doc": "设置节点动作排序" + }, { "name": "UpdateNodeActionRequest", "code": "message UpdateNodeActionRequest {\n\tint64 nodeActionId = 1; // 动作ID\n\tbytes condsJSON = 2;\n\tbytes actionJSON = 3;\n\tbytes durationJSON = 4; // 持续时间\n\tbool isOn = 5; // 是否启用\n}", diff --git a/pkg/rpc/pb/service_node_action.pb.go b/pkg/rpc/pb/service_node_action.pb.go index 34441d3..11758d4 100644 --- a/pkg/rpc/pb/service_node_action.pb.go +++ b/pkg/rpc/pb/service_node_action.pb.go @@ -482,6 +482,54 @@ func (x *FindNodeActionResponse) GetNodeAction() *NodeAction { return nil } +// 设置节点动作排序 +type UpdateNodeActionOrdersRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + NodeActionIds []int64 `protobuf:"varint,1,rep,packed,name=nodeActionIds,proto3" json:"nodeActionIds,omitempty"` // 节点动作ID列表 +} + +func (x *UpdateNodeActionOrdersRequest) Reset() { + *x = UpdateNodeActionOrdersRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_service_node_action_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *UpdateNodeActionOrdersRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*UpdateNodeActionOrdersRequest) ProtoMessage() {} + +func (x *UpdateNodeActionOrdersRequest) ProtoReflect() protoreflect.Message { + mi := &file_service_node_action_proto_msgTypes[8] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use UpdateNodeActionOrdersRequest.ProtoReflect.Descriptor instead. +func (*UpdateNodeActionOrdersRequest) Descriptor() ([]byte, []int) { + return file_service_node_action_proto_rawDescGZIP(), []int{8} +} + +func (x *UpdateNodeActionOrdersRequest) GetNodeActionIds() []int64 { + if x != nil { + return x.NodeActionIds + } + return nil +} + var File_service_node_action_proto protoreflect.FileDescriptor var file_service_node_action_proto_rawDesc = []byte{ @@ -538,32 +586,42 @@ var file_service_node_action_proto_rawDesc = []byte{ 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2e, 0x0a, 0x0a, 0x6e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x6e, - 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x32, 0x82, 0x03, 0x0a, 0x11, 0x4e, 0x6f, - 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, - 0x4d, 0x0a, 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, - 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, - 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x1a, 0x1c, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, - 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3f, - 0x0a, 0x10, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, - 0x6f, 0x6e, 0x12, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, - 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, - 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x52, 0x50, 0x43, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, - 0x3f, 0x0a, 0x10, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, - 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, - 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x1a, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x52, 0x50, 0x43, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, - 0x12, 0x53, 0x0a, 0x12, 0x66, 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x4e, 0x6f, 0x64, 0x65, 0x41, - 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x1d, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, - 0x41, 0x6c, 0x6c, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x41, - 0x6c, 0x6c, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x47, 0x0a, 0x0e, 0x66, 0x69, 0x6e, 0x64, 0x4e, 0x6f, 0x64, - 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x19, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, - 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x4e, 0x6f, 0x64, 0x65, - 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x06, - 0x5a, 0x04, 0x2e, 0x2f, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x45, 0x0a, 0x1d, 0x55, 0x70, 0x64, + 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x72, 0x64, + 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x24, 0x0a, 0x0d, 0x6e, 0x6f, + 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, + 0x03, 0x52, 0x0d, 0x6e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x73, + 0x32, 0xcf, 0x03, 0x0a, 0x11, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x53, + 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x4d, 0x0a, 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, + 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x2e, 0x70, 0x62, 0x2e, + 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x72, 0x65, + 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3f, 0x0a, 0x10, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, + 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x44, + 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x52, 0x50, 0x43, 0x53, + 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x3f, 0x0a, 0x10, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, + 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x2e, 0x70, 0x62, 0x2e, + 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x52, 0x50, 0x43, + 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x53, 0x0a, 0x12, 0x66, 0x69, 0x6e, 0x64, 0x41, + 0x6c, 0x6c, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x1d, 0x2e, + 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, + 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, + 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, + 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x47, 0x0a, 0x0e, + 0x66, 0x69, 0x6e, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x19, + 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, + 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x46, + 0x69, 0x6e, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x16, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, + 0x6f, 0x64, 0x65, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x73, 0x12, + 0x21, 0x2e, 0x70, 0x62, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x41, + 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x52, 0x50, 0x43, 0x53, 0x75, 0x63, 0x63, 0x65, + 0x73, 0x73, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x2f, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x33, } var ( @@ -578,37 +636,40 @@ func file_service_node_action_proto_rawDescGZIP() []byte { return file_service_node_action_proto_rawDescData } -var file_service_node_action_proto_msgTypes = make([]protoimpl.MessageInfo, 8) +var file_service_node_action_proto_msgTypes = make([]protoimpl.MessageInfo, 9) var file_service_node_action_proto_goTypes = []interface{}{ - (*CreateNodeActionRequest)(nil), // 0: pb.CreateNodeActionRequest - (*CreateNodeActionResponse)(nil), // 1: pb.CreateNodeActionResponse - (*DeleteNodeActionRequest)(nil), // 2: pb.DeleteNodeActionRequest - (*UpdateNodeActionRequest)(nil), // 3: pb.UpdateNodeActionRequest - (*FindAllNodeActionsRequest)(nil), // 4: pb.FindAllNodeActionsRequest - (*FindAllNodeActionsResponse)(nil), // 5: pb.FindAllNodeActionsResponse - (*FindNodeActionRequest)(nil), // 6: pb.FindNodeActionRequest - (*FindNodeActionResponse)(nil), // 7: pb.FindNodeActionResponse - (*NodeAction)(nil), // 8: pb.NodeAction - (*RPCSuccess)(nil), // 9: pb.RPCSuccess + (*CreateNodeActionRequest)(nil), // 0: pb.CreateNodeActionRequest + (*CreateNodeActionResponse)(nil), // 1: pb.CreateNodeActionResponse + (*DeleteNodeActionRequest)(nil), // 2: pb.DeleteNodeActionRequest + (*UpdateNodeActionRequest)(nil), // 3: pb.UpdateNodeActionRequest + (*FindAllNodeActionsRequest)(nil), // 4: pb.FindAllNodeActionsRequest + (*FindAllNodeActionsResponse)(nil), // 5: pb.FindAllNodeActionsResponse + (*FindNodeActionRequest)(nil), // 6: pb.FindNodeActionRequest + (*FindNodeActionResponse)(nil), // 7: pb.FindNodeActionResponse + (*UpdateNodeActionOrdersRequest)(nil), // 8: pb.UpdateNodeActionOrdersRequest + (*NodeAction)(nil), // 9: pb.NodeAction + (*RPCSuccess)(nil), // 10: pb.RPCSuccess } var file_service_node_action_proto_depIdxs = []int32{ - 8, // 0: pb.FindAllNodeActionsResponse.nodeActions:type_name -> pb.NodeAction - 8, // 1: pb.FindNodeActionResponse.nodeAction:type_name -> pb.NodeAction - 0, // 2: pb.NodeActionService.createNodeAction:input_type -> pb.CreateNodeActionRequest - 2, // 3: pb.NodeActionService.deleteNodeAction:input_type -> pb.DeleteNodeActionRequest - 3, // 4: pb.NodeActionService.updateNodeAction:input_type -> pb.UpdateNodeActionRequest - 4, // 5: pb.NodeActionService.findAllNodeActions:input_type -> pb.FindAllNodeActionsRequest - 6, // 6: pb.NodeActionService.findNodeAction:input_type -> pb.FindNodeActionRequest - 1, // 7: pb.NodeActionService.createNodeAction:output_type -> pb.CreateNodeActionResponse - 9, // 8: pb.NodeActionService.deleteNodeAction:output_type -> pb.RPCSuccess - 9, // 9: pb.NodeActionService.updateNodeAction:output_type -> pb.RPCSuccess - 5, // 10: pb.NodeActionService.findAllNodeActions:output_type -> pb.FindAllNodeActionsResponse - 7, // 11: pb.NodeActionService.findNodeAction:output_type -> pb.FindNodeActionResponse - 7, // [7:12] is the sub-list for method output_type - 2, // [2:7] is the sub-list for method input_type - 2, // [2:2] is the sub-list for extension type_name - 2, // [2:2] is the sub-list for extension extendee - 0, // [0:2] is the sub-list for field type_name + 9, // 0: pb.FindAllNodeActionsResponse.nodeActions:type_name -> pb.NodeAction + 9, // 1: pb.FindNodeActionResponse.nodeAction:type_name -> pb.NodeAction + 0, // 2: pb.NodeActionService.createNodeAction:input_type -> pb.CreateNodeActionRequest + 2, // 3: pb.NodeActionService.deleteNodeAction:input_type -> pb.DeleteNodeActionRequest + 3, // 4: pb.NodeActionService.updateNodeAction:input_type -> pb.UpdateNodeActionRequest + 4, // 5: pb.NodeActionService.findAllNodeActions:input_type -> pb.FindAllNodeActionsRequest + 6, // 6: pb.NodeActionService.findNodeAction:input_type -> pb.FindNodeActionRequest + 8, // 7: pb.NodeActionService.updateNodeActionOrders:input_type -> pb.UpdateNodeActionOrdersRequest + 1, // 8: pb.NodeActionService.createNodeAction:output_type -> pb.CreateNodeActionResponse + 10, // 9: pb.NodeActionService.deleteNodeAction:output_type -> pb.RPCSuccess + 10, // 10: pb.NodeActionService.updateNodeAction:output_type -> pb.RPCSuccess + 5, // 11: pb.NodeActionService.findAllNodeActions:output_type -> pb.FindAllNodeActionsResponse + 7, // 12: pb.NodeActionService.findNodeAction:output_type -> pb.FindNodeActionResponse + 10, // 13: pb.NodeActionService.updateNodeActionOrders:output_type -> pb.RPCSuccess + 8, // [8:14] is the sub-list for method output_type + 2, // [2:8] is the sub-list for method input_type + 2, // [2:2] is the sub-list for extension type_name + 2, // [2:2] is the sub-list for extension extendee + 0, // [0:2] is the sub-list for field type_name } func init() { file_service_node_action_proto_init() } @@ -715,6 +776,18 @@ func file_service_node_action_proto_init() { return nil } } + file_service_node_action_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*UpdateNodeActionOrdersRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } } type x struct{} out := protoimpl.TypeBuilder{ @@ -722,7 +795,7 @@ func file_service_node_action_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_service_node_action_proto_rawDesc, NumEnums: 0, - NumMessages: 8, + NumMessages: 9, NumExtensions: 0, NumServices: 1, }, @@ -758,6 +831,8 @@ type NodeActionServiceClient interface { FindAllNodeActions(ctx context.Context, in *FindAllNodeActionsRequest, opts ...grpc.CallOption) (*FindAllNodeActionsResponse, error) // 查找单个节点动作 FindNodeAction(ctx context.Context, in *FindNodeActionRequest, opts ...grpc.CallOption) (*FindNodeActionResponse, error) + // 设置节点动作排序 + UpdateNodeActionOrders(ctx context.Context, in *UpdateNodeActionOrdersRequest, opts ...grpc.CallOption) (*RPCSuccess, error) } type nodeActionServiceClient struct { @@ -813,6 +888,15 @@ func (c *nodeActionServiceClient) FindNodeAction(ctx context.Context, in *FindNo return out, nil } +func (c *nodeActionServiceClient) UpdateNodeActionOrders(ctx context.Context, in *UpdateNodeActionOrdersRequest, opts ...grpc.CallOption) (*RPCSuccess, error) { + out := new(RPCSuccess) + err := c.cc.Invoke(ctx, "/pb.NodeActionService/updateNodeActionOrders", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // NodeActionServiceServer is the server API for NodeActionService service. type NodeActionServiceServer interface { // 添加动作 @@ -825,6 +909,8 @@ type NodeActionServiceServer interface { FindAllNodeActions(context.Context, *FindAllNodeActionsRequest) (*FindAllNodeActionsResponse, error) // 查找单个节点动作 FindNodeAction(context.Context, *FindNodeActionRequest) (*FindNodeActionResponse, error) + // 设置节点动作排序 + UpdateNodeActionOrders(context.Context, *UpdateNodeActionOrdersRequest) (*RPCSuccess, error) } // UnimplementedNodeActionServiceServer can be embedded to have forward compatible implementations. @@ -846,6 +932,9 @@ func (*UnimplementedNodeActionServiceServer) FindAllNodeActions(context.Context, func (*UnimplementedNodeActionServiceServer) FindNodeAction(context.Context, *FindNodeActionRequest) (*FindNodeActionResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method FindNodeAction not implemented") } +func (*UnimplementedNodeActionServiceServer) UpdateNodeActionOrders(context.Context, *UpdateNodeActionOrdersRequest) (*RPCSuccess, error) { + return nil, status.Errorf(codes.Unimplemented, "method UpdateNodeActionOrders not implemented") +} func RegisterNodeActionServiceServer(s *grpc.Server, srv NodeActionServiceServer) { s.RegisterService(&_NodeActionService_serviceDesc, srv) @@ -941,6 +1030,24 @@ func _NodeActionService_FindNodeAction_Handler(srv interface{}, ctx context.Cont return interceptor(ctx, in, info, handler) } +func _NodeActionService_UpdateNodeActionOrders_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(UpdateNodeActionOrdersRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(NodeActionServiceServer).UpdateNodeActionOrders(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/pb.NodeActionService/UpdateNodeActionOrders", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(NodeActionServiceServer).UpdateNodeActionOrders(ctx, req.(*UpdateNodeActionOrdersRequest)) + } + return interceptor(ctx, in, info, handler) +} + var _NodeActionService_serviceDesc = grpc.ServiceDesc{ ServiceName: "pb.NodeActionService", HandlerType: (*NodeActionServiceServer)(nil), @@ -965,6 +1072,10 @@ var _NodeActionService_serviceDesc = grpc.ServiceDesc{ MethodName: "findNodeAction", Handler: _NodeActionService_FindNodeAction_Handler, }, + { + MethodName: "updateNodeActionOrders", + Handler: _NodeActionService_UpdateNodeActionOrders_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "service_node_action.proto", diff --git a/pkg/rpc/protos/service_node_action.proto b/pkg/rpc/protos/service_node_action.proto index a7128e0..f0529ab 100644 --- a/pkg/rpc/protos/service_node_action.proto +++ b/pkg/rpc/protos/service_node_action.proto @@ -22,6 +22,9 @@ service NodeActionService { // 查找单个节点动作 rpc findNodeAction(FindNodeActionRequest) returns (FindNodeActionResponse); + + // 设置节点动作排序 + rpc updateNodeActionOrders(UpdateNodeActionOrdersRequest) returns (RPCSuccess); } // 添加动作 @@ -68,4 +71,9 @@ message FindNodeActionRequest { message FindNodeActionResponse { NodeAction nodeAction = 1; +} + +// 设置节点动作排序 +message UpdateNodeActionOrdersRequest { + repeated int64 nodeActionIds = 1; // 节点动作ID列表 } \ No newline at end of file