services

Documentation

Index

• func ExecuteFFmpegProbe(ctx *ServiceContext, conf *config.FFmpegConfig, filename string) (*map[string]interface{}, error)
• func ExecuteFFmpegTranscode(ctx *ServiceContext, conf *config.FFmpegConfig, cmd string) (*environment.ExecutionResult, error)
• func ExecuteRife(ctx *ServiceContext, conf *config.RifeConfig, ratio int, uhd bool, skip bool, ...) error
• func ExecuteVideo2x(ctx *ServiceContext, conf *config.Video2xConfig, driver string, ratio int, ...) error
• type ServiceContext
  • func NewServiceContext(env environment.Environment, tracker *Tracker) *ServiceContext
• type Tracker
  • func NewTracker(client zbc.Client, job entities.Job) *Tracker
  • func (self *Tracker) Crit(msg string, ctx ...interface{})
  • func (self *Tracker) Debug(msg string, ctx ...interface{})
  • func (self *Tracker) Error(msg string, ctx ...interface{})
  • func (self *Tracker) Info(msg string, ctx ...interface{})
  • func (self *Tracker) Progress(progress float64) error
  • func (self *Tracker) Warn(msg string, ctx ...interface{})

Functions

func ExecuteFFmpegProbe

func ExecuteFFmpegProbe(ctx *ServiceContext, conf *config.FFmpegConfig, filename string) (*map[string]interface{}, error)

func ExecuteFFmpegTranscode

func ExecuteFFmpegTranscode(ctx *ServiceContext, conf *config.FFmpegConfig, cmd string) (*environment.ExecutionResult, error)

ExecuteFFmpeg -

func ExecuteRife

func ExecuteRife(ctx *ServiceContext, conf *config.RifeConfig, ratio int, uhd bool, skip bool, filename string, outputfilename string) error

func ExecuteVideo2x

func ExecuteVideo2x(ctx *ServiceContext, conf *config.Video2xConfig, driver string, ratio int, filename string, outputfilename string) error

Types

type ServiceContext

type ServiceContext struct {
	Environment environment.Environment
	Tracker     *Tracker
}

ServiceContext - context for a services

func NewServiceContext

func NewServiceContext(env environment.Environment, tracker *Tracker) *ServiceContext

type Tracker

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

func NewTracker

func NewTracker(client zbc.Client, job entities.Job) *Tracker

func (*Tracker) Crit

func (self *Tracker) Crit(msg string, ctx ...interface{})

func (*Tracker) Debug

func (self *Tracker) Debug(msg string, ctx ...interface{})

func (*Tracker) Error

func (self *Tracker) Error(msg string, ctx ...interface{})

func (*Tracker) Info

func (self *Tracker) Info(msg string, ctx ...interface{})

func (*Tracker) Progress

func (self *Tracker) Progress(progress float64) error

func (*Tracker) Warn

func (self *Tracker) Warn(msg string, ctx ...interface{})