transcode

Nov 3, 2026

Changes in this version

+ func GPUVendor(device string) string

Nov 1, 2026

Changes in this version

+ var ErrEncoderCapacity = errors.New("transcode: encoder retirement capacity exhausted")

+ func H264HighLevel(width, height int, fps float64, peakKbps, dpbFrames int) int

+ func H264HighLevelLimits(level int) (int, int, bool)

+ func HasQuirk(product, platform, device, model, version, name string) bool

+ func LookPath() string

+ func OutputGeometry(width, height, maxHeight int) (int, int)

+ func PolicyStamp(product, platform, device, model, version string, ...) (dv []int, subs []string, dvChanged, subsChanged bool)

+ func ProfileVideoKbps(height int) int

+ func WithSubtitleSource(ctx context.Context, source string) context.Context

+ type Capability struct

+ Colour []string

+ FiltersProbed bool

+ Notice string

+ PlaybackError string

+ ToneMap []string

type ClientPolicy

+ func ResolvePolicy(c core.ClientCaps, overrides []core.ClientCapabilityOverride) ClientPolicy

+ type GraphError struct

+ Message string

+ func (e *GraphError) Error() string

type Manager

+ func (m *Manager) Capability() Capability

+ func (m *Manager) StartHLSOwned(ctx context.Context, req core.HLSRequest) (core.HLSSession, core.EncoderRetirement, error)

type Option

+ func WithTracePlayback(on bool) Option

+ type PlaybackDefaults struct

+ Audio []string

+ Containers []string

+ DolbyVision bool

+ HDR10 bool

+ HeightLocked bool

+ ID string

+ MaxHeight int

+ Video []string

+ func PlaybackDefaultsFor(product, platform, device, model, version string, ...) PlaybackDefaults

type Session

+ func (s *Session) EncoderRetirement() core.EncoderRetirement

+ func (s *Session) IndependentSegments() bool

+ func (s *Session) RetireEncoder() error

type Thumbnails

+ func (t *Thumbnails) PreviewInterval() time.Duration

+ func (t *Thumbnails) PreviewWidth() int

Oct 30, 2026

Changes in this version

type Option

+ func WithEncoderObserver(f func(sessionID string, started bool, excerpt string)) Option

Oct 28, 2026

Changes in this version

type Option

+ func WithAudioMatchBudget(d time.Duration) Option

Oct 26, 2026

Changes in this version

type Option

+ func WithRuntimeDir(dir string) Option

Oct 25, 2026

Changes in this version

type Session

+ func (s *Session) PlaybackState(state string)

+ func (s *Session) PrepareSwap(ctx context.Context, input string, info core.MediaInfo, at time.Duration) error

Oct 22, 2026

Changes in this version

type Session

+ func (s *Session) RecoveryBuffer() core.RecoveryBuffer

+ func (s *Session) SwapInputBuffered(ctx context.Context, inputURL string, info core.MediaInfo, at time.Duration) error

Oct 22, 2026

Changes in this version

+ type RTXRunner interface

+ StartRTX func(Command) (Process, error)

Oct 21, 2026

Changes in this version

+ var ErrIncompatibleSwap = errors.New("transcode: replacement cannot match the delivered video")

+ var ErrProbeIncomplete = errors.New("transcode: native probe incomplete")

+ func ProbeSource(ctx context.Context, src io.ReaderAt, size int64) (*core.MediaInfo, error)

+ func ProbeTrailer(ctx context.Context, src io.ReaderAt, size int64, m *core.MediaInfo) bool

type ExecRunner — darwin/amd64, js/wasm, linux/amd64

+ func (ExecRunner) StartRTX(Command) (Process, error)

type ExecRunner — windows/amd64

+ func (ExecRunner) StartRTX(c Command) (Process, error)

type Manager

+ func (m *Manager) EnhancementStatus() core.VideoEnhancementSupport

type Option

+ func WithInputFailureHandler(f func(sessionID, inputURL string, at time.Duration, err error)) Option

+ func WithRunStartHandler(f func(inputURL string, from, to time.Duration)) Option

type Session

+ func (s *Session) CheckSwap(info core.MediaInfo) error

+ func (s *Session) RequestedPosition() time.Duration

type Timeline

+ func (tl *Timeline) Keyframed() bool

Oct 20, 2026

Changes in this version

+ const AccelNVENC

+ const AccelNone

+ const AccelQSV

+ const AccelVAAPI

+ const AccelVideoToolbox

+ const ContainerFMP4

+ const ContainerMPEGTS

+ const ContainerMatroska

+ const DefaultDASHSegmentDuration

+ const DefaultSegmentDuration

+ const DefaultVAAPIDevice

+ const InitSegment

+ const InitSegmentName

+ const MatroskaHeaderName

+ var ErrFFmpegNotFound = errors.New("transcode: ffmpeg not found")

+ var ErrImageSubtitle = errors.New("transcode: bitmap subtitles cannot be converted to text")

+ var ErrNoCues = errors.New("transcode: no subtitle cues found")

+ var ErrPauseUnsupported = errors.New("transcode: pausing processes is not supported on this platform")

+ var ErrTooManyTranscodes = errors.New("transcode: too many concurrent transcodes")

+ func Decide(info core.MediaInfo, caps core.ClientCaps, opts core.DecideOptions, pol Policy) core.Decision

+ func DownloadCopyable(info core.MediaInfo, audioStream int) (video, audio *core.StreamInfo, ok bool)

+ func HLSContainer(caps core.ClientCaps, videoCodec, audioCodec string) string

+ func HLSVariantAttributes(info core.MediaInfo, d core.Decision) string

+ func IsImageSubtitle(codec string) bool

+ func IsJPEG(b []byte) bool

+ func IsTextSubtitle(codec string) bool

+ func MarshalBIF(frames []BIFFrame) ([]byte, error)

+ func NormalizeCodec(c string) string

+ func NormalizeContainer(formatName string) string

+ func ParseProbe(b []byte) (*core.MediaInfo, error)

+ func ParseSegmentName(name string) (int, bool)

+ func PlexDASHURLs(sessionID string) (string, string)

+ func SRTToVTT(dst io.Writer, src io.Reader) error

+ func SegmentName(n int, container string) string

+ func SupportsDVProfile(c core.ClientCaps, profile int) bool

+ func VTTToSRT(dst io.Writer, src io.Reader) error

+ func WriteBIF(w io.Writer, frames []BIFFrame) error

+ func WriteSRT(dst io.Writer, cues []Cue) error

+ func WriteVTT(dst io.Writer, cues []Cue) error

+ type BIF struct

+ Multiplier uint32

+ Version uint32

+ func ParseBIF(data []byte) (*BIF, error)

+ func (b *BIF) Frame(i int) []byte

+ func (b *BIF) FrameAt(at time.Duration) ([]byte, bool)

+ func (b *BIF) Len() int

+ func (b *BIF) Time(i int) time.Duration

+ type BIFFrame struct

+ JPEG []byte

+ Time time.Duration

+ type ClientPolicy struct

+ DolbyVisionProfiles []int

+ Family string

+ Notes string

+ SubtitleCodecs []string

+ func ClientPolicies() []ClientPolicy

+ func ClientPolicyFor(c core.ClientCaps) ClientPolicy

+ type Command struct

+ Args []string

+ Dir string

+ Path string

+ Stderr io.Writer

+ Stdout io.Writer

+ type Cue struct

+ End time.Duration

+ Settings string

+ Start time.Duration

+ Text string

+ type DASHURLs func(sessionID string) (initialization, media string)

+ type DownloadRemuxer struct

+ func (d *DownloadRemuxer) ReleaseDownload(path string)

+ func (d *DownloadRemuxer) RemuxDownload(ctx context.Context, req core.DownloadRemuxRequest, progress func(float64)) (string, int64, error)

+ func (d *DownloadRemuxer) UsedBytes() int64

+ type ExecRunner struct

+ func (ExecRunner) Run(ctx context.Context, c Command) error

+ func (ExecRunner) Start(c Command) (Process, error)

+ type Manager struct

+ func New(cfg config.Transcode, logger *slog.Logger, opts ...Option) (*Manager, error)

+ func (m *Manager) Close() error

+ func (m *Manager) Decide(info core.MediaInfo, caps core.ClientCaps, opts core.DecideOptions) core.Decision

+ func (m *Manager) ExtractSubtitle(ctx context.Context, inputURL string, streamIndex int, codec string, ...) error

+ func (m *Manager) FFmpegPath() string

+ func (m *Manager) FFprobePath() string

+ func (m *Manager) HWAccel() core.HWAccel

+ func (m *Manager) NewDownloadRemuxer(cfg config.Downloads) (*DownloadRemuxer, error)

+ func (m *Manager) Policy() Policy

+ func (m *Manager) Probe(ctx context.Context, inputURL string) (*core.MediaInfo, error)

+ func (m *Manager) ProbeLive(ctx context.Context, inputURL string) (*core.MediaInfo, error)

+ func (m *Manager) ProbeLiveWithHeaders(ctx context.Context, input string, headers map[string]string) (*core.MediaInfo, error)

+ func (m *Manager) Session(id string) (core.HLSSession, bool)

+ func (m *Manager) Sessions() []*Session

+ func (m *Manager) StartHLS(ctx context.Context, req core.HLSRequest) (core.HLSSession, error)

+ func (m *Manager) Stop(id string)

+ func (m *Manager) UpdateConfig(cfg config.Transcode)

+ func (m *Manager) Version() string

+ type Option func(*options)

+ func WithBuffering(restartAhead, maxAhead, keepBehind time.Duration) Option

+ func WithDASHURLs(f DASHURLs) Option

+ func WithFailureHandler(f func(sessionID string, at time.Duration, err error)) Option

+ func WithIdleTimeout(d time.Duration) Option

+ func WithManifestWait(d time.Duration) Option

+ func WithRunner(r Runner) Option

+ func WithSegmentTimeout(d time.Duration) Option

+ func WithSegmentURI(f func(n int, container string) string) Option

+ func WithoutHWDetection() Option

+ type Policy struct

+ HEVCEncoder bool

+ HEVCHardware bool

+ RemoteMaxBitrateKbps int

+ type Process interface

+ Done func() <-chan struct{}

+ Err func() error

+ Pause func() error

+ Resume func() error

+ Stop func()

+ type Progress struct

+ Bitrate string

+ Ended bool

+ FPS float64

+ Frame int64

+ OutTime time.Duration

+ Speed float64

+ Updated time.Time

+ type Runner interface

+ Run func(ctx context.Context, cmd Command) error

+ Start func(cmd Command) (Process, error)

+ type SegMode uint8

+ const ModeClamp

+ const ModeCopy

+ const ModeFastStart

+ const ModeTranscode

+ type SegmentPlan struct

+ DiscontinuityBefore bool

+ Duration time.Duration

+ Index int

+ Mode SegMode

+ Start time.Duration

+ type Session struct

+ func (s *Session) Close() error

+ func (s *Session) Container() string

+ func (s *Session) Decision() core.Decision

+ func (s *Session) GoodputKbps() int

+ func (s *Session) HWAccelerated() bool

+ func (s *Session) ID() string

+ func (s *Session) Info() core.MediaInfo

+ func (s *Session) LastAccess() time.Time

+ func (s *Session) Progress() Progress

+ func (s *Session) Protocol() string

+ func (s *Session) Rungs() []core.HLSRung

+ func (s *Session) SegmentDuration() time.Duration

+ func (s *Session) ServeInit(w http.ResponseWriter, r *http.Request, rep int)

+ func (s *Session) ServeManifest(w http.ResponseWriter, r *http.Request)

+ func (s *Session) ServeMedia(w http.ResponseWriter, r *http.Request, rep, n int)

+ func (s *Session) ServePlaylist(w http.ResponseWriter, r *http.Request)

+ func (s *Session) ServeRungPlaylist(w http.ResponseWriter, r *http.Request, rungID string)

+ func (s *Session) ServeRungSegment(w http.ResponseWriter, r *http.Request, rungID string, n int)

+ func (s *Session) ServeSegment(w http.ResponseWriter, r *http.Request, n int)

+ func (s *Session) SwapInput(ctx context.Context, inputURL string, info core.MediaInfo, at time.Duration) error

+ func (s *Session) Touch()

+ type ThumbOptions struct

+ BatchFrames int

+ BatchPause time.Duration

+ FFmpeg string

+ FrameTimeout time.Duration

+ Interval time.Duration

+ Logger *slog.Logger

+ MaxBytes int64

+ MaxConcurrent int

+ MaxReleases int

+ Quality int

+ RetryBackoff time.Duration

+ Runner Runner

+ Width int

+ type Thumbnails struct

+ func NewThumbnails(o ThumbOptions) *Thumbnails

+ func (t *Thumbnails) CancelTrickplay(releaseID string)

+ func (t *Thumbnails) Close() error

+ func (t *Thumbnails) EnsureTrickplay(_ context.Context, src core.TrickplaySource)

+ func (t *Thumbnails) SetTrickplayFallback(releaseID string, jpeg []byte)

+ func (t *Thumbnails) TrickplayAvailable(releaseID string) bool

+ func (t *Thumbnails) TrickplayBIF(releaseID string) ([]byte, bool)

+ func (t *Thumbnails) TrickplayFrame(releaseID string, at time.Duration) ([]byte, bool)

+ type Timeline struct

+ SwitchSeg int

+ func (tl *Timeline) ClampKbps(n int) int

+ func (tl *Timeline) Dur(n int) time.Duration

+ func (tl *Timeline) IndexAt(rel time.Duration) int

+ func (tl *Timeline) ModeAt(n int) SegMode

+ func (tl *Timeline) NextChange(n int) int

+ func (tl *Timeline) Plan(n int) SegmentPlan

+ func (tl *Timeline) SetClamp(n, kbps int)

+ func (tl *Timeline) Start(n int) time.Duration

+ func (tl *Timeline) TargetDuration() time.Duration

+ func (tl *Timeline) Total() int