encoder

Documentation

Index

• func ProgressToProto(progress models.Progress) (*proto.JobStatus, error)
• type DefaultEncodeJob
  • func (d *DefaultEncodeJob) Cancel()
  • func (d *DefaultEncodeJob) GetStatus() <-chan *proto.JobStatus
  • func (d *DefaultEncodeJob) SetBitrate(bitrate string) EncodeJob
  • func (d *DefaultEncodeJob) SetCodec(codec string) EncodeJob
  • func (d *DefaultEncodeJob) SetDestPath(path string) EncodeJob
  • func (d *DefaultEncodeJob) SetSourcePath(path string) EncodeJob
  • func (d *DefaultEncodeJob) Start()
  • func (d *DefaultEncodeJob) Wait()
• type EncodeJob
  • func NewEncodeJob(logger *zap.Logger, cfg aws.Config, tempPath string) EncodeJob

Functions

func ProgressToProto

func ProgressToProto(progress models.Progress) (*proto.JobStatus, error)

Types

type DefaultEncodeJob

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

func (*DefaultEncodeJob) Cancel

func (d *DefaultEncodeJob) Cancel()

func (*DefaultEncodeJob) GetStatus

func (d *DefaultEncodeJob) GetStatus() <-chan *proto.JobStatus

func (*DefaultEncodeJob) SetBitrate

func (d *DefaultEncodeJob) SetBitrate(bitrate string) EncodeJob

func (*DefaultEncodeJob) SetCodec

func (d *DefaultEncodeJob) SetCodec(codec string) EncodeJob

func (*DefaultEncodeJob) SetDestPath

func (d *DefaultEncodeJob) SetDestPath(path string) EncodeJob

func (*DefaultEncodeJob) SetSourcePath

func (d *DefaultEncodeJob) SetSourcePath(path string) EncodeJob

func (*DefaultEncodeJob) Start

func (d *DefaultEncodeJob) Start()

func (*DefaultEncodeJob) Wait

func (d *DefaultEncodeJob) Wait()

type EncodeJob

type EncodeJob interface {
	SetSourcePath(path string) EncodeJob
	SetDestPath(path string) EncodeJob
	SetCodec(codec string) EncodeJob
	SetBitrate(bitrate string) EncodeJob

	GetStatus() <-chan *proto.JobStatus
	Start()
	Wait()
	Cancel()
}

func NewEncodeJob

func NewEncodeJob(logger *zap.Logger, cfg aws.Config, tempPath string) EncodeJob