worker

package

v0.2.0 Latest Latest Go to latest Published: Nov 21, 2022 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var (
	Count = runtime.NumCPU()
)

func GitContent(_ int, err error) string

func GitHeader(idx int, err error) string

func HandleErrors(errs []error, h *ErrorHandler) error

type Action[T any] func(name string, val *T) error

type ErrorHandler struct {
	Name string

	LogPath string

	Header  func(idx int, err error) string
	Content func(idx int, err error) string
}

type Task[T any] struct {
	Name   string
	Action Action[T]
	Value  *T
}

type Worker[T any] struct {
	// contains filtered or unexported fields
}

func New[T any](verb string, tasks []*Task[T]) *Worker[T]

func (w *Worker[T]) Run(action Action[T]) []error