download

Documentation

Index

• type Dispatcher
  • func NewDispatcher(worker Worker, maxWorkers int, queueSize int) *Dispatcher
  • func (d *Dispatcher) AddJob(job *Job)
  • func (d *Dispatcher) AddJobs(jobs []*Job)
  • func (d *Dispatcher) Start(ctx context.Context)
  • func (d *Dispatcher) Wait()
• type Job
• type JobManager
  • func NewJobManager(logger logging.Logger, conf *config.Configuration, drive *gdrive.DriveService) (*JobManager, error)
  • func (jm *JobManager) CreateJob(driveId string) error
  • func (jm *JobManager) FinishJob(job *Job) error
  • func (jm *JobManager) Run() error
  • func (jm *JobManager) RunJob(job *Job)
• type Worker

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(worker Worker, maxWorkers int, queueSize int) *Dispatcher

func (*Dispatcher) AddJob

func (d *Dispatcher) AddJob(job *Job)

func (*Dispatcher) AddJobs

func (d *Dispatcher) AddJobs(jobs []*Job)

func (*Dispatcher) Start

func (d *Dispatcher) Start(ctx context.Context)

func (*Dispatcher) Wait

func (d *Dispatcher) Wait()

type Job

type Job struct {
	Path string
	*drive.File
}

type JobManager

type JobManager struct {
	CompletedDirectoryPath  string
	IncompleteDirectoryPath string
	// contains filtered or unexported fields
}

func NewJobManager

func NewJobManager(logger logging.Logger, conf *config.Configuration, drive *gdrive.DriveService) (*JobManager, error)

func (*JobManager) CreateJob

func (jm *JobManager) CreateJob(driveId string) error

func (*JobManager) FinishJob

func (jm *JobManager) FinishJob(job *Job) error

func (*JobManager) Run

func (jm *JobManager) Run() error

func (*JobManager) RunJob

func (jm *JobManager) RunJob(job *Job)

type Worker

type Worker interface {
	RunJob(job *Job)
}