transcode

package

Go to main page

Versions in this module

v0

v0.1.7

Jun 27, 2026

Changes in this version

+ type ActiveJob struct

+ Kind JobKind

+ Quality Quality

+ SourceBits int

+ SourceRel string

+ SourceSampleRate int

+ StartedAtUnixMs int64

+ TargetBits int

+ TargetSampleRate int

+ type ActiveJobView struct

+ Busy bool

+ Kind string

+ Quality string

+ SourceBits int

+ SourceRel string

+ SourceSampleRate int

+ StartedAtUnixMs int64

+ TargetBits int

+ TargetSampleRate int

+ WorkerID int

type JobSpec

+ SourceBits int

type Pool

+ func (p *Pool) ActiveWorkers() []ActiveJobView

+ type SoxInfo struct

+ Formats []string

+ FormatsKnown bool

+ HasFLAC bool

+ Path string

+ Version string

+ func ProbeSox(ctx context.Context) (SoxInfo, error)

v0.1.6

Jun 14, 2026

v0.1.5

Jun 2, 2026

v0.1.4

May 25, 2026

Changes in this version

+ const VariantPrefixOptimized

+ const VariantPrefixUpscaled

+ func OptimizeEligible(sourcePath, codec string, sourceRate, sourceBits int) bool

+ func ResolveTargetRateForOptimize(sourceRate int) (int, error)

+ func TargetRateForOptimize(sourceRate int) int

type Coordinator

+ func (c *Coordinator) SubmitOptimize(ctx context.Context, path string, outputDir string) (*SubmitResult, error)

+ type JobKind string

+ const JobKindOptimize

+ const JobKindUpscale

type JobSpec

+ Kind JobKind

v0.1.3

May 15, 2026

Changes in this version

+ const DefaultDiskSafetyMargin

+ const FLACCompressionFactor16Bit

+ const FLACCompressionFactor24Bit

+ const OutputDirSubdir

+ var ErrBatchNotFound = errors.New("upscale batch not found")

+ var ErrInsufficientDiskSpace = errors.New("insufficient disk space")

+ func AvailableDiskSpace(dir string) (int64, error)

+ func DefaultCompressionFactor(targetBits int) float64

+ func DiskHasHeadroom(dir string, projectedBytes int64, safetyMargin float64) (ok bool, freeBytes int64, err error)

+ func OutputDirFor(dataDir string) string

+ func ProjectedSize(sourceSize int64, sourceRate, sourceBits int, targetRate, targetBits int, ...) int64

+ type BatchProgressEvent struct

+ BatchID string

+ Error string

+ FailedFiles int

+ Path string

+ ProcessedFiles int

+ Status string

+ TargetBits int

+ TargetRate int

+ TotalFiles int

+ UpdatedAt time.Time

+ type Coordinator struct

+ func NewCoordinator(pool *Pool, store *manifest.Store, dataDir string, ...) (*Coordinator, error)

+ func (c *Coordinator) Cancel(batchID uuid.UUID) error

+ func (c *Coordinator) OnJobComplete(path, variantID string, sampleRate, bitsPerSample int, durationSeconds float64, ...)

+ func (c *Coordinator) OnJobFailed(path, variantID, errMsg string, durationSeconds float64, batchID uuid.UUID, ...)

+ func (c *Coordinator) SetPublish(publish CoordinatorPublishFunc)

+ func (c *Coordinator) Submit(ctx context.Context, path string, targetRate, targetBits int, outputDir string) (*SubmitResult, error)

+ func (c *Coordinator) Throughput() ThroughputSnapshot

+ type CoordinatorPublishFunc func(evt BatchProgressEvent)

+ type InsufficientDiskSpaceError struct

+ AvailableBytes int64

+ Dir string

+ ProjectedBytes int64

+ RequiredBytes int64

+ func (e *InsufficientDiskSpaceError) Error() string

+ func (e *InsufficientDiskSpaceError) Unwrap() error

type JobSpec

+ BatchID uuid.UUID

type Pool

+ func (p *Pool) DropInflight(matches func(sourcePath string) bool) int

+ func (p *Pool) SetOnJobComplete(...)

+ func (p *Pool) SetOnJobFailed(...)

+ type ResolverFunc func(libraryRel string) (absPath string, err error)

+ type SubmitResult struct

+ AlreadyCovered int

+ AvailableBytes int64

+ BatchID uuid.UUID

+ EnqueuedCount int

+ Path string

+ ProjectedSizeBytes int64

+ TargetBits int

+ TargetRate int

+ TotalFiles int

+ type ThroughputSnapshot struct

+ EtaSeconds float64

+ JobsPerHour float64

+ Samples int

v0.1.2

May 8, 2026

Changes in this version

+ const VariantSchemaVersion

+ var ErrPoolClosed = errors.New("transcode pool is closed")

+ var ErrQueueFull = errors.New("transcode pool queue is full")

+ var ErrSoxMissing = errors.New("sox binary not found on PATH")

+ func CreatedAtNow() int64

+ func PickTargetRate(sourceRate int) int

+ func PrecheckSox() error

+ func ResolveTargetRate(flagValue string, sourceRate int) (int, error)

+ func RunSox(ctx context.Context, j JobSpec) (int64, error)

+ type JobSpec struct

+ OutputDir string

+ Quality Quality

+ SourceAbsPath string

+ SourceLibraryRel string

+ SourceMTimeNS int64

+ SourceSampleRate int

+ SourceSize int64

+ TargetBits int

+ TargetSampleRate int

+ func (j *JobSpec) FreshnessFromFile() error

+ func (j JobSpec) SidecarPath() string

+ func (j JobSpec) SoxArgs() ([]string, string)

+ func (j JobSpec) VariantID() string

+ type Pool struct

+ func NewPool(store *manifest.Store, workers, queueCap int) *Pool

+ func (p *Pool) Enqueue(spec JobSpec) error

+ func (p *Pool) SetOnStateChange(fn func())

+ func (p *Pool) Stats() PoolStats

+ func (p *Pool) Stop()

+ type PoolStats struct

+ Done uint64

+ Enqueued uint64

+ Failed uint64

+ Inflight int

+ QueueCap int

+ QueueLen int

+ Workers int

+ type Quality string

+ const QualityHigh

+ const QualityMedium

+ const QualityVeryHigh

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