task

Documentation

Index

• Variables
• type Task
  • func NewTask(payload []byte) Task
  • func (t *Task) Execute(workerId int) (*outcome.Outcome, error)
  • func (t *Task) LogFields() []any
• type TaskPool
  • func NewTaskPool(ctx context.Context, cfg *config.Pool, dest destination.Destination, ...) *TaskPool
  • func (tp *TaskPool) LogFields() []any
  • func (tp *TaskPool) Start(ctx context.Context)
  • func (tp *TaskPool) Submit(t any)
  • func (tp *TaskPool) Wait()

Variables

var (
	ErrNoDERs = errors.New("received empty DER array")
)

Types

type Task

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

func NewTask

func NewTask(payload []byte) Task

func (*Task) Execute

func (t *Task) Execute(workerId int) (*outcome.Outcome, error)

func (*Task) LogFields

func (t *Task) LogFields() []any

type TaskPool

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

func NewTaskPool

func NewTaskPool(
	ctx context.Context,
	cfg *config.Pool,
	dest destination.Destination,
	log *slog.Logger,
) *TaskPool

func (*TaskPool) LogFields

func (tp *TaskPool) LogFields() []any

func (*TaskPool) Start

func (tp *TaskPool) Start(ctx context.Context)

func (*TaskPool) Submit

func (tp *TaskPool) Submit(t any)

func (*TaskPool) Wait

func (tp *TaskPool) Wait()