worker

Documentation

Index

• type Worker
  • func New(s domain.Store, p domain.Parser) *Worker
  • func (w *Worker) Process(ctx context.Context, packageID string) error

Types

type Worker

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

Worker is responsible for processing incoming data.

func New

func New(s domain.Store, p domain.Parser) *Worker

New returns new instance of worker.

func (*Worker) Process

func (w *Worker) Process(ctx context.Context, packageID string) error

Process dispatches event as to a handler.