// Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.36.11 // protoc v3.19.6 // source: service_report_node.proto package pb import ( protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" unsafe "unsafe" ) const ( // Verify that this generated code is sufficiently up-to-date. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) // Verify that runtime/protoimpl is sufficiently up-to-date. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) // 添加终端 type CreateReportNodeRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` Isp string `protobuf:"bytes,3,opt,name=isp,proto3" json:"isp,omitempty"` AllowIPs []string `protobuf:"bytes,4,rep,name=allowIPs,proto3" json:"allowIPs,omitempty"` ReportNodeGroupIds []int64 `protobuf:"varint,5,rep,packed,name=reportNodeGroupIds,proto3" json:"reportNodeGroupIds,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *CreateReportNodeRequest) Reset() { *x = CreateReportNodeRequest{} mi := &file_service_report_node_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *CreateReportNodeRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*CreateReportNodeRequest) ProtoMessage() {} func (x *CreateReportNodeRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[0] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use CreateReportNodeRequest.ProtoReflect.Descriptor instead. func (*CreateReportNodeRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{0} } func (x *CreateReportNodeRequest) GetName() string { if x != nil { return x.Name } return "" } func (x *CreateReportNodeRequest) GetLocation() string { if x != nil { return x.Location } return "" } func (x *CreateReportNodeRequest) GetIsp() string { if x != nil { return x.Isp } return "" } func (x *CreateReportNodeRequest) GetAllowIPs() []string { if x != nil { return x.AllowIPs } return nil } func (x *CreateReportNodeRequest) GetReportNodeGroupIds() []int64 { if x != nil { return x.ReportNodeGroupIds } return nil } type CreateReportNodeResponse struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNodeId int64 `protobuf:"varint,1,opt,name=reportNodeId,proto3" json:"reportNodeId,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *CreateReportNodeResponse) Reset() { *x = CreateReportNodeResponse{} mi := &file_service_report_node_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *CreateReportNodeResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*CreateReportNodeResponse) ProtoMessage() {} func (x *CreateReportNodeResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[1] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use CreateReportNodeResponse.ProtoReflect.Descriptor instead. func (*CreateReportNodeResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{1} } func (x *CreateReportNodeResponse) GetReportNodeId() int64 { if x != nil { return x.ReportNodeId } return 0 } // 删除终端 type DeleteReportNodeRequest struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNodeId int64 `protobuf:"varint,1,opt,name=reportNodeId,proto3" json:"reportNodeId,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *DeleteReportNodeRequest) Reset() { *x = DeleteReportNodeRequest{} mi := &file_service_report_node_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *DeleteReportNodeRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*DeleteReportNodeRequest) ProtoMessage() {} func (x *DeleteReportNodeRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[2] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use DeleteReportNodeRequest.ProtoReflect.Descriptor instead. func (*DeleteReportNodeRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{2} } func (x *DeleteReportNodeRequest) GetReportNodeId() int64 { if x != nil { return x.ReportNodeId } return 0 } // 修改终端 type UpdateReportNodeRequest struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNodeId int64 `protobuf:"varint,1,opt,name=reportNodeId,proto3" json:"reportNodeId,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Location string `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"` Isp string `protobuf:"bytes,4,opt,name=isp,proto3" json:"isp,omitempty"` AllowIPs []string `protobuf:"bytes,5,rep,name=allowIPs,proto3" json:"allowIPs,omitempty"` IsOn bool `protobuf:"varint,6,opt,name=isOn,proto3" json:"isOn,omitempty"` ReportNodeGroupIds []int64 `protobuf:"varint,7,rep,packed,name=reportNodeGroupIds,proto3" json:"reportNodeGroupIds,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *UpdateReportNodeRequest) Reset() { *x = UpdateReportNodeRequest{} mi := &file_service_report_node_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *UpdateReportNodeRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*UpdateReportNodeRequest) ProtoMessage() {} func (x *UpdateReportNodeRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[3] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use UpdateReportNodeRequest.ProtoReflect.Descriptor instead. func (*UpdateReportNodeRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{3} } func (x *UpdateReportNodeRequest) GetReportNodeId() int64 { if x != nil { return x.ReportNodeId } return 0 } func (x *UpdateReportNodeRequest) GetName() string { if x != nil { return x.Name } return "" } func (x *UpdateReportNodeRequest) GetLocation() string { if x != nil { return x.Location } return "" } func (x *UpdateReportNodeRequest) GetIsp() string { if x != nil { return x.Isp } return "" } func (x *UpdateReportNodeRequest) GetAllowIPs() []string { if x != nil { return x.AllowIPs } return nil } func (x *UpdateReportNodeRequest) GetIsOn() bool { if x != nil { return x.IsOn } return false } func (x *UpdateReportNodeRequest) GetReportNodeGroupIds() []int64 { if x != nil { return x.ReportNodeGroupIds } return nil } // 计算终端数量 type CountAllEnabledReportNodesRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Keyword string `protobuf:"bytes,1,opt,name=keyword,proto3" json:"keyword,omitempty"` ReportNodeGroupId int64 `protobuf:"varint,2,opt,name=reportNodeGroupId,proto3" json:"reportNodeGroupId,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *CountAllEnabledReportNodesRequest) Reset() { *x = CountAllEnabledReportNodesRequest{} mi := &file_service_report_node_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *CountAllEnabledReportNodesRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*CountAllEnabledReportNodesRequest) ProtoMessage() {} func (x *CountAllEnabledReportNodesRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[4] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use CountAllEnabledReportNodesRequest.ProtoReflect.Descriptor instead. func (*CountAllEnabledReportNodesRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{4} } func (x *CountAllEnabledReportNodesRequest) GetKeyword() string { if x != nil { return x.Keyword } return "" } func (x *CountAllEnabledReportNodesRequest) GetReportNodeGroupId() int64 { if x != nil { return x.ReportNodeGroupId } return 0 } // 列出单页终端 type ListEnabledReportNodesRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Keyword string `protobuf:"bytes,1,opt,name=keyword,proto3" json:"keyword,omitempty"` ReportNodeGroupId int64 `protobuf:"varint,4,opt,name=reportNodeGroupId,proto3" json:"reportNodeGroupId,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ListEnabledReportNodesRequest) Reset() { *x = ListEnabledReportNodesRequest{} mi := &file_service_report_node_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ListEnabledReportNodesRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*ListEnabledReportNodesRequest) ProtoMessage() {} func (x *ListEnabledReportNodesRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[5] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ListEnabledReportNodesRequest.ProtoReflect.Descriptor instead. func (*ListEnabledReportNodesRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{5} } func (x *ListEnabledReportNodesRequest) GetKeyword() string { if x != nil { return x.Keyword } return "" } func (x *ListEnabledReportNodesRequest) GetReportNodeGroupId() int64 { if x != nil { return x.ReportNodeGroupId } return 0 } func (x *ListEnabledReportNodesRequest) GetOffset() int64 { if x != nil { return x.Offset } return 0 } func (x *ListEnabledReportNodesRequest) GetSize() int64 { if x != nil { return x.Size } return 0 } type ListEnabledReportNodesResponse struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNodes []*ReportNode `protobuf:"bytes,1,rep,name=reportNodes,proto3" json:"reportNodes,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ListEnabledReportNodesResponse) Reset() { *x = ListEnabledReportNodesResponse{} mi := &file_service_report_node_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ListEnabledReportNodesResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*ListEnabledReportNodesResponse) ProtoMessage() {} func (x *ListEnabledReportNodesResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[6] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ListEnabledReportNodesResponse.ProtoReflect.Descriptor instead. func (*ListEnabledReportNodesResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{6} } func (x *ListEnabledReportNodesResponse) GetReportNodes() []*ReportNode { if x != nil { return x.ReportNodes } return nil } // 查找单个终端 type FindEnabledReportNodeRequest struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNodeId int64 `protobuf:"varint,1,opt,name=reportNodeId,proto3" json:"reportNodeId,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindEnabledReportNodeRequest) Reset() { *x = FindEnabledReportNodeRequest{} mi := &file_service_report_node_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindEnabledReportNodeRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindEnabledReportNodeRequest) ProtoMessage() {} func (x *FindEnabledReportNodeRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[7] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindEnabledReportNodeRequest.ProtoReflect.Descriptor instead. func (*FindEnabledReportNodeRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{7} } func (x *FindEnabledReportNodeRequest) GetReportNodeId() int64 { if x != nil { return x.ReportNodeId } return 0 } type FindEnabledReportNodeResponse struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNode *ReportNode `protobuf:"bytes,1,opt,name=reportNode,proto3" json:"reportNode,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindEnabledReportNodeResponse) Reset() { *x = FindEnabledReportNodeResponse{} mi := &file_service_report_node_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindEnabledReportNodeResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindEnabledReportNodeResponse) ProtoMessage() {} func (x *FindEnabledReportNodeResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[8] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindEnabledReportNodeResponse.ProtoReflect.Descriptor instead. func (*FindEnabledReportNodeResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{8} } func (x *FindEnabledReportNodeResponse) GetReportNode() *ReportNode { if x != nil { return x.ReportNode } return nil } // 终端stream type ReportNodeStreamMessage struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNodeId int64 `protobuf:"varint,1,opt,name=reportNodeId,proto3" json:"reportNodeId,omitempty"` RequestId int64 `protobuf:"varint,2,opt,name=requestId,proto3" json:"requestId,omitempty"` TimeoutSeconds int32 `protobuf:"varint,3,opt,name=timeoutSeconds,proto3" json:"timeoutSeconds,omitempty"` Code string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"` DataJSON []byte `protobuf:"bytes,5,opt,name=dataJSON,proto3" json:"dataJSON,omitempty"` IsOk bool `protobuf:"varint,6,opt,name=isOk,proto3" json:"isOk,omitempty"` Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ReportNodeStreamMessage) Reset() { *x = ReportNodeStreamMessage{} mi := &file_service_report_node_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ReportNodeStreamMessage) String() string { return protoimpl.X.MessageStringOf(x) } func (*ReportNodeStreamMessage) ProtoMessage() {} func (x *ReportNodeStreamMessage) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[9] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ReportNodeStreamMessage.ProtoReflect.Descriptor instead. func (*ReportNodeStreamMessage) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{9} } func (x *ReportNodeStreamMessage) GetReportNodeId() int64 { if x != nil { return x.ReportNodeId } return 0 } func (x *ReportNodeStreamMessage) GetRequestId() int64 { if x != nil { return x.RequestId } return 0 } func (x *ReportNodeStreamMessage) GetTimeoutSeconds() int32 { if x != nil { return x.TimeoutSeconds } return 0 } func (x *ReportNodeStreamMessage) GetCode() string { if x != nil { return x.Code } return "" } func (x *ReportNodeStreamMessage) GetDataJSON() []byte { if x != nil { return x.DataJSON } return nil } func (x *ReportNodeStreamMessage) GetIsOk() bool { if x != nil { return x.IsOk } return false } func (x *ReportNodeStreamMessage) GetMessage() string { if x != nil { return x.Message } return "" } // 更新节点状态 type UpdateReportNodeStatusRequest struct { state protoimpl.MessageState `protogen:"open.v1"` StatusJSON []byte `protobuf:"bytes,1,opt,name=statusJSON,proto3" json:"statusJSON,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *UpdateReportNodeStatusRequest) Reset() { *x = UpdateReportNodeStatusRequest{} mi := &file_service_report_node_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *UpdateReportNodeStatusRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*UpdateReportNodeStatusRequest) ProtoMessage() {} func (x *UpdateReportNodeStatusRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[10] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use UpdateReportNodeStatusRequest.ProtoReflect.Descriptor instead. func (*UpdateReportNodeStatusRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{10} } func (x *UpdateReportNodeStatusRequest) GetStatusJSON() []byte { if x != nil { return x.StatusJSON } return nil } // 获取当前节点信息 type FindCurrentReportNodeConfigRequest struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindCurrentReportNodeConfigRequest) Reset() { *x = FindCurrentReportNodeConfigRequest{} mi := &file_service_report_node_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindCurrentReportNodeConfigRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindCurrentReportNodeConfigRequest) ProtoMessage() {} func (x *FindCurrentReportNodeConfigRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[11] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindCurrentReportNodeConfigRequest.ProtoReflect.Descriptor instead. func (*FindCurrentReportNodeConfigRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{11} } type FindCurrentReportNodeConfigResponse struct { state protoimpl.MessageState `protogen:"open.v1"` ReportNodeJSON []byte `protobuf:"bytes,1,opt,name=reportNodeJSON,proto3" json:"reportNodeJSON,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindCurrentReportNodeConfigResponse) Reset() { *x = FindCurrentReportNodeConfigResponse{} mi := &file_service_report_node_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindCurrentReportNodeConfigResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindCurrentReportNodeConfigResponse) ProtoMessage() {} func (x *FindCurrentReportNodeConfigResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[12] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindCurrentReportNodeConfigResponse.ProtoReflect.Descriptor instead. func (*FindCurrentReportNodeConfigResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{12} } func (x *FindCurrentReportNodeConfigResponse) GetReportNodeJSON() []byte { if x != nil { return x.ReportNodeJSON } return nil } // 读取任务 type FindReportNodeTasksRequest struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindReportNodeTasksRequest) Reset() { *x = FindReportNodeTasksRequest{} mi := &file_service_report_node_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindReportNodeTasksRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindReportNodeTasksRequest) ProtoMessage() {} func (x *FindReportNodeTasksRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[13] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindReportNodeTasksRequest.ProtoReflect.Descriptor instead. func (*FindReportNodeTasksRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{13} } type FindReportNodeTasksResponse struct { state protoimpl.MessageState `protogen:"open.v1"` IpAddrTasksJSON []byte `protobuf:"bytes,1,opt,name=ipAddrTasksJSON,proto3" json:"ipAddrTasksJSON,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindReportNodeTasksResponse) Reset() { *x = FindReportNodeTasksResponse{} mi := &file_service_report_node_proto_msgTypes[14] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindReportNodeTasksResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindReportNodeTasksResponse) ProtoMessage() {} func (x *FindReportNodeTasksResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[14] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindReportNodeTasksResponse.ProtoReflect.Descriptor instead. func (*FindReportNodeTasksResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{14} } func (x *FindReportNodeTasksResponse) GetIpAddrTasksJSON() []byte { if x != nil { return x.IpAddrTasksJSON } return nil } // 取得最新的版本号 type FindLatestReportNodeVersionRequest struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindLatestReportNodeVersionRequest) Reset() { *x = FindLatestReportNodeVersionRequest{} mi := &file_service_report_node_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindLatestReportNodeVersionRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindLatestReportNodeVersionRequest) ProtoMessage() {} func (x *FindLatestReportNodeVersionRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[15] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindLatestReportNodeVersionRequest.ProtoReflect.Descriptor instead. func (*FindLatestReportNodeVersionRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{15} } type FindLatestReportNodeVersionResponse struct { state protoimpl.MessageState `protogen:"open.v1"` Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FindLatestReportNodeVersionResponse) Reset() { *x = FindLatestReportNodeVersionResponse{} mi := &file_service_report_node_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FindLatestReportNodeVersionResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*FindLatestReportNodeVersionResponse) ProtoMessage() {} func (x *FindLatestReportNodeVersionResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[16] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use FindLatestReportNodeVersionResponse.ProtoReflect.Descriptor instead. func (*FindLatestReportNodeVersionResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{16} } func (x *FindLatestReportNodeVersionResponse) GetVersion() string { if x != nil { return x.Version } return "" } // 计算任务数量 type CountAllReportNodeTasksRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"` NodeClusterId int64 `protobuf:"varint,2,opt,name=nodeClusterId,proto3" json:"nodeClusterId,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *CountAllReportNodeTasksRequest) Reset() { *x = CountAllReportNodeTasksRequest{} mi := &file_service_report_node_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *CountAllReportNodeTasksRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*CountAllReportNodeTasksRequest) ProtoMessage() {} func (x *CountAllReportNodeTasksRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[17] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use CountAllReportNodeTasksRequest.ProtoReflect.Descriptor instead. func (*CountAllReportNodeTasksRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{17} } func (x *CountAllReportNodeTasksRequest) GetRole() string { if x != nil { return x.Role } return "" } func (x *CountAllReportNodeTasksRequest) GetNodeClusterId() int64 { if x != nil { return x.NodeClusterId } return 0 } func (x *CountAllReportNodeTasksRequest) GetType() string { if x != nil { return x.Type } return "" } // 列出单页任务 type ListReportNodeTasksRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"` NodeClusterId int64 `protobuf:"varint,2,opt,name=nodeClusterId,proto3" json:"nodeClusterId,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` Size int64 `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ListReportNodeTasksRequest) Reset() { *x = ListReportNodeTasksRequest{} mi := &file_service_report_node_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ListReportNodeTasksRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*ListReportNodeTasksRequest) ProtoMessage() {} func (x *ListReportNodeTasksRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[18] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ListReportNodeTasksRequest.ProtoReflect.Descriptor instead. func (*ListReportNodeTasksRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{18} } func (x *ListReportNodeTasksRequest) GetRole() string { if x != nil { return x.Role } return "" } func (x *ListReportNodeTasksRequest) GetNodeClusterId() int64 { if x != nil { return x.NodeClusterId } return 0 } func (x *ListReportNodeTasksRequest) GetType() string { if x != nil { return x.Type } return "" } func (x *ListReportNodeTasksRequest) GetOffset() int64 { if x != nil { return x.Offset } return 0 } func (x *ListReportNodeTasksRequest) GetSize() int64 { if x != nil { return x.Size } return 0 } type ListReportNodeTasksResponse struct { state protoimpl.MessageState `protogen:"open.v1"` IpAddrReportTasks []*IPAddrReportTask `protobuf:"bytes,1,rep,name=ipAddrReportTasks,proto3" json:"ipAddrReportTasks,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ListReportNodeTasksResponse) Reset() { *x = ListReportNodeTasksResponse{} mi := &file_service_report_node_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ListReportNodeTasksResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*ListReportNodeTasksResponse) ProtoMessage() {} func (x *ListReportNodeTasksResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[19] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ListReportNodeTasksResponse.ProtoReflect.Descriptor instead. func (*ListReportNodeTasksResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{19} } func (x *ListReportNodeTasksResponse) GetIpAddrReportTasks() []*IPAddrReportTask { if x != nil { return x.IpAddrReportTasks } return nil } // 修改全局设置 type UpdateReportNodeGlobalSetting struct { state protoimpl.MessageState `protogen:"open.v1"` SettingJSON []byte `protobuf:"bytes,1,opt,name=settingJSON,proto3" json:"settingJSON,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *UpdateReportNodeGlobalSetting) Reset() { *x = UpdateReportNodeGlobalSetting{} mi := &file_service_report_node_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *UpdateReportNodeGlobalSetting) String() string { return protoimpl.X.MessageStringOf(x) } func (*UpdateReportNodeGlobalSetting) ProtoMessage() {} func (x *UpdateReportNodeGlobalSetting) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[20] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use UpdateReportNodeGlobalSetting.ProtoReflect.Descriptor instead. func (*UpdateReportNodeGlobalSetting) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{20} } func (x *UpdateReportNodeGlobalSetting) GetSettingJSON() []byte { if x != nil { return x.SettingJSON } return nil } // 读取全局设置 type ReadReportNodeGlobalSettingRequest struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ReadReportNodeGlobalSettingRequest) Reset() { *x = ReadReportNodeGlobalSettingRequest{} mi := &file_service_report_node_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ReadReportNodeGlobalSettingRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*ReadReportNodeGlobalSettingRequest) ProtoMessage() {} func (x *ReadReportNodeGlobalSettingRequest) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[21] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ReadReportNodeGlobalSettingRequest.ProtoReflect.Descriptor instead. func (*ReadReportNodeGlobalSettingRequest) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{21} } type ReadReportNodeGlobalSettingResponse struct { state protoimpl.MessageState `protogen:"open.v1"` SettingJSON []byte `protobuf:"bytes,1,opt,name=settingJSON,proto3" json:"settingJSON,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ReadReportNodeGlobalSettingResponse) Reset() { *x = ReadReportNodeGlobalSettingResponse{} mi := &file_service_report_node_proto_msgTypes[22] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ReadReportNodeGlobalSettingResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*ReadReportNodeGlobalSettingResponse) ProtoMessage() {} func (x *ReadReportNodeGlobalSettingResponse) ProtoReflect() protoreflect.Message { mi := &file_service_report_node_proto_msgTypes[22] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ReadReportNodeGlobalSettingResponse.ProtoReflect.Descriptor instead. func (*ReadReportNodeGlobalSettingResponse) Descriptor() ([]byte, []int) { return file_service_report_node_proto_rawDescGZIP(), []int{22} } func (x *ReadReportNodeGlobalSettingResponse) GetSettingJSON() []byte { if x != nil { return x.SettingJSON } return nil } var File_service_report_node_proto protoreflect.FileDescriptor const file_service_report_node_proto_rawDesc = "" + "\n" + "\x19service_report_node.proto\x12\x02pb\x1a\x1emodels/model_report_node.proto\x1a\x1emodels/model_report_task.proto\x1a\x19models/rpc_messages.proto\"\xa7\x01\n" + "\x17CreateReportNodeRequest\x12\x12\n" + "\x04name\x18\x01 \x01(\tR\x04name\x12\x1a\n" + "\blocation\x18\x02 \x01(\tR\blocation\x12\x10\n" + "\x03isp\x18\x03 \x01(\tR\x03isp\x12\x1a\n" + "\ballowIPs\x18\x04 \x03(\tR\ballowIPs\x12.\n" + "\x12reportNodeGroupIds\x18\x05 \x03(\x03R\x12reportNodeGroupIds\">\n" + "\x18CreateReportNodeResponse\x12\"\n" + "\freportNodeId\x18\x01 \x01(\x03R\freportNodeId\"=\n" + "\x17DeleteReportNodeRequest\x12\"\n" + "\freportNodeId\x18\x01 \x01(\x03R\freportNodeId\"\xdf\x01\n" + "\x17UpdateReportNodeRequest\x12\"\n" + "\freportNodeId\x18\x01 \x01(\x03R\freportNodeId\x12\x12\n" + "\x04name\x18\x02 \x01(\tR\x04name\x12\x1a\n" + "\blocation\x18\x03 \x01(\tR\blocation\x12\x10\n" + "\x03isp\x18\x04 \x01(\tR\x03isp\x12\x1a\n" + "\ballowIPs\x18\x05 \x03(\tR\ballowIPs\x12\x12\n" + "\x04isOn\x18\x06 \x01(\bR\x04isOn\x12.\n" + "\x12reportNodeGroupIds\x18\a \x03(\x03R\x12reportNodeGroupIds\"k\n" + "!CountAllEnabledReportNodesRequest\x12\x18\n" + "\akeyword\x18\x01 \x01(\tR\akeyword\x12,\n" + "\x11reportNodeGroupId\x18\x02 \x01(\x03R\x11reportNodeGroupId\"\x93\x01\n" + "\x1dListEnabledReportNodesRequest\x12\x18\n" + "\akeyword\x18\x01 \x01(\tR\akeyword\x12,\n" + "\x11reportNodeGroupId\x18\x04 \x01(\x03R\x11reportNodeGroupId\x12\x16\n" + "\x06offset\x18\x02 \x01(\x03R\x06offset\x12\x12\n" + "\x04size\x18\x03 \x01(\x03R\x04size\"R\n" + "\x1eListEnabledReportNodesResponse\x120\n" + "\vreportNodes\x18\x01 \x03(\v2\x0e.pb.ReportNodeR\vreportNodes\"B\n" + "\x1cFindEnabledReportNodeRequest\x12\"\n" + "\freportNodeId\x18\x01 \x01(\x03R\freportNodeId\"O\n" + "\x1dFindEnabledReportNodeResponse\x12.\n" + "\n" + "reportNode\x18\x01 \x01(\v2\x0e.pb.ReportNodeR\n" + "reportNode\"\xe1\x01\n" + "\x17ReportNodeStreamMessage\x12\"\n" + "\freportNodeId\x18\x01 \x01(\x03R\freportNodeId\x12\x1c\n" + "\trequestId\x18\x02 \x01(\x03R\trequestId\x12&\n" + "\x0etimeoutSeconds\x18\x03 \x01(\x05R\x0etimeoutSeconds\x12\x12\n" + "\x04code\x18\x04 \x01(\tR\x04code\x12\x1a\n" + "\bdataJSON\x18\x05 \x01(\fR\bdataJSON\x12\x12\n" + "\x04isOk\x18\x06 \x01(\bR\x04isOk\x12\x18\n" + "\amessage\x18\a \x01(\tR\amessage\"?\n" + "\x1dUpdateReportNodeStatusRequest\x12\x1e\n" + "\n" + "statusJSON\x18\x01 \x01(\fR\n" + "statusJSON\"$\n" + "\"FindCurrentReportNodeConfigRequest\"M\n" + "#FindCurrentReportNodeConfigResponse\x12&\n" + "\x0ereportNodeJSON\x18\x01 \x01(\fR\x0ereportNodeJSON\"\x1c\n" + "\x1aFindReportNodeTasksRequest\"G\n" + "\x1bFindReportNodeTasksResponse\x12(\n" + "\x0fipAddrTasksJSON\x18\x01 \x01(\fR\x0fipAddrTasksJSON\"$\n" + "\"FindLatestReportNodeVersionRequest\"?\n" + "#FindLatestReportNodeVersionResponse\x12\x18\n" + "\aversion\x18\x01 \x01(\tR\aversion\"n\n" + "\x1eCountAllReportNodeTasksRequest\x12\x12\n" + "\x04role\x18\x01 \x01(\tR\x04role\x12$\n" + "\rnodeClusterId\x18\x02 \x01(\x03R\rnodeClusterId\x12\x12\n" + "\x04type\x18\x03 \x01(\tR\x04type\"\x96\x01\n" + "\x1aListReportNodeTasksRequest\x12\x12\n" + "\x04role\x18\x01 \x01(\tR\x04role\x12$\n" + "\rnodeClusterId\x18\x02 \x01(\x03R\rnodeClusterId\x12\x12\n" + "\x04type\x18\x03 \x01(\tR\x04type\x12\x16\n" + "\x06offset\x18\x04 \x01(\x03R\x06offset\x12\x12\n" + "\x04size\x18\x05 \x01(\x03R\x04size\"a\n" + "\x1bListReportNodeTasksResponse\x12B\n" + "\x11ipAddrReportTasks\x18\x01 \x03(\v2\x14.pb.IPAddrReportTaskR\x11ipAddrReportTasks\"A\n" + "\x1dUpdateReportNodeGlobalSetting\x12 \n" + "\vsettingJSON\x18\x01 \x01(\fR\vsettingJSON\"$\n" + "\"ReadReportNodeGlobalSettingRequest\"G\n" + "#ReadReportNodeGlobalSettingResponse\x12 \n" + "\vsettingJSON\x18\x01 \x01(\fR\vsettingJSON2\xc6\n" + "\n" + "\x11ReportNodeService\x12M\n" + "\x10createReportNode\x12\x1b.pb.CreateReportNodeRequest\x1a\x1c.pb.CreateReportNodeResponse\x12?\n" + "\x10deleteReportNode\x12\x1b.pb.DeleteReportNodeRequest\x1a\x0e.pb.RPCSuccess\x12?\n" + "\x10updateReportNode\x12\x1b.pb.UpdateReportNodeRequest\x1a\x0e.pb.RPCSuccess\x12Y\n" + "\x1acountAllEnabledReportNodes\x12%.pb.CountAllEnabledReportNodesRequest\x1a\x14.pb.RPCCountResponse\x12_\n" + "\x16listEnabledReportNodes\x12!.pb.ListEnabledReportNodesRequest\x1a\".pb.ListEnabledReportNodesResponse\x12\\\n" + "\x15findEnabledReportNode\x12 .pb.FindEnabledReportNodeRequest\x1a!.pb.FindEnabledReportNodeResponse\x12P\n" + "\x10reportNodeStream\x12\x1b.pb.ReportNodeStreamMessage\x1a\x1b.pb.ReportNodeStreamMessage(\x010\x01\x12K\n" + "\x16updateReportNodeStatus\x12!.pb.UpdateReportNodeStatusRequest\x1a\x0e.pb.RPCSuccess\x12n\n" + "\x1bfindCurrentReportNodeConfig\x12&.pb.FindCurrentReportNodeConfigRequest\x1a'.pb.FindCurrentReportNodeConfigResponse\x12V\n" + "\x13findReportNodeTasks\x12\x1e.pb.FindReportNodeTasksRequest\x1a\x1f.pb.FindReportNodeTasksResponse\x12n\n" + "\x1bfindLatestReportNodeVersion\x12&.pb.FindLatestReportNodeVersionRequest\x1a'.pb.FindLatestReportNodeVersionResponse\x12S\n" + "\x17countAllReportNodeTasks\x12\".pb.CountAllReportNodeTasksRequest\x1a\x14.pb.RPCCountResponse\x12V\n" + "\x13listReportNodeTasks\x12\x1e.pb.ListReportNodeTasksRequest\x1a\x1f.pb.ListReportNodeTasksResponse\x12R\n" + "\x1dupdateReportNodeGlobalSetting\x12!.pb.UpdateReportNodeGlobalSetting\x1a\x0e.pb.RPCSuccess\x12n\n" + "\x1breadReportNodeGlobalSetting\x12&.pb.ReadReportNodeGlobalSettingRequest\x1a'.pb.ReadReportNodeGlobalSettingResponseB\x06Z\x04./pbb\x06proto3" var ( file_service_report_node_proto_rawDescOnce sync.Once file_service_report_node_proto_rawDescData []byte ) func file_service_report_node_proto_rawDescGZIP() []byte { file_service_report_node_proto_rawDescOnce.Do(func() { file_service_report_node_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_service_report_node_proto_rawDesc), len(file_service_report_node_proto_rawDesc))) }) return file_service_report_node_proto_rawDescData } var file_service_report_node_proto_msgTypes = make([]protoimpl.MessageInfo, 23) var file_service_report_node_proto_goTypes = []any{ (*CreateReportNodeRequest)(nil), // 0: pb.CreateReportNodeRequest (*CreateReportNodeResponse)(nil), // 1: pb.CreateReportNodeResponse (*DeleteReportNodeRequest)(nil), // 2: pb.DeleteReportNodeRequest (*UpdateReportNodeRequest)(nil), // 3: pb.UpdateReportNodeRequest (*CountAllEnabledReportNodesRequest)(nil), // 4: pb.CountAllEnabledReportNodesRequest (*ListEnabledReportNodesRequest)(nil), // 5: pb.ListEnabledReportNodesRequest (*ListEnabledReportNodesResponse)(nil), // 6: pb.ListEnabledReportNodesResponse (*FindEnabledReportNodeRequest)(nil), // 7: pb.FindEnabledReportNodeRequest (*FindEnabledReportNodeResponse)(nil), // 8: pb.FindEnabledReportNodeResponse (*ReportNodeStreamMessage)(nil), // 9: pb.ReportNodeStreamMessage (*UpdateReportNodeStatusRequest)(nil), // 10: pb.UpdateReportNodeStatusRequest (*FindCurrentReportNodeConfigRequest)(nil), // 11: pb.FindCurrentReportNodeConfigRequest (*FindCurrentReportNodeConfigResponse)(nil), // 12: pb.FindCurrentReportNodeConfigResponse (*FindReportNodeTasksRequest)(nil), // 13: pb.FindReportNodeTasksRequest (*FindReportNodeTasksResponse)(nil), // 14: pb.FindReportNodeTasksResponse (*FindLatestReportNodeVersionRequest)(nil), // 15: pb.FindLatestReportNodeVersionRequest (*FindLatestReportNodeVersionResponse)(nil), // 16: pb.FindLatestReportNodeVersionResponse (*CountAllReportNodeTasksRequest)(nil), // 17: pb.CountAllReportNodeTasksRequest (*ListReportNodeTasksRequest)(nil), // 18: pb.ListReportNodeTasksRequest (*ListReportNodeTasksResponse)(nil), // 19: pb.ListReportNodeTasksResponse (*UpdateReportNodeGlobalSetting)(nil), // 20: pb.UpdateReportNodeGlobalSetting (*ReadReportNodeGlobalSettingRequest)(nil), // 21: pb.ReadReportNodeGlobalSettingRequest (*ReadReportNodeGlobalSettingResponse)(nil), // 22: pb.ReadReportNodeGlobalSettingResponse (*ReportNode)(nil), // 23: pb.ReportNode (*IPAddrReportTask)(nil), // 24: pb.IPAddrReportTask (*RPCSuccess)(nil), // 25: pb.RPCSuccess (*RPCCountResponse)(nil), // 26: pb.RPCCountResponse } var file_service_report_node_proto_depIdxs = []int32{ 23, // 0: pb.ListEnabledReportNodesResponse.reportNodes:type_name -> pb.ReportNode 23, // 1: pb.FindEnabledReportNodeResponse.reportNode:type_name -> pb.ReportNode 24, // 2: pb.ListReportNodeTasksResponse.ipAddrReportTasks:type_name -> pb.IPAddrReportTask 0, // 3: pb.ReportNodeService.createReportNode:input_type -> pb.CreateReportNodeRequest 2, // 4: pb.ReportNodeService.deleteReportNode:input_type -> pb.DeleteReportNodeRequest 3, // 5: pb.ReportNodeService.updateReportNode:input_type -> pb.UpdateReportNodeRequest 4, // 6: pb.ReportNodeService.countAllEnabledReportNodes:input_type -> pb.CountAllEnabledReportNodesRequest 5, // 7: pb.ReportNodeService.listEnabledReportNodes:input_type -> pb.ListEnabledReportNodesRequest 7, // 8: pb.ReportNodeService.findEnabledReportNode:input_type -> pb.FindEnabledReportNodeRequest 9, // 9: pb.ReportNodeService.reportNodeStream:input_type -> pb.ReportNodeStreamMessage 10, // 10: pb.ReportNodeService.updateReportNodeStatus:input_type -> pb.UpdateReportNodeStatusRequest 11, // 11: pb.ReportNodeService.findCurrentReportNodeConfig:input_type -> pb.FindCurrentReportNodeConfigRequest 13, // 12: pb.ReportNodeService.findReportNodeTasks:input_type -> pb.FindReportNodeTasksRequest 15, // 13: pb.ReportNodeService.findLatestReportNodeVersion:input_type -> pb.FindLatestReportNodeVersionRequest 17, // 14: pb.ReportNodeService.countAllReportNodeTasks:input_type -> pb.CountAllReportNodeTasksRequest 18, // 15: pb.ReportNodeService.listReportNodeTasks:input_type -> pb.ListReportNodeTasksRequest 20, // 16: pb.ReportNodeService.updateReportNodeGlobalSetting:input_type -> pb.UpdateReportNodeGlobalSetting 21, // 17: pb.ReportNodeService.readReportNodeGlobalSetting:input_type -> pb.ReadReportNodeGlobalSettingRequest 1, // 18: pb.ReportNodeService.createReportNode:output_type -> pb.CreateReportNodeResponse 25, // 19: pb.ReportNodeService.deleteReportNode:output_type -> pb.RPCSuccess 25, // 20: pb.ReportNodeService.updateReportNode:output_type -> pb.RPCSuccess 26, // 21: pb.ReportNodeService.countAllEnabledReportNodes:output_type -> pb.RPCCountResponse 6, // 22: pb.ReportNodeService.listEnabledReportNodes:output_type -> pb.ListEnabledReportNodesResponse 8, // 23: pb.ReportNodeService.findEnabledReportNode:output_type -> pb.FindEnabledReportNodeResponse 9, // 24: pb.ReportNodeService.reportNodeStream:output_type -> pb.ReportNodeStreamMessage 25, // 25: pb.ReportNodeService.updateReportNodeStatus:output_type -> pb.RPCSuccess 12, // 26: pb.ReportNodeService.findCurrentReportNodeConfig:output_type -> pb.FindCurrentReportNodeConfigResponse 14, // 27: pb.ReportNodeService.findReportNodeTasks:output_type -> pb.FindReportNodeTasksResponse 16, // 28: pb.ReportNodeService.findLatestReportNodeVersion:output_type -> pb.FindLatestReportNodeVersionResponse 26, // 29: pb.ReportNodeService.countAllReportNodeTasks:output_type -> pb.RPCCountResponse 19, // 30: pb.ReportNodeService.listReportNodeTasks:output_type -> pb.ListReportNodeTasksResponse 25, // 31: pb.ReportNodeService.updateReportNodeGlobalSetting:output_type -> pb.RPCSuccess 22, // 32: pb.ReportNodeService.readReportNodeGlobalSetting:output_type -> pb.ReadReportNodeGlobalSettingResponse 18, // [18:33] is the sub-list for method output_type 3, // [3:18] is the sub-list for method input_type 3, // [3:3] is the sub-list for extension type_name 3, // [3:3] is the sub-list for extension extendee 0, // [0:3] is the sub-list for field type_name } func init() { file_service_report_node_proto_init() } func file_service_report_node_proto_init() { if File_service_report_node_proto != nil { return } file_models_model_report_node_proto_init() file_models_model_report_task_proto_init() file_models_rpc_messages_proto_init() type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_service_report_node_proto_rawDesc), len(file_service_report_node_proto_rawDesc)), NumEnums: 0, NumMessages: 23, NumExtensions: 0, NumServices: 1, }, GoTypes: file_service_report_node_proto_goTypes, DependencyIndexes: file_service_report_node_proto_depIdxs, MessageInfos: file_service_report_node_proto_msgTypes, }.Build() File_service_report_node_proto = out.File file_service_report_node_proto_goTypes = nil file_service_report_node_proto_depIdxs = nil }