v1

package
v0.0.0-...-9e464cf Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 14, 2026 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AlertService_CreateAlertRule_FullMethodName = "/api.admin.v1.AlertService/CreateAlertRule"
	AlertService_GetAlertRule_FullMethodName    = "/api.admin.v1.AlertService/GetAlertRule"
	AlertService_ListAlertRules_FullMethodName  = "/api.admin.v1.AlertService/ListAlertRules"
	AlertService_UpdateAlertRule_FullMethodName = "/api.admin.v1.AlertService/UpdateAlertRule"
	AlertService_DeleteAlertRule_FullMethodName = "/api.admin.v1.AlertService/DeleteAlertRule"
	AlertService_ListAlertEvents_FullMethodName = "/api.admin.v1.AlertService/ListAlertEvents"
)
View Source 
const (
	NodeService_GetNode_FullMethodName           = "/api.admin.v1.NodeService/GetNode"
	NodeService_DeleteNode_FullMethodName        = "/api.admin.v1.NodeService/DeleteNode"
	NodeService_UpdateNode_FullMethodName        = "/api.admin.v1.NodeService/UpdateNode"
	NodeService_UpdateNodeLabels_FullMethodName  = "/api.admin.v1.NodeService/UpdateNodeLabels"
	NodeService_ListNodes_FullMethodName         = "/api.admin.v1.NodeService/ListNodes"
	NodeService_GetNodeStatistics_FullMethodName = "/api.admin.v1.NodeService/GetNodeStatistics"
)
View Source 
const (
	TaskService_CreateTask_FullMethodName         = "/api.admin.v1.TaskService/CreateTask"
	TaskService_ListTasks_FullMethodName          = "/api.admin.v1.TaskService/ListTasks"
	TaskService_GetTask_FullMethodName            = "/api.admin.v1.TaskService/GetTask"
	TaskService_PauseTask_FullMethodName          = "/api.admin.v1.TaskService/PauseTask"
	TaskService_ResumeTask_FullMethodName         = "/api.admin.v1.TaskService/ResumeTask"
	TaskService_DeleteTask_FullMethodName         = "/api.admin.v1.TaskService/DeleteTask"
	TaskService_ListTaskRuns_FullMethodName       = "/api.admin.v1.TaskService/ListTaskRuns"
	TaskService_ListTaskRunResults_FullMethodName = "/api.admin.v1.TaskService/ListTaskRunResults"
)
View Source 
const OperationAlertServiceCreateAlertRule = "/api.admin.v1.AlertService/CreateAlertRule"
View Source 
const OperationAlertServiceDeleteAlertRule = "/api.admin.v1.AlertService/DeleteAlertRule"
View Source 
const OperationAlertServiceGetAlertRule = "/api.admin.v1.AlertService/GetAlertRule"
View Source 
const OperationAlertServiceListAlertEvents = "/api.admin.v1.AlertService/ListAlertEvents"
View Source 
const OperationAlertServiceListAlertRules = "/api.admin.v1.AlertService/ListAlertRules"
View Source 
const OperationAlertServiceUpdateAlertRule = "/api.admin.v1.AlertService/UpdateAlertRule"
View Source 
const OperationNodeServiceDeleteNode = "/api.admin.v1.NodeService/DeleteNode"
View Source 
const OperationNodeServiceGetNode = "/api.admin.v1.NodeService/GetNode"
View Source 
const OperationNodeServiceGetNodeStatistics = "/api.admin.v1.NodeService/GetNodeStatistics"
View Source 
const OperationNodeServiceListNodes = "/api.admin.v1.NodeService/ListNodes"
View Source 
const OperationNodeServiceUpdateNode = "/api.admin.v1.NodeService/UpdateNode"
View Source 
const OperationNodeServiceUpdateNodeLabels = "/api.admin.v1.NodeService/UpdateNodeLabels"
View Source 
const OperationRealtimeServiceGetRealtimeOverview = "/api.admin.v1.RealtimeService/GetRealtimeOverview"
View Source 
const OperationTaskServiceCreateTask = "/api.admin.v1.TaskService/CreateTask"
View Source 
const OperationTaskServiceDeleteTask = "/api.admin.v1.TaskService/DeleteTask"
View Source 
const OperationTaskServiceGetTask = "/api.admin.v1.TaskService/GetTask"
View Source 
const OperationTaskServiceListTaskRunResults = "/api.admin.v1.TaskService/ListTaskRunResults"
View Source 
const OperationTaskServiceListTaskRuns = "/api.admin.v1.TaskService/ListTaskRuns"
View Source 
const OperationTaskServiceListTasks = "/api.admin.v1.TaskService/ListTasks"
View Source 
const OperationTaskServicePauseTask = "/api.admin.v1.TaskService/PauseTask"
View Source 
const OperationTaskServiceResumeTask = "/api.admin.v1.TaskService/ResumeTask"
View Source 
const (
	RealtimeService_GetRealtimeOverview_FullMethodName = "/api.admin.v1.RealtimeService/GetRealtimeOverview"
)

Variables

View Source 
var (
	AlertWindow_name = map[int32]string{
		0:   "ALERT_WINDOW_UNSPECIFIED",
		60:  "ALERT_WINDOW_1_MINUTE",
		300: "ALERT_WINDOW_5_MINUTES",
		900: "ALERT_WINDOW_15_MINUTES",
	}
	AlertWindow_value = map[string]int32{
		"ALERT_WINDOW_UNSPECIFIED": 0,
		"ALERT_WINDOW_1_MINUTE":    60,
		"ALERT_WINDOW_5_MINUTES":   300,
		"ALERT_WINDOW_15_MINUTES":  900,
	}
)

Enum value maps for AlertWindow.

View Source 
var (
	AlertGroupOperator_name = map[int32]string{
		0: "ALERT_GROUP_OPERATOR_UNSPECIFIED",
		1: "ALERT_GROUP_OPERATOR_AND",
		2: "ALERT_GROUP_OPERATOR_OR",
	}
	AlertGroupOperator_value = map[string]int32{
		"ALERT_GROUP_OPERATOR_UNSPECIFIED": 0,
		"ALERT_GROUP_OPERATOR_AND":         1,
		"ALERT_GROUP_OPERATOR_OR":          2,
	}
)

Enum value maps for AlertGroupOperator.

View Source 
var (
	AlertMetric_name = map[int32]string{
		0: "ALERT_METRIC_UNSPECIFIED",
		1: "ALERT_METRIC_SUCCESS_RATE",
		2: "ALERT_METRIC_STATUS_INFO",
		3: "ALERT_METRIC_METADATA",
		4: "ALERT_METRIC_LATENCY_MS",
	}
	AlertMetric_value = map[string]int32{
		"ALERT_METRIC_UNSPECIFIED":  0,
		"ALERT_METRIC_SUCCESS_RATE": 1,
		"ALERT_METRIC_STATUS_INFO":  2,
		"ALERT_METRIC_METADATA":     3,
		"ALERT_METRIC_LATENCY_MS":   4,
	}
)

Enum value maps for AlertMetric.

View Source 
var (
	AlertComparison_name = map[int32]string{
		0: "ALERT_COMPARISON_UNSPECIFIED",
		1: "ALERT_COMPARISON_GT",
		2: "ALERT_COMPARISON_GTE",
		3: "ALERT_COMPARISON_LT",
		4: "ALERT_COMPARISON_LTE",
		5: "ALERT_COMPARISON_BETWEEN",
		6: "ALERT_COMPARISON_EQ",
		7: "ALERT_COMPARISON_NE",
		8: "ALERT_COMPARISON_CONTAINS",
	}
	AlertComparison_value = map[string]int32{
		"ALERT_COMPARISON_UNSPECIFIED": 0,
		"ALERT_COMPARISON_GT":          1,
		"ALERT_COMPARISON_GTE":         2,
		"ALERT_COMPARISON_LT":          3,
		"ALERT_COMPARISON_LTE":         4,
		"ALERT_COMPARISON_BETWEEN":     5,
		"ALERT_COMPARISON_EQ":          6,
		"ALERT_COMPARISON_NE":          7,
		"ALERT_COMPARISON_CONTAINS":    8,
	}
)

Enum value maps for AlertComparison.

View Source 
var (
	AlertState_name = map[int32]string{
		0: "ALERT_STATE_UNSPECIFIED",
		1: "ALERT_STATE_NORMAL",
		2: "ALERT_STATE_FIRING",
	}
	AlertState_value = map[string]int32{
		"ALERT_STATE_UNSPECIFIED": 0,
		"ALERT_STATE_NORMAL":      1,
		"ALERT_STATE_FIRING":      2,
	}
)

Enum value maps for AlertState.

View Source 
var (
	AlertEvaluationOutcome_name = map[int32]string{
		0: "ALERT_EVALUATION_OUTCOME_UNSPECIFIED",
		1: "ALERT_EVALUATION_OUTCOME_MATCHED",
		2: "ALERT_EVALUATION_OUTCOME_NOT_MATCHED",
		3: "ALERT_EVALUATION_OUTCOME_NO_DATA",
	}
	AlertEvaluationOutcome_value = map[string]int32{
		"ALERT_EVALUATION_OUTCOME_UNSPECIFIED": 0,
		"ALERT_EVALUATION_OUTCOME_MATCHED":     1,
		"ALERT_EVALUATION_OUTCOME_NOT_MATCHED": 2,
		"ALERT_EVALUATION_OUTCOME_NO_DATA":     3,
	}
)

Enum value maps for AlertEvaluationOutcome.

View Source 
var (
	AlertEventStatus_name = map[int32]string{
		0: "ALERT_EVENT_STATUS_UNSPECIFIED",
		1: "ALERT_EVENT_STATUS_FIRING",
		2: "ALERT_EVENT_STATUS_RESOLVED",
	}
	AlertEventStatus_value = map[string]int32{
		"ALERT_EVENT_STATUS_UNSPECIFIED": 0,
		"ALERT_EVENT_STATUS_FIRING":      1,
		"ALERT_EVENT_STATUS_RESOLVED":    2,
	}
)

Enum value maps for AlertEventStatus.

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "TASK_STATUS_UNSPECIFIED",
		1: "TASK_STATUS_PENDING",
		2: "TASK_STATUS_RUNNING",
		3: "TASK_STATUS_COMPLETED",
		4: "TASK_STATUS_FAILED",
		5: "TASK_STATUS_PAUSED",
	}
	TaskStatus_value = map[string]int32{
		"TASK_STATUS_UNSPECIFIED": 0,
		"TASK_STATUS_PENDING":     1,
		"TASK_STATUS_RUNNING":     2,
		"TASK_STATUS_COMPLETED":   3,
		"TASK_STATUS_FAILED":      4,
		"TASK_STATUS_PAUSED":      5,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	TaskType_name = map[int32]string{
		0: "TASK_TYPE_UNSPECIFIED",
		1: "TASK_TYPE_ONCE",
		2: "TASK_TYPE_PERIODIC",
	}
	TaskType_value = map[string]int32{
		"TASK_TYPE_UNSPECIFIED": 0,
		"TASK_TYPE_ONCE":        1,
		"TASK_TYPE_PERIODIC":    2,
	}
)

Enum value maps for TaskType.

View Source 
var (
	TaskRunStatus_name = map[int32]string{
		0: "TASK_RUN_STATUS_UNSPECIFIED",
		1: "TASK_RUN_STATUS_RUNNING",
		2: "TASK_RUN_STATUS_COMPLETED",
		3: "TASK_RUN_STATUS_PARTIAL",
		4: "TASK_RUN_STATUS_TIMED_OUT",
	}
	TaskRunStatus_value = map[string]int32{
		"TASK_RUN_STATUS_UNSPECIFIED": 0,
		"TASK_RUN_STATUS_RUNNING":     1,
		"TASK_RUN_STATUS_COMPLETED":   2,
		"TASK_RUN_STATUS_PARTIAL":     3,
		"TASK_RUN_STATUS_TIMED_OUT":   4,
	}
)

Enum value maps for TaskRunStatus.

View Source 
var (
	TaskRunResultStatus_name = map[int32]string{
		0: "TASK_RUN_RESULT_STATUS_UNSPECIFIED",
		1: "TASK_RUN_RESULT_STATUS_WAITING",
		2: "TASK_RUN_RESULT_STATUS_SUCCESS",
		3: "TASK_RUN_RESULT_STATUS_FAILED",
		4: "TASK_RUN_RESULT_STATUS_TIMED_OUT",
	}
	TaskRunResultStatus_value = map[string]int32{
		"TASK_RUN_RESULT_STATUS_UNSPECIFIED": 0,
		"TASK_RUN_RESULT_STATUS_WAITING":     1,
		"TASK_RUN_RESULT_STATUS_SUCCESS":     2,
		"TASK_RUN_RESULT_STATUS_FAILED":      3,
		"TASK_RUN_RESULT_STATUS_TIMED_OUT":   4,
	}
)

Enum value maps for TaskRunResultStatus.

View Source 
var (
	CreateTaskRequest_Protocol_name = map[int32]string{
		0: "PROTOCOL_UNSPECIFIED",
		1: "ICMP",
		2: "TCP",
		3: "UDP",
		4: "HTTP",
		5: "HTTPS",
		6: "DNS",
		7: "BROWSER",
	}
	CreateTaskRequest_Protocol_value = map[string]int32{
		"PROTOCOL_UNSPECIFIED": 0,
		"ICMP":                 1,
		"TCP":                  2,
		"UDP":                  3,
		"HTTP":                 4,
		"HTTPS":                5,
		"DNS":                  6,
		"BROWSER":              7,
	}
)

Enum value maps for CreateTaskRequest_Protocol.

View Source 
var AlertService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.admin.v1.AlertService",
	HandlerType: (*AlertServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateAlertRule",
			Handler:    _AlertService_CreateAlertRule_Handler,
		},
		{
			MethodName: "GetAlertRule",
			Handler:    _AlertService_GetAlertRule_Handler,
		},
		{
			MethodName: "ListAlertRules",
			Handler:    _AlertService_ListAlertRules_Handler,
		},
		{
			MethodName: "UpdateAlertRule",
			Handler:    _AlertService_UpdateAlertRule_Handler,
		},
		{
			MethodName: "DeleteAlertRule",
			Handler:    _AlertService_DeleteAlertRule_Handler,
		},
		{
			MethodName: "ListAlertEvents",
			Handler:    _AlertService_ListAlertEvents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "admin/v1/alert.proto",
}

AlertService_ServiceDesc is the grpc.ServiceDesc for AlertService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_admin_v1_alert_proto protoreflect.FileDescriptor
View Source 
var File_admin_v1_node_proto protoreflect.FileDescriptor
View Source 
var File_admin_v1_realtime_proto protoreflect.FileDescriptor
View Source 
var File_admin_v1_task_proto protoreflect.FileDescriptor
View Source 
var NodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.admin.v1.NodeService",
	HandlerType: (*NodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNode",
			Handler:    _NodeService_GetNode_Handler,
		},
		{
			MethodName: "DeleteNode",
			Handler:    _NodeService_DeleteNode_Handler,
		},
		{
			MethodName: "UpdateNode",
			Handler:    _NodeService_UpdateNode_Handler,
		},
		{
			MethodName: "UpdateNodeLabels",
			Handler:    _NodeService_UpdateNodeLabels_Handler,
		},
		{
			MethodName: "ListNodes",
			Handler:    _NodeService_ListNodes_Handler,
		},
		{
			MethodName: "GetNodeStatistics",
			Handler:    _NodeService_GetNodeStatistics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "admin/v1/node.proto",
}

NodeService_ServiceDesc is the grpc.ServiceDesc for NodeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RealtimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.admin.v1.RealtimeService",
	HandlerType: (*RealtimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRealtimeOverview",
			Handler:    _RealtimeService_GetRealtimeOverview_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "admin/v1/realtime.proto",
}

RealtimeService_ServiceDesc is the grpc.ServiceDesc for RealtimeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.admin.v1.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTask",
			Handler:    _TaskService_CreateTask_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _TaskService_ListTasks_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _TaskService_GetTask_Handler,
		},
		{
			MethodName: "PauseTask",
			Handler:    _TaskService_PauseTask_Handler,
		},
		{
			MethodName: "ResumeTask",
			Handler:    _TaskService_ResumeTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _TaskService_DeleteTask_Handler,
		},
		{
			MethodName: "ListTaskRuns",
			Handler:    _TaskService_ListTaskRuns_Handler,
		},
		{
			MethodName: "ListTaskRunResults",
			Handler:    _TaskService_ListTaskRunResults_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "admin/v1/task.proto",
}

TaskService_ServiceDesc is the grpc.ServiceDesc for TaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAlertServiceHTTPServer 

func RegisterAlertServiceHTTPServer(s *http.Server, srv AlertServiceHTTPServer)

func RegisterAlertServiceServer 

func RegisterAlertServiceServer(s grpc.ServiceRegistrar, srv AlertServiceServer)

func RegisterNodeServiceHTTPServer 

func RegisterNodeServiceHTTPServer(s *http.Server, srv NodeServiceHTTPServer)

func RegisterNodeServiceServer 

func RegisterNodeServiceServer(s grpc.ServiceRegistrar, srv NodeServiceServer)

func RegisterRealtimeServiceHTTPServer 

func RegisterRealtimeServiceHTTPServer(s *http.Server, srv RealtimeServiceHTTPServer)

func RegisterRealtimeServiceServer 

func RegisterRealtimeServiceServer(s grpc.ServiceRegistrar, srv RealtimeServiceServer)

func RegisterTaskServiceHTTPServer 

func RegisterTaskServiceHTTPServer(s *http.Server, srv TaskServiceHTTPServer)

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

Types

type AlertComparison 

type AlertComparison int32
const (
	AlertComparison_ALERT_COMPARISON_UNSPECIFIED AlertComparison = 0
	AlertComparison_ALERT_COMPARISON_GT          AlertComparison = 1
	AlertComparison_ALERT_COMPARISON_GTE         AlertComparison = 2
	AlertComparison_ALERT_COMPARISON_LT          AlertComparison = 3
	AlertComparison_ALERT_COMPARISON_LTE         AlertComparison = 4
	AlertComparison_ALERT_COMPARISON_BETWEEN     AlertComparison = 5
	AlertComparison_ALERT_COMPARISON_EQ          AlertComparison = 6
	AlertComparison_ALERT_COMPARISON_NE          AlertComparison = 7
	AlertComparison_ALERT_COMPARISON_CONTAINS    AlertComparison = 8
)

func (AlertComparison) Descriptor 

func (AlertComparison) Descriptor() protoreflect.EnumDescriptor

func (AlertComparison) Enum 

func (x AlertComparison) Enum() *AlertComparison

func (AlertComparison) EnumDescriptor deprecated 

func (AlertComparison) EnumDescriptor() ([]byte, []int)

Deprecated: Use AlertComparison.Descriptor instead.

func (AlertComparison) Number 

func (x AlertComparison) Number() protoreflect.EnumNumber

func (AlertComparison) String 

func (x AlertComparison) String() string

func (AlertComparison) Type 

func (AlertComparison) Type() protoreflect.EnumType

type AlertCondition 

type AlertCondition struct {
	Metric      AlertMetric     `protobuf:"varint,1,opt,name=metric,proto3,enum=api.admin.v1.AlertMetric" json:"metric,omitempty"`
	Comparison  AlertComparison `protobuf:"varint,2,opt,name=comparison,proto3,enum=api.admin.v1.AlertComparison" json:"comparison,omitempty"`
	Value       float64         `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	UpperValue  float64         `protobuf:"fixed64,4,opt,name=upper_value,json=upperValue,proto3" json:"upper_value,omitempty"`
	TextValue   string          `protobuf:"bytes,5,opt,name=text_value,json=textValue,proto3" json:"text_value,omitempty"`
	MetadataKey string          `protobuf:"bytes,6,opt,name=metadata_key,json=metadataKey,proto3" json:"metadata_key,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertCondition) Descriptor deprecated 

func (*AlertCondition) Descriptor() ([]byte, []int)

Deprecated: Use AlertCondition.ProtoReflect.Descriptor instead.

func (*AlertCondition) GetComparison 

func (x *AlertCondition) GetComparison() AlertComparison

func (*AlertCondition) GetMetadataKey 

func (x *AlertCondition) GetMetadataKey() string

func (*AlertCondition) GetMetric 

func (x *AlertCondition) GetMetric() AlertMetric

func (*AlertCondition) GetTextValue 

func (x *AlertCondition) GetTextValue() string

func (*AlertCondition) GetUpperValue 

func (x *AlertCondition) GetUpperValue() float64

func (*AlertCondition) GetValue 

func (x *AlertCondition) GetValue() float64

func (*AlertCondition) ProtoMessage 

func (*AlertCondition) ProtoMessage()

func (*AlertCondition) ProtoReflect 

func (x *AlertCondition) ProtoReflect() protoreflect.Message

func (*AlertCondition) Reset 

func (x *AlertCondition) Reset()

func (*AlertCondition) String 

func (x *AlertCondition) String() string

type AlertConditionGroup 

type AlertConditionGroup struct {
	Operator AlertGroupOperator `protobuf:"varint,1,opt,name=operator,proto3,enum=api.admin.v1.AlertGroupOperator" json:"operator,omitempty"`
	Children []*AlertExpression `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertConditionGroup) Descriptor deprecated 

func (*AlertConditionGroup) Descriptor() ([]byte, []int)

Deprecated: Use AlertConditionGroup.ProtoReflect.Descriptor instead.

func (*AlertConditionGroup) GetChildren 

func (x *AlertConditionGroup) GetChildren() []*AlertExpression

func (*AlertConditionGroup) GetOperator 

func (x *AlertConditionGroup) GetOperator() AlertGroupOperator

func (*AlertConditionGroup) ProtoMessage 

func (*AlertConditionGroup) ProtoMessage()

func (*AlertConditionGroup) ProtoReflect 

func (x *AlertConditionGroup) ProtoReflect() protoreflect.Message

func (*AlertConditionGroup) Reset 

func (x *AlertConditionGroup) Reset()

func (*AlertConditionGroup) String 

func (x *AlertConditionGroup) String() string

type AlertEvaluationOutcome 

type AlertEvaluationOutcome int32
const (
	AlertEvaluationOutcome_ALERT_EVALUATION_OUTCOME_UNSPECIFIED AlertEvaluationOutcome = 0
	AlertEvaluationOutcome_ALERT_EVALUATION_OUTCOME_MATCHED     AlertEvaluationOutcome = 1
	AlertEvaluationOutcome_ALERT_EVALUATION_OUTCOME_NOT_MATCHED AlertEvaluationOutcome = 2
	AlertEvaluationOutcome_ALERT_EVALUATION_OUTCOME_NO_DATA     AlertEvaluationOutcome = 3
)

func (AlertEvaluationOutcome) Descriptor 

func (AlertEvaluationOutcome) Descriptor() protoreflect.EnumDescriptor

func (AlertEvaluationOutcome) Enum 

func (x AlertEvaluationOutcome) Enum() *AlertEvaluationOutcome

func (AlertEvaluationOutcome) EnumDescriptor deprecated 

func (AlertEvaluationOutcome) EnumDescriptor() ([]byte, []int)

Deprecated: Use AlertEvaluationOutcome.Descriptor instead.

func (AlertEvaluationOutcome) Number 

func (x AlertEvaluationOutcome) Number() protoreflect.EnumNumber

func (AlertEvaluationOutcome) String 

func (x AlertEvaluationOutcome) String() string

func (AlertEvaluationOutcome) Type 

func (AlertEvaluationOutcome) Type() protoreflect.EnumType

type AlertEvent 

type AlertEvent struct {
	Id          int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	RuleId      int64                  `protobuf:"varint,2,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	TaskId      int64                  `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	UserId      int64                  `protobuf:"varint,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	RuleVersion int64                  `protobuf:"varint,5,opt,name=rule_version,json=ruleVersion,proto3" json:"rule_version,omitempty"`
	Status      AlertEventStatus       `protobuf:"varint,6,opt,name=status,proto3,enum=api.admin.v1.AlertEventStatus" json:"status,omitempty"`
	Reason      string                 `protobuf:"bytes,7,opt,name=reason,proto3" json:"reason,omitempty"`
	Evidence    *AlertEvidence         `protobuf:"bytes,8,opt,name=evidence,proto3" json:"evidence,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertEvent) Descriptor deprecated 

func (*AlertEvent) Descriptor() ([]byte, []int)

Deprecated: Use AlertEvent.ProtoReflect.Descriptor instead.

func (*AlertEvent) GetCreatedAt 

func (x *AlertEvent) GetCreatedAt() *timestamppb.Timestamp

func (*AlertEvent) GetEvidence 

func (x *AlertEvent) GetEvidence() *AlertEvidence

func (*AlertEvent) GetId 

func (x *AlertEvent) GetId() int64

func (*AlertEvent) GetReason 

func (x *AlertEvent) GetReason() string

func (*AlertEvent) GetRuleId 

func (x *AlertEvent) GetRuleId() int64

func (*AlertEvent) GetRuleVersion 

func (x *AlertEvent) GetRuleVersion() int64

func (*AlertEvent) GetStatus 

func (x *AlertEvent) GetStatus() AlertEventStatus

func (*AlertEvent) GetTaskId 

func (x *AlertEvent) GetTaskId() int64

func (*AlertEvent) GetUserId 

func (x *AlertEvent) GetUserId() int64

func (*AlertEvent) ProtoMessage 

func (*AlertEvent) ProtoMessage()

func (*AlertEvent) ProtoReflect 

func (x *AlertEvent) ProtoReflect() protoreflect.Message

func (*AlertEvent) Reset 

func (x *AlertEvent) Reset()

func (*AlertEvent) String 

func (x *AlertEvent) String() string

type AlertEventStatus 

type AlertEventStatus int32
const (
	AlertEventStatus_ALERT_EVENT_STATUS_UNSPECIFIED AlertEventStatus = 0
	AlertEventStatus_ALERT_EVENT_STATUS_FIRING      AlertEventStatus = 1
	AlertEventStatus_ALERT_EVENT_STATUS_RESOLVED    AlertEventStatus = 2
)

func (AlertEventStatus) Descriptor 

func (AlertEventStatus) Descriptor() protoreflect.EnumDescriptor

func (AlertEventStatus) Enum 

func (x AlertEventStatus) Enum() *AlertEventStatus

func (AlertEventStatus) EnumDescriptor deprecated 

func (AlertEventStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use AlertEventStatus.Descriptor instead.

func (AlertEventStatus) Number 

func (x AlertEventStatus) Number() protoreflect.EnumNumber

func (AlertEventStatus) String 

func (x AlertEventStatus) String() string

func (AlertEventStatus) Type 

func (AlertEventStatus) Type() protoreflect.EnumType

type AlertEvidence 

type AlertEvidence struct {
	WindowStart   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`
	WindowEnd     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=window_end,json=windowEnd,proto3" json:"window_end,omitempty"`
	SampleTotal   int64                  `protobuf:"varint,3,opt,name=sample_total,json=sampleTotal,proto3" json:"sample_total,omitempty"`
	SuccessTotal  int64                  `protobuf:"varint,4,opt,name=success_total,json=successTotal,proto3" json:"success_total,omitempty"`
	FailureTotal  int64                  `protobuf:"varint,5,opt,name=failure_total,json=failureTotal,proto3" json:"failure_total,omitempty"`
	TimeoutTotal  int64                  `protobuf:"varint,6,opt,name=timeout_total,json=timeoutTotal,proto3" json:"timeout_total,omitempty"`
	SuccessRate   float64                `protobuf:"fixed64,7,opt,name=success_rate,json=successRate,proto3" json:"success_rate,omitempty"`
	MatchedResult *AlertResultEvidence   `protobuf:"bytes,8,opt,name=matched_result,json=matchedResult,proto3" json:"matched_result,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertEvidence) Descriptor deprecated 

func (*AlertEvidence) Descriptor() ([]byte, []int)

Deprecated: Use AlertEvidence.ProtoReflect.Descriptor instead.

func (*AlertEvidence) GetFailureTotal 

func (x *AlertEvidence) GetFailureTotal() int64

func (*AlertEvidence) GetMatchedResult 

func (x *AlertEvidence) GetMatchedResult() *AlertResultEvidence

func (*AlertEvidence) GetSampleTotal 

func (x *AlertEvidence) GetSampleTotal() int64

func (*AlertEvidence) GetSuccessRate 

func (x *AlertEvidence) GetSuccessRate() float64

func (*AlertEvidence) GetSuccessTotal 

func (x *AlertEvidence) GetSuccessTotal() int64

func (*AlertEvidence) GetTimeoutTotal 

func (x *AlertEvidence) GetTimeoutTotal() int64

func (*AlertEvidence) GetWindowEnd 

func (x *AlertEvidence) GetWindowEnd() *timestamppb.Timestamp

func (*AlertEvidence) GetWindowStart 

func (x *AlertEvidence) GetWindowStart() *timestamppb.Timestamp

func (*AlertEvidence) ProtoMessage 

func (*AlertEvidence) ProtoMessage()

func (*AlertEvidence) ProtoReflect 

func (x *AlertEvidence) ProtoReflect() protoreflect.Message

func (*AlertEvidence) Reset 

func (x *AlertEvidence) Reset()

func (*AlertEvidence) String 

func (x *AlertEvidence) String() string

type AlertExpression 

type AlertExpression struct {

	// Types that are valid to be assigned to Node:
	//
	//	*AlertExpression_Group
	//	*AlertExpression_Condition
	Node isAlertExpression_Node `protobuf_oneof:"node"`
	// contains filtered or unexported fields
}

func (*AlertExpression) Descriptor deprecated 

func (*AlertExpression) Descriptor() ([]byte, []int)

Deprecated: Use AlertExpression.ProtoReflect.Descriptor instead.

func (*AlertExpression) GetCondition 

func (x *AlertExpression) GetCondition() *AlertCondition

func (*AlertExpression) GetGroup 

func (x *AlertExpression) GetGroup() *AlertConditionGroup

func (*AlertExpression) GetNode 

func (x *AlertExpression) GetNode() isAlertExpression_Node

func (*AlertExpression) ProtoMessage 

func (*AlertExpression) ProtoMessage()

func (*AlertExpression) ProtoReflect 

func (x *AlertExpression) ProtoReflect() protoreflect.Message

func (*AlertExpression) Reset 

func (x *AlertExpression) Reset()

func (*AlertExpression) String 

func (x *AlertExpression) String() string

type AlertExpression_Condition 

type AlertExpression_Condition struct {
	Condition *AlertCondition `protobuf:"bytes,2,opt,name=condition,proto3,oneof"`
}

type AlertExpression_Group 

type AlertExpression_Group struct {
	Group *AlertConditionGroup `protobuf:"bytes,1,opt,name=group,proto3,oneof"`
}

type AlertGroupOperator 

type AlertGroupOperator int32
const (
	AlertGroupOperator_ALERT_GROUP_OPERATOR_UNSPECIFIED AlertGroupOperator = 0
	AlertGroupOperator_ALERT_GROUP_OPERATOR_AND         AlertGroupOperator = 1
	AlertGroupOperator_ALERT_GROUP_OPERATOR_OR          AlertGroupOperator = 2
)

func (AlertGroupOperator) Descriptor 

func (AlertGroupOperator) Descriptor() protoreflect.EnumDescriptor

func (AlertGroupOperator) Enum 

func (x AlertGroupOperator) Enum() *AlertGroupOperator

func (AlertGroupOperator) EnumDescriptor deprecated 

func (AlertGroupOperator) EnumDescriptor() ([]byte, []int)

Deprecated: Use AlertGroupOperator.Descriptor instead.

func (AlertGroupOperator) Number 

func (x AlertGroupOperator) Number() protoreflect.EnumNumber

func (AlertGroupOperator) String 

func (x AlertGroupOperator) String() string

func (AlertGroupOperator) Type 

func (AlertGroupOperator) Type() protoreflect.EnumType

type AlertMetric 

type AlertMetric int32
const (
	AlertMetric_ALERT_METRIC_UNSPECIFIED  AlertMetric = 0
	AlertMetric_ALERT_METRIC_SUCCESS_RATE AlertMetric = 1
	AlertMetric_ALERT_METRIC_STATUS_INFO  AlertMetric = 2
	AlertMetric_ALERT_METRIC_METADATA     AlertMetric = 3
	AlertMetric_ALERT_METRIC_LATENCY_MS   AlertMetric = 4
)

func (AlertMetric) Descriptor 

func (AlertMetric) Descriptor() protoreflect.EnumDescriptor

func (AlertMetric) Enum 

func (x AlertMetric) Enum() *AlertMetric

func (AlertMetric) EnumDescriptor deprecated 

func (AlertMetric) EnumDescriptor() ([]byte, []int)

Deprecated: Use AlertMetric.Descriptor instead.

func (AlertMetric) Number 

func (x AlertMetric) Number() protoreflect.EnumNumber

func (AlertMetric) String 

func (x AlertMetric) String() string

func (AlertMetric) Type 

func (AlertMetric) Type() protoreflect.EnumType

type AlertResultEvidence 

type AlertResultEvidence struct {
	ResultId   int64                  `protobuf:"varint,1,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"`
	RunId      int64                  `protobuf:"varint,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	NodeId     string                 `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Status     TaskRunResultStatus    `protobuf:"varint,4,opt,name=status,proto3,enum=api.admin.v1.TaskRunResultStatus" json:"status,omitempty"`
	LatencyMs  int64                  `protobuf:"varint,5,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
	StatusInfo string                 `protobuf:"bytes,6,opt,name=status_info,json=statusInfo,proto3" json:"status_info,omitempty"`
	Metadata   map[string]string      `` /* 143-byte string literal not displayed */
	ReportedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=reported_at,json=reportedAt,proto3" json:"reported_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertResultEvidence) Descriptor deprecated 

func (*AlertResultEvidence) Descriptor() ([]byte, []int)

Deprecated: Use AlertResultEvidence.ProtoReflect.Descriptor instead.

func (*AlertResultEvidence) GetLatencyMs 

func (x *AlertResultEvidence) GetLatencyMs() int64

func (*AlertResultEvidence) GetMetadata 

func (x *AlertResultEvidence) GetMetadata() map[string]string

func (*AlertResultEvidence) GetNodeId 

func (x *AlertResultEvidence) GetNodeId() string

func (*AlertResultEvidence) GetReportedAt 

func (x *AlertResultEvidence) GetReportedAt() *timestamppb.Timestamp

func (*AlertResultEvidence) GetResultId 

func (x *AlertResultEvidence) GetResultId() int64

func (*AlertResultEvidence) GetRunId 

func (x *AlertResultEvidence) GetRunId() int64

func (*AlertResultEvidence) GetStatus 

func (x *AlertResultEvidence) GetStatus() TaskRunResultStatus

func (*AlertResultEvidence) GetStatusInfo 

func (x *AlertResultEvidence) GetStatusInfo() string

func (*AlertResultEvidence) ProtoMessage 

func (*AlertResultEvidence) ProtoMessage()

func (*AlertResultEvidence) ProtoReflect 

func (x *AlertResultEvidence) ProtoReflect() protoreflect.Message

func (*AlertResultEvidence) Reset 

func (x *AlertResultEvidence) Reset()

func (*AlertResultEvidence) String 

func (x *AlertResultEvidence) String() string

type AlertRule 

type AlertRule struct {
	Id              int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId          int64                  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	TaskId          int64                  `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Name            string                 `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Enabled         bool                   `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Window          AlertWindow            `protobuf:"varint,6,opt,name=window,proto3,enum=api.admin.v1.AlertWindow" json:"window,omitempty"`
	MinimumResults  uint32                 `protobuf:"varint,7,opt,name=minimum_results,json=minimumResults,proto3" json:"minimum_results,omitempty"`
	Expression      *AlertExpression       `protobuf:"bytes,8,opt,name=expression,proto3" json:"expression,omitempty"`
	Version         int64                  `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"`
	State           AlertState             `protobuf:"varint,10,opt,name=state,proto3,enum=api.admin.v1.AlertState" json:"state,omitempty"`
	LastOutcome     AlertEvaluationOutcome `` /* 137-byte string literal not displayed */
	LastEvaluatedAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=last_evaluated_at,json=lastEvaluatedAt,proto3" json:"last_evaluated_at,omitempty"`
	CreatedAt       *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt       *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertRule) Descriptor deprecated 

func (*AlertRule) Descriptor() ([]byte, []int)

Deprecated: Use AlertRule.ProtoReflect.Descriptor instead.

func (*AlertRule) GetCreatedAt 

func (x *AlertRule) GetCreatedAt() *timestamppb.Timestamp

func (*AlertRule) GetEnabled 

func (x *AlertRule) GetEnabled() bool

func (*AlertRule) GetExpression 

func (x *AlertRule) GetExpression() *AlertExpression

func (*AlertRule) GetId 

func (x *AlertRule) GetId() int64

func (*AlertRule) GetLastEvaluatedAt 

func (x *AlertRule) GetLastEvaluatedAt() *timestamppb.Timestamp

func (*AlertRule) GetLastOutcome 

func (x *AlertRule) GetLastOutcome() AlertEvaluationOutcome

func (*AlertRule) GetMinimumResults 

func (x *AlertRule) GetMinimumResults() uint32

func (*AlertRule) GetName 

func (x *AlertRule) GetName() string

func (*AlertRule) GetState 

func (x *AlertRule) GetState() AlertState

func (*AlertRule) GetTaskId 

func (x *AlertRule) GetTaskId() int64

func (*AlertRule) GetUpdatedAt 

func (x *AlertRule) GetUpdatedAt() *timestamppb.Timestamp

func (*AlertRule) GetUserId 

func (x *AlertRule) GetUserId() int64

func (*AlertRule) GetVersion 

func (x *AlertRule) GetVersion() int64

func (*AlertRule) GetWindow 

func (x *AlertRule) GetWindow() AlertWindow

func (*AlertRule) ProtoMessage 

func (*AlertRule) ProtoMessage()

func (*AlertRule) ProtoReflect 

func (x *AlertRule) ProtoReflect() protoreflect.Message

func (*AlertRule) Reset 

func (x *AlertRule) Reset()

func (*AlertRule) String 

func (x *AlertRule) String() string

type AlertServiceClient 

type AlertServiceClient interface {
	CreateAlertRule(ctx context.Context, in *CreateAlertRuleRequest, opts ...grpc.CallOption) (*AlertRule, error)
	GetAlertRule(ctx context.Context, in *GetAlertRuleRequest, opts ...grpc.CallOption) (*AlertRule, error)
	ListAlertRules(ctx context.Context, in *ListAlertRulesRequest, opts ...grpc.CallOption) (*ListAlertRulesReply, error)
	UpdateAlertRule(ctx context.Context, in *UpdateAlertRuleRequest, opts ...grpc.CallOption) (*AlertRule, error)
	DeleteAlertRule(ctx context.Context, in *DeleteAlertRuleRequest, opts ...grpc.CallOption) (*DeleteAlertRuleReply, error)
	ListAlertEvents(ctx context.Context, in *ListAlertEventsRequest, opts ...grpc.CallOption) (*ListAlertEventsReply, error)
}

AlertServiceClient is the client API for AlertService 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.

func NewAlertServiceClient 

func NewAlertServiceClient(cc grpc.ClientConnInterface) AlertServiceClient

type AlertServiceHTTPClient 

type AlertServiceHTTPClient interface {
	CreateAlertRule(ctx context.Context, req *CreateAlertRuleRequest, opts ...http.CallOption) (rsp *AlertRule, err error)
	DeleteAlertRule(ctx context.Context, req *DeleteAlertRuleRequest, opts ...http.CallOption) (rsp *DeleteAlertRuleReply, err error)
	GetAlertRule(ctx context.Context, req *GetAlertRuleRequest, opts ...http.CallOption) (rsp *AlertRule, err error)
	ListAlertEvents(ctx context.Context, req *ListAlertEventsRequest, opts ...http.CallOption) (rsp *ListAlertEventsReply, err error)
	ListAlertRules(ctx context.Context, req *ListAlertRulesRequest, opts ...http.CallOption) (rsp *ListAlertRulesReply, err error)
	UpdateAlertRule(ctx context.Context, req *UpdateAlertRuleRequest, opts ...http.CallOption) (rsp *AlertRule, err error)
}

func NewAlertServiceHTTPClient 

func NewAlertServiceHTTPClient(client *http.Client) AlertServiceHTTPClient

type AlertServiceHTTPClientImpl 

type AlertServiceHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*AlertServiceHTTPClientImpl) CreateAlertRule 

func (c *AlertServiceHTTPClientImpl) CreateAlertRule(ctx context.Context, in *CreateAlertRuleRequest, opts ...http.CallOption) (*AlertRule, error)

func (*AlertServiceHTTPClientImpl) DeleteAlertRule 

func (c *AlertServiceHTTPClientImpl) DeleteAlertRule(ctx context.Context, in *DeleteAlertRuleRequest, opts ...http.CallOption) (*DeleteAlertRuleReply, error)

func (*AlertServiceHTTPClientImpl) GetAlertRule 

func (c *AlertServiceHTTPClientImpl) GetAlertRule(ctx context.Context, in *GetAlertRuleRequest, opts ...http.CallOption) (*AlertRule, error)

func (*AlertServiceHTTPClientImpl) ListAlertEvents 

func (c *AlertServiceHTTPClientImpl) ListAlertEvents(ctx context.Context, in *ListAlertEventsRequest, opts ...http.CallOption) (*ListAlertEventsReply, error)

func (*AlertServiceHTTPClientImpl) ListAlertRules 

func (c *AlertServiceHTTPClientImpl) ListAlertRules(ctx context.Context, in *ListAlertRulesRequest, opts ...http.CallOption) (*ListAlertRulesReply, error)

func (*AlertServiceHTTPClientImpl) UpdateAlertRule 

func (c *AlertServiceHTTPClientImpl) UpdateAlertRule(ctx context.Context, in *UpdateAlertRuleRequest, opts ...http.CallOption) (*AlertRule, error)

type AlertServiceHTTPServer 

type AlertServiceHTTPServer interface {
	CreateAlertRule(context.Context, *CreateAlertRuleRequest) (*AlertRule, error)
	DeleteAlertRule(context.Context, *DeleteAlertRuleRequest) (*DeleteAlertRuleReply, error)
	GetAlertRule(context.Context, *GetAlertRuleRequest) (*AlertRule, error)
	ListAlertEvents(context.Context, *ListAlertEventsRequest) (*ListAlertEventsReply, error)
	ListAlertRules(context.Context, *ListAlertRulesRequest) (*ListAlertRulesReply, error)
	UpdateAlertRule(context.Context, *UpdateAlertRuleRequest) (*AlertRule, error)
}

type AlertServiceServer 

type AlertServiceServer interface {
	CreateAlertRule(context.Context, *CreateAlertRuleRequest) (*AlertRule, error)
	GetAlertRule(context.Context, *GetAlertRuleRequest) (*AlertRule, error)
	ListAlertRules(context.Context, *ListAlertRulesRequest) (*ListAlertRulesReply, error)
	UpdateAlertRule(context.Context, *UpdateAlertRuleRequest) (*AlertRule, error)
	DeleteAlertRule(context.Context, *DeleteAlertRuleRequest) (*DeleteAlertRuleReply, error)
	ListAlertEvents(context.Context, *ListAlertEventsRequest) (*ListAlertEventsReply, error)
	// contains filtered or unexported methods
}

AlertServiceServer is the server API for AlertService service. All implementations must embed UnimplementedAlertServiceServer for forward compatibility.

type AlertState 

type AlertState int32
const (
	AlertState_ALERT_STATE_UNSPECIFIED AlertState = 0
	AlertState_ALERT_STATE_NORMAL      AlertState = 1
	AlertState_ALERT_STATE_FIRING      AlertState = 2
)

func (AlertState) Descriptor 

func (AlertState) Descriptor() protoreflect.EnumDescriptor

func (AlertState) Enum 

func (x AlertState) Enum() *AlertState

func (AlertState) EnumDescriptor deprecated 

func (AlertState) EnumDescriptor() ([]byte, []int)

Deprecated: Use AlertState.Descriptor instead.

func (AlertState) Number 

func (x AlertState) Number() protoreflect.EnumNumber

func (AlertState) String 

func (x AlertState) String() string

func (AlertState) Type 

func (AlertState) Type() protoreflect.EnumType

type AlertWindow 

type AlertWindow int32
const (
	AlertWindow_ALERT_WINDOW_UNSPECIFIED AlertWindow = 0
	AlertWindow_ALERT_WINDOW_1_MINUTE    AlertWindow = 60
	AlertWindow_ALERT_WINDOW_5_MINUTES   AlertWindow = 300
	AlertWindow_ALERT_WINDOW_15_MINUTES  AlertWindow = 900
)

func (AlertWindow) Descriptor 

func (AlertWindow) Descriptor() protoreflect.EnumDescriptor

func (AlertWindow) Enum 

func (x AlertWindow) Enum() *AlertWindow

func (AlertWindow) EnumDescriptor deprecated 

func (AlertWindow) EnumDescriptor() ([]byte, []int)

Deprecated: Use AlertWindow.Descriptor instead.

func (AlertWindow) Number 

func (x AlertWindow) Number() protoreflect.EnumNumber

func (AlertWindow) String 

func (x AlertWindow) String() string

func (AlertWindow) Type 

func (AlertWindow) Type() protoreflect.EnumType

type CreateAlertRuleRequest 

type CreateAlertRuleRequest struct {
	UserId         int64            `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	TaskId         int64            `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Name           string           `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Enabled        bool             `protobuf:"varint,4,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Window         AlertWindow      `protobuf:"varint,5,opt,name=window,proto3,enum=api.admin.v1.AlertWindow" json:"window,omitempty"`
	MinimumResults uint32           `protobuf:"varint,6,opt,name=minimum_results,json=minimumResults,proto3" json:"minimum_results,omitempty"`
	Expression     *AlertExpression `protobuf:"bytes,7,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAlertRuleRequest) Descriptor deprecated 

func (*CreateAlertRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateAlertRuleRequest.ProtoReflect.Descriptor instead.

func (*CreateAlertRuleRequest) GetEnabled 

func (x *CreateAlertRuleRequest) GetEnabled() bool

func (*CreateAlertRuleRequest) GetExpression 

func (x *CreateAlertRuleRequest) GetExpression() *AlertExpression

func (*CreateAlertRuleRequest) GetMinimumResults 

func (x *CreateAlertRuleRequest) GetMinimumResults() uint32

func (*CreateAlertRuleRequest) GetName 

func (x *CreateAlertRuleRequest) GetName() string

func (*CreateAlertRuleRequest) GetTaskId 

func (x *CreateAlertRuleRequest) GetTaskId() int64

func (*CreateAlertRuleRequest) GetUserId 

func (x *CreateAlertRuleRequest) GetUserId() int64

func (*CreateAlertRuleRequest) GetWindow 

func (x *CreateAlertRuleRequest) GetWindow() AlertWindow

func (*CreateAlertRuleRequest) ProtoMessage 

func (*CreateAlertRuleRequest) ProtoMessage()

func (*CreateAlertRuleRequest) ProtoReflect 

func (x *CreateAlertRuleRequest) ProtoReflect() protoreflect.Message

func (*CreateAlertRuleRequest) Reset 

func (x *CreateAlertRuleRequest) Reset()

func (*CreateAlertRuleRequest) String 

func (x *CreateAlertRuleRequest) String() string

type CreateTaskReply 

type CreateTaskReply struct {
	// contains filtered or unexported fields
}

func (*CreateTaskReply) Descriptor deprecated 

func (*CreateTaskReply) Descriptor() ([]byte, []int)

Deprecated: Use CreateTaskReply.ProtoReflect.Descriptor instead.

func (*CreateTaskReply) ProtoMessage 

func (*CreateTaskReply) ProtoMessage()

func (*CreateTaskReply) ProtoReflect 

func (x *CreateTaskReply) ProtoReflect() protoreflect.Message

func (*CreateTaskReply) Reset 

func (x *CreateTaskReply) Reset()

func (*CreateTaskReply) String 

func (x *CreateTaskReply) String() string

type CreateTaskRequest 

type CreateTaskRequest struct {
	Proto        CreateTaskRequest_Protocol `protobuf:"varint,1,opt,name=proto,proto3,enum=api.admin.v1.CreateTaskRequest_Protocol" json:"proto,omitempty"`
	Target       string                     `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Timeout      uint32                     `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Payload      []byte                     `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata     map[string]string          `` /* 143-byte string literal not displayed */
	NodeSelector map[string]string          `` /* 171-byte string literal not displayed */
	UserId       int64                      `protobuf:"varint,7,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Type         TaskType                   `protobuf:"varint,8,opt,name=type,proto3,enum=api.admin.v1.TaskType" json:"type,omitempty"`
	Interval     uint32                     `protobuf:"varint,9,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskRequest) Descriptor deprecated 

func (*CreateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetInterval 

func (x *CreateTaskRequest) GetInterval() uint32

func (*CreateTaskRequest) GetMetadata 

func (x *CreateTaskRequest) GetMetadata() map[string]string

func (*CreateTaskRequest) GetNodeSelector 

func (x *CreateTaskRequest) GetNodeSelector() map[string]string

func (*CreateTaskRequest) GetPayload 

func (x *CreateTaskRequest) GetPayload() []byte

func (*CreateTaskRequest) GetProto 

func (x *CreateTaskRequest) GetProto() CreateTaskRequest_Protocol

func (*CreateTaskRequest) GetTarget 

func (x *CreateTaskRequest) GetTarget() string

func (*CreateTaskRequest) GetTimeout 

func (x *CreateTaskRequest) GetTimeout() uint32

func (*CreateTaskRequest) GetType 

func (x *CreateTaskRequest) GetType() TaskType

func (*CreateTaskRequest) GetUserId 

func (x *CreateTaskRequest) GetUserId() int64

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect 

func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message

func (*CreateTaskRequest) Reset 

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (x *CreateTaskRequest) String() string

type CreateTaskRequest_Protocol 

type CreateTaskRequest_Protocol int32
const (
	CreateTaskRequest_PROTOCOL_UNSPECIFIED CreateTaskRequest_Protocol = 0
	CreateTaskRequest_ICMP                 CreateTaskRequest_Protocol = 1
	CreateTaskRequest_TCP                  CreateTaskRequest_Protocol = 2
	CreateTaskRequest_UDP                  CreateTaskRequest_Protocol = 3
	CreateTaskRequest_HTTP                 CreateTaskRequest_Protocol = 4
	CreateTaskRequest_HTTPS                CreateTaskRequest_Protocol = 5
	CreateTaskRequest_DNS                  CreateTaskRequest_Protocol = 6
	CreateTaskRequest_BROWSER              CreateTaskRequest_Protocol = 7
)

func (CreateTaskRequest_Protocol) Descriptor 

func (CreateTaskRequest_Protocol) Descriptor() protoreflect.EnumDescriptor

func (CreateTaskRequest_Protocol) Enum 

func (x CreateTaskRequest_Protocol) Enum() *CreateTaskRequest_Protocol

func (CreateTaskRequest_Protocol) EnumDescriptor deprecated 

func (CreateTaskRequest_Protocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use CreateTaskRequest_Protocol.Descriptor instead.

func (CreateTaskRequest_Protocol) Number 

func (x CreateTaskRequest_Protocol) Number() protoreflect.EnumNumber

func (CreateTaskRequest_Protocol) String 

func (x CreateTaskRequest_Protocol) String() string

func (CreateTaskRequest_Protocol) Type 

func (CreateTaskRequest_Protocol) Type() protoreflect.EnumType

type DeleteAlertRuleReply 

type DeleteAlertRuleReply struct {
	// contains filtered or unexported fields
}

func (*DeleteAlertRuleReply) Descriptor deprecated 

func (*DeleteAlertRuleReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAlertRuleReply.ProtoReflect.Descriptor instead.

func (*DeleteAlertRuleReply) ProtoMessage 

func (*DeleteAlertRuleReply) ProtoMessage()

func (*DeleteAlertRuleReply) ProtoReflect 

func (x *DeleteAlertRuleReply) ProtoReflect() protoreflect.Message

func (*DeleteAlertRuleReply) Reset 

func (x *DeleteAlertRuleReply) Reset()

func (*DeleteAlertRuleReply) String 

func (x *DeleteAlertRuleReply) String() string

type DeleteAlertRuleRequest 

type DeleteAlertRuleRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAlertRuleRequest) Descriptor deprecated 

func (*DeleteAlertRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAlertRuleRequest.ProtoReflect.Descriptor instead.

func (*DeleteAlertRuleRequest) GetId 

func (x *DeleteAlertRuleRequest) GetId() int64

func (*DeleteAlertRuleRequest) GetUserId 

func (x *DeleteAlertRuleRequest) GetUserId() int64

func (*DeleteAlertRuleRequest) ProtoMessage 

func (*DeleteAlertRuleRequest) ProtoMessage()

func (*DeleteAlertRuleRequest) ProtoReflect 

func (x *DeleteAlertRuleRequest) ProtoReflect() protoreflect.Message

func (*DeleteAlertRuleRequest) Reset 

func (x *DeleteAlertRuleRequest) Reset()

func (*DeleteAlertRuleRequest) String 

func (x *DeleteAlertRuleRequest) String() string

type DeleteNodeReply 

type DeleteNodeReply struct {
	// contains filtered or unexported fields
}

func (*DeleteNodeReply) Descriptor deprecated 

func (*DeleteNodeReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteNodeReply.ProtoReflect.Descriptor instead.

func (*DeleteNodeReply) ProtoMessage 

func (*DeleteNodeReply) ProtoMessage()

func (*DeleteNodeReply) ProtoReflect 

func (x *DeleteNodeReply) ProtoReflect() protoreflect.Message

func (*DeleteNodeReply) Reset 

func (x *DeleteNodeReply) Reset()

func (*DeleteNodeReply) String 

func (x *DeleteNodeReply) String() string

type DeleteNodeRequest 

type DeleteNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNodeRequest) Descriptor deprecated 

func (*DeleteNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteNodeRequest.ProtoReflect.Descriptor instead.

func (*DeleteNodeRequest) GetNodeId 

func (x *DeleteNodeRequest) GetNodeId() string

func (*DeleteNodeRequest) ProtoMessage 

func (*DeleteNodeRequest) ProtoMessage()

func (*DeleteNodeRequest) ProtoReflect 

func (x *DeleteNodeRequest) ProtoReflect() protoreflect.Message

func (*DeleteNodeRequest) Reset 

func (x *DeleteNodeRequest) Reset()

func (*DeleteNodeRequest) String 

func (x *DeleteNodeRequest) String() string

type DeleteTaskReply 

type DeleteTaskReply struct {
	// contains filtered or unexported fields
}

func (*DeleteTaskReply) Descriptor deprecated 

func (*DeleteTaskReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTaskReply.ProtoReflect.Descriptor instead.

func (*DeleteTaskReply) ProtoMessage 

func (*DeleteTaskReply) ProtoMessage()

func (*DeleteTaskReply) ProtoReflect 

func (x *DeleteTaskReply) ProtoReflect() protoreflect.Message

func (*DeleteTaskReply) Reset 

func (x *DeleteTaskReply) Reset()

func (*DeleteTaskReply) String 

func (x *DeleteTaskReply) String() string

type DeleteTaskRequest 

type DeleteTaskRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTaskRequest) Descriptor deprecated 

func (*DeleteTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetId 

func (x *DeleteTaskRequest) GetId() int64

func (*DeleteTaskRequest) GetUserId 

func (x *DeleteTaskRequest) GetUserId() int64

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect 

func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

type GetAlertRuleRequest 

type GetAlertRuleRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAlertRuleRequest) Descriptor deprecated 

func (*GetAlertRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAlertRuleRequest.ProtoReflect.Descriptor instead.

func (*GetAlertRuleRequest) GetId 

func (x *GetAlertRuleRequest) GetId() int64

func (*GetAlertRuleRequest) GetUserId 

func (x *GetAlertRuleRequest) GetUserId() int64

func (*GetAlertRuleRequest) ProtoMessage 

func (*GetAlertRuleRequest) ProtoMessage()

func (*GetAlertRuleRequest) ProtoReflect 

func (x *GetAlertRuleRequest) ProtoReflect() protoreflect.Message

func (*GetAlertRuleRequest) Reset 

func (x *GetAlertRuleRequest) Reset()

func (*GetAlertRuleRequest) String 

func (x *GetAlertRuleRequest) String() string

type GetNodeReply 

type GetNodeReply struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeReply) Descriptor deprecated 

func (*GetNodeReply) Descriptor() ([]byte, []int)

Deprecated: Use GetNodeReply.ProtoReflect.Descriptor instead.

func (*GetNodeReply) GetNode 

func (x *GetNodeReply) GetNode() *Node

func (*GetNodeReply) ProtoMessage 

func (*GetNodeReply) ProtoMessage()

func (*GetNodeReply) ProtoReflect 

func (x *GetNodeReply) ProtoReflect() protoreflect.Message

func (*GetNodeReply) Reset 

func (x *GetNodeReply) Reset()

func (*GetNodeReply) String 

func (x *GetNodeReply) String() string

type GetNodeRequest 

type GetNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeRequest) Descriptor deprecated 

func (*GetNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.

func (*GetNodeRequest) GetNodeId 

func (x *GetNodeRequest) GetNodeId() string

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) ProtoReflect 

func (x *GetNodeRequest) ProtoReflect() protoreflect.Message

func (*GetNodeRequest) Reset 

func (x *GetNodeRequest) Reset()

func (*GetNodeRequest) String 

func (x *GetNodeRequest) String() string

type GetNodeStatisticsReply 

type GetNodeStatisticsReply struct {
	TotalNodes       int64 `protobuf:"varint,1,opt,name=total_nodes,json=totalNodes,proto3" json:"total_nodes,omitempty"`
	OnlineNodes      int64 `protobuf:"varint,2,opt,name=online_nodes,json=onlineNodes,proto3" json:"online_nodes,omitempty"`
	GeoIpMatches     int64 `protobuf:"varint,3,opt,name=geo_ip_matches,json=geoIpMatches,proto3" json:"geo_ip_matches,omitempty"`
	CoveredProvinces int64 `protobuf:"varint,4,opt,name=covered_provinces,json=coveredProvinces,proto3" json:"covered_provinces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeStatisticsReply) Descriptor deprecated 

func (*GetNodeStatisticsReply) Descriptor() ([]byte, []int)

Deprecated: Use GetNodeStatisticsReply.ProtoReflect.Descriptor instead.

func (*GetNodeStatisticsReply) GetCoveredProvinces 

func (x *GetNodeStatisticsReply) GetCoveredProvinces() int64

func (*GetNodeStatisticsReply) GetGeoIpMatches 

func (x *GetNodeStatisticsReply) GetGeoIpMatches() int64

func (*GetNodeStatisticsReply) GetOnlineNodes 

func (x *GetNodeStatisticsReply) GetOnlineNodes() int64

func (*GetNodeStatisticsReply) GetTotalNodes 

func (x *GetNodeStatisticsReply) GetTotalNodes() int64

func (*GetNodeStatisticsReply) ProtoMessage 

func (*GetNodeStatisticsReply) ProtoMessage()

func (*GetNodeStatisticsReply) ProtoReflect 

func (x *GetNodeStatisticsReply) ProtoReflect() protoreflect.Message

func (*GetNodeStatisticsReply) Reset 

func (x *GetNodeStatisticsReply) Reset()

func (*GetNodeStatisticsReply) String 

func (x *GetNodeStatisticsReply) String() string

type GetNodeStatisticsRequest 

type GetNodeStatisticsRequest struct {
	// contains filtered or unexported fields
}

func (*GetNodeStatisticsRequest) Descriptor deprecated 

func (*GetNodeStatisticsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetNodeStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetNodeStatisticsRequest) ProtoMessage 

func (*GetNodeStatisticsRequest) ProtoMessage()

func (*GetNodeStatisticsRequest) ProtoReflect 

func (x *GetNodeStatisticsRequest) ProtoReflect() protoreflect.Message

func (*GetNodeStatisticsRequest) Reset 

func (x *GetNodeStatisticsRequest) Reset()

func (*GetNodeStatisticsRequest) String 

func (x *GetNodeStatisticsRequest) String() string

type GetRealtimeOverviewRequest 

type GetRealtimeOverviewRequest struct {
	UserId        int64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	TaskId        int64 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	WindowSeconds int32 `protobuf:"varint,3,opt,name=window_seconds,json=windowSeconds,proto3" json:"window_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRealtimeOverviewRequest) Descriptor deprecated 

func (*GetRealtimeOverviewRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRealtimeOverviewRequest.ProtoReflect.Descriptor instead.

func (*GetRealtimeOverviewRequest) GetTaskId 

func (x *GetRealtimeOverviewRequest) GetTaskId() int64

func (*GetRealtimeOverviewRequest) GetUserId 

func (x *GetRealtimeOverviewRequest) GetUserId() int64

func (*GetRealtimeOverviewRequest) GetWindowSeconds 

func (x *GetRealtimeOverviewRequest) GetWindowSeconds() int32

func (*GetRealtimeOverviewRequest) ProtoMessage 

func (*GetRealtimeOverviewRequest) ProtoMessage()

func (*GetRealtimeOverviewRequest) ProtoReflect 

func (x *GetRealtimeOverviewRequest) ProtoReflect() protoreflect.Message

func (*GetRealtimeOverviewRequest) Reset 

func (x *GetRealtimeOverviewRequest) Reset()

func (*GetRealtimeOverviewRequest) String 

func (x *GetRealtimeOverviewRequest) String() string

type GetTaskRequest 

type GetTaskRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskRequest) Descriptor deprecated 

func (*GetTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetId 

func (x *GetTaskRequest) GetId() int64

func (*GetTaskRequest) GetUserId 

func (x *GetTaskRequest) GetUserId() int64

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect 

func (x *GetTaskRequest) ProtoReflect() protoreflect.Message

func (*GetTaskRequest) Reset 

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (x *GetTaskRequest) String() string

type ListAlertEventsReply 

type ListAlertEventsReply struct {
	Data       []*AlertEvent        `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAlertEventsReply) Descriptor deprecated 

func (*ListAlertEventsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListAlertEventsReply.ProtoReflect.Descriptor instead.

func (*ListAlertEventsReply) GetData 

func (x *ListAlertEventsReply) GetData() []*AlertEvent

func (*ListAlertEventsReply) GetPagination 

func (x *ListAlertEventsReply) GetPagination() *protobuf.Pagination

func (*ListAlertEventsReply) ProtoMessage 

func (*ListAlertEventsReply) ProtoMessage()

func (*ListAlertEventsReply) ProtoReflect 

func (x *ListAlertEventsReply) ProtoReflect() protoreflect.Message

func (*ListAlertEventsReply) Reset 

func (x *ListAlertEventsReply) Reset()

func (*ListAlertEventsReply) String 

func (x *ListAlertEventsReply) String() string

type ListAlertEventsRequest 

type ListAlertEventsRequest struct {
	UserId     int64                `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	RuleId     int64                `protobuf:"varint,2,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	TaskId     int64                `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Status     AlertEventStatus     `protobuf:"varint,4,opt,name=status,proto3,enum=api.admin.v1.AlertEventStatus" json:"status,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,5,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAlertEventsRequest) Descriptor deprecated 

func (*ListAlertEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAlertEventsRequest.ProtoReflect.Descriptor instead.

func (*ListAlertEventsRequest) GetPagination 

func (x *ListAlertEventsRequest) GetPagination() *protobuf.Pagination

func (*ListAlertEventsRequest) GetRuleId 

func (x *ListAlertEventsRequest) GetRuleId() int64

func (*ListAlertEventsRequest) GetStatus 

func (x *ListAlertEventsRequest) GetStatus() AlertEventStatus

func (*ListAlertEventsRequest) GetTaskId 

func (x *ListAlertEventsRequest) GetTaskId() int64

func (*ListAlertEventsRequest) GetUserId 

func (x *ListAlertEventsRequest) GetUserId() int64

func (*ListAlertEventsRequest) ProtoMessage 

func (*ListAlertEventsRequest) ProtoMessage()

func (*ListAlertEventsRequest) ProtoReflect 

func (x *ListAlertEventsRequest) ProtoReflect() protoreflect.Message

func (*ListAlertEventsRequest) Reset 

func (x *ListAlertEventsRequest) Reset()

func (*ListAlertEventsRequest) String 

func (x *ListAlertEventsRequest) String() string

type ListAlertRulesReply 

type ListAlertRulesReply struct {
	Data       []*AlertRule         `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAlertRulesReply) Descriptor deprecated 

func (*ListAlertRulesReply) Descriptor() ([]byte, []int)

Deprecated: Use ListAlertRulesReply.ProtoReflect.Descriptor instead.

func (*ListAlertRulesReply) GetData 

func (x *ListAlertRulesReply) GetData() []*AlertRule

func (*ListAlertRulesReply) GetPagination 

func (x *ListAlertRulesReply) GetPagination() *protobuf.Pagination

func (*ListAlertRulesReply) ProtoMessage 

func (*ListAlertRulesReply) ProtoMessage()

func (*ListAlertRulesReply) ProtoReflect 

func (x *ListAlertRulesReply) ProtoReflect() protoreflect.Message

func (*ListAlertRulesReply) Reset 

func (x *ListAlertRulesReply) Reset()

func (*ListAlertRulesReply) String 

func (x *ListAlertRulesReply) String() string

type ListAlertRulesRequest 

type ListAlertRulesRequest struct {
	UserId     int64                `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	TaskId     int64                `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Enabled    *bool                `protobuf:"varint,3,opt,name=enabled,proto3,oneof" json:"enabled,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,4,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAlertRulesRequest) Descriptor deprecated 

func (*ListAlertRulesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAlertRulesRequest.ProtoReflect.Descriptor instead.

func (*ListAlertRulesRequest) GetEnabled 

func (x *ListAlertRulesRequest) GetEnabled() bool

func (*ListAlertRulesRequest) GetPagination 

func (x *ListAlertRulesRequest) GetPagination() *protobuf.Pagination

func (*ListAlertRulesRequest) GetTaskId 

func (x *ListAlertRulesRequest) GetTaskId() int64

func (*ListAlertRulesRequest) GetUserId 

func (x *ListAlertRulesRequest) GetUserId() int64

func (*ListAlertRulesRequest) ProtoMessage 

func (*ListAlertRulesRequest) ProtoMessage()

func (*ListAlertRulesRequest) ProtoReflect 

func (x *ListAlertRulesRequest) ProtoReflect() protoreflect.Message

func (*ListAlertRulesRequest) Reset 

func (x *ListAlertRulesRequest) Reset()

func (*ListAlertRulesRequest) String 

func (x *ListAlertRulesRequest) String() string

type ListNodesReply 

type ListNodesReply struct {
	Data       []*Node              `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodesReply) Descriptor deprecated 

func (*ListNodesReply) Descriptor() ([]byte, []int)

Deprecated: Use ListNodesReply.ProtoReflect.Descriptor instead.

func (*ListNodesReply) GetData 

func (x *ListNodesReply) GetData() []*Node

func (*ListNodesReply) GetPagination 

func (x *ListNodesReply) GetPagination() *protobuf.Pagination

func (*ListNodesReply) ProtoMessage 

func (*ListNodesReply) ProtoMessage()

func (*ListNodesReply) ProtoReflect 

func (x *ListNodesReply) ProtoReflect() protoreflect.Message

func (*ListNodesReply) Reset 

func (x *ListNodesReply) Reset()

func (*ListNodesReply) String 

func (x *ListNodesReply) String() string

type ListNodesRequest 

type ListNodesRequest struct {
	Pagination *protobuf.Pagination `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodesRequest) Descriptor deprecated 

func (*ListNodesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) GetPagination 

func (x *ListNodesRequest) GetPagination() *protobuf.Pagination

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect 

func (x *ListNodesRequest) ProtoReflect() protoreflect.Message

func (*ListNodesRequest) Reset 

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (x *ListNodesRequest) String() string

type ListTaskRunResultsReply 

type ListTaskRunResultsReply struct {
	Data       []*TaskRunResult     `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskRunResultsReply) Descriptor deprecated 

func (*ListTaskRunResultsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListTaskRunResultsReply.ProtoReflect.Descriptor instead.

func (*ListTaskRunResultsReply) GetData 

func (x *ListTaskRunResultsReply) GetData() []*TaskRunResult

func (*ListTaskRunResultsReply) GetPagination 

func (x *ListTaskRunResultsReply) GetPagination() *protobuf.Pagination

func (*ListTaskRunResultsReply) ProtoMessage 

func (*ListTaskRunResultsReply) ProtoMessage()

func (*ListTaskRunResultsReply) ProtoReflect 

func (x *ListTaskRunResultsReply) ProtoReflect() protoreflect.Message

func (*ListTaskRunResultsReply) Reset 

func (x *ListTaskRunResultsReply) Reset()

func (*ListTaskRunResultsReply) String 

func (x *ListTaskRunResultsReply) String() string

type ListTaskRunResultsRequest 

type ListTaskRunResultsRequest struct {
	RunId      int64                `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	UserId     int64                `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskRunResultsRequest) Descriptor deprecated 

func (*ListTaskRunResultsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTaskRunResultsRequest.ProtoReflect.Descriptor instead.

func (*ListTaskRunResultsRequest) GetPagination 

func (x *ListTaskRunResultsRequest) GetPagination() *protobuf.Pagination

func (*ListTaskRunResultsRequest) GetRunId 

func (x *ListTaskRunResultsRequest) GetRunId() int64

func (*ListTaskRunResultsRequest) GetUserId 

func (x *ListTaskRunResultsRequest) GetUserId() int64

func (*ListTaskRunResultsRequest) ProtoMessage 

func (*ListTaskRunResultsRequest) ProtoMessage()

func (*ListTaskRunResultsRequest) ProtoReflect 

func (x *ListTaskRunResultsRequest) ProtoReflect() protoreflect.Message

func (*ListTaskRunResultsRequest) Reset 

func (x *ListTaskRunResultsRequest) Reset()

func (*ListTaskRunResultsRequest) String 

func (x *ListTaskRunResultsRequest) String() string

type ListTaskRunsReply 

type ListTaskRunsReply struct {
	Data       []*TaskRun           `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskRunsReply) Descriptor deprecated 

func (*ListTaskRunsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListTaskRunsReply.ProtoReflect.Descriptor instead.

func (*ListTaskRunsReply) GetData 

func (x *ListTaskRunsReply) GetData() []*TaskRun

func (*ListTaskRunsReply) GetPagination 

func (x *ListTaskRunsReply) GetPagination() *protobuf.Pagination

func (*ListTaskRunsReply) ProtoMessage 

func (*ListTaskRunsReply) ProtoMessage()

func (*ListTaskRunsReply) ProtoReflect 

func (x *ListTaskRunsReply) ProtoReflect() protoreflect.Message

func (*ListTaskRunsReply) Reset 

func (x *ListTaskRunsReply) Reset()

func (*ListTaskRunsReply) String 

func (x *ListTaskRunsReply) String() string

type ListTaskRunsRequest 

type ListTaskRunsRequest struct {
	TaskId     int64                `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	UserId     int64                `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskRunsRequest) Descriptor deprecated 

func (*ListTaskRunsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTaskRunsRequest.ProtoReflect.Descriptor instead.

func (*ListTaskRunsRequest) GetPagination 

func (x *ListTaskRunsRequest) GetPagination() *protobuf.Pagination

func (*ListTaskRunsRequest) GetTaskId 

func (x *ListTaskRunsRequest) GetTaskId() int64

func (*ListTaskRunsRequest) GetUserId 

func (x *ListTaskRunsRequest) GetUserId() int64

func (*ListTaskRunsRequest) ProtoMessage 

func (*ListTaskRunsRequest) ProtoMessage()

func (*ListTaskRunsRequest) ProtoReflect 

func (x *ListTaskRunsRequest) ProtoReflect() protoreflect.Message

func (*ListTaskRunsRequest) Reset 

func (x *ListTaskRunsRequest) Reset()

func (*ListTaskRunsRequest) String 

func (x *ListTaskRunsRequest) String() string

type ListTasksReply 

type ListTasksReply struct {
	Data       []*Task              `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksReply) Descriptor deprecated 

func (*ListTasksReply) Descriptor() ([]byte, []int)

Deprecated: Use ListTasksReply.ProtoReflect.Descriptor instead.

func (*ListTasksReply) GetData 

func (x *ListTasksReply) GetData() []*Task

func (*ListTasksReply) GetPagination 

func (x *ListTasksReply) GetPagination() *protobuf.Pagination

func (*ListTasksReply) ProtoMessage 

func (*ListTasksReply) ProtoMessage()

func (*ListTasksReply) ProtoReflect 

func (x *ListTasksReply) ProtoReflect() protoreflect.Message

func (*ListTasksReply) Reset 

func (x *ListTasksReply) Reset()

func (*ListTasksReply) String 

func (x *ListTasksReply) String() string

type ListTasksRequest 

type ListTasksRequest struct {
	UserId     int64                `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Pagination *protobuf.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// 任务状态过滤，TASK_STATUS_UNSPECIFIED 表示不过滤
	Status TaskStatus `protobuf:"varint,3,opt,name=status,proto3,enum=api.admin.v1.TaskStatus" json:"status,omitempty"`
	// 协议类型过滤，PROTOCOL_UNSPECIFIED 表示不过滤
	Proto CreateTaskRequest_Protocol `protobuf:"varint,4,opt,name=proto,proto3,enum=api.admin.v1.CreateTaskRequest_Protocol" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

func (*ListTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetPagination 

func (x *ListTasksRequest) GetPagination() *protobuf.Pagination

func (*ListTasksRequest) GetProto 

func (x *ListTasksRequest) GetProto() CreateTaskRequest_Protocol

func (*ListTasksRequest) GetStatus 

func (x *ListTasksRequest) GetStatus() TaskStatus

func (*ListTasksRequest) GetUserId 

func (x *ListTasksRequest) GetUserId() int64

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

func (x *ListTasksRequest) ProtoReflect() protoreflect.Message

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type Node 

type Node struct {
	Id          int64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeId      string            `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Name        string            `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string            `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	PublicIp    string            `protobuf:"bytes,5,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"`
	PrivateIp   string            `protobuf:"bytes,6,opt,name=private_ip,json=privateIp,proto3" json:"private_ip,omitempty"`
	LastSeen    int64             `protobuf:"varint,7,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	Area        string            `protobuf:"bytes,8,opt,name=area,proto3" json:"area,omitempty"`
	Country     string            `protobuf:"bytes,9,opt,name=country,proto3" json:"country,omitempty"`
	Region      string            `protobuf:"bytes,10,opt,name=region,proto3" json:"region,omitempty"`
	City        string            `protobuf:"bytes,11,opt,name=city,proto3" json:"city,omitempty"`
	Isp         string            `protobuf:"bytes,12,opt,name=isp,proto3" json:"isp,omitempty"`
	Labels      map[string]string `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetArea 

func (x *Node) GetArea() string

func (*Node) GetCity 

func (x *Node) GetCity() string

func (*Node) GetCountry 

func (x *Node) GetCountry() string

func (*Node) GetDescription 

func (x *Node) GetDescription() string

func (*Node) GetId 

func (x *Node) GetId() int64

func (*Node) GetIsp 

func (x *Node) GetIsp() string

func (*Node) GetLabels 

func (x *Node) GetLabels() map[string]string

func (*Node) GetLastSeen 

func (x *Node) GetLastSeen() int64

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetNodeId 

func (x *Node) GetNodeId() string

func (*Node) GetPrivateIp 

func (x *Node) GetPrivateIp() string

func (*Node) GetPublicIp 

func (x *Node) GetPublicIp() string

func (*Node) GetRegion 

func (x *Node) GetRegion() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeServiceClient 

type NodeServiceClient interface {
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeReply, error)
	DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*DeleteNodeReply, error)
	UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeReply, error)
	UpdateNodeLabels(ctx context.Context, in *UpdateNodeLabelsRequest, opts ...grpc.CallOption) (*UpdateNodeReply, error)
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesReply, error)
	GetNodeStatistics(ctx context.Context, in *GetNodeStatisticsRequest, opts ...grpc.CallOption) (*GetNodeStatisticsReply, error)
}

NodeServiceClient is the client API for NodeService 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.

func NewNodeServiceClient 

func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient

type NodeServiceHTTPClient 

type NodeServiceHTTPClient interface {
	DeleteNode(ctx context.Context, req *DeleteNodeRequest, opts ...http.CallOption) (rsp *DeleteNodeReply, err error)
	GetNode(ctx context.Context, req *GetNodeRequest, opts ...http.CallOption) (rsp *GetNodeReply, err error)
	GetNodeStatistics(ctx context.Context, req *GetNodeStatisticsRequest, opts ...http.CallOption) (rsp *GetNodeStatisticsReply, err error)
	ListNodes(ctx context.Context, req *ListNodesRequest, opts ...http.CallOption) (rsp *ListNodesReply, err error)
	UpdateNode(ctx context.Context, req *UpdateNodeRequest, opts ...http.CallOption) (rsp *UpdateNodeReply, err error)
	UpdateNodeLabels(ctx context.Context, req *UpdateNodeLabelsRequest, opts ...http.CallOption) (rsp *UpdateNodeReply, err error)
}

func NewNodeServiceHTTPClient 

func NewNodeServiceHTTPClient(client *http.Client) NodeServiceHTTPClient

type NodeServiceHTTPClientImpl 

type NodeServiceHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*NodeServiceHTTPClientImpl) DeleteNode 

func (c *NodeServiceHTTPClientImpl) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...http.CallOption) (*DeleteNodeReply, error)

func (*NodeServiceHTTPClientImpl) GetNode 

func (c *NodeServiceHTTPClientImpl) GetNode(ctx context.Context, in *GetNodeRequest, opts ...http.CallOption) (*GetNodeReply, error)

func (*NodeServiceHTTPClientImpl) GetNodeStatistics 

func (c *NodeServiceHTTPClientImpl) GetNodeStatistics(ctx context.Context, in *GetNodeStatisticsRequest, opts ...http.CallOption) (*GetNodeStatisticsReply, error)

func (*NodeServiceHTTPClientImpl) ListNodes 

func (c *NodeServiceHTTPClientImpl) ListNodes(ctx context.Context, in *ListNodesRequest, opts ...http.CallOption) (*ListNodesReply, error)

func (*NodeServiceHTTPClientImpl) UpdateNode 

func (c *NodeServiceHTTPClientImpl) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...http.CallOption) (*UpdateNodeReply, error)

func (*NodeServiceHTTPClientImpl) UpdateNodeLabels 

func (c *NodeServiceHTTPClientImpl) UpdateNodeLabels(ctx context.Context, in *UpdateNodeLabelsRequest, opts ...http.CallOption) (*UpdateNodeReply, error)

type NodeServiceHTTPServer 

type NodeServiceHTTPServer interface {
	DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeReply, error)
	GetNode(context.Context, *GetNodeRequest) (*GetNodeReply, error)
	GetNodeStatistics(context.Context, *GetNodeStatisticsRequest) (*GetNodeStatisticsReply, error)
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesReply, error)
	UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeReply, error)
	UpdateNodeLabels(context.Context, *UpdateNodeLabelsRequest) (*UpdateNodeReply, error)
}

type NodeServiceServer 

type NodeServiceServer interface {
	GetNode(context.Context, *GetNodeRequest) (*GetNodeReply, error)
	DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeReply, error)
	UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeReply, error)
	UpdateNodeLabels(context.Context, *UpdateNodeLabelsRequest) (*UpdateNodeReply, error)
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesReply, error)
	GetNodeStatistics(context.Context, *GetNodeStatisticsRequest) (*GetNodeStatisticsReply, error)
	// contains filtered or unexported methods
}

NodeServiceServer is the server API for NodeService service. All implementations must embed UnimplementedNodeServiceServer for forward compatibility.

type PauseTaskReply 

type PauseTaskReply struct {
	// contains filtered or unexported fields
}

func (*PauseTaskReply) Descriptor deprecated 

func (*PauseTaskReply) Descriptor() ([]byte, []int)

Deprecated: Use PauseTaskReply.ProtoReflect.Descriptor instead.

func (*PauseTaskReply) ProtoMessage 

func (*PauseTaskReply) ProtoMessage()

func (*PauseTaskReply) ProtoReflect 

func (x *PauseTaskReply) ProtoReflect() protoreflect.Message

func (*PauseTaskReply) Reset 

func (x *PauseTaskReply) Reset()

func (*PauseTaskReply) String 

func (x *PauseTaskReply) String() string

type PauseTaskRequest 

type PauseTaskRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseTaskRequest) Descriptor deprecated 

func (*PauseTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use PauseTaskRequest.ProtoReflect.Descriptor instead.

func (*PauseTaskRequest) GetId 

func (x *PauseTaskRequest) GetId() int64

func (*PauseTaskRequest) GetUserId 

func (x *PauseTaskRequest) GetUserId() int64

func (*PauseTaskRequest) ProtoMessage 

func (*PauseTaskRequest) ProtoMessage()

func (*PauseTaskRequest) ProtoReflect 

func (x *PauseTaskRequest) ProtoReflect() protoreflect.Message

func (*PauseTaskRequest) Reset 

func (x *PauseTaskRequest) Reset()

func (*PauseTaskRequest) String 

func (x *PauseTaskRequest) String() string

type RealtimeEvent 

type RealtimeEvent struct {
	ResultId   int64                  `protobuf:"varint,1,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"`
	TaskId     int64                  `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Target     string                 `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	NodeId     string                 `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	NodeName   string                 `protobuf:"bytes,5,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Status     int32                  `protobuf:"varint,6,opt,name=status,proto3" json:"status,omitempty"`
	LatencyMs  int64                  `protobuf:"varint,7,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
	StatusInfo string                 `protobuf:"bytes,8,opt,name=status_info,json=statusInfo,proto3" json:"status_info,omitempty"`
	ReportedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=reported_at,json=reportedAt,proto3" json:"reported_at,omitempty"`
	// contains filtered or unexported fields
}

func (*RealtimeEvent) Descriptor deprecated 

func (*RealtimeEvent) Descriptor() ([]byte, []int)

Deprecated: Use RealtimeEvent.ProtoReflect.Descriptor instead.

func (*RealtimeEvent) GetLatencyMs 

func (x *RealtimeEvent) GetLatencyMs() int64

func (*RealtimeEvent) GetNodeId 

func (x *RealtimeEvent) GetNodeId() string

func (*RealtimeEvent) GetNodeName 

func (x *RealtimeEvent) GetNodeName() string

func (*RealtimeEvent) GetReportedAt 

func (x *RealtimeEvent) GetReportedAt() *timestamppb.Timestamp

func (*RealtimeEvent) GetResultId 

func (x *RealtimeEvent) GetResultId() int64

func (*RealtimeEvent) GetStatus 

func (x *RealtimeEvent) GetStatus() int32

func (*RealtimeEvent) GetStatusInfo 

func (x *RealtimeEvent) GetStatusInfo() string

func (*RealtimeEvent) GetTarget 

func (x *RealtimeEvent) GetTarget() string

func (*RealtimeEvent) GetTaskId 

func (x *RealtimeEvent) GetTaskId() int64

func (*RealtimeEvent) ProtoMessage 

func (*RealtimeEvent) ProtoMessage()

func (*RealtimeEvent) ProtoReflect 

func (x *RealtimeEvent) ProtoReflect() protoreflect.Message

func (*RealtimeEvent) Reset 

func (x *RealtimeEvent) Reset()

func (*RealtimeEvent) String 

func (x *RealtimeEvent) String() string

type RealtimeNodeMetric 

type RealtimeNodeMetric struct {
	NodeId           string  `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,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"`
	ProbeTotal       int64   `protobuf:"varint,4,opt,name=probe_total,json=probeTotal,proto3" json:"probe_total,omitempty"`
	AverageLatencyMs float64 `protobuf:"fixed64,5,opt,name=average_latency_ms,json=averageLatencyMs,proto3" json:"average_latency_ms,omitempty"`
	SuccessRate      float64 `protobuf:"fixed64,6,opt,name=success_rate,json=successRate,proto3" json:"success_rate,omitempty"`
	Online           bool    `protobuf:"varint,7,opt,name=online,proto3" json:"online,omitempty"`
	// contains filtered or unexported fields
}

func (*RealtimeNodeMetric) Descriptor deprecated 

func (*RealtimeNodeMetric) Descriptor() ([]byte, []int)

Deprecated: Use RealtimeNodeMetric.ProtoReflect.Descriptor instead.

func (*RealtimeNodeMetric) GetAverageLatencyMs 

func (x *RealtimeNodeMetric) GetAverageLatencyMs() float64

func (*RealtimeNodeMetric) GetLocation 

func (x *RealtimeNodeMetric) GetLocation() string

func (*RealtimeNodeMetric) GetName 

func (x *RealtimeNodeMetric) GetName() string

func (*RealtimeNodeMetric) GetNodeId 

func (x *RealtimeNodeMetric) GetNodeId() string

func (*RealtimeNodeMetric) GetOnline 

func (x *RealtimeNodeMetric) GetOnline() bool

func (*RealtimeNodeMetric) GetProbeTotal 

func (x *RealtimeNodeMetric) GetProbeTotal() int64

func (*RealtimeNodeMetric) GetSuccessRate 

func (x *RealtimeNodeMetric) GetSuccessRate() float64

func (*RealtimeNodeMetric) ProtoMessage 

func (*RealtimeNodeMetric) ProtoMessage()

func (*RealtimeNodeMetric) ProtoReflect 

func (x *RealtimeNodeMetric) ProtoReflect() protoreflect.Message

func (*RealtimeNodeMetric) Reset 

func (x *RealtimeNodeMetric) Reset()

func (*RealtimeNodeMetric) String 

func (x *RealtimeNodeMetric) String() string

type RealtimeOverview 

type RealtimeOverview struct {
	UpdatedAt        *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	WindowSeconds    int32                  `protobuf:"varint,2,opt,name=window_seconds,json=windowSeconds,proto3" json:"window_seconds,omitempty"`
	ProbeTotal       int64                  `protobuf:"varint,3,opt,name=probe_total,json=probeTotal,proto3" json:"probe_total,omitempty"`
	ProbesPerMinute  float64                `protobuf:"fixed64,4,opt,name=probes_per_minute,json=probesPerMinute,proto3" json:"probes_per_minute,omitempty"`
	AverageLatencyMs float64                `protobuf:"fixed64,5,opt,name=average_latency_ms,json=averageLatencyMs,proto3" json:"average_latency_ms,omitempty"`
	SuccessRate      float64                `protobuf:"fixed64,6,opt,name=success_rate,json=successRate,proto3" json:"success_rate,omitempty"`
	AbnormalTotal    int64                  `protobuf:"varint,7,opt,name=abnormal_total,json=abnormalTotal,proto3" json:"abnormal_total,omitempty"`
	ActiveTasks      int64                  `protobuf:"varint,8,opt,name=active_tasks,json=activeTasks,proto3" json:"active_tasks,omitempty"`
	TotalTasks       int64                  `protobuf:"varint,9,opt,name=total_tasks,json=totalTasks,proto3" json:"total_tasks,omitempty"`
	OnlineNodes      int64                  `protobuf:"varint,10,opt,name=online_nodes,json=onlineNodes,proto3" json:"online_nodes,omitempty"`
	TotalNodes       int64                  `protobuf:"varint,11,opt,name=total_nodes,json=totalNodes,proto3" json:"total_nodes,omitempty"`
	HealthScore      int32                  `protobuf:"varint,12,opt,name=health_score,json=healthScore,proto3" json:"health_score,omitempty"`
	Trend            []*RealtimeTrendPoint  `protobuf:"bytes,13,rep,name=trend,proto3" json:"trend,omitempty"`
	Nodes            []*RealtimeNodeMetric  `protobuf:"bytes,14,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Events           []*RealtimeEvent       `protobuf:"bytes,15,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*RealtimeOverview) Descriptor deprecated 

func (*RealtimeOverview) Descriptor() ([]byte, []int)

Deprecated: Use RealtimeOverview.ProtoReflect.Descriptor instead.

func (*RealtimeOverview) GetAbnormalTotal 

func (x *RealtimeOverview) GetAbnormalTotal() int64

func (*RealtimeOverview) GetActiveTasks 

func (x *RealtimeOverview) GetActiveTasks() int64

func (*RealtimeOverview) GetAverageLatencyMs 

func (x *RealtimeOverview) GetAverageLatencyMs() float64

func (*RealtimeOverview) GetEvents 

func (x *RealtimeOverview) GetEvents() []*RealtimeEvent

func (*RealtimeOverview) GetHealthScore 

func (x *RealtimeOverview) GetHealthScore() int32

func (*RealtimeOverview) GetNodes 

func (x *RealtimeOverview) GetNodes() []*RealtimeNodeMetric

func (*RealtimeOverview) GetOnlineNodes 

func (x *RealtimeOverview) GetOnlineNodes() int64

func (*RealtimeOverview) GetProbeTotal 

func (x *RealtimeOverview) GetProbeTotal() int64

func (*RealtimeOverview) GetProbesPerMinute 

func (x *RealtimeOverview) GetProbesPerMinute() float64

func (*RealtimeOverview) GetSuccessRate 

func (x *RealtimeOverview) GetSuccessRate() float64

func (*RealtimeOverview) GetTotalNodes 

func (x *RealtimeOverview) GetTotalNodes() int64

func (*RealtimeOverview) GetTotalTasks 

func (x *RealtimeOverview) GetTotalTasks() int64

func (*RealtimeOverview) GetTrend 

func (x *RealtimeOverview) GetTrend() []*RealtimeTrendPoint

func (*RealtimeOverview) GetUpdatedAt 

func (x *RealtimeOverview) GetUpdatedAt() *timestamppb.Timestamp

func (*RealtimeOverview) GetWindowSeconds 

func (x *RealtimeOverview) GetWindowSeconds() int32

func (*RealtimeOverview) ProtoMessage 

func (*RealtimeOverview) ProtoMessage()

func (*RealtimeOverview) ProtoReflect 

func (x *RealtimeOverview) ProtoReflect() protoreflect.Message

func (*RealtimeOverview) Reset 

func (x *RealtimeOverview) Reset()

func (*RealtimeOverview) String 

func (x *RealtimeOverview) String() string

type RealtimeServiceClient 

type RealtimeServiceClient interface {
	GetRealtimeOverview(ctx context.Context, in *GetRealtimeOverviewRequest, opts ...grpc.CallOption) (*RealtimeOverview, error)
}

RealtimeServiceClient is the client API for RealtimeService 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.

func NewRealtimeServiceClient 

func NewRealtimeServiceClient(cc grpc.ClientConnInterface) RealtimeServiceClient

type RealtimeServiceHTTPClient 

type RealtimeServiceHTTPClient interface {
	GetRealtimeOverview(ctx context.Context, req *GetRealtimeOverviewRequest, opts ...http.CallOption) (rsp *RealtimeOverview, err error)
}

func NewRealtimeServiceHTTPClient 

func NewRealtimeServiceHTTPClient(client *http.Client) RealtimeServiceHTTPClient

type RealtimeServiceHTTPClientImpl 

type RealtimeServiceHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*RealtimeServiceHTTPClientImpl) GetRealtimeOverview 

func (c *RealtimeServiceHTTPClientImpl) GetRealtimeOverview(ctx context.Context, in *GetRealtimeOverviewRequest, opts ...http.CallOption) (*RealtimeOverview, error)

type RealtimeServiceHTTPServer 

type RealtimeServiceHTTPServer interface {
	GetRealtimeOverview(context.Context, *GetRealtimeOverviewRequest) (*RealtimeOverview, error)
}

type RealtimeServiceServer 

type RealtimeServiceServer interface {
	GetRealtimeOverview(context.Context, *GetRealtimeOverviewRequest) (*RealtimeOverview, error)
	// contains filtered or unexported methods
}

RealtimeServiceServer is the server API for RealtimeService service. All implementations must embed UnimplementedRealtimeServiceServer for forward compatibility.

type RealtimeTrendPoint 

type RealtimeTrendPoint struct {
	Timestamp        *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ProbeTotal       int64                  `protobuf:"varint,2,opt,name=probe_total,json=probeTotal,proto3" json:"probe_total,omitempty"`
	AverageLatencyMs float64                `protobuf:"fixed64,3,opt,name=average_latency_ms,json=averageLatencyMs,proto3" json:"average_latency_ms,omitempty"`
	SuccessRate      float64                `protobuf:"fixed64,4,opt,name=success_rate,json=successRate,proto3" json:"success_rate,omitempty"`
	// contains filtered or unexported fields
}

func (*RealtimeTrendPoint) Descriptor deprecated 

func (*RealtimeTrendPoint) Descriptor() ([]byte, []int)

Deprecated: Use RealtimeTrendPoint.ProtoReflect.Descriptor instead.

func (*RealtimeTrendPoint) GetAverageLatencyMs 

func (x *RealtimeTrendPoint) GetAverageLatencyMs() float64

func (*RealtimeTrendPoint) GetProbeTotal 

func (x *RealtimeTrendPoint) GetProbeTotal() int64

func (*RealtimeTrendPoint) GetSuccessRate 

func (x *RealtimeTrendPoint) GetSuccessRate() float64

func (*RealtimeTrendPoint) GetTimestamp 

func (x *RealtimeTrendPoint) GetTimestamp() *timestamppb.Timestamp

func (*RealtimeTrendPoint) ProtoMessage 

func (*RealtimeTrendPoint) ProtoMessage()

func (*RealtimeTrendPoint) ProtoReflect 

func (x *RealtimeTrendPoint) ProtoReflect() protoreflect.Message

func (*RealtimeTrendPoint) Reset 

func (x *RealtimeTrendPoint) Reset()

func (*RealtimeTrendPoint) String 

func (x *RealtimeTrendPoint) String() string

type ResumeTaskReply 

type ResumeTaskReply struct {
	// contains filtered or unexported fields
}

func (*ResumeTaskReply) Descriptor deprecated 

func (*ResumeTaskReply) Descriptor() ([]byte, []int)

Deprecated: Use ResumeTaskReply.ProtoReflect.Descriptor instead.

func (*ResumeTaskReply) ProtoMessage 

func (*ResumeTaskReply) ProtoMessage()

func (*ResumeTaskReply) ProtoReflect 

func (x *ResumeTaskReply) ProtoReflect() protoreflect.Message

func (*ResumeTaskReply) Reset 

func (x *ResumeTaskReply) Reset()

func (*ResumeTaskReply) String 

func (x *ResumeTaskReply) String() string

type ResumeTaskRequest 

type ResumeTaskRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeTaskRequest) Descriptor deprecated 

func (*ResumeTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResumeTaskRequest.ProtoReflect.Descriptor instead.

func (*ResumeTaskRequest) GetId 

func (x *ResumeTaskRequest) GetId() int64

func (*ResumeTaskRequest) GetUserId 

func (x *ResumeTaskRequest) GetUserId() int64

func (*ResumeTaskRequest) ProtoMessage 

func (*ResumeTaskRequest) ProtoMessage()

func (*ResumeTaskRequest) ProtoReflect 

func (x *ResumeTaskRequest) ProtoReflect() protoreflect.Message

func (*ResumeTaskRequest) Reset 

func (x *ResumeTaskRequest) Reset()

func (*ResumeTaskRequest) String 

func (x *ResumeTaskRequest) String() string

type Task 

type Task struct {
	Id              int64                      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId          int64                      `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	TaskSn          string                     `protobuf:"bytes,3,opt,name=task_sn,json=taskSn,proto3" json:"task_sn,omitempty"`
	Target          string                     `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	Proto           CreateTaskRequest_Protocol `protobuf:"varint,5,opt,name=proto,proto3,enum=api.admin.v1.CreateTaskRequest_Protocol" json:"proto,omitempty"`
	Type            TaskType                   `protobuf:"varint,6,opt,name=type,proto3,enum=api.admin.v1.TaskType" json:"type,omitempty"`
	Timeout         int64                      `protobuf:"varint,7,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Status          TaskStatus                 `protobuf:"varint,8,opt,name=status,proto3,enum=api.admin.v1.TaskStatus" json:"status,omitempty"`
	ExecutorTotal   int64                      `protobuf:"varint,9,opt,name=executor_total,json=executorTotal,proto3" json:"executor_total,omitempty"`
	ExecutorSucc    int64                      `protobuf:"varint,10,opt,name=executor_succ,json=executorSucc,proto3" json:"executor_succ,omitempty"`
	ExecutorFail    int64                      `protobuf:"varint,11,opt,name=executor_fail,json=executorFail,proto3" json:"executor_fail,omitempty"`
	NodeSelector    map[string]string          `` /* 172-byte string literal not displayed */
	CreatedAt       *timestamppb.Timestamp     `protobuf:"bytes,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt       *timestamppb.Timestamp     `protobuf:"bytes,14,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Interval        *durationpb.Duration       `protobuf:"bytes,15,opt,name=interval,proto3" json:"interval,omitempty"`
	NextRunAt       *timestamppb.Timestamp     `protobuf:"bytes,16,opt,name=next_run_at,json=nextRunAt,proto3" json:"next_run_at,omitempty"`
	LatestRunId     int64                      `protobuf:"varint,17,opt,name=latest_run_id,json=latestRunId,proto3" json:"latest_run_id,omitempty"`
	ExecutorTimeout int64                      `protobuf:"varint,18,opt,name=executor_timeout,json=executorTimeout,proto3" json:"executor_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

func (*Task) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt 

func (x *Task) GetCreatedAt() *timestamppb.Timestamp

func (*Task) GetExecutorFail 

func (x *Task) GetExecutorFail() int64

func (*Task) GetExecutorSucc 

func (x *Task) GetExecutorSucc() int64

func (*Task) GetExecutorTimeout 

func (x *Task) GetExecutorTimeout() int64

func (*Task) GetExecutorTotal 

func (x *Task) GetExecutorTotal() int64

func (*Task) GetId 

func (x *Task) GetId() int64

func (*Task) GetInterval 

func (x *Task) GetInterval() *durationpb.Duration

func (*Task) GetLatestRunId 

func (x *Task) GetLatestRunId() int64

func (*Task) GetNextRunAt 

func (x *Task) GetNextRunAt() *timestamppb.Timestamp

func (*Task) GetNodeSelector 

func (x *Task) GetNodeSelector() map[string]string

func (*Task) GetProto 

func (x *Task) GetProto() CreateTaskRequest_Protocol

func (*Task) GetStatus 

func (x *Task) GetStatus() TaskStatus

func (*Task) GetTarget 

func (x *Task) GetTarget() string

func (*Task) GetTaskSn 

func (x *Task) GetTaskSn() string

func (*Task) GetTimeout 

func (x *Task) GetTimeout() int64

func (*Task) GetType 

func (x *Task) GetType() TaskType

func (*Task) GetUpdatedAt 

func (x *Task) GetUpdatedAt() *timestamppb.Timestamp

func (*Task) GetUserId 

func (x *Task) GetUserId() int64

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskRun 

type TaskRun struct {
	Id               int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TaskId           int64                  `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	RunNo            int64                  `protobuf:"varint,3,opt,name=run_no,json=runNo,proto3" json:"run_no,omitempty"`
	Status           TaskRunStatus          `protobuf:"varint,4,opt,name=status,proto3,enum=api.admin.v1.TaskRunStatus" json:"status,omitempty"`
	ScheduledAt      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	StartedAt        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	DeadlineAt       *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=deadline_at,json=deadlineAt,proto3" json:"deadline_at,omitempty"`
	FinishedAt       *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	ExecutorTotal    int64                  `protobuf:"varint,9,opt,name=executor_total,json=executorTotal,proto3" json:"executor_total,omitempty"`
	ReportedTotal    int64                  `protobuf:"varint,10,opt,name=reported_total,json=reportedTotal,proto3" json:"reported_total,omitempty"`
	SuccessTotal     int64                  `protobuf:"varint,11,opt,name=success_total,json=successTotal,proto3" json:"success_total,omitempty"`
	FailureTotal     int64                  `protobuf:"varint,12,opt,name=failure_total,json=failureTotal,proto3" json:"failure_total,omitempty"`
	TimeoutTotal     int64                  `protobuf:"varint,13,opt,name=timeout_total,json=timeoutTotal,proto3" json:"timeout_total,omitempty"`
	LatencyMinMs     int64                  `protobuf:"varint,14,opt,name=latency_min_ms,json=latencyMinMs,proto3" json:"latency_min_ms,omitempty"`
	LatencyMaxMs     int64                  `protobuf:"varint,15,opt,name=latency_max_ms,json=latencyMaxMs,proto3" json:"latency_max_ms,omitempty"`
	LatencyAvgMs     float64                `protobuf:"fixed64,16,opt,name=latency_avg_ms,json=latencyAvgMs,proto3" json:"latency_avg_ms,omitempty"`
	SelectorSnapshot map[string]string      `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskRun) Descriptor deprecated 

func (*TaskRun) Descriptor() ([]byte, []int)

Deprecated: Use TaskRun.ProtoReflect.Descriptor instead.

func (*TaskRun) GetDeadlineAt 

func (x *TaskRun) GetDeadlineAt() *timestamppb.Timestamp

func (*TaskRun) GetExecutorTotal 

func (x *TaskRun) GetExecutorTotal() int64

func (*TaskRun) GetFailureTotal 

func (x *TaskRun) GetFailureTotal() int64

func (*TaskRun) GetFinishedAt 

func (x *TaskRun) GetFinishedAt() *timestamppb.Timestamp

func (*TaskRun) GetId 

func (x *TaskRun) GetId() int64

func (*TaskRun) GetLatencyAvgMs 

func (x *TaskRun) GetLatencyAvgMs() float64

func (*TaskRun) GetLatencyMaxMs 

func (x *TaskRun) GetLatencyMaxMs() int64

func (*TaskRun) GetLatencyMinMs 

func (x *TaskRun) GetLatencyMinMs() int64

func (*TaskRun) GetReportedTotal 

func (x *TaskRun) GetReportedTotal() int64

func (*TaskRun) GetRunNo 

func (x *TaskRun) GetRunNo() int64

func (*TaskRun) GetScheduledAt 

func (x *TaskRun) GetScheduledAt() *timestamppb.Timestamp

func (*TaskRun) GetSelectorSnapshot 

func (x *TaskRun) GetSelectorSnapshot() map[string]string

func (*TaskRun) GetStartedAt 

func (x *TaskRun) GetStartedAt() *timestamppb.Timestamp

func (*TaskRun) GetStatus 

func (x *TaskRun) GetStatus() TaskRunStatus

func (*TaskRun) GetSuccessTotal 

func (x *TaskRun) GetSuccessTotal() int64

func (*TaskRun) GetTaskId 

func (x *TaskRun) GetTaskId() int64

func (*TaskRun) GetTimeoutTotal 

func (x *TaskRun) GetTimeoutTotal() int64

func (*TaskRun) ProtoMessage 

func (*TaskRun) ProtoMessage()

func (*TaskRun) ProtoReflect 

func (x *TaskRun) ProtoReflect() protoreflect.Message

func (*TaskRun) Reset 

func (x *TaskRun) Reset()

func (*TaskRun) String 

func (x *TaskRun) String() string

type TaskRunResult 

type TaskRunResult struct {
	Id         int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	RunId      int64                  `protobuf:"varint,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskId     int64                  `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NodeId     string                 `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Status     TaskRunResultStatus    `protobuf:"varint,5,opt,name=status,proto3,enum=api.admin.v1.TaskRunResultStatus" json:"status,omitempty"`
	DurationMs int64                  `protobuf:"varint,6,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	LatencyMs  int64                  `protobuf:"varint,7,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
	StatusInfo string                 `protobuf:"bytes,8,opt,name=status_info,json=statusInfo,proto3" json:"status_info,omitempty"`
	Metadata   map[string]string      `` /* 143-byte string literal not displayed */
	Errors     map[string]string      `` /* 140-byte string literal not displayed */
	ReportedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=reported_at,json=reportedAt,proto3" json:"reported_at,omitempty"`
	Node       *Node                  `protobuf:"bytes,12,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRunResult) Descriptor deprecated 

func (*TaskRunResult) Descriptor() ([]byte, []int)

Deprecated: Use TaskRunResult.ProtoReflect.Descriptor instead.

func (*TaskRunResult) GetDurationMs 

func (x *TaskRunResult) GetDurationMs() int64

func (*TaskRunResult) GetErrors 

func (x *TaskRunResult) GetErrors() map[string]string

func (*TaskRunResult) GetId 

func (x *TaskRunResult) GetId() int64

func (*TaskRunResult) GetLatencyMs 

func (x *TaskRunResult) GetLatencyMs() int64

func (*TaskRunResult) GetMetadata 

func (x *TaskRunResult) GetMetadata() map[string]string

func (*TaskRunResult) GetNode 

func (x *TaskRunResult) GetNode() *Node

func (*TaskRunResult) GetNodeId 

func (x *TaskRunResult) GetNodeId() string

func (*TaskRunResult) GetReportedAt 

func (x *TaskRunResult) GetReportedAt() *timestamppb.Timestamp

func (*TaskRunResult) GetRunId 

func (x *TaskRunResult) GetRunId() int64

func (*TaskRunResult) GetStatus 

func (x *TaskRunResult) GetStatus() TaskRunResultStatus

func (*TaskRunResult) GetStatusInfo 

func (x *TaskRunResult) GetStatusInfo() string

func (*TaskRunResult) GetTaskId 

func (x *TaskRunResult) GetTaskId() int64

func (*TaskRunResult) ProtoMessage 

func (*TaskRunResult) ProtoMessage()

func (*TaskRunResult) ProtoReflect 

func (x *TaskRunResult) ProtoReflect() protoreflect.Message

func (*TaskRunResult) Reset 

func (x *TaskRunResult) Reset()

func (*TaskRunResult) String 

func (x *TaskRunResult) String() string

type TaskRunResultStatus 

type TaskRunResultStatus int32
const (
	TaskRunResultStatus_TASK_RUN_RESULT_STATUS_UNSPECIFIED TaskRunResultStatus = 0
	TaskRunResultStatus_TASK_RUN_RESULT_STATUS_WAITING     TaskRunResultStatus = 1
	TaskRunResultStatus_TASK_RUN_RESULT_STATUS_SUCCESS     TaskRunResultStatus = 2
	TaskRunResultStatus_TASK_RUN_RESULT_STATUS_FAILED      TaskRunResultStatus = 3
	TaskRunResultStatus_TASK_RUN_RESULT_STATUS_TIMED_OUT   TaskRunResultStatus = 4
)

func (TaskRunResultStatus) Descriptor 

func (TaskRunResultStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskRunResultStatus) Enum 

func (x TaskRunResultStatus) Enum() *TaskRunResultStatus

func (TaskRunResultStatus) EnumDescriptor deprecated 

func (TaskRunResultStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskRunResultStatus.Descriptor instead.

func (TaskRunResultStatus) Number 

func (x TaskRunResultStatus) Number() protoreflect.EnumNumber

func (TaskRunResultStatus) String 

func (x TaskRunResultStatus) String() string

func (TaskRunResultStatus) Type 

func (TaskRunResultStatus) Type() protoreflect.EnumType

type TaskRunStatus 

type TaskRunStatus int32
const (
	TaskRunStatus_TASK_RUN_STATUS_UNSPECIFIED TaskRunStatus = 0
	TaskRunStatus_TASK_RUN_STATUS_RUNNING     TaskRunStatus = 1
	TaskRunStatus_TASK_RUN_STATUS_COMPLETED   TaskRunStatus = 2
	TaskRunStatus_TASK_RUN_STATUS_PARTIAL     TaskRunStatus = 3
	TaskRunStatus_TASK_RUN_STATUS_TIMED_OUT   TaskRunStatus = 4
)

func (TaskRunStatus) Descriptor 

func (TaskRunStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskRunStatus) Enum 

func (x TaskRunStatus) Enum() *TaskRunStatus

func (TaskRunStatus) EnumDescriptor deprecated 

func (TaskRunStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskRunStatus.Descriptor instead.

func (TaskRunStatus) Number 

func (x TaskRunStatus) Number() protoreflect.EnumNumber

func (TaskRunStatus) String 

func (x TaskRunStatus) String() string

func (TaskRunStatus) Type 

func (TaskRunStatus) Type() protoreflect.EnumType

type TaskServiceClient 

type TaskServiceClient interface {
	// CreateTask ...
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskReply, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksReply, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
	PauseTask(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*PauseTaskReply, error)
	ResumeTask(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*ResumeTaskReply, error)
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteTaskReply, error)
	ListTaskRuns(ctx context.Context, in *ListTaskRunsRequest, opts ...grpc.CallOption) (*ListTaskRunsReply, error)
	ListTaskRunResults(ctx context.Context, in *ListTaskRunResultsRequest, opts ...grpc.CallOption) (*ListTaskRunResultsReply, error)
}

TaskServiceClient is the client API for TaskService 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.

TaskService ...

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceHTTPClient 

type TaskServiceHTTPClient interface {
	// CreateTask CreateTask ...
	CreateTask(ctx context.Context, req *CreateTaskRequest, opts ...http.CallOption) (rsp *CreateTaskReply, err error)
	DeleteTask(ctx context.Context, req *DeleteTaskRequest, opts ...http.CallOption) (rsp *DeleteTaskReply, err error)
	GetTask(ctx context.Context, req *GetTaskRequest, opts ...http.CallOption) (rsp *Task, err error)
	ListTaskRunResults(ctx context.Context, req *ListTaskRunResultsRequest, opts ...http.CallOption) (rsp *ListTaskRunResultsReply, err error)
	ListTaskRuns(ctx context.Context, req *ListTaskRunsRequest, opts ...http.CallOption) (rsp *ListTaskRunsReply, err error)
	ListTasks(ctx context.Context, req *ListTasksRequest, opts ...http.CallOption) (rsp *ListTasksReply, err error)
	PauseTask(ctx context.Context, req *PauseTaskRequest, opts ...http.CallOption) (rsp *PauseTaskReply, err error)
	ResumeTask(ctx context.Context, req *ResumeTaskRequest, opts ...http.CallOption) (rsp *ResumeTaskReply, err error)
}

func NewTaskServiceHTTPClient 

func NewTaskServiceHTTPClient(client *http.Client) TaskServiceHTTPClient

type TaskServiceHTTPClientImpl 

type TaskServiceHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*TaskServiceHTTPClientImpl) CreateTask 

func (c *TaskServiceHTTPClientImpl) CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...http.CallOption) (*CreateTaskReply, error)

CreateTask CreateTask ...

func (*TaskServiceHTTPClientImpl) DeleteTask 

func (c *TaskServiceHTTPClientImpl) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...http.CallOption) (*DeleteTaskReply, error)

func (*TaskServiceHTTPClientImpl) GetTask 

func (c *TaskServiceHTTPClientImpl) GetTask(ctx context.Context, in *GetTaskRequest, opts ...http.CallOption) (*Task, error)

func (*TaskServiceHTTPClientImpl) ListTaskRunResults 

func (c *TaskServiceHTTPClientImpl) ListTaskRunResults(ctx context.Context, in *ListTaskRunResultsRequest, opts ...http.CallOption) (*ListTaskRunResultsReply, error)

func (*TaskServiceHTTPClientImpl) ListTaskRuns 

func (c *TaskServiceHTTPClientImpl) ListTaskRuns(ctx context.Context, in *ListTaskRunsRequest, opts ...http.CallOption) (*ListTaskRunsReply, error)

func (*TaskServiceHTTPClientImpl) ListTasks 

func (c *TaskServiceHTTPClientImpl) ListTasks(ctx context.Context, in *ListTasksRequest, opts ...http.CallOption) (*ListTasksReply, error)

func (*TaskServiceHTTPClientImpl) PauseTask 

func (c *TaskServiceHTTPClientImpl) PauseTask(ctx context.Context, in *PauseTaskRequest, opts ...http.CallOption) (*PauseTaskReply, error)

func (*TaskServiceHTTPClientImpl) ResumeTask 

func (c *TaskServiceHTTPClientImpl) ResumeTask(ctx context.Context, in *ResumeTaskRequest, opts ...http.CallOption) (*ResumeTaskReply, error)

type TaskServiceHTTPServer 

type TaskServiceHTTPServer interface {
	// CreateTask CreateTask ...
	CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskReply, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteTaskReply, error)
	GetTask(context.Context, *GetTaskRequest) (*Task, error)
	ListTaskRunResults(context.Context, *ListTaskRunResultsRequest) (*ListTaskRunResultsReply, error)
	ListTaskRuns(context.Context, *ListTaskRunsRequest) (*ListTaskRunsReply, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksReply, error)
	PauseTask(context.Context, *PauseTaskRequest) (*PauseTaskReply, error)
	ResumeTask(context.Context, *ResumeTaskRequest) (*ResumeTaskReply, error)
}

type TaskServiceServer 

type TaskServiceServer interface {
	// CreateTask ...
	CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskReply, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksReply, error)
	GetTask(context.Context, *GetTaskRequest) (*Task, error)
	PauseTask(context.Context, *PauseTaskRequest) (*PauseTaskReply, error)
	ResumeTask(context.Context, *ResumeTaskRequest) (*ResumeTaskReply, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteTaskReply, error)
	ListTaskRuns(context.Context, *ListTaskRunsRequest) (*ListTaskRunsReply, error)
	ListTaskRunResults(context.Context, *ListTaskRunResultsRequest) (*ListTaskRunResultsReply, error)
	// contains filtered or unexported methods
}

TaskServiceServer is the server API for TaskService service. All implementations must embed UnimplementedTaskServiceServer for forward compatibility.

TaskService ...

type TaskStatus 

type TaskStatus int32
const (
	TaskStatus_TASK_STATUS_UNSPECIFIED TaskStatus = 0
	TaskStatus_TASK_STATUS_PENDING     TaskStatus = 1
	TaskStatus_TASK_STATUS_RUNNING     TaskStatus = 2
	TaskStatus_TASK_STATUS_COMPLETED   TaskStatus = 3
	TaskStatus_TASK_STATUS_FAILED      TaskStatus = 4
	TaskStatus_TASK_STATUS_PAUSED      TaskStatus = 5
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

func (TaskStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type TaskType 

type TaskType int32
const (
	TaskType_TASK_TYPE_UNSPECIFIED TaskType = 0
	TaskType_TASK_TYPE_ONCE        TaskType = 1
	TaskType_TASK_TYPE_PERIODIC    TaskType = 2
)

func (TaskType) Descriptor 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated 

func (TaskType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) Number 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

func (TaskType) Type 

func (TaskType) Type() protoreflect.EnumType

type UnimplementedAlertServiceServer 

type UnimplementedAlertServiceServer struct{}

UnimplementedAlertServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAlertServiceServer) CreateAlertRule 

func (UnimplementedAlertServiceServer) CreateAlertRule(context.Context, *CreateAlertRuleRequest) (*AlertRule, error)

func (UnimplementedAlertServiceServer) DeleteAlertRule 

func (UnimplementedAlertServiceServer) DeleteAlertRule(context.Context, *DeleteAlertRuleRequest) (*DeleteAlertRuleReply, error)

func (UnimplementedAlertServiceServer) GetAlertRule 

func (UnimplementedAlertServiceServer) GetAlertRule(context.Context, *GetAlertRuleRequest) (*AlertRule, error)

func (UnimplementedAlertServiceServer) ListAlertEvents 

func (UnimplementedAlertServiceServer) ListAlertEvents(context.Context, *ListAlertEventsRequest) (*ListAlertEventsReply, error)

func (UnimplementedAlertServiceServer) ListAlertRules 

func (UnimplementedAlertServiceServer) ListAlertRules(context.Context, *ListAlertRulesRequest) (*ListAlertRulesReply, error)

func (UnimplementedAlertServiceServer) UpdateAlertRule 

func (UnimplementedAlertServiceServer) UpdateAlertRule(context.Context, *UpdateAlertRuleRequest) (*AlertRule, error)

type UnimplementedNodeServiceServer 

type UnimplementedNodeServiceServer struct{}

UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedNodeServiceServer) DeleteNode 

func (UnimplementedNodeServiceServer) DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeReply, error)

func (UnimplementedNodeServiceServer) GetNode 

func (UnimplementedNodeServiceServer) GetNode(context.Context, *GetNodeRequest) (*GetNodeReply, error)

func (UnimplementedNodeServiceServer) GetNodeStatistics 

func (UnimplementedNodeServiceServer) GetNodeStatistics(context.Context, *GetNodeStatisticsRequest) (*GetNodeStatisticsReply, error)

func (UnimplementedNodeServiceServer) ListNodes 

func (UnimplementedNodeServiceServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesReply, error)

func (UnimplementedNodeServiceServer) UpdateNode 

func (UnimplementedNodeServiceServer) UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeReply, error)

func (UnimplementedNodeServiceServer) UpdateNodeLabels 

func (UnimplementedNodeServiceServer) UpdateNodeLabels(context.Context, *UpdateNodeLabelsRequest) (*UpdateNodeReply, error)

type UnimplementedRealtimeServiceServer 

type UnimplementedRealtimeServiceServer struct{}

UnimplementedRealtimeServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRealtimeServiceServer) GetRealtimeOverview 

func (UnimplementedRealtimeServiceServer) GetRealtimeOverview(context.Context, *GetRealtimeOverviewRequest) (*RealtimeOverview, error)

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct{}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTaskServiceServer) CreateTask 

func (UnimplementedTaskServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskReply, error)

func (UnimplementedTaskServiceServer) DeleteTask 

func (UnimplementedTaskServiceServer) DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteTaskReply, error)

func (UnimplementedTaskServiceServer) GetTask 

func (UnimplementedTaskServiceServer) GetTask(context.Context, *GetTaskRequest) (*Task, error)

func (UnimplementedTaskServiceServer) ListTaskRunResults 

func (UnimplementedTaskServiceServer) ListTaskRunResults(context.Context, *ListTaskRunResultsRequest) (*ListTaskRunResultsReply, error)

func (UnimplementedTaskServiceServer) ListTaskRuns 

func (UnimplementedTaskServiceServer) ListTaskRuns(context.Context, *ListTaskRunsRequest) (*ListTaskRunsReply, error)

func (UnimplementedTaskServiceServer) ListTasks 

func (UnimplementedTaskServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksReply, error)

func (UnimplementedTaskServiceServer) PauseTask 

func (UnimplementedTaskServiceServer) PauseTask(context.Context, *PauseTaskRequest) (*PauseTaskReply, error)

func (UnimplementedTaskServiceServer) ResumeTask 

func (UnimplementedTaskServiceServer) ResumeTask(context.Context, *ResumeTaskRequest) (*ResumeTaskReply, error)

type UnsafeAlertServiceServer 

type UnsafeAlertServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAlertServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AlertServiceServer will result in compilation errors.

type UnsafeNodeServiceServer 

type UnsafeNodeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNodeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeServiceServer will result in compilation errors.

type UnsafeRealtimeServiceServer 

type UnsafeRealtimeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRealtimeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RealtimeServiceServer will result in compilation errors.

type UnsafeTaskServiceServer 

type UnsafeTaskServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskServiceServer will result in compilation errors.

type UpdateAlertRuleRequest 

type UpdateAlertRuleRequest struct {
	Id             int64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId         int64            `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	TaskId         int64            `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Name           string           `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Enabled        bool             `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Window         AlertWindow      `protobuf:"varint,6,opt,name=window,proto3,enum=api.admin.v1.AlertWindow" json:"window,omitempty"`
	MinimumResults uint32           `protobuf:"varint,7,opt,name=minimum_results,json=minimumResults,proto3" json:"minimum_results,omitempty"`
	Expression     *AlertExpression `protobuf:"bytes,8,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAlertRuleRequest) Descriptor deprecated 

func (*UpdateAlertRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateAlertRuleRequest.ProtoReflect.Descriptor instead.

func (*UpdateAlertRuleRequest) GetEnabled 

func (x *UpdateAlertRuleRequest) GetEnabled() bool

func (*UpdateAlertRuleRequest) GetExpression 

func (x *UpdateAlertRuleRequest) GetExpression() *AlertExpression

func (*UpdateAlertRuleRequest) GetId 

func (x *UpdateAlertRuleRequest) GetId() int64

func (*UpdateAlertRuleRequest) GetMinimumResults 

func (x *UpdateAlertRuleRequest) GetMinimumResults() uint32

func (*UpdateAlertRuleRequest) GetName 

func (x *UpdateAlertRuleRequest) GetName() string

func (*UpdateAlertRuleRequest) GetTaskId 

func (x *UpdateAlertRuleRequest) GetTaskId() int64

func (*UpdateAlertRuleRequest) GetUserId 

func (x *UpdateAlertRuleRequest) GetUserId() int64

func (*UpdateAlertRuleRequest) GetWindow 

func (x *UpdateAlertRuleRequest) GetWindow() AlertWindow

func (*UpdateAlertRuleRequest) ProtoMessage 

func (*UpdateAlertRuleRequest) ProtoMessage()

func (*UpdateAlertRuleRequest) ProtoReflect 

func (x *UpdateAlertRuleRequest) ProtoReflect() protoreflect.Message

func (*UpdateAlertRuleRequest) Reset 

func (x *UpdateAlertRuleRequest) Reset()

func (*UpdateAlertRuleRequest) String 

func (x *UpdateAlertRuleRequest) String() string

type UpdateNodeLabelsRequest 

type UpdateNodeLabelsRequest struct {
	NodeId string            `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateNodeLabelsRequest) Descriptor deprecated 

func (*UpdateNodeLabelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNodeLabelsRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodeLabelsRequest) GetLabels 

func (x *UpdateNodeLabelsRequest) GetLabels() map[string]string

func (*UpdateNodeLabelsRequest) GetNodeId 

func (x *UpdateNodeLabelsRequest) GetNodeId() string

func (*UpdateNodeLabelsRequest) ProtoMessage 

func (*UpdateNodeLabelsRequest) ProtoMessage()

func (*UpdateNodeLabelsRequest) ProtoReflect 

func (x *UpdateNodeLabelsRequest) ProtoReflect() protoreflect.Message

func (*UpdateNodeLabelsRequest) Reset 

func (x *UpdateNodeLabelsRequest) Reset()

func (*UpdateNodeLabelsRequest) String 

func (x *UpdateNodeLabelsRequest) String() string

type UpdateNodeReply 

type UpdateNodeReply struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNodeReply) Descriptor deprecated 

func (*UpdateNodeReply) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNodeReply.ProtoReflect.Descriptor instead.

func (*UpdateNodeReply) GetNode 

func (x *UpdateNodeReply) GetNode() *Node

func (*UpdateNodeReply) ProtoMessage 

func (*UpdateNodeReply) ProtoMessage()

func (*UpdateNodeReply) ProtoReflect 

func (x *UpdateNodeReply) ProtoReflect() protoreflect.Message

func (*UpdateNodeReply) Reset 

func (x *UpdateNodeReply) Reset()

func (*UpdateNodeReply) String 

func (x *UpdateNodeReply) String() string

type UpdateNodeRequest 

type UpdateNodeRequest struct {
	NodeId      string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	PublicIp    string `protobuf:"bytes,4,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"`
	PrivateIp   string `protobuf:"bytes,5,opt,name=private_ip,json=privateIp,proto3" json:"private_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNodeRequest) Descriptor deprecated 

func (*UpdateNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNodeRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodeRequest) GetDescription 

func (x *UpdateNodeRequest) GetDescription() string

func (*UpdateNodeRequest) GetName 

func (x *UpdateNodeRequest) GetName() string

func (*UpdateNodeRequest) GetNodeId 

func (x *UpdateNodeRequest) GetNodeId() string

func (*UpdateNodeRequest) GetPrivateIp 

func (x *UpdateNodeRequest) GetPrivateIp() string

func (*UpdateNodeRequest) GetPublicIp 

func (x *UpdateNodeRequest) GetPublicIp() string

func (*UpdateNodeRequest) ProtoMessage 

func (*UpdateNodeRequest) ProtoMessage()

func (*UpdateNodeRequest) ProtoReflect 

func (x *UpdateNodeRequest) ProtoReflect() protoreflect.Message

func (*UpdateNodeRequest) Reset 

func (x *UpdateNodeRequest) Reset()

func (*UpdateNodeRequest) String 

func (x *UpdateNodeRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.