task

package

v0.3.3 Latest Latest Go to latest Published: Apr 7, 2022 License: MIT Imports: 38 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/livepeer/task-runner

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func IsUnretriable(err error) bool
func ReportProgress(ctx context.Context, lapi *livepeerAPI.Client, taskID string, size uint64, ...)
func TaskExport(tctx *TaskContext) (*data.TaskOutput, error)
func TaskImport(tctx *TaskContext) (*data.TaskOutput, error)
func TaskTranscode(tctx *TaskContext) (*data.TaskOutput, error)
type FileMetadata
- func Probe(ctx context.Context, filename string, data *ReadCounter) (*FileMetadata, error)
type ReadCounter
- func NewReadCounter(r io.Reader) *ReadCounter
- func (h *ReadCounter) Count() uint64
- func (h *ReadCounter) Read(p []byte) (int, error)
type ReadHasher
- 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
type ReaderClose
- func (ReaderClose) Close() error
type Runner
- func NewRunner(opts RunnerOptions) Runner
type RunnerOptions
type TaskContext
- func (r TaskContext) Shutdown(ctx context.Context) error
- func (r TaskContext) Start() error
type TaskHandler
type UnretriableError
- func (e UnretriableError) Error() string
- func (e UnretriableError) Unwrap() error
type WriteSeekCloser
type WriterSeeker
- 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)

Constants ¶

This section is empty.

Variables ¶

View Source

var DefaultClient = clients.BaseClient{}

Functions ¶

func IsUnretriable ¶

func IsUnretriable(err error) bool

func ReportProgress ¶ added in v0.2.0

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

func TaskExport ¶ added in v0.2.0

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

func TaskImport ¶

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

func TaskTranscode ¶ added in v0.3.0

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

Types ¶

type FileMetadata ¶

type FileMetadata struct {
	MD5       string                 `json:"md5"`
	SHA256    string                 `json:"sha256"`
	Ffprobe   *ffprobe.ProbeData     `json:"ffprobe"`
	AssetSpec *livepeerAPI.AssetSpec `json:"assetSpec"`
}

func Probe ¶

func Probe(ctx context.Context, filename string, data *ReadCounter) (*FileMetadata, error)

type ReadCounter ¶ added in v0.2.0

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

func NewReadCounter ¶ added in v0.2.0

func NewReadCounter(r io.Reader) *ReadCounter

func (*ReadCounter) Count ¶ added in v0.2.0

func (h *ReadCounter) Count() uint64

func (*ReadCounter) Read ¶ added in v0.2.0

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

type ReadHasher ¶

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

func NewReadHasher ¶

func NewReadHasher(r io.Reader) *ReadHasher

func (*ReadHasher) FinishReader ¶

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

func (*ReadHasher) MD5 ¶

func (h *ReadHasher) MD5() string

func (*ReadHasher) Read ¶

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

func (*ReadHasher) SHA256 ¶

func (h *ReadHasher) SHA256() string

type ReaderClose ¶ added in v0.3.0

type ReaderClose struct {
	bytes.Reader
}

func (ReaderClose) Close ¶ added in v0.3.0

func (ReaderClose) Close() error

type Runner ¶

type Runner interface {
	Start() error
	Shutdown(ctx context.Context) error
}

func NewRunner ¶

func NewRunner(opts RunnerOptions) Runner

type RunnerOptions ¶

type RunnerOptions struct {
	AMQPUri            string
	ExchangeName       string
	QueueName          string
	LivepeerAPIOptions livepeerAPI.ClientOptions
	PinataAccessToken  string

	TaskHandlers map[string]TaskHandler
}

type TaskContext ¶

type TaskContext struct {
	context.Context

	data.TaskInfo
	*livepeerAPI.Task
	InputAsset, OutputAsset *livepeerAPI.Asset
	// contains filtered or unexported fields
}

func (TaskContext) Shutdown ¶ added in v0.2.0

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

func (TaskContext) Start ¶ added in v0.2.0

func (r TaskContext) Start() error

type TaskHandler ¶

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

type UnretriableError ¶

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

func (UnretriableError) Error ¶

func (e UnretriableError) Error() string

func (UnretriableError) Unwrap ¶

func (e UnretriableError) Unwrap() error

type WriteSeekCloser ¶ added in v0.3.0

type WriteSeekCloser interface {
	io.WriteSeeker
	io.Closer
	Reader() io.Reader
}

type WriterSeeker ¶ added in v0.3.0

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

WriterSeeker is an in-memory io.WriteSeeker implementation

func (*WriterSeeker) Close ¶ added in v0.3.0

func (ws *WriterSeeker) Close() error

Close :

func (*WriterSeeker) Reader ¶ added in v0.3.0

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

Reader returns an io.Reader. Use it, for example, with io.Copy, to copy the content of the WriterSeeker buffer to an io.Writer

func (*WriterSeeker) Seek ¶ added in v0.3.0

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

Seek seeks in the buffer of this WriterSeeker instance

func (*WriterSeeker) Write ¶ added in v0.3.0

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

Write writes to the buffer of this WriterSeeker instance

Source Files ¶

View all Source files

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