worker

package

v2.2.3 Latest Latest Go to latest Published: Apr 22, 2025 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

BaseWorker runs a workload in a cancellable goroutine.

func NewBaseWorker(name string, logger Logger, workload Workload) *BaseWorker

NewBaseWorker creates a new worker with custom logger and workload.

func (w *BaseWorker) Name() string

func (w *BaseWorker) Start(ctx context.Context)

func (w *BaseWorker) Stop()

type Logger interface {
	Info(format string, a ...any)
	Error(format string, a ...any)
}

Logger defines an interface for logging.

type StdLogger struct{}

StdLogger is a default implementation using Go's log package.

func (l StdLogger) Error(format string, a ...any)

Error logs an error message using formatting.

func (l StdLogger) Info(format string, a ...any)

Info logs an informational message using formatting.

type Worker interface {
	Start(ctx context.Context)
	Stop()
	Name() string
}

Worker defines the worker interface.

type Workload func(ctx context.Context, log Logger)

Workload defines the task a worker should perform.