entity

Documentation

Index

• type CronTask
• type CronTasks
• type DelayTask
• type DelayTasks
• type ResourceQuota
  • func NewResourceQuota(tid, typ string, val int64) ResourceQuota
  • func (q *ResourceQuota) Fields() []interface{}
• type TaskRun
• type TaskRunLog
• type TaskRunLogs
• type TaskRuns
• type Tasks
• type Tenant
  • func (t *Tenant) Fields() []interface{}
  • func (t *Tenant) FieldsWithQuota() []interface{}
• type Tenants
• type UserTask
  • func (t *UserTask) Fields() []interface{}
• type UserTasks
  • func (ut UserTasks) TaskIds() []string

Types

type CronTask

type CronTask struct {
	Uid              string
	TenantId         string
	Handler          string
	Name             string
	Description      string
	Cron             string
	Config           interface{}
	ScheduleStrategy string
	Priority         int32
	CreatedAt        time.Time
	UpdatedAt        time.Time
	NextTick         time.Time
	Status           enum.TaskStatus
}

CronTask defines the cron task

type CronTasks

type CronTasks []*CronTask

CronTasks is an array of CronTask

type DelayTask

type DelayTask struct {
	Uid              string
	TenantId         string
	Handler          string
	Config           interface{}
	ScheduleStrategy string
	Priority         int32
	CreatedAt        time.Time
	UpdatedAt        time.Time
	TimeToRun        time.Time
	Status           enum.TaskStatus
}

DelayTask defines the delay task

type DelayTasks

type DelayTasks []*DelayTask

DelayTasks is an array of DelayTask

type ResourceQuota

type ResourceQuota struct {
	Id          string
	TenantId    string
	Type        string
	CPU         sql.NullInt64
	Memory      sql.NullInt64
	Storage     sql.NullInt64
	GPU         sql.NullInt64
	Concurrency sql.NullInt64
	Custom      sql.NullInt64
	Peak        sql.NullFloat64
}

func NewResourceQuota

func NewResourceQuota(tid, typ string, val int64) ResourceQuota

func (*ResourceQuota) Fields

func (q *ResourceQuota) Fields() []interface{}

type TaskRun

type TaskRun struct {
	Id           string
	TenantId     string
	TaskId       string
	TaskType     string
	ScheduleType string
	Status       string
	Result       *string
	Error        *string
	Start        *time.Time
	End          *time.Time
}

type TaskRunLog

type TaskRunLog struct {
	Id  int64
	Log string
}

type TaskRunLogs

type TaskRunLogs []*TaskRunLog

type TaskRuns

type TaskRuns []*TaskRun

TaskRuns is an array of TaskRun

type Tasks

type Tasks struct {
	CronTasks  CronTasks
	UserTasks  UserTasks
	DelayTasks DelayTasks
}

type Tenant

type Tenant struct {
	Uid        string
	Zone       string
	Partition  string
	Priority   int32
	Name       string
	Status     string
	CreatedAt  time.Time
	UpdatedAt  time.Time
	LastActive time.Time

	ResourceQuota ResourceQuota
}

Tenant defines the tenant

func (*Tenant) Fields

func (t *Tenant) Fields() []interface{}

func (*Tenant) FieldsWithQuota

func (t *Tenant) FieldsWithQuota() []interface{}

type Tenants

type Tenants []*Tenant

Tenants is an array of Tenant

type UserTask

type UserTask struct {
	Uid              string
	TenantId         string
	Handler          string
	Config           interface{}
	ScheduleStrategy string
	Priority         int32
	Progress         int32
	CreatedAt        time.Time
	UpdatedAt        time.Time
	Status           enum.TaskStatus
}

UserTask defines the user task

func (*UserTask) Fields

func (t *UserTask) Fields() []interface{}

type UserTasks

type UserTasks []*UserTask

UserTasks is an array of UserTask

func (UserTasks) TaskIds

func (ut UserTasks) TaskIds() []string

TaskIds returns task ids