workflow

Documentation

Index

• Constants
• Variables
• type Workflow
  • func (wkf *Workflow) NewCustomCommandWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow
  • func (wkf *Workflow) NewCustomOneOutWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow
  • func (wkf *Workflow) NewGetWidthLengthWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow
  • func (wkf *Workflow) NewImageEnhanceWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow
  • func (wkf *Workflow) NewSynthesisWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow
  • func (wkf *Workflow) NewTask(taskName string, inputData map[string]string) *workflow.SimpleTask
  • func (wkf *Workflow) NewWorkflow(name string, excutor *executor.WorkflowExecutor, version int) (*workflow.ConductorWorkflow, error)

Constants

const CUSTOM = "Custom"

const CUSTOMONEOUT = "CustomOneOut"

const GETWIDTHLENGTH = "GetWidthLength"

const IMAGEENCHANCE = "ImageEnhance"

const SYNTHESIS = "Synthesis"

定义工作流名称

Variables

var (
	TaskName5     string
	WorkflowName4 string
)

var (
	TaskName4     string
	WorkflowName3 string
)

var (
	TaskName3     string
	WorkflowName2 string
)

var (
	TaskName6     string
	WorkflowName5 string
)

var (
	TaskName     string
	TaskName2    string
	WorkflowName string
)

var (
	WorkflowFunction    Workflow
	WorkflowMap         = make(map[string](func(*executor.WorkflowExecutor, int) *workflow.ConductorWorkflow))
	TaskOwnerEmail      string
	WorkflowDescription string
	WorkflowOwnerEmail  string
)

Types

type Workflow

type Workflow struct {
	Wf *workflow.ConductorWorkflow
}

func (*Workflow) NewCustomCommandWorkflow

func (wkf *Workflow) NewCustomCommandWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow

NewCustomCommandWorkflow 创建自定义ffmpeg请求workflow

func (*Workflow) NewCustomOneOutWorkflow

func (wkf *Workflow) NewCustomOneOutWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow

NewCustomOneOutWorkflow 创建自定义ffmpeg请求单路输出workflow

func (*Workflow) NewGetWidthLengthWorkflow

func (wkf *Workflow) NewGetWidthLengthWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow

NewGetWidthLengthWorkflow 创建获取视频长宽信息workflow

func (*Workflow) NewImageEnhanceWorkflow

func (wkf *Workflow) NewImageEnhanceWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow

NewImageEnhanceWorkflow 创建图片画质增强workflow

func (*Workflow) NewSynthesisWorkflow

func (wkf *Workflow) NewSynthesisWorkflow(excutor *executor.WorkflowExecutor, version int) *workflow.ConductorWorkflow

NewSynthesisWorkflow 创建视频合成workflow

func (*Workflow) NewTask

func (wkf *Workflow) NewTask(taskName string, inputData map[string]string) *workflow.SimpleTask

创建新task

func (*Workflow) NewWorkflow

func (wkf *Workflow) NewWorkflow(name string, excutor *executor.WorkflowExecutor, version int) (*workflow.ConductorWorkflow, error)

NewWorkflow 创建新的workflow