background

Documentation

Index

• type ArchiveBackroundJob
  • func NewArchiveBackroundJob(workerPool *worker.ArchiveWorkerPool, duration time.Duration) *ArchiveBackroundJob
  • func (bgJob *ArchiveBackroundJob) Start(ctx context.Context)
  • func (bgJob *ArchiveBackroundJob) Stop() error

Types

type ArchiveBackroundJob

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

ArchiveBackroundJob inits archivation process with given ticker duration

func NewArchiveBackroundJob

func NewArchiveBackroundJob(workerPool *worker.ArchiveWorkerPool, duration time.Duration) *ArchiveBackroundJob

NewArchiveBackroundJob constructs new ArchiveBackroundJob

func (*ArchiveBackroundJob) Start

func (bgJob *ArchiveBackroundJob) Start(ctx context.Context)

Start starts ticker checking in another goroutine

func (*ArchiveBackroundJob) Stop

func (bgJob *ArchiveBackroundJob) Stop() error

Stop stops ticker by context cancelling