worker

package

v0.1.0-rc1 Latest Latest Go to latest Published: Aug 26, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrServerStarted = errors.New("already started")
	ErrServerStopped = errors.New("already stopped")
)

This section is empty.

type Worker struct {
	DB *db.DB
	// contains filtered or unexported fields
}

func NewWorker(ctx context.Context, cfg config.WorkerConfig, db *db.DB, queue queue.TaskQueue) *Worker

func (w *Worker) Start() error

Start starts worker

func (w *Worker) Stop() error

Stop stops worker

Path	Synopsis
deliverer
retry