worker

Documentation

Index

• type Worker
  • func NewGCPWorker(u upload.FileUploader, t transcribe.Transcriber, m money.Broker, p pick.Picker, ...) *Worker
  • func (w *Worker) MaybeSchedule(ctx context.Context) (bool, error)
  • func (w *Worker) Run(ctx context.Context) error

Types

type Worker

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

Worker does the actual job of checking the balance, scheduling tasks, downloading audio files, transcribing them, etc.

func NewGCPWorker

func NewGCPWorker(u upload.FileUploader, t transcribe.Transcriber, m money.Broker, p pick.Picker, i indexer.Indexer, soxPath string, h health.Checker) *Worker

NewGCPWorker creates a new worker that does its work using Google Cloud Platform.

func (*Worker) MaybeSchedule

func (w *Worker) MaybeSchedule(ctx context.Context) (bool, error)

MaybeSchedule checks the current balance and schedule new audio tracks to be transcribed. Simple greedy algorithm, should use dynamic programming if I want to optimize for the number of courses converted vs pure length. Returns whether new tasks were scheduled.

func (*Worker) Run

func (w *Worker) Run(ctx context.Context) error

Run checks for scheduled tasks and handle all of them if any.