task

Documentation

Index

• Variables
• type Task
  • func (*Task) Descriptor() ([]byte, []int)
  • func (x *Task) GetCallbackUrl() string
  • func (x *Task) GetCtime() int64
  • func (x *Task) GetExpireTime() int64
  • func (x *Task) GetId() string
  • func (x *Task) GetInputArgs() []byte
  • func (x *Task) GetMaxRetryCnt() int64
  • func (x *Task) GetNamespace() string
  • func (x *Task) GetOutputArgs() []byte
  • func (x *Task) GetState() string
  • func (x *Task) GetTaskType() string
  • func (x *Task) GetTraceId() string
  • func (x *Task) GetUtime() int64
  • func (*Task) ProtoMessage()
  • func (x *Task) ProtoReflect() protoreflect.Message
  • func (x *Task) Reset()
  • func (x *Task) String() string

Variables

var File_task_v1_task_proto protoreflect.FileDescriptor

Types

type Task

type Task struct {

	// 任务id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 所属命名空间
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 任务类型
	TaskType string `protobuf:"bytes,3,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// 输入参数
	InputArgs []byte `protobuf:"bytes,4,opt,name=input_args,json=inputArgs,proto3" json:"input_args,omitempty"`
	// 输出参数
	OutputArgs []byte `protobuf:"bytes,5,opt,name=output_args,json=outputArgs,proto3,oneof" json:"output_args,omitempty"`
	// 回调url
	CallbackUrl string `protobuf:"bytes,6,opt,name=callback_url,json=callbackUrl,proto3" json:"callback_url,omitempty"`
	// 任务状态
	State string `protobuf:"bytes,7,opt,name=state,proto3" json:"state,omitempty"`
	// 最大重试次数 -1表示无限重试直到超时, 0表示不重试
	MaxRetryCnt int64 `protobuf:"varint,8,opt,name=max_retry_cnt,json=maxRetryCnt,proto3" json:"max_retry_cnt,omitempty"`
	// 任务过期时间 unix ms
	ExpireTime int64 `protobuf:"varint,9,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	// 创建时间 unix ms
	Ctime int64 `protobuf:"varint,10,opt,name=ctime,proto3" json:"ctime,omitempty"`
	// 更新时间 unix ms
	Utime int64 `protobuf:"varint,11,opt,name=utime,proto3" json:"utime,omitempty"`
	// trace id
	TraceId string `protobuf:"bytes,12,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCallbackUrl

func (x *Task) GetCallbackUrl() string

func (*Task) GetCtime

func (x *Task) GetCtime() int64

func (*Task) GetExpireTime

func (x *Task) GetExpireTime() int64

func (*Task) GetId

func (x *Task) GetId() string

func (*Task) GetInputArgs

func (x *Task) GetInputArgs() []byte

func (*Task) GetMaxRetryCnt

func (x *Task) GetMaxRetryCnt() int64

func (*Task) GetNamespace

func (x *Task) GetNamespace() string

func (*Task) GetOutputArgs

func (x *Task) GetOutputArgs() []byte

func (*Task) GetState

func (x *Task) GetState() string

func (*Task) GetTaskType

func (x *Task) GetTaskType() string

func (*Task) GetTraceId

func (x *Task) GetTraceId() string

func (*Task) GetUtime

func (x *Task) GetUtime() 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