task

Documentation

Index

• type Task
  • func New() *Task
  • func (cls *Task) GetOneTimeTaskState(ctx context.Context, taskId string) (processing bool, progress int64, err errors.Error)
  • func (cls *Task) StartOneTimeTask(ctx context.Context, tag string, values map[string]any, ...) (string, errors.Error)

Types

type Task

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

func New

func New() *Task

func (*Task) GetOneTimeTaskState

func (cls *Task) GetOneTimeTaskState(ctx context.Context, taskId string) (processing bool, progress int64, err errors.Error)

func (*Task) StartOneTimeTask

func (cls *Task) StartOneTimeTask(ctx context.Context, tag string, values map[string]any, caller func(ctx context.Context, values map[string]any, progress func(int64)) errors.Error, timeout time.Duration, unique bool) (string, errors.Error)