Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.