model

package

v1.0.1 Latest Latest Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 9 Imported by: 3

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xyzbit/minitaskx

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GenerateResourceUsage() (map[string]string, error)
func GenerateStain(ru map[string]string, disable bool) (map[string]string, error)
func ParseResourceUsage(metadata map[string]string) map[string]float64
func Parsestain(metadata map[string]string) map[string]string
type Change
- func (c Change) GetUniKey() Change
- func (c Change) IsException() bool
type ChangeType
- func GetChangeType(realRunStatus, wantRunStatus TaskStatus) (ChangeType, error)
type Task
- func (t *Task) Clone() *Task
type TaskExecParam
type TaskExecResult
type TaskFilter
type TaskStatus

Constants ¶

View Source

const (
	CpuUsageKey    = "rs_cpu_usage"
	MemTotalKey    = "rs_mem_total"
	MemUsedKey     = "rs_mem_used"
	MemUsageKey    = "rs_mem_usage"
	GoGcPauseKey   = "rs_go_gc_pause"
	GoGcCountKey   = "rs_go_gc_count"
	GoGoroutineKey = "rs_go_goroutine"
)

Variables ¶

This section is empty.

Functions ¶

func GenerateResourceUsage ¶

func GenerateResourceUsage() (map[string]string, error)

func GenerateStain ¶

func GenerateStain(ru map[string]string, disable bool) (map[string]string, error)

生成污点标签

func ParseResourceUsage ¶

func ParseResourceUsage(metadata map[string]string) map[string]float64

func Parsestain ¶

func Parsestain(metadata map[string]string) map[string]string

Types ¶

type Change ¶

type Change struct {
	TaskKey    string
	TaskType   string
	ChangeType ChangeType
	// 仅在 ChangeType == ChangeCreate 时有值.
	Task *Task
}

func (Change) GetUniKey ¶

func (c Change) GetUniKey() Change

func (Change) IsException ¶

func (c Change) IsException() bool

type ChangeType ¶

type ChangeType string

const (
	ChangeCreate ChangeType = "create"
	ChangeDelete ChangeType = "delete"
	ChangeResume ChangeType = "resume"
	ChangePause  ChangeType = "pause"
	ChangeStop   ChangeType = "stop"

	ChangeExceptionUpdate ChangeType = "exception_update"
	ChangeExceptionFinish ChangeType = "exception_finish"
)

func GetChangeType ¶

func GetChangeType(
	realRunStatus, wantRunStatus TaskStatus,
) (ChangeType, error)

type Task ¶

type Task struct {
	ID            int64             `json:"id,omitempty"`
	TaskKey       string            `json:"task_key,omitempty"`
	BizID         string            `json:"biz_id,omitempty"`
	BizType       string            `json:"biz_type,omitempty"`
	Type          string            `json:"type,omitempty"`
	Payload       string            `json:"payload,omitempty"`
	Labels        map[string]string `json:"labels,omitempty"`
	Stains        map[string]string `json:"stains,omitempty"`
	Extra         map[string]string `json:"extra,omitempty"`
	Status        TaskStatus        `json:"status,omitempty"`          // current real status
	WantRunStatus TaskStatus        `json:"want_run_status,omitempty"` // want status
	WorkerID      string            `json:"worker_id,omitempty"`
	NextRunAt     *time.Time        `json:"next_run_at,omitempty"`
	Msg           string            `json:"msg,omitempty"`
	CreatedAt     time.Time         `json:"created_at,omitempty"`
	UpdatedAt     time.Time         `json:"updated_at,omitempty"`
}

func (*Task) Clone ¶

func (t *Task) Clone() *Task

type TaskExecParam ¶ added in v1.0.1

type TaskExecParam struct {
	TaskKey string `json:"task_key,omitempty"`
	BizID   string `json:"biz_id,omitempty"`
	BizType string `json:"biz_type,omitempty"`
	Payload string `json:"payload,omitempty"`
}

Task Exec Param.

type TaskExecResult ¶ added in v1.0.1

type TaskExecResult struct {
	TaskKey  string     `json:"task_key,omitempty"`
	TaskType string     `json:"task_type,omitempty"`
	Status   TaskStatus `json:"status,omitempty"`
	Msg      string     `json:"msg,omitempty"`
}

Task Exec Result.

type TaskFilter ¶

type TaskFilter struct {
	BizIDs  []string
	BizType string
	Type    string

	Offset int
	Limit  int
}

type TaskStatus ¶

type TaskStatus string

const (
	TaskStatusNotExist       TaskStatus = "not_exist" // It is a virtual state used to mark that the task does not exist for deletion processing.
	TaskStatusWaitScheduling TaskStatus = "wait_scheduling"
	TaskStatusWaitRunning    TaskStatus = "wait_running"
	TaskStatusRunning        TaskStatus = "running"
	TaskStatusWaitPaused     TaskStatus = "wait_paused"
	TaskStatusPaused         TaskStatus = "paused"
	TaskStatusWaitStop       TaskStatus = "wait_stopped"
	TaskStatusStop           TaskStatus = "stop"
	TaskStatusSuccess        TaskStatus = "success"
	TaskStatusFailed         TaskStatus = "failed"
)

func (TaskStatus) CanTransition ¶

func (ts TaskStatus) CanTransition(nextStatus TaskStatus) error

func (TaskStatus) IsFinalStatus ¶

func (ts TaskStatus) IsFinalStatus() bool

func (TaskStatus) IsWaitStatus ¶

func (ts TaskStatus) IsWaitStatus() bool

func (TaskStatus) PreWaitStatus ¶

func (ts TaskStatus) PreWaitStatus() TaskStatus

func (TaskStatus) String ¶

func (ts TaskStatus) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL