Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

task

package

Go to main page

Versions in this module

v1

v1.0.20

Aug 22, 2024

v1.0.19

Jun 30, 2024

v1.0.18

Jun 30, 2024

v1.0.17

Jun 30, 2024

v1.0.16

Jun 30, 2024

v1.0.15

Jun 30, 2024

v1.0.14

Jun 30, 2024

v1.0.13

Jun 30, 2024

v1.0.12

Jun 30, 2024

v1.0.10

Jun 30, 2024

v1.0.9

Jun 30, 2024

v1.0.8

Jun 30, 2024

v1.0.7

Jun 30, 2024

Changes in this version

+ type Factory interface

+ AddCron func(id uint32, spec string) error

+ CancelExec func(ctx kratosx.Context, uuid string) error

+ DrySpec func(s string) bool

+ RemoveCron func(id uint32) error

+ Scheduler func(id uint32, force bool) error

+ UpdateCron func(id uint32, spec string) error

+ type GetTaskGroupRequest struct

+ Id *uint32

+ type GetTaskRequest struct

+ Id *uint32

+ type ListTaskGroupRequest struct

+ Name *string

+ Order *string

+ OrderBy *string

+ Page uint32

+ PageSize uint32

+ type ListTaskRequest struct

+ GroupId *uint32

+ Name *string

+ Order *string

+ OrderBy *string

+ Page uint32

+ PageSize uint32

+ Status *bool

+ Tag *string

+ type Repo interface

+ CreateTask func(ctx kratosx.Context, req *Task) (uint32, error)

+ CreateTaskGroup func(ctx kratosx.Context, req *TaskGroup) (uint32, error)

+ DeleteTask func(ctx kratosx.Context, id uint32) error

+ DeleteTaskGroup func(ctx kratosx.Context, id uint32) error

+ GetSpecs func(ctx kratosx.Context) map[uint32]string

+ GetTask func(ctx kratosx.Context, id uint32) (*Task, error)

+ GetTaskGroup func(ctx kratosx.Context, id uint32) (*TaskGroup, error)

+ ListTask func(ctx kratosx.Context, req *ListTaskRequest) ([]*Task, uint32, error)

+ ListTaskGroup func(ctx kratosx.Context, req *ListTaskGroupRequest) ([]*TaskGroup, uint32, error)

+ UpdateTask func(ctx kratosx.Context, req *Task) error

+ UpdateTaskGroup func(ctx kratosx.Context, req *TaskGroup) error

+ UpdateTaskStatus func(ctx kratosx.Context, id uint32, status bool) error

+ type Task struct

+ CreatedAt int64

+ Description *string

+ ExecType string

+ ExecValue string

+ ExpectCode uint32

+ Group *TaskGroup

+ GroupId uint32

+ Id uint32

+ MaxExecTime uint32

+ Name string

+ RetryCount uint32

+ RetryWaitTime uint32

+ Spec string

+ Status *bool

+ Tag string

+ UpdatedAt int64

+ Version string

+ Worker *Worker

+ WorkerGroup *WorkerGroup

+ WorkerGroupId *uint32

+ WorkerId *uint32

+ WorkerType string

+ type TaskGroup struct

+ CreatedAt int64

+ Description *string

+ Id uint32

+ Name string

+ UpdatedAt int64

+ type UseCase struct

+ func NewUseCase(config *conf.Config, repo Repo, factory Factory) *UseCase

+ func (u *UseCase) CancelExecTask(ctx kratosx.Context, uuid string) error

+ func (u *UseCase) CreateTask(ctx kratosx.Context, req *Task) (uint32, error)

+ func (u *UseCase) CreateTaskGroup(ctx kratosx.Context, req *TaskGroup) (uint32, error)

+ func (u *UseCase) DeleteTask(ctx kratosx.Context, id uint32) error

+ func (u *UseCase) DeleteTaskGroup(ctx kratosx.Context, id uint32) error

+ func (u *UseCase) ExecTask(ctx kratosx.Context, id uint32) error

+ func (u *UseCase) GetTask(ctx kratosx.Context, req *GetTaskRequest) (*Task, error)

+ func (u *UseCase) GetTaskGroup(ctx kratosx.Context, req *GetTaskGroupRequest) (*TaskGroup, error)

+ func (u *UseCase) ListTask(ctx kratosx.Context, req *ListTaskRequest) ([]*Task, uint32, error)

+ func (u *UseCase) ListTaskGroup(ctx kratosx.Context, req *ListTaskGroupRequest) ([]*TaskGroup, uint32, error)

+ func (u *UseCase) UpdateTask(ctx kratosx.Context, req *Task) error

+ func (u *UseCase) UpdateTaskGroup(ctx kratosx.Context, req *TaskGroup) error

+ func (u *UseCase) UpdateTaskStatus(ctx kratosx.Context, id uint32, status bool) error

+ type Worker struct

+ Name string

+ type WorkerGroup struct

+ Name string