task

package

v0.9.4 Latest Latest Go to latest Published: Apr 7, 2025 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

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

func NewTask(payload []byte) Task

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

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

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

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

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

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

func (tp *TaskPool) Submit(t any)

func (tp *TaskPool) Wait()