task

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

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

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

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

type OutputName string

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

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

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

type Runner interface {
	Start() error
	HandleCatalysis(ctx context.Context, taskId, nextStep, attemptID string, callback *clients.CatalystCallback) error
	Shutdown(ctx context.Context) error
}

type RunnerOptions struct {
	AMQPUri                 string
	ExchangeName, QueueName string
	OldQueueName            string
	DeadLetter              struct {
		ExchangeName, QueueName string
	}

	MinTaskProcessingTime time.Duration
	MaxTaskProcessingTime time.Duration
	MaxConcurrentTasks    uint
	HumanizeErrors        bool

	LivepeerAPIOptions api.ClientOptions
	Catalyst           *clients.CatalystOptions
	ExportTaskConfig
	UploadTaskConfig

	VodDecryptPrivateKey string
	VodDecryptPublicKey  string

	TaskHandlers map[string]TaskHandler
}

type TaskContext struct {
	context.Context

	data.TaskInfo
	*api.Task
	Progress                *ProgressReporter
	InputAsset, OutputAsset *api.Asset
	InputOSObj, OutputOSObj *api.ObjectStore
	// contains filtered or unexported fields
}

type TaskHandler func(tctx *TaskContext) (*TaskHandlerOutput, error)

type TaskHandlerOutput struct {
	*data.TaskOutput
	Continue bool
}

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

type UploadTaskConfig struct {
	// Ordered list of IPFS gateways (includes /ipfs/ suffix) to import assets from
	ImportIPFSGatewayURLs []*url.URL
}