diff --git a/pkg/rpc/pb/service_node_cluster_firewall_action.pb.go b/pkg/rpc/pb/service_node_cluster_firewall_action.pb.go index d89c99c..d193be3 100644 --- a/pkg/rpc/pb/service_node_cluster_firewall_action.pb.go +++ b/pkg/rpc/pb/service_node_cluster_firewall_action.pb.go @@ -474,6 +474,54 @@ func (x *FindEnabledNodeClusterFirewallActionResponse) GetNodeClusterFirewallAct return nil } +// 计算动作数量 +type CountAllEnabledNodeClusterFirewallActionsRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + NodeClusterId int64 `protobuf:"varint,1,opt,name=nodeClusterId,proto3" json:"nodeClusterId,omitempty"` +} + +func (x *CountAllEnabledNodeClusterFirewallActionsRequest) Reset() { + *x = CountAllEnabledNodeClusterFirewallActionsRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_service_node_cluster_firewall_action_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *CountAllEnabledNodeClusterFirewallActionsRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CountAllEnabledNodeClusterFirewallActionsRequest) ProtoMessage() {} + +func (x *CountAllEnabledNodeClusterFirewallActionsRequest) ProtoReflect() protoreflect.Message { + mi := &file_service_node_cluster_firewall_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 CountAllEnabledNodeClusterFirewallActionsRequest.ProtoReflect.Descriptor instead. +func (*CountAllEnabledNodeClusterFirewallActionsRequest) Descriptor() ([]byte, []int) { + return file_service_node_cluster_firewall_action_proto_rawDescGZIP(), []int{8} +} + +func (x *CountAllEnabledNodeClusterFirewallActionsRequest) GetNodeClusterId() int64 { + if x != nil { + return x.NodeClusterId + } + return 0 +} + var File_service_node_cluster_firewall_action_proto protoreflect.FileDescriptor var file_service_node_cluster_firewall_action_proto_rawDesc = []byte{ @@ -553,48 +601,61 @@ var file_service_node_cluster_firewall_action_proto_rawDesc = []byte{ 0x1d, 0x2e, 0x70, 0x62, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x19, 0x6e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, - 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x32, 0xfa, 0x04, 0x0a, 0x20, 0x4e, 0x6f, - 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, - 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x74, - 0x0a, 0x1f, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, + 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x58, 0x0a, 0x30, 0x43, 0x6f, 0x75, + 0x6e, 0x74, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, + 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, + 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x24, 0x0a, + 0x0d, 0x6e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, 0x64, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x6e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, + 0x72, 0x49, 0x64, 0x32, 0xf3, 0x05, 0x0a, 0x20, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, - 0x6e, 0x12, 0x2a, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, - 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, - 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, - 0x70, 0x62, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, - 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x5d, 0x0a, 0x1f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, 0x6f, - 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, - 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x2a, 0x2e, 0x70, 0x62, 0x2e, 0x55, 0x70, 0x64, - 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, - 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 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, 0x5d, 0x0a, 0x1f, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, - 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, - 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x2a, 0x2e, 0x70, 0x62, 0x2e, 0x44, 0x65, 0x6c, 0x65, + 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x74, 0x0a, 0x1f, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, - 0x65, 0x77, 0x61, 0x6c, 0x6c, 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, 0x95, 0x01, 0x0a, 0x28, 0x66, 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x45, 0x6e, - 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, - 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, - 0x33, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x61, 0x62, - 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, - 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x41, 0x6c, - 0x6c, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, + 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x2a, 0x2e, 0x70, 0x62, + 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, + 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x70, 0x62, 0x2e, 0x4e, 0x6f, 0x64, + 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, + 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x5d, + 0x0a, 0x1f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, - 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x89, 0x01, 0x0a, 0x24, 0x66, - 0x69, 0x6e, 0x64, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, - 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, - 0x69, 0x6f, 0x6e, 0x12, 0x2f, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x45, 0x6e, 0x61, + 0x6e, 0x12, 0x2a, 0x2e, 0x70, 0x62, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4e, 0x6f, 0x64, + 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, + 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, 0x5d, 0x0a, + 0x1f, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, + 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, + 0x12, 0x2a, 0x2e, 0x70, 0x62, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, + 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 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, 0x95, 0x01, 0x0a, + 0x28, 0x66, 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, + 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, + 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x33, 0x2e, 0x70, 0x62, 0x2e, 0x46, + 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, + 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, + 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, + 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x61, 0x62, 0x6c, + 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, + 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, + 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x89, 0x01, 0x0a, 0x24, 0x66, 0x69, 0x6e, 0x64, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, - 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x30, 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x45, 0x6e, - 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, - 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 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, + 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x2f, 0x2e, + 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, 0x6f, + 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, 0x6c, + 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x30, + 0x2e, 0x70, 0x62, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x4e, + 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, 0x65, 0x77, 0x61, + 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x77, 0x0a, 0x29, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x61, 0x62, + 0x6c, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, + 0x72, 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x34, 0x2e, + 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x41, 0x6c, 0x6c, 0x45, 0x6e, 0x61, 0x62, 0x6c, + 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x46, 0x69, 0x72, + 0x65, 0x77, 0x61, 0x6c, 0x6c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x14, 0x2e, 0x70, 0x62, 0x2e, 0x52, 0x50, 0x43, 0x43, 0x6f, 0x75, 0x6e, + 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x2f, 0x70, + 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -609,7 +670,7 @@ func file_service_node_cluster_firewall_action_proto_rawDescGZIP() []byte { return file_service_node_cluster_firewall_action_proto_rawDescData } -var file_service_node_cluster_firewall_action_proto_msgTypes = make([]protoimpl.MessageInfo, 8) +var file_service_node_cluster_firewall_action_proto_msgTypes = make([]protoimpl.MessageInfo, 9) var file_service_node_cluster_firewall_action_proto_goTypes = []interface{}{ (*CreateNodeClusterFirewallActionRequest)(nil), // 0: pb.CreateNodeClusterFirewallActionRequest (*NodeClusterFirewallActionResponse)(nil), // 1: pb.NodeClusterFirewallActionResponse @@ -619,27 +680,31 @@ var file_service_node_cluster_firewall_action_proto_goTypes = []interface{}{ (*FindAllEnabledNodeClusterFirewallActionsResponse)(nil), // 5: pb.FindAllEnabledNodeClusterFirewallActionsResponse (*FindEnabledNodeClusterFirewallActionRequest)(nil), // 6: pb.FindEnabledNodeClusterFirewallActionRequest (*FindEnabledNodeClusterFirewallActionResponse)(nil), // 7: pb.FindEnabledNodeClusterFirewallActionResponse - (*NodeClusterFirewallAction)(nil), // 8: pb.NodeClusterFirewallAction - (*RPCSuccess)(nil), // 9: pb.RPCSuccess + (*CountAllEnabledNodeClusterFirewallActionsRequest)(nil), // 8: pb.CountAllEnabledNodeClusterFirewallActionsRequest + (*NodeClusterFirewallAction)(nil), // 9: pb.NodeClusterFirewallAction + (*RPCSuccess)(nil), // 10: pb.RPCSuccess + (*RPCCountResponse)(nil), // 11: pb.RPCCountResponse } var file_service_node_cluster_firewall_action_proto_depIdxs = []int32{ - 8, // 0: pb.FindAllEnabledNodeClusterFirewallActionsResponse.nodeClusterFirewallActions:type_name -> pb.NodeClusterFirewallAction - 8, // 1: pb.FindEnabledNodeClusterFirewallActionResponse.nodeClusterFirewallAction:type_name -> pb.NodeClusterFirewallAction - 0, // 2: pb.NodeClusterFirewallActionService.createNodeClusterFirewallAction:input_type -> pb.CreateNodeClusterFirewallActionRequest - 2, // 3: pb.NodeClusterFirewallActionService.updateNodeClusterFirewallAction:input_type -> pb.UpdateNodeClusterFirewallActionRequest - 3, // 4: pb.NodeClusterFirewallActionService.deleteNodeClusterFirewallAction:input_type -> pb.DeleteNodeClusterFirewallActionRequest - 4, // 5: pb.NodeClusterFirewallActionService.findAllEnabledNodeClusterFirewallActions:input_type -> pb.FindAllEnabledNodeClusterFirewallActionsRequest - 6, // 6: pb.NodeClusterFirewallActionService.findEnabledNodeClusterFirewallAction:input_type -> pb.FindEnabledNodeClusterFirewallActionRequest - 1, // 7: pb.NodeClusterFirewallActionService.createNodeClusterFirewallAction:output_type -> pb.NodeClusterFirewallActionResponse - 9, // 8: pb.NodeClusterFirewallActionService.updateNodeClusterFirewallAction:output_type -> pb.RPCSuccess - 9, // 9: pb.NodeClusterFirewallActionService.deleteNodeClusterFirewallAction:output_type -> pb.RPCSuccess - 5, // 10: pb.NodeClusterFirewallActionService.findAllEnabledNodeClusterFirewallActions:output_type -> pb.FindAllEnabledNodeClusterFirewallActionsResponse - 7, // 11: pb.NodeClusterFirewallActionService.findEnabledNodeClusterFirewallAction:output_type -> pb.FindEnabledNodeClusterFirewallActionResponse - 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.FindAllEnabledNodeClusterFirewallActionsResponse.nodeClusterFirewallActions:type_name -> pb.NodeClusterFirewallAction + 9, // 1: pb.FindEnabledNodeClusterFirewallActionResponse.nodeClusterFirewallAction:type_name -> pb.NodeClusterFirewallAction + 0, // 2: pb.NodeClusterFirewallActionService.createNodeClusterFirewallAction:input_type -> pb.CreateNodeClusterFirewallActionRequest + 2, // 3: pb.NodeClusterFirewallActionService.updateNodeClusterFirewallAction:input_type -> pb.UpdateNodeClusterFirewallActionRequest + 3, // 4: pb.NodeClusterFirewallActionService.deleteNodeClusterFirewallAction:input_type -> pb.DeleteNodeClusterFirewallActionRequest + 4, // 5: pb.NodeClusterFirewallActionService.findAllEnabledNodeClusterFirewallActions:input_type -> pb.FindAllEnabledNodeClusterFirewallActionsRequest + 6, // 6: pb.NodeClusterFirewallActionService.findEnabledNodeClusterFirewallAction:input_type -> pb.FindEnabledNodeClusterFirewallActionRequest + 8, // 7: pb.NodeClusterFirewallActionService.countAllEnabledNodeClusterFirewallActions:input_type -> pb.CountAllEnabledNodeClusterFirewallActionsRequest + 1, // 8: pb.NodeClusterFirewallActionService.createNodeClusterFirewallAction:output_type -> pb.NodeClusterFirewallActionResponse + 10, // 9: pb.NodeClusterFirewallActionService.updateNodeClusterFirewallAction:output_type -> pb.RPCSuccess + 10, // 10: pb.NodeClusterFirewallActionService.deleteNodeClusterFirewallAction:output_type -> pb.RPCSuccess + 5, // 11: pb.NodeClusterFirewallActionService.findAllEnabledNodeClusterFirewallActions:output_type -> pb.FindAllEnabledNodeClusterFirewallActionsResponse + 7, // 12: pb.NodeClusterFirewallActionService.findEnabledNodeClusterFirewallAction:output_type -> pb.FindEnabledNodeClusterFirewallActionResponse + 11, // 13: pb.NodeClusterFirewallActionService.countAllEnabledNodeClusterFirewallActions:output_type -> pb.RPCCountResponse + 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_cluster_firewall_action_proto_init() } @@ -746,6 +811,18 @@ func file_service_node_cluster_firewall_action_proto_init() { return nil } } + file_service_node_cluster_firewall_action_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*CountAllEnabledNodeClusterFirewallActionsRequest); 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{ @@ -753,7 +830,7 @@ func file_service_node_cluster_firewall_action_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_service_node_cluster_firewall_action_proto_rawDesc, NumEnums: 0, - NumMessages: 8, + NumMessages: 9, NumExtensions: 0, NumServices: 1, }, @@ -789,6 +866,8 @@ type NodeClusterFirewallActionServiceClient interface { FindAllEnabledNodeClusterFirewallActions(ctx context.Context, in *FindAllEnabledNodeClusterFirewallActionsRequest, opts ...grpc.CallOption) (*FindAllEnabledNodeClusterFirewallActionsResponse, error) // 查询单个动作 FindEnabledNodeClusterFirewallAction(ctx context.Context, in *FindEnabledNodeClusterFirewallActionRequest, opts ...grpc.CallOption) (*FindEnabledNodeClusterFirewallActionResponse, error) + // 计算动作数量 + CountAllEnabledNodeClusterFirewallActions(ctx context.Context, in *CountAllEnabledNodeClusterFirewallActionsRequest, opts ...grpc.CallOption) (*RPCCountResponse, error) } type nodeClusterFirewallActionServiceClient struct { @@ -844,6 +923,15 @@ func (c *nodeClusterFirewallActionServiceClient) FindEnabledNodeClusterFirewallA return out, nil } +func (c *nodeClusterFirewallActionServiceClient) CountAllEnabledNodeClusterFirewallActions(ctx context.Context, in *CountAllEnabledNodeClusterFirewallActionsRequest, opts ...grpc.CallOption) (*RPCCountResponse, error) { + out := new(RPCCountResponse) + err := c.cc.Invoke(ctx, "/pb.NodeClusterFirewallActionService/countAllEnabledNodeClusterFirewallActions", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // NodeClusterFirewallActionServiceServer is the server API for NodeClusterFirewallActionService service. type NodeClusterFirewallActionServiceServer interface { // 创建动作 @@ -856,6 +944,8 @@ type NodeClusterFirewallActionServiceServer interface { FindAllEnabledNodeClusterFirewallActions(context.Context, *FindAllEnabledNodeClusterFirewallActionsRequest) (*FindAllEnabledNodeClusterFirewallActionsResponse, error) // 查询单个动作 FindEnabledNodeClusterFirewallAction(context.Context, *FindEnabledNodeClusterFirewallActionRequest) (*FindEnabledNodeClusterFirewallActionResponse, error) + // 计算动作数量 + CountAllEnabledNodeClusterFirewallActions(context.Context, *CountAllEnabledNodeClusterFirewallActionsRequest) (*RPCCountResponse, error) } // UnimplementedNodeClusterFirewallActionServiceServer can be embedded to have forward compatible implementations. @@ -877,6 +967,9 @@ func (*UnimplementedNodeClusterFirewallActionServiceServer) FindAllEnabledNodeCl func (*UnimplementedNodeClusterFirewallActionServiceServer) FindEnabledNodeClusterFirewallAction(context.Context, *FindEnabledNodeClusterFirewallActionRequest) (*FindEnabledNodeClusterFirewallActionResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method FindEnabledNodeClusterFirewallAction not implemented") } +func (*UnimplementedNodeClusterFirewallActionServiceServer) CountAllEnabledNodeClusterFirewallActions(context.Context, *CountAllEnabledNodeClusterFirewallActionsRequest) (*RPCCountResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method CountAllEnabledNodeClusterFirewallActions not implemented") +} func RegisterNodeClusterFirewallActionServiceServer(s *grpc.Server, srv NodeClusterFirewallActionServiceServer) { s.RegisterService(&_NodeClusterFirewallActionService_serviceDesc, srv) @@ -972,6 +1065,24 @@ func _NodeClusterFirewallActionService_FindEnabledNodeClusterFirewallAction_Hand return interceptor(ctx, in, info, handler) } +func _NodeClusterFirewallActionService_CountAllEnabledNodeClusterFirewallActions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(CountAllEnabledNodeClusterFirewallActionsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(NodeClusterFirewallActionServiceServer).CountAllEnabledNodeClusterFirewallActions(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/pb.NodeClusterFirewallActionService/CountAllEnabledNodeClusterFirewallActions", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(NodeClusterFirewallActionServiceServer).CountAllEnabledNodeClusterFirewallActions(ctx, req.(*CountAllEnabledNodeClusterFirewallActionsRequest)) + } + return interceptor(ctx, in, info, handler) +} + var _NodeClusterFirewallActionService_serviceDesc = grpc.ServiceDesc{ ServiceName: "pb.NodeClusterFirewallActionService", HandlerType: (*NodeClusterFirewallActionServiceServer)(nil), @@ -996,6 +1107,10 @@ var _NodeClusterFirewallActionService_serviceDesc = grpc.ServiceDesc{ MethodName: "findEnabledNodeClusterFirewallAction", Handler: _NodeClusterFirewallActionService_FindEnabledNodeClusterFirewallAction_Handler, }, + { + MethodName: "countAllEnabledNodeClusterFirewallActions", + Handler: _NodeClusterFirewallActionService_CountAllEnabledNodeClusterFirewallActions_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "service_node_cluster_firewall_action.proto", diff --git a/pkg/rpc/protos/service_node_cluster_firewall_action.proto b/pkg/rpc/protos/service_node_cluster_firewall_action.proto index 00766ef..102d1f1 100644 --- a/pkg/rpc/protos/service_node_cluster_firewall_action.proto +++ b/pkg/rpc/protos/service_node_cluster_firewall_action.proto @@ -22,6 +22,9 @@ service NodeClusterFirewallActionService { // 查询单个动作 rpc findEnabledNodeClusterFirewallAction (FindEnabledNodeClusterFirewallActionRequest) returns (FindEnabledNodeClusterFirewallActionResponse); + + // 计算动作数量 + rpc countAllEnabledNodeClusterFirewallActions (CountAllEnabledNodeClusterFirewallActionsRequest) returns (RPCCountResponse); } // 创建动作 @@ -67,4 +70,9 @@ message FindEnabledNodeClusterFirewallActionRequest { message FindEnabledNodeClusterFirewallActionResponse { NodeClusterFirewallAction nodeClusterFirewallAction = 1; +} + +// 计算动作数量 +message CountAllEnabledNodeClusterFirewallActionsRequest { + int64 nodeClusterId = 1; } \ No newline at end of file