worker

Documentation

Index

• type OnStepHook
• type Worker
  • func New(input <-chan tasks.ReadFile) Worker
  • func (w *Worker) MainLoop(cx context.Context) error

Types

type OnStepHook

type OnStepHook func(file os.FileInfo, readBytes int, take time.Duration)

type Worker

type Worker struct {
	OnStep      OnStepHook
	RateLimiter *rate.Limiter
	// contains filtered or unexported fields
}

Worker is the handler for reading tasks. It shall be !Send.

func New

func New(input <-chan tasks.ReadFile) Worker

func (*Worker) MainLoop

func (w *Worker) MainLoop(cx context.Context) error