worker

package

v0.5.0 Latest Latest Go to latest Published: Dec 13, 2022 License: MIT Imports: 19 Imported by: 0

Details

This section is empty.

View Source

var Count = runtime.NumCPU()

This section is empty.

type Action[T any] func(task *Task[T]) error

type Bytes struct {
	Tracker Tracker[BytesTask]

	Tasks []*Task[BytesTask]

	LogPath string
}

func (b *Bytes) Download(dir string) error

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

func (t *BytesBarTracker) Add(task *Task[BytesTask])

func (t *BytesBarTracker) Render(_ int) func()

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

func (bt *BytesTask) Read(p []byte) (int, error)

func (bt *BytesTask) Write(data []byte) (int, error)

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

func (t *BytesTracker) Add(task *Task[BytesTask])

func (t *BytesTracker) Render(_ int) func()

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

	Action Action[T]
	// contains filtered or unexported fields
}

func DownloadTask(name string, reader io.ReadCloser, total uint64) *Task[BytesTask]

type Tracker[T any] interface {
	Render(total int) func()

	Add(task *Task[T])
}

func NewBytesBarTracker(tasks []*Task[BytesTask]) Tracker[BytesTask]

func NewBytesTracker(tasks []*Task[BytesTask]) Tracker[BytesTask]

func NewJobTracker[T any](verb string) Tracker[T]

type Worker[T any] struct {
	Name string

	Tasks   []*Task[T]
	Tracker Tracker[T]

	LogPath string
}

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