task

package
v0.0.0-...-6f193cf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 28, 2020 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertToMp4Task

func ConvertToMp4Task(args ...string) error

ConvertToMp4Task ...

func ExtractAudioFromMp4Task

func ExtractAudioFromMp4Task(args ...string) error

ExtractAudioFromMp4Task ...

func FFprobeTask

func FFprobeTask(args ...string) error

FFprobeTask ...

func FallbackRenditionTask

func FallbackRenditionTask(args ...string) error

FallbackRenditionTask ...

func GenerateImageFromFrameVideoTask

func GenerateImageFromFrameVideoTask(args ...string) error

GenerateImageFromFrameVideoTask ...

func Get

func Get() map[string]interface{}

Get return the tasks

func IPFSAddDir

func IPFSAddDir(directory, resourceID string, server *machinery.Server) *tasks.TaskState

IPFSAddDir send the directory to ipfs

func LongRunningTask

func LongRunningTask() error

LongRunningTask ...

func ManagerEmbedByVoodfy

func ManagerEmbedByVoodfy(resourceID, title, description string) string

ManagerEmbedByVoodfy setup an account at Voodfy

func ManagerIPFS

func ManagerIPFS(directory, resourceID string, server *machinery.Server)

ManagerIPFS managment of the task

func ManagerLoginVoodfy

func ManagerLoginVoodfy(secret string) string

ManagerLoginVoodfy setup an account at Voodfy

func ManagerPowergate

func ManagerPowergate(directoryID string) string

ManagerPowergate managment of the task that will use the powergate

func ManagerSetupAccountVoodfy

func ManagerSetupAccountVoodfy() string

ManagerSetupAccountVoodfy setup an account at Voodfy

func ManagerTranscoder

func ManagerTranscoder(kind, resourceID, resourceName, directory, tracker string, server *machinery.Server) error

ManagerTranscoder managment of the task

func PinDirToIPFSClusterTask

func PinDirToIPFSClusterTask(args ...string) error

PinDirToIPFSClusterTask send final directory to ipfs cluster

func Ping

func Ping(server machinery.Server)

Ping send ping to queue

func RemoveAudioFromMp4Task

func RemoveAudioFromMp4Task(args ...string) error

RemoveAudioFromMp4Task ...

func RenditionTask

func RenditionTask(args ...string) error

RenditionTask will send and receive the chunck transcoded by livepeer

func SendDirToFilecoinTask

func SendDirToFilecoinTask(args ...string) ([]string, error)

SendDirToFilecoinTask send final directory to filecoin

func SendDirToIPFSTask

func SendDirToIPFSTask(args ...string) (string, error)

SendDirToIPFSTask send final directory to ipfs

func ThumbsPreviewGeneratorTask

func ThumbsPreviewGeneratorTask(args ...string) error

ThumbsPreviewGeneratorTask ...

Types

type AsyncResultArray

type AsyncResultArray []result.AsyncResult

AsyncResultArray slice of AsyncResult

func Local

func Local(resourceID, resourceName, directory, tracker string, server *machinery.Server) AsyncResultArray

Local task to use ffmpeg

Jump to

Keyboard shortcuts

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