worker

Documentation

Index

• type ArchiveWorkerPool
  • func NewArchiveWorkerPool(service *service.Service, workerCount int) *ArchiveWorkerPool
  • func (w *ArchiveWorkerPool) Send()
  • func (w *ArchiveWorkerPool) Start(ctx context.Context)
  • func (w *ArchiveWorkerPool) Stop() error

Types

type ArchiveWorkerPool

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

ArchiveWorkerPool handles workers that processes tasks archivation

func NewArchiveWorkerPool

func NewArchiveWorkerPool(service *service.Service, workerCount int) *ArchiveWorkerPool

NewArchiveWorkerPool creates new ArchiveWorkerPool

func (*ArchiveWorkerPool) Send

func (w *ArchiveWorkerPool) Send()

Send is an interface for starting up archivation

func (*ArchiveWorkerPool) Start

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

Start inits and starts up processor goroutines with error group

func (*ArchiveWorkerPool) Stop

func (w *ArchiveWorkerPool) Stop() error

Stop stops all goroutines gracefully