task

type AudioEncodeMediaRequest struct {
	Reader io.Reader `json:"-"`
	ProbeRequestOpts
	Stream  *uint64              `json:"stream,omitempty" name:"stream" help:"Index of the stream to encode; 0-based." example:"0"`
	Profile profile.AudioProfile `json:"profile,omitempty" name:"profile" help:"Audio encoding profile to use."`
}

type AudioEncodeMediaResponse struct {
	// Path is the location of the encoded output. For now this is always a
	// temporary file, until a real upload/storage destination exists.
	Path string `json:"path" help:"Path to the encoded output file."`
}

type Context struct {
	context.Context

	// Otel Tracer (can be nil)
	Tracer trace.Tracer

	// Progress reports how far the task has got, in task-defined units (e.g.
	// bytes, frames, streams) - total is 0 if not known in advance.
	Progress func(current, total int64)

	// Result sets the task's output, retrievable afterwards via the
	// Manager's Status.
	Result func(any)
}

type Manager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type MetadataRequest struct {
	Reader io.Reader `json:"-"`
}

type MetadataResponse struct {
	Name     string             `json:"name,omitempty" help:"Name of the probed input, if known (e.g. the uploaded filename)." example:"sample.mp3"`
	Type     string             `json:"type,omitempty" help:"Detected content type (MIME type) of the input, e.g. \"video/mp4\"." example:"video/mp4"`
	Metadata []profile.Metadata `json:"metadata,omitempty" help:"Container-level metadata tags, e.g. \"title\", \"artist\"; excludes artwork and chapters."`
	Artwork  []profile.Artwork  `json:"artwork,omitempty" help:"Artwork images embedded in the input, e.g. album cover art."`
}

type ProbeMediaRequest struct {
	Reader io.Reader `json:"-"`
	ProbeRequestOpts
}

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

type ProbeRequestOpts struct {
	Format string   `json:"format,omitempty" name:"format" help:"Input format name (e.g. mpegts)"`
	Opts   []string `json:"opts,omitempty" name:"opts" help:"Input format options"`
}

type ProbeResponse struct {
	Name     string                   `json:"name,omitempty" help:"Name of the probed input, if known (e.g. the uploaded filename)." example:"sample.mp3"`
	Format   *profile.FormatMeta      `json:"format,omitempty" help:"Detected container format."`
	Duration profile.Duration         `` /* 236-byte string literal not displayed */
	Streams  []*profile.StreamProfile `json:"streams,omitempty" help:"Audio, video, subtitle, data, and attachment streams found in the input."`
	Metadata []profile.Metadata       `json:"metadata,omitempty" help:"Container-level metadata tags, e.g. \"title\", \"artist\"; excludes artwork and chapters."`
	Artwork  []profile.Artwork        `json:"artwork,omitempty" help:"Embedded artwork (cover art, thumbnail, etc.) found in the input; absent if none was found."`
	Chapters []profile.Chapter        `json:"chapters,omitempty" help:"Chapter markers found in the input, if any."`
}

type ProbeSourceRequest struct {
	Url string `` /* 137-byte string literal not displayed */
	ProbeRequestOpts
}

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

type Progress struct {
	Current int64
	Total   int64
}

type State string

type Status struct {
	UUID      uuid.UUID
	Name      string
	Progress  Progress
	Result    any
	Started   time.Time // zero until the task has been run
	Finished  time.Time // zero until the task has finished
	Cancelled bool      // set by Cancel, regardless of the error the task returns
	Err       error
}

type Task interface {
	// Run the task
	Run(ctx Context) error
}

type TaskList []Status

type TaskListRequest struct {
	Name  *string `json:"name,omitempty"`
	State *State  `json:"state,omitempty"`
}