task

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

type ExportTaskConfig struct {
	PinataAccessToken  string
	PlayerImmutableURL *url.URL
	PlayerExternalURL  *url.URL
}

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

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

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

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

type RunnerOptions struct {
	AMQPUri            string
	ExchangeName       string
	QueueName          string
	LivepeerAPIOptions api.ClientOptions
	ExportTaskConfig

	TaskHandlers map[string]TaskHandler
}

type TaskContext struct {
	context.Context

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

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

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

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