task

Mar 12, 2024

Changes in this version

+ var OutputNameClipSource = OutputName("clip_source")

+ type InputError struct

type RunnerOptions

+ VodDecryptPrivateKey string

+ VodDecryptPublicKey string

type TaskHandlerOutput

+ func TaskClip(tctx *TaskContext) (*TaskHandlerOutput, error)

+ func TaskExportData(tctx *TaskContext) (*TaskHandlerOutput, error)

+ type UploadTaskConfig struct

+ ImportIPFSGatewayURLs []*url.URL

May 9, 2023

Changes in this version

+ const OUTPUT_DISABLED

+ const OUTPUT_ENABLED

+ const OUTPUT_ONLY_SHORT

+ var OutputNameEmpty = OutputName("empty_output")

Jan 9, 2023

Changes in this version

type TaskHandlerOutput

+ func TaskTranscodeFile(tctx *TaskContext) (*TaskHandlerOutput, error)

Dec 7, 2022

Changes in this version

type RunnerOptions

+ DeadLetter struct{ ... }

+ OldQueueName string

Nov 30, 2022

Changes in this version

+ var ContinueAsync = &TaskHandlerOutput

+ type TaskHandlerOutput struct

+ Continue bool

Nov 21, 2022

Changes in this version

+ const DefaultMaxConcurrentTasks

+ const DefaultMaxTaskProcessingTime

+ const DefaultMinTaskProcessingTime

+ func NewCatalystError(msg string, unretriable bool) error

+ type CatalystError struct

+ func (e CatalystError) Error() string

type RunnerOptions

+ HumanizeErrors bool

+ MaxConcurrentTasks uint

+ MaxTaskProcessingTime time.Duration

+ MinTaskProcessingTime time.Duration

Nov 4, 2022

Changes in this version

+ var FlagCatalystCopiesSourceFile = false

+ var FlagCatalystProbesFile = false

type FileMetadata

+ CatalystResult *clients.CatalystCallback

+ type ProgressReporter struct

+ func NewProgressReporter(ctx context.Context, lapi *api.Client, taskID string) *ProgressReporter

+ func (p *ProgressReporter) Set(val float64)

+ func (p *ProgressReporter) Stop()

+ func (p *ProgressReporter) Track(getProgress func() float64, end float64)

+ func (p *ProgressReporter) TrackCount(getCount func() uint64, size uint64, endProgress float64)

+ func (p *ProgressReporter) TrackReader(r io.Reader, size uint64, endProgress float64) *ReadCounter

type TaskContext

+ Progress *ProgressReporter

Oct 26, 2022

Changes in this version

+ const ARWEAVE_PREFIX

+ const IPFS_PREFIX

+ type ImportTaskConfig struct

+ ImportIPFSGatewayURLs []string

Sep 24, 2022

Changes in this version

+ var ErrYieldExecution = errors.New("yield execution")

+ var FlagCatalystSupportsIPFS = false

+ var OutputNameIPFSSourceMP4 = OutputName("ipfs_source_mp4")

+ var OutputNameOSPlaylistHLS = OutputName("playlist_hls")

+ var OutputNameOSSourceMP4 = OutputName("source_mp4")

+ type OutputName string

Aug 10, 2022

Changes in this version

+ func TaskUpload(tctx *TaskContext) (*data.TaskOutput, error)

type Runner

+ HandleCatalysis func(ctx context.Context, taskId, nextStep string, ...) error

type RunnerOptions

+ Catalyst *clients.CatalystOptions

type TaskContext

+ InputOSObj *api.ObjectStore

+ OutputOSObj *api.ObjectStore

+ func (r TaskContext) HandleCatalysis(ctx context.Context, taskId, nextStep string, ...) error

Jun 17, 2022

Changes in this version

+ type Accumulator struct

+ func NewAccumulator() *Accumulator

+ func (a *Accumulator) Accumulate(size uint64)

+ func (a *Accumulator) Size() uint64

May 31, 2022

Changes in this version

+ type ExportTaskConfig struct

+ PinataAccessToken string

+ PlayerExternalURL *url.URL

+ PlayerImmutableURL *url.URL

type TaskContext

+ func (t *TaskContext) WithContext(ctx context.Context) *TaskContext

May 3, 2022

Changes in this version

+ func Prepare(tctx *TaskContext, assetSpec *livepeerAPI.AssetSpec, file io.ReadSeekCloser) (string, error)

Mar 3, 2022

Changes in this version

+ func TaskTranscode(tctx *TaskContext) (*data.TaskOutput, error)

+ type ReaderClose struct

+ func (ReaderClose) Close() error

+ type WriteSeekCloser interface

+ Reader func() io.Reader

+ type WriterSeeker struct

+ func (ws *WriterSeeker) Close() error

+ func (ws *WriterSeeker) Reader() io.Reader

+ func (ws *WriterSeeker) Seek(offset int64, whence int) (int64, error)

+ func (ws *WriterSeeker) Write(p []byte) (n int, err error)

Feb 11, 2022

Changes in this version

+ var DefaultClient = clients.BaseClient

+ func ReportProgress(ctx context.Context, lapi *livepeerAPI.Client, taskID string, size uint64, ...)

+ func TaskExport(tctx *TaskContext) (*data.TaskOutput, error)

+ type ReadCounter struct

+ func NewReadCounter(r io.Reader) *ReadCounter

+ func (h *ReadCounter) Count() uint64

+ func (h *ReadCounter) Read(p []byte) (int, error)

type RunnerOptions

+ PinataAccessToken string

type TaskContext

+ InputAsset *livepeerAPI.Asset

+ OutputAsset *livepeerAPI.Asset

+ func (r TaskContext) Shutdown(ctx context.Context) error

+ func (r TaskContext) Start() error

Feb 8, 2022

Changes in this version

+ func IsUnretriable(err error) bool

+ func NilIfUnretriable(err error) error

+ func TaskImport(tctx *TaskContext) (*data.TaskOutput, error)

+ type FileMetadata struct

+ AssetSpec *livepeerAPI.AssetSpec

+ Ffprobe *ffprobe.ProbeData

+ MD5 string

+ SHA256 string

+ func Probe(ctx context.Context, filename string, data io.Reader) (*FileMetadata, error)

+ type ReadHasher struct

+ func NewReadHasher(r io.Reader) *ReadHasher

+ func (h *ReadHasher) FinishReader() (int64, error)

+ func (h *ReadHasher) MD5() string

+ func (h *ReadHasher) Read(p []byte) (int, error)

+ func (h *ReadHasher) SHA256() string

+ func (h *ReadHasher) Size() uint64

+ type Runner interface

+ Shutdown func(ctx context.Context) error

+ Start func() error

+ func NewRunner(opts RunnerOptions) Runner

+ type RunnerOptions struct

+ AMQPUri string

+ ExchangeName string

+ LivepeerAPIOptions livepeerAPI.ClientOptions

+ QueueName string

+ TaskHandlers map[string]TaskHandler

+ type TaskContext struct

+ type TaskHandler func(tctx *TaskContext) (*data.TaskOutput, error)

+ type UnretriableError struct

+ func (e UnretriableError) Error() string

+ func (e UnretriableError) Unwrap() error