transcoding

package

Go to main page

Versions in this module

v0

v0.11.0

Aug 17, 2026

v0.10.1

Aug 9, 2026

v0.10.0

Aug 8, 2026

v0.10.0-preview.1

Jul 28, 2026

v0.9.1

Jul 19, 2026

v0.9.0

Jul 18, 2026

v0.8.1

Jul 2, 2026

v0.8.0

Jun 30, 2026

v0.7.2

Jun 15, 2026

Changes in this version

type TranscodeOptions

+ CRF int

v0.7.1

Jun 15, 2026

v0.7.0

Jun 14, 2026

Changes in this version

type HardwareCapabilities

+ func ProbeHardwareCapabilitiesExplicit(ffmpegPath string) *HardwareCapabilities

v0.6.0

Jun 5, 2026

Changes in this version

+ type CompletionFunc func(task *storage.TranscodeTask, success bool)

type ManagerConfig

+ Config *config.Config

+ EventBus *event.EventBus

type TranscodeQueue

+ func (q *TranscodeQueue) SetCompletionFunc(fn CompletionFunc)

v0.5.0

May 30, 2026

Changes in this version

+ func BuildFFmpegCommand(opts TranscodeOptions, caps HardwareCapabilities) ([]string, error)

+ func CheckDiskSpaceForTranscode(inputPath, outputDir string, safetyFactor float64) error

+ func CheckSufficient(caps *HardwareCapabilities, requiredCodec string) (bool, string)

+ func CleanOrphanedTranscodes(ctx context.Context, dataDir string, db DBTaskLister) error

+ func GetDisabledReason() string

+ func ResetProbe()

+ func SetDisabledReason(reason string)

+ func TranscodeMJPEG(ctx context.Context, inputDir string, outputPath string, fps int, ...) error

+ func ValidateOutput(ffprobePath, outputPath string) error

+ type DBTaskLister interface

+ ListTranscodeTasks func(ctx context.Context, f storage.TranscodeTaskFilter) ([]storage.TranscodeTask, int, error)

+ type DownloadState struct

+ DownloadURL string

+ DownloadedBytes int64

+ Error string

+ LastUpdated string

+ Progress float64

+ Status string

+ TotalBytes int64

+ Version string

+ type DownloadStatus struct

+ DownloadedBytes int64

+ Error string

+ Progress float64

+ Status string

+ TotalBytes int64

+ Version string

+ type Downloader struct

+ func NewDownloader(dataDir string, onProgress func(downloaded, total int64)) *Downloader

+ func (d *Downloader) Cancel()

+ func (d *Downloader) DownloadFFmpeg(ctx context.Context) error

+ func (d *Downloader) FFmpegPath() string

+ func (d *Downloader) FFprobePath() string

+ func (d *Downloader) GetFFmpegStatus() DownloadStatus

+ func (d *Downloader) StatePath() string

+ type EncoderType string

+ const EncoderNVENC

+ const EncoderSoftware

+ const EncoderV4L2M2M

+ const EncoderVAAPI

+ type HardwareCapabilities struct

+ Arch string

+ Devices []string

+ EstimatedFPS float64

+ FFmpegAvailable bool

+ FFmpegPath string

+ H264Decoder string

+ H264DecoderType EncoderType

+ H264Encoder string

+ H264EncoderType EncoderType

+ H265Decoder string

+ H265DecoderType EncoderType

+ H265Encoder string

+ H265EncoderType EncoderType

+ MaxConcurrentStreams int

+ MaxEncodeHeight int

+ MaxEncodeWidth int

+ TotalCores int

+ TotalMemoryMB uint64

+ func ProbeHardwareCapabilities(ffmpegPath string) *HardwareCapabilities

+ type ManagerConfig struct

+ DataDir string

+ FFmpegPath string

+ FFprobePath string

+ MaxWorkers int

+ ReplaceOriginal bool

+ Transcoding config.TranscodingConfig

+ type ManagerStatus struct

+ ActiveJobs int

+ DisabledReason string

+ Enabled bool

+ Hardware *HardwareCapabilities

+ QueueLength int

+ RecentResults []TranscodeTask

+ type MediaInfo struct

+ CodecName string

+ Duration float64

+ Height int

+ Width int

+ func GetMediaInfo(ffprobePath, filePath string) (*MediaInfo, error)

+ type QueueAPI interface

+ CancelTask func(ctx context.Context, id int64) error

+ Enqueue func(ctx context.Context, task *storage.TranscodeTask) error

+ type QueueConfig struct

+ DataDir string

+ FFmpegPath string

+ FFprobePath string

+ JobTimeout time.Duration

+ MaxWorkers int

+ ReplaceOriginal bool

+ type TranscodeCleaner struct

+ func NewTranscodeCleaner(ffprobePath string) *TranscodeCleaner

+ func (c *TranscodeCleaner) RollbackFailedTranscode(outputPath string)

+ func (c *TranscodeCleaner) VerifyAndClean(ctx context.Context, inputPath string, outputPath string, inputFormat string, ...) error

+ type TranscodeEngine struct

+ func NewTranscodeEngine(ffmpegPath, ffprobePath string) *TranscodeEngine

+ func (e *TranscodeEngine) Transcode(ctx context.Context, opts TranscodeOptions, caps HardwareCapabilities, ...) error

+ type TranscodeManager struct

+ func NewTranscodeManager(store *storage.DB, cfg ManagerConfig, m *metrics.Metrics) (*TranscodeManager, error)

+ func (m *TranscodeManager) Downloader() *Downloader

+ func (m *TranscodeManager) EnqueueRecording(cameraID, recordingID, inputPath, inputFormat string, targetCodec string) error

+ func (m *TranscodeManager) GetStatus() ManagerStatus

+ func (m *TranscodeManager) HardwareInfo() *HardwareCapabilities

+ func (m *TranscodeManager) Queue() QueueAPI

+ func (m *TranscodeManager) Run(ctx context.Context)

+ func (m *TranscodeManager) Stop()

+ type TranscodeOptions struct

+ Bitrate string

+ ForceSoftware bool

+ Framerate int

+ Height int

+ InputCodec string

+ InputPath string

+ OutputCodec string

+ OutputPath string

+ Preset string

+ Width int

+ type TranscodeQueue struct

+ func NewTranscodeQueue(store *storage.DB, caps *HardwareCapabilities, dl *Downloader, cfg QueueConfig, ...) *TranscodeQueue

+ func (q *TranscodeQueue) ActiveCount() int

+ func (q *TranscodeQueue) CancelTask(ctx context.Context, id int64) error

+ func (q *TranscodeQueue) Enqueue(ctx context.Context, task *storage.TranscodeTask) error

+ func (q *TranscodeQueue) GetStatus() ManagerStatus

+ func (q *TranscodeQueue) Run(ctx context.Context) error

+ func (q *TranscodeQueue) Stop()

+ type TranscodeStatus string

+ const StatusCancelled

+ const StatusCompleted

+ const StatusFailed

+ const StatusPending

+ const StatusRunning

+ type TranscodeTask struct

+ CameraID string

+ CompletedAt *string

+ CreatedAt string

+ Error string

+ ID int64

+ InputFormat string

+ InputPath string

+ OriginalDeleted bool

+ OutputFormat string

+ OutputPath string

+ Progress float64

+ RecordingID string

+ StartedAt *string

+ Status TranscodeStatus

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL