v2

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jul 19, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Task_Add_FullMethodName            = "/api.platform.task.v2.Task/Add"
	Task_GetList_FullMethodName        = "/api.platform.task.v2.Task/GetList"
	Task_Execution_FullMethodName      = "/api.platform.task.v2.Task/Execution"
	Task_AddEscalation_FullMethodName  = "/api.platform.task.v2.Task/AddEscalation"
	Task_DistributeUser_FullMethodName = "/api.platform.task.v2.Task/DistributeUser"
)

Variables

View Source 
var (
	TaskType_name = map[int32]string{
		0: "EXECUTE_IMMEDIATELY",
		1: "DELAY_EXECUTION",
		2: "TIMED_EXECUTION",
	}
	TaskType_value = map[string]int32{
		"EXECUTE_IMMEDIATELY": 0,
		"DELAY_EXECUTION":     1,
		"TIMED_EXECUTION":     2,
	}
)

Enum value maps for TaskType.

View Source 
var (
	TaskCountType_name = map[int32]string{
		0: "unknown",
		1: "USER_INFO_DISTRIBUTE",
		2: "USER_INFO_ESCALATION",
		3: "NODE_INFO_DISTRIBUTE",
	}
	TaskCountType_value = map[string]int32{
		"unknown":              0,
		"USER_INFO_DISTRIBUTE": 1,
		"USER_INFO_ESCALATION": 2,
		"NODE_INFO_DISTRIBUTE": 3,
	}
)

Enum value maps for TaskCountType.

View Source 
var (
	TaskModel_name = map[int32]string{
		0: "UNKNOWN_MODEL",
		1: "USER",
		2: "NODE",
	}
	TaskModel_value = map[string]int32{
		"UNKNOWN_MODEL": 0,
		"USER":          1,
		"NODE":          2,
	}
)

Enum value maps for TaskModel.

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "UNKNOWN_STATUS",
		1: "WAITING",
		2: "IN_PROGRESS",
		3: "EXECUTION_FAILED",
		4: "EXECUTION_SUCCEEDED",
	}
	TaskStatus_value = map[string]int32{
		"UNKNOWN_STATUS":      0,
		"WAITING":             1,
		"IN_PROGRESS":         2,
		"EXECUTION_FAILED":    3,
		"EXECUTION_SUCCEEDED": 4,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	ErrorTaskReason_name = map[int32]string{
		0: "NODE_NOT_FOUND",
		1: "ADD_TASK_ERROR",
		3: "EXECUTION_TASK_ERROR",
	}
	ErrorTaskReason_value = map[string]int32{
		"NODE_NOT_FOUND":       0,
		"ADD_TASK_ERROR":       1,
		"EXECUTION_TASK_ERROR": 3,
	}
)

Enum value maps for ErrorTaskReason.

View Source 
var File_api_platform_task_v2_task_error_proto protoreflect.FileDescriptor
View Source 
var File_platform_task_v2_task_proto protoreflect.FileDescriptor
View Source 
var Task_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.platform.task.v2.Task",
	HandlerType: (*TaskServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Add",
			Handler:    _Task_Add_Handler,
		},
		{
			MethodName: "GetList",
			Handler:    _Task_GetList_Handler,
		},
		{
			MethodName: "Execution",
			Handler:    _Task_Execution_Handler,
		},
		{
			MethodName: "AddEscalation",
			Handler:    _Task_AddEscalation_Handler,
		},
		{
			MethodName: "DistributeUser",
			Handler:    _Task_DistributeUser_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "platform/task/v2/task.proto",
}

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

Functions

func ErrorAddTaskError 

func ErrorAddTaskError(format string, args ...interface{}) *errors.Error

添加任务失败

func ErrorExecutionTaskError 

func ErrorExecutionTaskError(format string, args ...interface{}) *errors.Error

执行任务失败

func ErrorNodeNotFound 

func ErrorNodeNotFound(format string, args ...interface{}) *errors.Error

节点信息未找到

func IsAddTaskError 

func IsAddTaskError(err error) bool

添加任务失败

func IsExecutionTaskError 

func IsExecutionTaskError(err error) bool

执行任务失败

func IsNodeNotFound 

func IsNodeNotFound(err error) bool

节点信息未找到

func RegisterTaskServer 

func RegisterTaskServer(s grpc.ServiceRegistrar, srv TaskServer)

Types

type AddEscalationReply 

type AddEscalationReply struct {
	Data *v2.SingedMsg `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` //加密
	// contains filtered or unexported fields
}

func (*AddEscalationReply) Descriptor deprecated 

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

Deprecated: Use AddEscalationReply.ProtoReflect.Descriptor instead.

func (*AddEscalationReply) GetData 

func (x *AddEscalationReply) GetData() *v2.SingedMsg

func (*AddEscalationReply) ProtoMessage 

func (*AddEscalationReply) ProtoMessage()

func (*AddEscalationReply) ProtoReflect 

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

func (*AddEscalationReply) Reset 

func (x *AddEscalationReply) Reset()

func (*AddEscalationReply) String 

func (x *AddEscalationReply) String() string

func (*AddEscalationReply) Validate 

func (m *AddEscalationReply) Validate() error

Validate checks the field values on AddEscalationReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddEscalationReply) ValidateAll 

func (m *AddEscalationReply) ValidateAll() error

ValidateAll checks the field values on AddEscalationReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddEscalationReplyMultiError, or nil if none found.

type AddEscalationReplyMultiError 

type AddEscalationReplyMultiError []error

AddEscalationReplyMultiError is an error wrapping multiple validation errors returned by AddEscalationReply.ValidateAll() if the designated constraints aren't met.

func (AddEscalationReplyMultiError) AllErrors 

func (m AddEscalationReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddEscalationReplyMultiError) Error 

func (m AddEscalationReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddEscalationReplyValidationError 

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

AddEscalationReplyValidationError is the validation error returned by AddEscalationReply.Validate if the designated constraints aren't met.

func (AddEscalationReplyValidationError) Cause 

func (e AddEscalationReplyValidationError) Cause() error

Cause function returns cause value.

func (AddEscalationReplyValidationError) Error 

func (e AddEscalationReplyValidationError) Error() string

Error satisfies the builtin error interface

func (AddEscalationReplyValidationError) ErrorName 

func (e AddEscalationReplyValidationError) ErrorName() string

ErrorName returns error name.

func (AddEscalationReplyValidationError) Field 

func (e AddEscalationReplyValidationError) Field() string

Field function returns field value.

func (AddEscalationReplyValidationError) Key 

func (e AddEscalationReplyValidationError) Key() bool

Key function returns key value.

func (AddEscalationReplyValidationError) Reason 

func (e AddEscalationReplyValidationError) Reason() string

Reason function returns reason value.

type AddEscalationReq 

type AddEscalationReq struct {
	StartTime   int64              `protobuf:"varint,1,opt,name=startTime,proto3" json:"startTime,omitempty"`                                             //任务开始时间
	Cron        string             `protobuf:"bytes,2,opt,name=cron,proto3" json:"cron,omitempty"`                                                        //定时表达式
	TaskType    TaskType           `protobuf:"varint,3,opt,name=taskType,proto3,enum=api.platform.task.v2.TaskType" json:"taskType,omitempty"`            //任务类型 0:立即执行 1:延迟执行 3:定时执行
	TaskModel   TaskModel          `protobuf:"varint,4,opt,name=taskModel,proto3,enum=api.platform.task.v2.TaskModel" json:"taskModel,omitempty"`         //任务所属模块 0:系统任务 1:用户模块 2:节点模块
	Data        *v2.EscalationData `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`                                                        //加密
	Description string             `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`                                          //任务描述
	ContentType TaskCountType      `protobuf:"varint,7,opt,name=contentType,proto3,enum=api.platform.task.v2.TaskCountType" json:"contentType,omitempty"` //任务内容类型 0:未定义 1:用户信息下发 2:用户信息下发 3:节点信息下发
	// contains filtered or unexported fields
}

增加上报任务 -------------------------------------------

func (*AddEscalationReq) Descriptor deprecated 

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

Deprecated: Use AddEscalationReq.ProtoReflect.Descriptor instead.

func (*AddEscalationReq) GetContentType 

func (x *AddEscalationReq) GetContentType() TaskCountType

func (*AddEscalationReq) GetCron 

func (x *AddEscalationReq) GetCron() string

func (*AddEscalationReq) GetData 

func (x *AddEscalationReq) GetData() *v2.EscalationData

func (*AddEscalationReq) GetDescription 

func (x *AddEscalationReq) GetDescription() string

func (*AddEscalationReq) GetStartTime 

func (x *AddEscalationReq) GetStartTime() int64

func (*AddEscalationReq) GetTaskModel 

func (x *AddEscalationReq) GetTaskModel() TaskModel

func (*AddEscalationReq) GetTaskType 

func (x *AddEscalationReq) GetTaskType() TaskType

func (*AddEscalationReq) ProtoMessage 

func (*AddEscalationReq) ProtoMessage()

func (*AddEscalationReq) ProtoReflect 

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

func (*AddEscalationReq) Reset 

func (x *AddEscalationReq) Reset()

func (*AddEscalationReq) String 

func (x *AddEscalationReq) String() string

func (*AddEscalationReq) Validate 

func (m *AddEscalationReq) Validate() error

Validate checks the field values on AddEscalationReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddEscalationReq) ValidateAll 

func (m *AddEscalationReq) ValidateAll() error

ValidateAll checks the field values on AddEscalationReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddEscalationReqMultiError, or nil if none found.

type AddEscalationReqMultiError 

type AddEscalationReqMultiError []error

AddEscalationReqMultiError is an error wrapping multiple validation errors returned by AddEscalationReq.ValidateAll() if the designated constraints aren't met.

func (AddEscalationReqMultiError) AllErrors 

func (m AddEscalationReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddEscalationReqMultiError) Error 

func (m AddEscalationReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddEscalationReqValidationError 

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

AddEscalationReqValidationError is the validation error returned by AddEscalationReq.Validate if the designated constraints aren't met.

func (AddEscalationReqValidationError) Cause 

func (e AddEscalationReqValidationError) Cause() error

Cause function returns cause value.

func (AddEscalationReqValidationError) Error 

func (e AddEscalationReqValidationError) Error() string

Error satisfies the builtin error interface

func (AddEscalationReqValidationError) ErrorName 

func (e AddEscalationReqValidationError) ErrorName() string

ErrorName returns error name.

func (AddEscalationReqValidationError) Field 

func (e AddEscalationReqValidationError) Field() string

Field function returns field value.

func (AddEscalationReqValidationError) Key 

func (e AddEscalationReqValidationError) Key() bool

Key function returns key value.

func (AddEscalationReqValidationError) Reason 

func (e AddEscalationReqValidationError) Reason() string

Reason function returns reason value.

type AddReply 

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

func (*AddReply) Descriptor deprecated 

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

Deprecated: Use AddReply.ProtoReflect.Descriptor instead.

func (*AddReply) ProtoMessage 

func (*AddReply) ProtoMessage()

func (*AddReply) ProtoReflect 

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

func (*AddReply) Reset 

func (x *AddReply) Reset()

func (*AddReply) String 

func (x *AddReply) String() string

func (*AddReply) Validate 

func (m *AddReply) Validate() error

Validate checks the field values on AddReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddReply) ValidateAll 

func (m *AddReply) ValidateAll() error

ValidateAll checks the field values on AddReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddReplyMultiError, or nil if none found.

type AddReplyMultiError 

type AddReplyMultiError []error

AddReplyMultiError is an error wrapping multiple validation errors returned by AddReply.ValidateAll() if the designated constraints aren't met.

func (AddReplyMultiError) AllErrors 

func (m AddReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddReplyMultiError) Error 

func (m AddReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddReplyValidationError 

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

AddReplyValidationError is the validation error returned by AddReply.Validate if the designated constraints aren't met.

func (AddReplyValidationError) Cause 

func (e AddReplyValidationError) Cause() error

Cause function returns cause value.

func (AddReplyValidationError) Error 

func (e AddReplyValidationError) Error() string

Error satisfies the builtin error interface

func (AddReplyValidationError) ErrorName 

func (e AddReplyValidationError) ErrorName() string

ErrorName returns error name.

func (AddReplyValidationError) Field 

func (e AddReplyValidationError) Field() string

Field function returns field value.

func (AddReplyValidationError) Key 

func (e AddReplyValidationError) Key() bool

Key function returns key value.

func (AddReplyValidationError) Reason 

func (e AddReplyValidationError) Reason() string

Reason function returns reason value.

type AddReq 

type AddReq struct {
	StartTime   int64         `protobuf:"varint,1,opt,name=startTime,proto3" json:"startTime,omitempty"`                                             //任务开始时间
	Cron        string        `protobuf:"bytes,2,opt,name=cron,proto3" json:"cron,omitempty"`                                                        //定时表达式
	TaskType    TaskType      `protobuf:"varint,3,opt,name=taskType,proto3,enum=api.platform.task.v2.TaskType" json:"taskType,omitempty"`            //任务类型
	TaskModel   TaskModel     `protobuf:"varint,4,opt,name=taskModel,proto3,enum=api.platform.task.v2.TaskModel" json:"taskModel,omitempty"`         //任务所属模块
	Data        []byte        `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`                                                        //任务所需数据
	Description string        `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`                                          //任务描述
	ContentType TaskCountType `protobuf:"varint,7,opt,name=contentType,proto3,enum=api.platform.task.v2.TaskCountType" json:"contentType,omitempty"` //任务内容类型
	// contains filtered or unexported fields
}

新加任务 -------------------------------------------

func (*AddReq) Descriptor deprecated 

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

Deprecated: Use AddReq.ProtoReflect.Descriptor instead.

func (*AddReq) GetContentType 

func (x *AddReq) GetContentType() TaskCountType

func (*AddReq) GetCron 

func (x *AddReq) GetCron() string

func (*AddReq) GetData 

func (x *AddReq) GetData() []byte

func (*AddReq) GetDescription 

func (x *AddReq) GetDescription() string

func (*AddReq) GetStartTime 

func (x *AddReq) GetStartTime() int64

func (*AddReq) GetTaskModel 

func (x *AddReq) GetTaskModel() TaskModel

func (*AddReq) GetTaskType 

func (x *AddReq) GetTaskType() TaskType

func (*AddReq) ProtoMessage 

func (*AddReq) ProtoMessage()

func (*AddReq) ProtoReflect 

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

func (*AddReq) Reset 

func (x *AddReq) Reset()

func (*AddReq) String 

func (x *AddReq) String() string

func (*AddReq) Validate 

func (m *AddReq) Validate() error

Validate checks the field values on AddReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddReq) ValidateAll 

func (m *AddReq) ValidateAll() error

ValidateAll checks the field values on AddReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddReqMultiError, or nil if none found.

type AddReqMultiError 

type AddReqMultiError []error

AddReqMultiError is an error wrapping multiple validation errors returned by AddReq.ValidateAll() if the designated constraints aren't met.

func (AddReqMultiError) AllErrors 

func (m AddReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddReqMultiError) Error 

func (m AddReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddReqValidationError 

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

AddReqValidationError is the validation error returned by AddReq.Validate if the designated constraints aren't met.

func (AddReqValidationError) Cause 

func (e AddReqValidationError) Cause() error

Cause function returns cause value.

func (AddReqValidationError) Error 

func (e AddReqValidationError) Error() string

Error satisfies the builtin error interface

func (AddReqValidationError) ErrorName 

func (e AddReqValidationError) ErrorName() string

ErrorName returns error name.

func (AddReqValidationError) Field 

func (e AddReqValidationError) Field() string

Field function returns field value.

func (AddReqValidationError) Key 

func (e AddReqValidationError) Key() bool

Key function returns key value.

func (AddReqValidationError) Reason 

func (e AddReqValidationError) Reason() string

Reason function returns reason value.

type DistributeUserReply 

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

func (*DistributeUserReply) Descriptor deprecated 

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

Deprecated: Use DistributeUserReply.ProtoReflect.Descriptor instead.

func (*DistributeUserReply) ProtoMessage 

func (*DistributeUserReply) ProtoMessage()

func (*DistributeUserReply) ProtoReflect 

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

func (*DistributeUserReply) Reset 

func (x *DistributeUserReply) Reset()

func (*DistributeUserReply) String 

func (x *DistributeUserReply) String() string

func (*DistributeUserReply) Validate 

func (m *DistributeUserReply) Validate() error

Validate checks the field values on DistributeUserReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DistributeUserReply) ValidateAll 

func (m *DistributeUserReply) ValidateAll() error

ValidateAll checks the field values on DistributeUserReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DistributeUserReplyMultiError, or nil if none found.

type DistributeUserReplyMultiError 

type DistributeUserReplyMultiError []error

DistributeUserReplyMultiError is an error wrapping multiple validation errors returned by DistributeUserReply.ValidateAll() if the designated constraints aren't met.

func (DistributeUserReplyMultiError) AllErrors 

func (m DistributeUserReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DistributeUserReplyMultiError) Error 

func (m DistributeUserReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DistributeUserReplyValidationError 

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

DistributeUserReplyValidationError is the validation error returned by DistributeUserReply.Validate if the designated constraints aren't met.

func (DistributeUserReplyValidationError) Cause 

func (e DistributeUserReplyValidationError) Cause() error

Cause function returns cause value.

func (DistributeUserReplyValidationError) Error 

func (e DistributeUserReplyValidationError) Error() string

Error satisfies the builtin error interface

func (DistributeUserReplyValidationError) ErrorName 

func (e DistributeUserReplyValidationError) ErrorName() string

ErrorName returns error name.

func (DistributeUserReplyValidationError) Field 

func (e DistributeUserReplyValidationError) Field() string

Field function returns field value.

func (DistributeUserReplyValidationError) Key 

func (e DistributeUserReplyValidationError) Key() bool

Key function returns key value.

func (DistributeUserReplyValidationError) Reason 

func (e DistributeUserReplyValidationError) Reason() string

Reason function returns reason value.

type DistributeUserReq 

type DistributeUserReq struct {
	User *v2.SyncUser `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` //用户信息
	// contains filtered or unexported fields
}

增加上报任务 -------------------------------------------

func (*DistributeUserReq) Descriptor deprecated 

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

Deprecated: Use DistributeUserReq.ProtoReflect.Descriptor instead.

func (*DistributeUserReq) GetUser 

func (x *DistributeUserReq) GetUser() *v2.SyncUser

func (*DistributeUserReq) ProtoMessage 

func (*DistributeUserReq) ProtoMessage()

func (*DistributeUserReq) ProtoReflect 

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

func (*DistributeUserReq) Reset 

func (x *DistributeUserReq) Reset()

func (*DistributeUserReq) String 

func (x *DistributeUserReq) String() string

func (*DistributeUserReq) Validate 

func (m *DistributeUserReq) Validate() error

Validate checks the field values on DistributeUserReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DistributeUserReq) ValidateAll 

func (m *DistributeUserReq) ValidateAll() error

ValidateAll checks the field values on DistributeUserReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DistributeUserReqMultiError, or nil if none found.

type DistributeUserReqMultiError 

type DistributeUserReqMultiError []error

DistributeUserReqMultiError is an error wrapping multiple validation errors returned by DistributeUserReq.ValidateAll() if the designated constraints aren't met.

func (DistributeUserReqMultiError) AllErrors 

func (m DistributeUserReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DistributeUserReqMultiError) Error 

func (m DistributeUserReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DistributeUserReqValidationError 

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

DistributeUserReqValidationError is the validation error returned by DistributeUserReq.Validate if the designated constraints aren't met.

func (DistributeUserReqValidationError) Cause 

func (e DistributeUserReqValidationError) Cause() error

Cause function returns cause value.

func (DistributeUserReqValidationError) Error 

func (e DistributeUserReqValidationError) Error() string

Error satisfies the builtin error interface

func (DistributeUserReqValidationError) ErrorName 

func (e DistributeUserReqValidationError) ErrorName() string

ErrorName returns error name.

func (DistributeUserReqValidationError) Field 

func (e DistributeUserReqValidationError) Field() string

Field function returns field value.

func (DistributeUserReqValidationError) Key 

func (e DistributeUserReqValidationError) Key() bool

Key function returns key value.

func (DistributeUserReqValidationError) Reason 

func (e DistributeUserReqValidationError) Reason() string

Reason function returns reason value.

type ErrorTaskReason 

type ErrorTaskReason int32
const (
	// 节点信息未找到
	ErrorTaskReason_NODE_NOT_FOUND ErrorTaskReason = 0
	// 添加任务失败
	ErrorTaskReason_ADD_TASK_ERROR ErrorTaskReason = 1
	// 执行任务失败
	ErrorTaskReason_EXECUTION_TASK_ERROR ErrorTaskReason = 3
)

func (ErrorTaskReason) Descriptor 

func (ErrorTaskReason) Descriptor() protoreflect.EnumDescriptor

func (ErrorTaskReason) Enum 

func (x ErrorTaskReason) Enum() *ErrorTaskReason

func (ErrorTaskReason) EnumDescriptor deprecated 

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

Deprecated: Use ErrorTaskReason.Descriptor instead.

func (ErrorTaskReason) Number 

func (x ErrorTaskReason) Number() protoreflect.EnumNumber

func (ErrorTaskReason) String 

func (x ErrorTaskReason) String() string

func (ErrorTaskReason) Type 

func (ErrorTaskReason) Type() protoreflect.EnumType

type ExecutionReply 

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

func (*ExecutionReply) Descriptor deprecated 

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

Deprecated: Use ExecutionReply.ProtoReflect.Descriptor instead.

func (*ExecutionReply) ProtoMessage 

func (*ExecutionReply) ProtoMessage()

func (*ExecutionReply) ProtoReflect 

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

func (*ExecutionReply) Reset 

func (x *ExecutionReply) Reset()

func (*ExecutionReply) String 

func (x *ExecutionReply) String() string

func (*ExecutionReply) Validate 

func (m *ExecutionReply) Validate() error

Validate checks the field values on ExecutionReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecutionReply) ValidateAll 

func (m *ExecutionReply) ValidateAll() error

ValidateAll checks the field values on ExecutionReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecutionReplyMultiError, or nil if none found.

type ExecutionReplyMultiError 

type ExecutionReplyMultiError []error

ExecutionReplyMultiError is an error wrapping multiple validation errors returned by ExecutionReply.ValidateAll() if the designated constraints aren't met.

func (ExecutionReplyMultiError) AllErrors 

func (m ExecutionReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecutionReplyMultiError) Error 

func (m ExecutionReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExecutionReplyValidationError 

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

ExecutionReplyValidationError is the validation error returned by ExecutionReply.Validate if the designated constraints aren't met.

func (ExecutionReplyValidationError) Cause 

func (e ExecutionReplyValidationError) Cause() error

Cause function returns cause value.

func (ExecutionReplyValidationError) Error 

func (e ExecutionReplyValidationError) Error() string

Error satisfies the builtin error interface

func (ExecutionReplyValidationError) ErrorName 

func (e ExecutionReplyValidationError) ErrorName() string

ErrorName returns error name.

func (ExecutionReplyValidationError) Field 

func (e ExecutionReplyValidationError) Field() string

Field function returns field value.

func (ExecutionReplyValidationError) Key 

func (e ExecutionReplyValidationError) Key() bool

Key function returns key value.

func (ExecutionReplyValidationError) Reason 

func (e ExecutionReplyValidationError) Reason() string

Reason function returns reason value.

type ExecutionReq 

type ExecutionReq struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` //任务id
	// contains filtered or unexported fields
}

获取任务列表 -------------------------------------------

func (*ExecutionReq) Descriptor deprecated 

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

Deprecated: Use ExecutionReq.ProtoReflect.Descriptor instead.

func (*ExecutionReq) GetId 

func (x *ExecutionReq) GetId() string

func (*ExecutionReq) ProtoMessage 

func (*ExecutionReq) ProtoMessage()

func (*ExecutionReq) ProtoReflect 

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

func (*ExecutionReq) Reset 

func (x *ExecutionReq) Reset()

func (*ExecutionReq) String 

func (x *ExecutionReq) String() string

func (*ExecutionReq) Validate 

func (m *ExecutionReq) Validate() error

Validate checks the field values on ExecutionReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecutionReq) ValidateAll 

func (m *ExecutionReq) ValidateAll() error

ValidateAll checks the field values on ExecutionReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecutionReqMultiError, or nil if none found.

type ExecutionReqMultiError 

type ExecutionReqMultiError []error

ExecutionReqMultiError is an error wrapping multiple validation errors returned by ExecutionReq.ValidateAll() if the designated constraints aren't met.

func (ExecutionReqMultiError) AllErrors 

func (m ExecutionReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecutionReqMultiError) Error 

func (m ExecutionReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExecutionReqValidationError 

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

ExecutionReqValidationError is the validation error returned by ExecutionReq.Validate if the designated constraints aren't met.

func (ExecutionReqValidationError) Cause 

func (e ExecutionReqValidationError) Cause() error

Cause function returns cause value.

func (ExecutionReqValidationError) Error 

func (e ExecutionReqValidationError) Error() string

Error satisfies the builtin error interface

func (ExecutionReqValidationError) ErrorName 

func (e ExecutionReqValidationError) ErrorName() string

ErrorName returns error name.

func (ExecutionReqValidationError) Field 

func (e ExecutionReqValidationError) Field() string

Field function returns field value.

func (ExecutionReqValidationError) Key 

func (e ExecutionReqValidationError) Key() bool

Key function returns key value.

func (ExecutionReqValidationError) Reason 

func (e ExecutionReqValidationError) Reason() string

Reason function returns reason value.

type GetListReply 

type GetListReply struct {
	Total int64          `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` //总数
	List  []*TaskDetails `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`    //任务详情
	// contains filtered or unexported fields
}

func (*GetListReply) Descriptor deprecated 

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

Deprecated: Use GetListReply.ProtoReflect.Descriptor instead.

func (*GetListReply) GetList 

func (x *GetListReply) GetList() []*TaskDetails

func (*GetListReply) GetTotal 

func (x *GetListReply) GetTotal() int64

func (*GetListReply) ProtoMessage 

func (*GetListReply) ProtoMessage()

func (*GetListReply) ProtoReflect 

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

func (*GetListReply) Reset 

func (x *GetListReply) Reset()

func (*GetListReply) String 

func (x *GetListReply) String() string

func (*GetListReply) Validate 

func (m *GetListReply) Validate() error

Validate checks the field values on GetListReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetListReply) ValidateAll 

func (m *GetListReply) ValidateAll() error

ValidateAll checks the field values on GetListReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetListReplyMultiError, or nil if none found.

type GetListReplyMultiError 

type GetListReplyMultiError []error

GetListReplyMultiError is an error wrapping multiple validation errors returned by GetListReply.ValidateAll() if the designated constraints aren't met.

func (GetListReplyMultiError) AllErrors 

func (m GetListReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetListReplyMultiError) Error 

func (m GetListReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetListReplyValidationError 

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

GetListReplyValidationError is the validation error returned by GetListReply.Validate if the designated constraints aren't met.

func (GetListReplyValidationError) Cause 

func (e GetListReplyValidationError) Cause() error

Cause function returns cause value.

func (GetListReplyValidationError) Error 

func (e GetListReplyValidationError) Error() string

Error satisfies the builtin error interface

func (GetListReplyValidationError) ErrorName 

func (e GetListReplyValidationError) ErrorName() string

ErrorName returns error name.

func (GetListReplyValidationError) Field 

func (e GetListReplyValidationError) Field() string

Field function returns field value.

func (GetListReplyValidationError) Key 

func (e GetListReplyValidationError) Key() bool

Key function returns key value.

func (GetListReplyValidationError) Reason 

func (e GetListReplyValidationError) Reason() string

Reason function returns reason value.

type GetListReq 

type GetListReq struct {
	Page      *v2.Pagination `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"`                                                //分页
	TaskType  TaskType       `protobuf:"varint,3,opt,name=taskType,proto3,enum=api.platform.task.v2.TaskType" json:"taskType,omitempty"`    //任务类型 0:立即执行 1:延迟执行 3:定时执行
	TaskModel TaskModel      `protobuf:"varint,4,opt,name=taskModel,proto3,enum=api.platform.task.v2.TaskModel" json:"taskModel,omitempty"` //任务所属模块 0:系统任务 1:用户模块 2:节点模块
	Status    TaskStatus     `protobuf:"varint,5,opt,name=status,proto3,enum=api.platform.task.v2.TaskStatus" json:"status,omitempty"`      // 状态  0:新建 1:等待执行 2:执行中 3:执行失败 4:执行成功
	// contains filtered or unexported fields
}

获取任务列表 -------------------------------------------

func (*GetListReq) Descriptor deprecated 

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

Deprecated: Use GetListReq.ProtoReflect.Descriptor instead.

func (*GetListReq) GetPage 

func (x *GetListReq) GetPage() *v2.Pagination

func (*GetListReq) GetStatus 

func (x *GetListReq) GetStatus() TaskStatus

func (*GetListReq) GetTaskModel 

func (x *GetListReq) GetTaskModel() TaskModel

func (*GetListReq) GetTaskType 

func (x *GetListReq) GetTaskType() TaskType

func (*GetListReq) ProtoMessage 

func (*GetListReq) ProtoMessage()

func (*GetListReq) ProtoReflect 

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

func (*GetListReq) Reset 

func (x *GetListReq) Reset()

func (*GetListReq) String 

func (x *GetListReq) String() string

func (*GetListReq) Validate 

func (m *GetListReq) Validate() error

Validate checks the field values on GetListReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetListReq) ValidateAll 

func (m *GetListReq) ValidateAll() error

ValidateAll checks the field values on GetListReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetListReqMultiError, or nil if none found.

type GetListReqMultiError 

type GetListReqMultiError []error

GetListReqMultiError is an error wrapping multiple validation errors returned by GetListReq.ValidateAll() if the designated constraints aren't met.

func (GetListReqMultiError) AllErrors 

func (m GetListReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetListReqMultiError) Error 

func (m GetListReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetListReqValidationError 

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

GetListReqValidationError is the validation error returned by GetListReq.Validate if the designated constraints aren't met.

func (GetListReqValidationError) Cause 

func (e GetListReqValidationError) Cause() error

Cause function returns cause value.

func (GetListReqValidationError) Error 

func (e GetListReqValidationError) Error() string

Error satisfies the builtin error interface

func (GetListReqValidationError) ErrorName 

func (e GetListReqValidationError) ErrorName() string

ErrorName returns error name.

func (GetListReqValidationError) Field 

func (e GetListReqValidationError) Field() string

Field function returns field value.

func (GetListReqValidationError) Key 

func (e GetListReqValidationError) Key() bool

Key function returns key value.

func (GetListReqValidationError) Reason 

func (e GetListReqValidationError) Reason() string

Reason function returns reason value.

type NodeDistribute 

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

节点信息下发

func (*NodeDistribute) Descriptor deprecated 

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

Deprecated: Use NodeDistribute.ProtoReflect.Descriptor instead.

func (*NodeDistribute) GetNodeId 

func (x *NodeDistribute) GetNodeId() string

func (*NodeDistribute) ProtoMessage 

func (*NodeDistribute) ProtoMessage()

func (*NodeDistribute) ProtoReflect 

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

func (*NodeDistribute) Reset 

func (x *NodeDistribute) Reset()

func (*NodeDistribute) String 

func (x *NodeDistribute) String() string

func (*NodeDistribute) Validate 

func (m *NodeDistribute) Validate() error

Validate checks the field values on NodeDistribute with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NodeDistribute) ValidateAll 

func (m *NodeDistribute) ValidateAll() error

ValidateAll checks the field values on NodeDistribute with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NodeDistributeMultiError, or nil if none found.

type NodeDistributeMultiError 

type NodeDistributeMultiError []error

NodeDistributeMultiError is an error wrapping multiple validation errors returned by NodeDistribute.ValidateAll() if the designated constraints aren't met.

func (NodeDistributeMultiError) AllErrors 

func (m NodeDistributeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NodeDistributeMultiError) Error 

func (m NodeDistributeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NodeDistributeValidationError 

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

NodeDistributeValidationError is the validation error returned by NodeDistribute.Validate if the designated constraints aren't met.

func (NodeDistributeValidationError) Cause 

func (e NodeDistributeValidationError) Cause() error

Cause function returns cause value.

func (NodeDistributeValidationError) Error 

func (e NodeDistributeValidationError) Error() string

Error satisfies the builtin error interface

func (NodeDistributeValidationError) ErrorName 

func (e NodeDistributeValidationError) ErrorName() string

ErrorName returns error name.

func (NodeDistributeValidationError) Field 

func (e NodeDistributeValidationError) Field() string

Field function returns field value.

func (NodeDistributeValidationError) Key 

func (e NodeDistributeValidationError) Key() bool

Key function returns key value.

func (NodeDistributeValidationError) Reason 

func (e NodeDistributeValidationError) Reason() string

Reason function returns reason value.

type TaskClient 

type TaskClient interface {
	// 新加任务
	Add(ctx context.Context, in *AddReq, opts ...grpc.CallOption) (*AddReply, error)
	// 获取任务列表
	GetList(ctx context.Context, in *GetListReq, opts ...grpc.CallOption) (*GetListReply, error)
	// 执行任务
	Execution(ctx context.Context, in *ExecutionReq, opts ...grpc.CallOption) (*ExecutionReply, error)
	// 增加上报任务
	AddEscalation(ctx context.Context, in *AddEscalationReq, opts ...grpc.CallOption) (*AddEscalationReply, error)
	// 下发用户
	DistributeUser(ctx context.Context, in *DistributeUserReq, opts ...grpc.CallOption) (*DistributeUserReply, error)
}

TaskClient is the client API for Task 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.

Task 任务

func NewTaskClient 

func NewTaskClient(cc grpc.ClientConnInterface) TaskClient

type TaskCountType 

type TaskCountType int32

任务内容类型 

const (
	TaskCountType_unknown              TaskCountType = 0
	TaskCountType_USER_INFO_DISTRIBUTE TaskCountType = 1 //用户信息下发
	TaskCountType_USER_INFO_ESCALATION TaskCountType = 2 //用户信息上报
	TaskCountType_NODE_INFO_DISTRIBUTE TaskCountType = 3 //节点信息下发
)

func (TaskCountType) Descriptor 

func (TaskCountType) Descriptor() protoreflect.EnumDescriptor

func (TaskCountType) Enum 

func (x TaskCountType) Enum() *TaskCountType

func (TaskCountType) EnumDescriptor deprecated 

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

Deprecated: Use TaskCountType.Descriptor instead.

func (TaskCountType) Number 

func (x TaskCountType) Number() protoreflect.EnumNumber

func (TaskCountType) String 

func (x TaskCountType) String() string

func (TaskCountType) Type 

func (TaskCountType) Type() protoreflect.EnumType

type TaskDetails 

type TaskDetails struct {
	Id          string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                                            //任务id
	StartTime   int64         `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`                                             //任务开始时间
	Cron        string        `protobuf:"bytes,3,opt,name=cron,proto3" json:"cron,omitempty"`                                                        //定时表达式
	TaskType    TaskType      `protobuf:"varint,4,opt,name=taskType,proto3,enum=api.platform.task.v2.TaskType" json:"taskType,omitempty"`            //任务类型 0:立即执行 1:延迟执行 3:定时执行
	TaskModel   TaskModel     `protobuf:"varint,5,opt,name=taskModel,proto3,enum=api.platform.task.v2.TaskModel" json:"taskModel,omitempty"`         //任务所属模块 0:系统任务 1:用户模块 2:节点模块
	Data        []byte        `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`                                                        //任务所需数据
	Description string        `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`                                          //任务描述
	Status      TaskStatus    `protobuf:"varint,8,opt,name=status,proto3,enum=api.platform.task.v2.TaskStatus" json:"status,omitempty"`              // 状态  0:新建 1:等待执行 2:执行中 3:执行失败 4:执行成功
	ContentType TaskCountType `protobuf:"varint,9,opt,name=contentType,proto3,enum=api.platform.task.v2.TaskCountType" json:"contentType,omitempty"` //任务内容类型 0:未定义 1:用户信息下发 2:用户信息下发 3:节点信息下发
	Reason      string        `protobuf:"bytes,10,opt,name=reason,proto3" json:"reason,omitempty"`                                                   //失败原因
	RetryCount  int64         `protobuf:"varint,11,opt,name=retryCount,proto3" json:"retryCount,omitempty"`                                          //重试次数
	CreatedAt   int64         `protobuf:"varint,12,opt,name=createdAt,proto3" json:"createdAt,omitempty"`                                            //创建时间
	UpdatedAt   int64         `protobuf:"varint,13,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`                                            //更新时间
	// contains filtered or unexported fields
}

func (*TaskDetails) Descriptor deprecated 

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

Deprecated: Use TaskDetails.ProtoReflect.Descriptor instead.

func (*TaskDetails) GetContentType 

func (x *TaskDetails) GetContentType() TaskCountType

func (*TaskDetails) GetCreatedAt 

func (x *TaskDetails) GetCreatedAt() int64

func (*TaskDetails) GetCron 

func (x *TaskDetails) GetCron() string

func (*TaskDetails) GetData 

func (x *TaskDetails) GetData() []byte

func (*TaskDetails) GetDescription 

func (x *TaskDetails) GetDescription() string

func (*TaskDetails) GetId 

func (x *TaskDetails) GetId() string

func (*TaskDetails) GetReason 

func (x *TaskDetails) GetReason() string

func (*TaskDetails) GetRetryCount 

func (x *TaskDetails) GetRetryCount() int64

func (*TaskDetails) GetStartTime 

func (x *TaskDetails) GetStartTime() int64

func (*TaskDetails) GetStatus 

func (x *TaskDetails) GetStatus() TaskStatus

func (*TaskDetails) GetTaskModel 

func (x *TaskDetails) GetTaskModel() TaskModel

func (*TaskDetails) GetTaskType 

func (x *TaskDetails) GetTaskType() TaskType

func (*TaskDetails) GetUpdatedAt 

func (x *TaskDetails) GetUpdatedAt() int64

func (*TaskDetails) ProtoMessage 

func (*TaskDetails) ProtoMessage()

func (*TaskDetails) ProtoReflect 

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

func (*TaskDetails) Reset 

func (x *TaskDetails) Reset()

func (*TaskDetails) String 

func (x *TaskDetails) String() string

func (*TaskDetails) Validate 

func (m *TaskDetails) Validate() error

Validate checks the field values on TaskDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskDetails) ValidateAll 

func (m *TaskDetails) ValidateAll() error

ValidateAll checks the field values on TaskDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskDetailsMultiError, or nil if none found.

type TaskDetailsMultiError 

type TaskDetailsMultiError []error

TaskDetailsMultiError is an error wrapping multiple validation errors returned by TaskDetails.ValidateAll() if the designated constraints aren't met.

func (TaskDetailsMultiError) AllErrors 

func (m TaskDetailsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskDetailsMultiError) Error 

func (m TaskDetailsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskDetailsValidationError 

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

TaskDetailsValidationError is the validation error returned by TaskDetails.Validate if the designated constraints aren't met.

func (TaskDetailsValidationError) Cause 

func (e TaskDetailsValidationError) Cause() error

Cause function returns cause value.

func (TaskDetailsValidationError) Error 

func (e TaskDetailsValidationError) Error() string

Error satisfies the builtin error interface

func (TaskDetailsValidationError) ErrorName 

func (e TaskDetailsValidationError) ErrorName() string

ErrorName returns error name.

func (TaskDetailsValidationError) Field 

func (e TaskDetailsValidationError) Field() string

Field function returns field value.

func (TaskDetailsValidationError) Key 

func (e TaskDetailsValidationError) Key() bool

Key function returns key value.

func (TaskDetailsValidationError) Reason 

func (e TaskDetailsValidationError) Reason() string

Reason function returns reason value.

type TaskModel 

type TaskModel int32

任务所属模块 

const (
	TaskModel_UNKNOWN_MODEL TaskModel = 0 //未知
	TaskModel_USER          TaskModel = 1 //用户模块任务
	TaskModel_NODE          TaskModel = 2 //任务模块任务
)

func (TaskModel) Descriptor 

func (TaskModel) Descriptor() protoreflect.EnumDescriptor

func (TaskModel) Enum 

func (x TaskModel) Enum() *TaskModel

func (TaskModel) EnumDescriptor deprecated 

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

Deprecated: Use TaskModel.Descriptor instead.

func (TaskModel) Number 

func (x TaskModel) Number() protoreflect.EnumNumber

func (TaskModel) String 

func (x TaskModel) String() string

func (TaskModel) Type 

func (TaskModel) Type() protoreflect.EnumType

type TaskServer 

type TaskServer interface {
	// 新加任务
	Add(context.Context, *AddReq) (*AddReply, error)
	// 获取任务列表
	GetList(context.Context, *GetListReq) (*GetListReply, error)
	// 执行任务
	Execution(context.Context, *ExecutionReq) (*ExecutionReply, error)
	// 增加上报任务
	AddEscalation(context.Context, *AddEscalationReq) (*AddEscalationReply, error)
	// 下发用户
	DistributeUser(context.Context, *DistributeUserReq) (*DistributeUserReply, error)
	// contains filtered or unexported methods
}

TaskServer is the server API for Task service. All implementations must embed UnimplementedTaskServer for forward compatibility

Task 任务

type TaskStatus 

type TaskStatus int32

任务状态 

const (
	TaskStatus_UNKNOWN_STATUS      TaskStatus = 0 //未知
	TaskStatus_WAITING             TaskStatus = 1 //创建等待执行
	TaskStatus_IN_PROGRESS         TaskStatus = 2 //执行中
	TaskStatus_EXECUTION_FAILED    TaskStatus = 3 //执行失败
	TaskStatus_EXECUTION_SUCCEEDED TaskStatus = 4 //执行成功
)

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_EXECUTE_IMMEDIATELY TaskType = 0 //立即单次执行
	TaskType_DELAY_EXECUTION     TaskType = 1 //延迟执行
	TaskType_TIMED_EXECUTION     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 UnimplementedTaskServer 

type UnimplementedTaskServer struct {
}

UnimplementedTaskServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServer) Add 

func (UnimplementedTaskServer) Add(context.Context, *AddReq) (*AddReply, error)

func (UnimplementedTaskServer) AddEscalation 

func (UnimplementedTaskServer) AddEscalation(context.Context, *AddEscalationReq) (*AddEscalationReply, error)

func (UnimplementedTaskServer) DistributeUser 

func (UnimplementedTaskServer) DistributeUser(context.Context, *DistributeUserReq) (*DistributeUserReply, error)

func (UnimplementedTaskServer) Execution 

func (UnimplementedTaskServer) Execution(context.Context, *ExecutionReq) (*ExecutionReply, error)

func (UnimplementedTaskServer) GetList 

func (UnimplementedTaskServer) GetList(context.Context, *GetListReq) (*GetListReply, error)

type UnsafeTaskServer 

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

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

type UserInfoDistribute 

type UserInfoDistribute struct {
	UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` //用户id
	NodeId string `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"` //节点id
	// contains filtered or unexported fields
}

用户信息下发

func (*UserInfoDistribute) Descriptor deprecated 

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

Deprecated: Use UserInfoDistribute.ProtoReflect.Descriptor instead.

func (*UserInfoDistribute) GetNodeId 

func (x *UserInfoDistribute) GetNodeId() string

func (*UserInfoDistribute) GetUserId 

func (x *UserInfoDistribute) GetUserId() string

func (*UserInfoDistribute) ProtoMessage 

func (*UserInfoDistribute) ProtoMessage()

func (*UserInfoDistribute) ProtoReflect 

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

func (*UserInfoDistribute) Reset 

func (x *UserInfoDistribute) Reset()

func (*UserInfoDistribute) String 

func (x *UserInfoDistribute) String() string

func (*UserInfoDistribute) Validate 

func (m *UserInfoDistribute) Validate() error

Validate checks the field values on UserInfoDistribute with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UserInfoDistribute) ValidateAll 

func (m *UserInfoDistribute) ValidateAll() error

ValidateAll checks the field values on UserInfoDistribute with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UserInfoDistributeMultiError, or nil if none found.

type UserInfoDistributeMultiError 

type UserInfoDistributeMultiError []error

UserInfoDistributeMultiError is an error wrapping multiple validation errors returned by UserInfoDistribute.ValidateAll() if the designated constraints aren't met.

func (UserInfoDistributeMultiError) AllErrors 

func (m UserInfoDistributeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UserInfoDistributeMultiError) Error 

func (m UserInfoDistributeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UserInfoDistributeValidationError 

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

UserInfoDistributeValidationError is the validation error returned by UserInfoDistribute.Validate if the designated constraints aren't met.

func (UserInfoDistributeValidationError) Cause 

func (e UserInfoDistributeValidationError) Cause() error

Cause function returns cause value.

func (UserInfoDistributeValidationError) Error 

func (e UserInfoDistributeValidationError) Error() string

Error satisfies the builtin error interface

func (UserInfoDistributeValidationError) ErrorName 

func (e UserInfoDistributeValidationError) ErrorName() string

ErrorName returns error name.

func (UserInfoDistributeValidationError) Field 

func (e UserInfoDistributeValidationError) Field() string

Field function returns field value.

func (UserInfoDistributeValidationError) Key 

func (e UserInfoDistributeValidationError) Key() bool

Key function returns key value.

func (UserInfoDistributeValidationError) Reason 

func (e UserInfoDistributeValidationError) Reason() string

Reason function returns reason value.

type UserInfoEscalation 

type UserInfoEscalation struct {
	Data *v2.EscalationData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` //用户信息
	// contains filtered or unexported fields
}

用户信息上报

func (*UserInfoEscalation) Descriptor deprecated 

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

Deprecated: Use UserInfoEscalation.ProtoReflect.Descriptor instead.

func (*UserInfoEscalation) GetData 

func (x *UserInfoEscalation) GetData() *v2.EscalationData

func (*UserInfoEscalation) ProtoMessage 

func (*UserInfoEscalation) ProtoMessage()

func (*UserInfoEscalation) ProtoReflect 

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

func (*UserInfoEscalation) Reset 

func (x *UserInfoEscalation) Reset()

func (*UserInfoEscalation) String 

func (x *UserInfoEscalation) String() string

func (*UserInfoEscalation) Validate 

func (m *UserInfoEscalation) Validate() error

Validate checks the field values on UserInfoEscalation with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UserInfoEscalation) ValidateAll 

func (m *UserInfoEscalation) ValidateAll() error

ValidateAll checks the field values on UserInfoEscalation with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UserInfoEscalationMultiError, or nil if none found.

type UserInfoEscalationMultiError 

type UserInfoEscalationMultiError []error

UserInfoEscalationMultiError is an error wrapping multiple validation errors returned by UserInfoEscalation.ValidateAll() if the designated constraints aren't met.

func (UserInfoEscalationMultiError) AllErrors 

func (m UserInfoEscalationMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UserInfoEscalationMultiError) Error 

func (m UserInfoEscalationMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UserInfoEscalationValidationError 

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

UserInfoEscalationValidationError is the validation error returned by UserInfoEscalation.Validate if the designated constraints aren't met.

func (UserInfoEscalationValidationError) Cause 

func (e UserInfoEscalationValidationError) Cause() error

Cause function returns cause value.

func (UserInfoEscalationValidationError) Error 

func (e UserInfoEscalationValidationError) Error() string

Error satisfies the builtin error interface

func (UserInfoEscalationValidationError) ErrorName 

func (e UserInfoEscalationValidationError) ErrorName() string

ErrorName returns error name.

func (UserInfoEscalationValidationError) Field 

func (e UserInfoEscalationValidationError) Field() string

Field function returns field value.

func (UserInfoEscalationValidationError) Key 

func (e UserInfoEscalationValidationError) Key() bool

Key function returns key value.

func (UserInfoEscalationValidationError) Reason 

func (e UserInfoEscalationValidationError) Reason() string

Reason function returns reason value.

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.