types

package

Go to main page

Versions in this module

v1

v1.0.0

Jan 11, 2023

v0

v0.2.7

Aug 7, 2024

v0.2.6

Aug 2, 2024

v0.2.5

Apr 10, 2024

v0.2.4

Jan 30, 2024

Changes in this version

+ var PendingTaskExpiredTime = time.Hour * 24 * 7

v0.2.3

Dec 2, 2023

v0.2.2

Dec 2, 2023

v0.2.1

Nov 27, 2023

v0.1.9

Jul 2, 2023

v0.1.8

Jul 1, 2023

v0.1.7

Jun 21, 2023

v0.1.6

Apr 24, 2023

Changes in this version

type DB

+ FindPendingTasks func(ctx context.Context, opt FindPendingTasksOption) (entity.Tasks, error)

+ type FindPendingTasksOption struct

+ MinUid *string

+ Status []enum.TaskStatus

+ TenantId *string

type GetTaskOption

+ TenantId string

type GetTaskStatusOption

+ TenantId string

type TaskHandler

+ MigrateError func() (*TaskContext, *TaskStatus, error)

+ PrepareMigration func() (*TaskContext, *TaskStatus, error)

+ StartMigratedTask func(finishC chan struct{}) (bool, error)

type TaskMetadata

+ func NewTaskMetadataFromTaskEntity(t *entity.Task) TaskMetadata

type UpdateTaskStatusOption

+ TenantId string

v0.1.5

Mar 13, 2023

v0.1.4

Mar 1, 2023

v0.1.3

Feb 1, 2023

v0.1.2

Feb 1, 2023

v0.1.1

Jan 12, 2023

Changes in this version

+ const LevelKey

+ type ActivateTenantsOption struct

+ ActiveTime time.Time

+ TenantId []string

+ type CountTenantPendingTasksOption struct

+ From time.Time

+ TenantId string

+ To time.Time

+ type DB interface

+ ActivateTenants func(ctx context.Context, opt ActivateTenantsOption) error

+ Close func() error

+ CountTenantPendingTasks func(ctx context.Context, opt CountTenantPendingTasksOption) (int64, error)

+ CreateTask func(ctx context.Context, t entity.UserTask) error

+ CreateTenant func(ctx context.Context, t entity.Tenant) error

+ FindActiveTenants func(ctx context.Context, opt FindActiveTenantsOption) (entity.Tenants, error)

+ FindRecentTasks func(ctx context.Context, opt FindRecentTasksOption) (entity.Tasks, error)

+ GetTask func(ctx context.Context, opt GetTaskOption) (entity.Tasks, error)

+ GetTaskStatus func(ctx context.Context, opt GetTaskStatusOption) (enum.TaskStatus, error)

+ GetTenant func(ctx context.Context, opt GetTenantOption) (*entity.Tenant, error)

+ UpdateTaskStatus func(ctx context.Context, opt UpdateTaskStatusOption) error

+ type FindActiveTenantsOption struct

+ From *time.Time

+ Partition *string

+ Zone *string

+ type FindRecentTasksOption struct

+ MinUserTaskId *string

+ Status []enum.TaskStatus

+ TaskType enum.TaskType

+ TenantId *string

+ type GetTaskOption struct

+ TaskType enum.TaskType

+ Uid string

+ type GetTaskStatusOption struct

+ TaskType enum.TaskType

+ Uid string

+ type GetTenantOption struct

+ TenantId string

+ type Level int8

+ const LevelDebug

+ const LevelError

+ const LevelFatal

+ const LevelInfo

+ const LevelTrace

+ const LevelWarn

+ func ParseLevel(s string) Level

+ func (l Level) String() string

+ type Listener interface

+ OnTaskCreated func(e ListenerEvent)

+ OnTaskDispatching func(e ListenerEvent)

+ OnTaskFailed func(e ListenerEvent)

+ OnTaskFinished func(e ListenerEvent)

+ OnTaskNeedsRetry func(e ListenerEvent)

+ OnTaskRunning func(e ListenerEvent)

+ OnTaskScheduling func(e ListenerEvent)

+ OnTaskTransition func(e ListenerEvent)

+ OnTaskTransitionError func(e ListenerEvent)

+ OnTaskTransitionFinished func(e ListenerEvent)

+ type ListenerEvent struct

+ SchedulerId string

+ Task TaskMetadata

+ WorkerId string

+ type Logger interface

+ Log func(level Level, keyvals ...interface{})

+ type OnMessageReceived func(from, to string, msg []byte) (result []byte, err error)

+ type ResourceUsage struct

+ CPU int64

+ Concurrency int64

+ Custom int64

+ GPU int64

+ Memory int64

+ Storage int64

+ Time time.Time

+ func (u *ResourceUsage) GetByType(typ string) int64

+ type Task struct

+ Config json.RawMessage

+ Handler string

+ InTransition bool

+ LastRun *TaskRun

+ RestartTimes int

+ SchedulerId string

+ TenantId string

+ Type enum.TaskType

+ Uid string

+ type TaskContext struct

+ Task Task

+ Worker *WorkerInfo

+ func (c *TaskContext) MarkDone(status enum.TaskRunStatus, res string, err error)

+ func (c *TaskContext) MarkProgress(v int)

+ func (c *TaskContext) MarkRunning()

+ func (c *TaskContext) NewMessage(typ enum.TaskMessageType, val interface{}) *TaskMessage

+ type TaskHandler interface

+ BeforeTransitionStart func() (*TaskContext, *TaskStatus, error)

+ HeartBeat func() (*TaskContext, *TaskStatus, error)

+ Start func() (bool, error)

+ StartTransitionTask func(finishSig chan struct{}) (bool, error)

+ Stop func() error

+ TransitionError func() (*TaskContext, *TaskStatus, error)

+ type TaskHandlerFactory func(ctx *TaskContext, info *WorkerInfo) (TaskHandler, error)

+ type TaskMessage struct

+ SchedulerId string

+ Task Task

+ Timestamp time.Time

+ Type enum.TaskMessageType

+ Value json.RawMessage

+ WorkerId string

+ type TaskMetadata struct

+ Handler string

+ TenantId string

+ Type enum.TaskType

+ Uid string

+ func NewTaskMetadataFromTaskMessage(msg *TaskMessage) TaskMetadata

+ func NewTaskMetadataFromUserTaskEntity(t *entity.UserTask) TaskMetadata

+ type TaskResourceUsage struct

+ Current ResourceUsage

+ History []ResourceUsage

+ TaskId int64

+ TaskType int

+ TenantId int64

+ type TaskRun struct

+ End time.Time

+ Error string

+ Progress *int

+ Result string

+ Start time.Time

+ Status enum.TaskRunStatus

+ type TaskStatus struct

+ Error error

+ Progress int

+ ResourceUsage struct{ ... }

+ State enum.TaskStatus

+ Timestamp time.Time

+ type TenantResourceUsage struct

+ Active map[int64]*TaskResourceUsage

+ History []*TaskResourceUsage

+ Stale []*TaskResourceUsage

+ type TenantResourceUsages map[int64]*TenantResourceUsage

+ type Transport interface

+ CloseReceive func() error

+ CloseSend func() error

+ OnReceive func(fn OnMessageReceived)

+ Send func(from, to string, msg []byte) error

+ Start func() error

+ type UpdateTaskStatusOption struct

+ Status enum.TaskStatus

+ TaskType enum.TaskType

+ Uids []string

+ type WorkerInfo struct

+ Generation int64

+ Id string

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