taskstatus

Documentation

Index

• type ShardingTaskProgress
  • func NewShardingTaskProgress(shardingProgressList []*ShardingTaskStatus) *ShardingTaskProgress
  • func (t *ShardingTaskProgress) GetShardingProgress() []*ShardingTaskStatus
  • func (t *ShardingTaskProgress) SetShardingTaskStatus(shardingProgress []*ShardingTaskStatus)
• type ShardingTaskStatus
  • func NewShardingTaskStatus(id int64, workerAddr string, status int32) *ShardingTaskStatus
  • func (s *ShardingTaskStatus) Id() int64
  • func (s *ShardingTaskStatus) SetId(id int64)
  • func (s *ShardingTaskStatus) SetStatus(status int32)
  • func (s *ShardingTaskStatus) SetStatusType(statusType *TypeInfo)
  • func (s *ShardingTaskStatus) SetWorkerAddr(workerAddr string)
  • func (s *ShardingTaskStatus) Status() int32
  • func (s *ShardingTaskStatus) StatusType() *TypeInfo
  • func (s *ShardingTaskStatus) WorkerAddr() string
• type TaskStatus
  • func Convert2TaskStatus(val int32) (TaskStatus, bool)
  • func (status TaskStatus) Descriptor() string
  • func (status TaskStatus) IsFinished() bool
• type TypeInfo
  • func NewTypeInfo(code, name string) *TypeInfo
  • func (t *TypeInfo) Code() string
  • func (t *TypeInfo) Name() string
  • func (t *TypeInfo) SetCode(code string)
  • func (t *TypeInfo) SetName(name string)
  • func (t *TypeInfo) SetTips(tips map[string]string)
  • func (t *TypeInfo) Tips() map[string]string

Types

type ShardingTaskProgress

type ShardingTaskProgress struct {
	ShardingProgress []*ShardingTaskStatus `json:"shardingProgress"`
}

func NewShardingTaskProgress

func NewShardingTaskProgress(shardingProgressList []*ShardingTaskStatus) *ShardingTaskProgress

func (*ShardingTaskProgress) GetShardingProgress

func (t *ShardingTaskProgress) GetShardingProgress() []*ShardingTaskStatus

func (*ShardingTaskProgress) SetShardingTaskStatus

func (t *ShardingTaskProgress) SetShardingTaskStatus(shardingProgress []*ShardingTaskStatus)

type ShardingTaskStatus

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

func NewShardingTaskStatus

func NewShardingTaskStatus(id int64, workerAddr string, status int32) *ShardingTaskStatus

func (*ShardingTaskStatus) Id

func (s *ShardingTaskStatus) Id() int64

func (*ShardingTaskStatus) SetId

func (s *ShardingTaskStatus) SetId(id int64)

func (*ShardingTaskStatus) SetStatus

func (s *ShardingTaskStatus) SetStatus(status int32)

func (*ShardingTaskStatus) SetStatusType

func (s *ShardingTaskStatus) SetStatusType(statusType *TypeInfo)

func (*ShardingTaskStatus) SetWorkerAddr

func (s *ShardingTaskStatus) SetWorkerAddr(workerAddr string)

func (*ShardingTaskStatus) Status

func (s *ShardingTaskStatus) Status() int32

func (*ShardingTaskStatus) StatusType

func (s *ShardingTaskStatus) StatusType() *TypeInfo

func (*ShardingTaskStatus) WorkerAddr

func (s *ShardingTaskStatus) WorkerAddr() string

type TaskStatus

type TaskStatus int32

const (
	TaskStatusUnknown TaskStatus = 0
	TaskStatusInit    TaskStatus = 1
	TaskStatusPulled  TaskStatus = 2
	TaskStatusRunning TaskStatus = 3
	TaskStatusSucceed TaskStatus = 4
	TaskStatusFailed  TaskStatus = 5
)

func Convert2TaskStatus

func Convert2TaskStatus(val int32) (TaskStatus, bool)

func (TaskStatus) Descriptor

func (status TaskStatus) Descriptor() string

func (TaskStatus) IsFinished

func (status TaskStatus) IsFinished() bool

type TypeInfo

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

func NewTypeInfo

func NewTypeInfo(code, name string) *TypeInfo

func (*TypeInfo) Code

func (t *TypeInfo) Code() string

func (*TypeInfo) Name

func (t *TypeInfo) Name() string

func (*TypeInfo) SetCode

func (t *TypeInfo) SetCode(code string)

func (*TypeInfo) SetName

func (t *TypeInfo) SetName(name string)

func (*TypeInfo) SetTips

func (t *TypeInfo) SetTips(tips map[string]string)

func (*TypeInfo) Tips

func (t *TypeInfo) Tips() map[string]string