ingestaudio

Documentation

Index

• func NewWorkerPool(num int, ingestTimeout time.Duration, doIt func(job *JobStruct) error, ...) (chan *JobStruct, io.Closer)
• type IngesterAudio
  • func NewIngester(dbClient mediaserverproto.DatabaseClient, vfs fs.FS, concurrentWorkers int, ...) (*IngesterAudio, error)
  • func (i *IngesterAudio) Close() error
  • func (i *IngesterAudio) Start() error
• type JobStruct
• type WriterNopcloser
  • func (WriterNopcloser) Close() error

Functions

func NewWorkerPool

func NewWorkerPool(num int, ingestTimeout time.Duration, doIt func(job *JobStruct) error, logger zLogger.ZLogger) (chan *JobStruct, io.Closer)

Types

type IngesterAudio

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

func NewIngester

func NewIngester(dbClient mediaserverproto.DatabaseClient, vfs fs.FS, concurrentWorkers int, ingestTimeout, ingestWait time.Duration, ffmpegPath, tempDir string, ffmpegOutputCodec map[string][]string, logger zLogger.ZLogger) (*IngesterAudio, error)

func (*IngesterAudio) Close

func (i *IngesterAudio) Close() error

func (*IngesterAudio) Start

func (i *IngesterAudio) Start() error

type JobStruct

type JobStruct struct {
	Width    int64
	Height   int64
	Duration int64
	Size     int64
	MimeType string
	Path     string
	Storage  *storageStruct
	Missing  []string
	// contains filtered or unexported fields
}

type WriterNopcloser

type WriterNopcloser struct {
	io.Writer
}

func (WriterNopcloser) Close

func (WriterNopcloser) Close() error