tasks

Documentation

Index

• Constants
• func NewTranscodingTask(req TranscodingRequest) (*asynq.Task, error)
• func WithLogger(logger logging.KVLogger) func(options *EncoderRunnerOptions)
• func WithName(name string) func(options *EncoderRunnerOptions)
• func WithOutputDir(dir string) func(options *EncoderRunnerOptions)
• func WithStreamsDir(dir string) func(options *EncoderRunnerOptions)
• type EncoderRunner
  • func NewEncoderRunner(storage *storage.S3Driver, encoder encoder.Encoder, resultWriter ResultWriter, ...) (*EncoderRunner, error)
  • func (r *EncoderRunner) Cleanup()
  • func (r *EncoderRunner) RetryDelay(n int, e error, t *asynq.Task) time.Duration
  • func (r *EncoderRunner) Run(ctx context.Context, t *asynq.Task) error
• type EncoderRunnerOptions
• type RedisResultWriter
  • func NewResultWriter(redisOpts asynq.RedisConnOpt) *RedisResultWriter
  • func (w *RedisResultWriter) Write(data []byte) (int, error)
• type ResultWriter
• type TranscodingRequest
  • func (m *TranscodingRequest) FromString(s string) error
  • func (m TranscodingRequest) String() string
• type TranscodingResult
  • func (m *TranscodingResult) FromString(s string) error
  • func (m TranscodingResult) String() string

Constants

const (
	TypeTranscodingRequest = "transcoder:transcode"

	StageAccepted     = "accepted"
	StageDownloading  = "downloading"
	StageEncoding     = "encoding"
	StageUploading    = "uploading"
	StageMetadataFill = "metadata_fill"

	QueueTranscodingResults = "transcoding:results"
)

Functions

func NewTranscodingTask

func NewTranscodingTask(req TranscodingRequest) (*asynq.Task, error)

func WithLogger

func WithLogger(logger logging.KVLogger) func(options *EncoderRunnerOptions)

func WithName

func WithName(name string) func(options *EncoderRunnerOptions)

WithName sets worker name (defaults to os.Hostname).

func WithOutputDir

func WithOutputDir(dir string) func(options *EncoderRunnerOptions)

func WithStreamsDir

func WithStreamsDir(dir string) func(options *EncoderRunnerOptions)

Types

type EncoderRunner

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

func NewEncoderRunner

func NewEncoderRunner(
	storage *storage.S3Driver, encoder encoder.Encoder, resultWriter ResultWriter, optionFuncs ...func(*EncoderRunnerOptions),
) (*EncoderRunner, error)

func (*EncoderRunner) Cleanup

func (r *EncoderRunner) Cleanup()

func (*EncoderRunner) RetryDelay

func (r *EncoderRunner) RetryDelay(n int, e error, t *asynq.Task) time.Duration

func (*EncoderRunner) Run

func (r *EncoderRunner) Run(ctx context.Context, t *asynq.Task) error

type EncoderRunnerOptions

type EncoderRunnerOptions struct {
	StreamsDir, OutputDir string
	Name                  string
	Logger                logging.KVLogger
}

type RedisResultWriter

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

func NewResultWriter

func NewResultWriter(redisOpts asynq.RedisConnOpt) *RedisResultWriter

func (*RedisResultWriter) Write

func (w *RedisResultWriter) Write(data []byte) (int, error)

type ResultWriter

type ResultWriter interface {
	io.Writer
}

type TranscodingRequest

type TranscodingRequest struct {
	URL    string `json:"url"`
	SDHash string `json:"sd_hash"`
}

func (*TranscodingRequest) FromString

func (m *TranscodingRequest) FromString(s string) error

func (TranscodingRequest) String

func (m TranscodingRequest) String() string

type TranscodingResult

type TranscodingResult struct {
	Stream *library.Stream `json:"stream"`
}

func (*TranscodingResult) FromString

func (m *TranscodingResult) FromString(s string) error

func (TranscodingResult) String

func (m TranscodingResult) String() string