business

Documentation

Index

• Variables
• type InputPath
  • func (*InputPath) Descriptor() ([]byte, []int)
  • func (x *InputPath) GetFileId() string
  • func (x *InputPath) GetTosBucket() string
  • func (x *InputPath) GetType() string
  • func (x *InputPath) GetVodSpaceName() string
  • func (*InputPath) ProtoMessage()
  • func (x *InputPath) ProtoReflect() protoreflect.Message
  • func (x *InputPath) Reset()
  • func (x *InputPath) String() string
• type JobExecution
  • func (*JobExecution) Descriptor() ([]byte, []int)
  • func (x *JobExecution) GetCreateAt() string
  • func (x *JobExecution) GetEnableLowPriority() string
  • func (x *JobExecution) GetFinishedAt() string
  • func (x *JobExecution) GetInputPath() *InputPath
  • func (x *JobExecution) GetJobId() string
  • func (x *JobExecution) GetJobSource() string
  • func (x *JobExecution) GetOutput() []*JobOutput
  • func (x *JobExecution) GetStatus() string
  • func (x *JobExecution) GetTemplateId() string
  • func (*JobExecution) ProtoMessage()
  • func (x *JobExecution) ProtoReflect() protoreflect.Message
  • func (x *JobExecution) Reset()
  • func (x *JobExecution) String() string
• type JobOutput
  • func (*JobOutput) Descriptor() ([]byte, []int)
  • func (x *JobOutput) GetActivityId() string
  • func (x *JobOutput) GetCode() string
  • func (x *JobOutput) GetEndTime() string
  • func (x *JobOutput) GetFileMessageId() string
  • func (x *JobOutput) GetProperties() string
  • func (x *JobOutput) GetStartTime() string
  • func (x *JobOutput) GetStatus() string
  • func (x *JobOutput) GetTaskType() string
  • func (x *JobOutput) GetTemplateId() string
  • func (x *JobOutput) GetTemplateName() string
  • func (*JobOutput) ProtoMessage()
  • func (x *JobOutput) ProtoReflect() protoreflect.Message
  • func (x *JobOutput) Reset()
  • func (x *JobOutput) String() string

Variables

var File_imp_business_imp_common_proto protoreflect.FileDescriptor

Types

type InputPath

type InputPath struct {
	Type         string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"` // 可选：VOD TOS
	TosBucket    string `protobuf:"bytes,2,opt,name=TosBucket,proto3" json:"TosBucket,omitempty"`
	VodSpaceName string `protobuf:"bytes,3,opt,name=VodSpaceName,proto3" json:"VodSpaceName,omitempty"`
	FileId       string `protobuf:"bytes,4,opt,name=FileId,proto3" json:"FileId,omitempty"`
	// contains filtered or unexported fields
}

func (*InputPath) Descriptor

func (*InputPath) Descriptor() ([]byte, []int)

Deprecated: Use InputPath.ProtoReflect.Descriptor instead.

func (*InputPath) GetFileId

func (x *InputPath) GetFileId() string

func (*InputPath) GetTosBucket

func (x *InputPath) GetTosBucket() string

func (*InputPath) GetType

func (x *InputPath) GetType() string

func (*InputPath) GetVodSpaceName

func (x *InputPath) GetVodSpaceName() string

func (*InputPath) ProtoMessage

func (*InputPath) ProtoMessage()

func (*InputPath) ProtoReflect

func (x *InputPath) ProtoReflect() protoreflect.Message

func (*InputPath) Reset

func (x *InputPath) Reset()

func (*InputPath) String

func (x *InputPath) String() string

type JobExecution

type JobExecution struct {
	JobId             string       `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`         // 工作流执行id
	InputPath         *InputPath   `protobuf:"bytes,2,opt,name=InputPath,proto3" json:"InputPath,omitempty"` // 输入文件info
	Output            []*JobOutput `protobuf:"bytes,3,rep,name=Output,proto3" json:"Output,omitempty"`       // 任务节点info
	Status            string       `protobuf:"bytes,4,opt,name=Status,proto3" json:"Status,omitempty"`       // 工作流状态
	CreateAt          string       `protobuf:"bytes,5,opt,name=CreateAt,proto3" json:"CreateAt,omitempty"`
	FinishedAt        string       `protobuf:"bytes,6,opt,name=FinishedAt,proto3" json:"FinishedAt,omitempty"`
	TemplateId        string       `protobuf:"bytes,7,opt,name=TemplateId,proto3" json:"TemplateId,omitempty"`               // 工作流模板id
	EnableLowPriority string       `protobuf:"bytes,8,opt,name=EnableLowPriority,proto3" json:"EnableLowPriority,omitempty"` // 是否开启闲时任务
	JobSource         string       `protobuf:"bytes,9,opt,name=JobSource,proto3" json:"JobSource,omitempty"`                 // 任务来源
	// contains filtered or unexported fields
}

func (*JobExecution) Descriptor

func (*JobExecution) Descriptor() ([]byte, []int)

Deprecated: Use JobExecution.ProtoReflect.Descriptor instead.

func (*JobExecution) GetCreateAt

func (x *JobExecution) GetCreateAt() string

func (*JobExecution) GetEnableLowPriority

func (x *JobExecution) GetEnableLowPriority() string

func (*JobExecution) GetFinishedAt

func (x *JobExecution) GetFinishedAt() string

func (*JobExecution) GetInputPath

func (x *JobExecution) GetInputPath() *InputPath

func (*JobExecution) GetJobId

func (x *JobExecution) GetJobId() string

func (*JobExecution) GetJobSource

func (x *JobExecution) GetJobSource() string

func (*JobExecution) GetOutput

func (x *JobExecution) GetOutput() []*JobOutput

func (*JobExecution) GetStatus

func (x *JobExecution) GetStatus() string

func (*JobExecution) GetTemplateId

func (x *JobExecution) GetTemplateId() string

func (*JobExecution) ProtoMessage

func (*JobExecution) ProtoMessage()

func (*JobExecution) ProtoReflect

func (x *JobExecution) ProtoReflect() protoreflect.Message

func (*JobExecution) Reset

func (x *JobExecution) Reset()

func (*JobExecution) String

func (x *JobExecution) String() string

type JobOutput

type JobOutput struct {
	TemplateId    string `protobuf:"bytes,1,opt,name=TemplateId,proto3" json:"TemplateId,omitempty"` // 任务模板id
	Properties    string `protobuf:"bytes,2,opt,name=Properties,proto3" json:"Properties,omitempty"` // 任务输出info
	Code          string `protobuf:"bytes,3,opt,name=Code,proto3" json:"Code,omitempty"`
	FileMessageId string `protobuf:"bytes,4,opt,name=FileMessageId,proto3" json:"FileMessageId,omitempty"`
	TaskType      string `protobuf:"bytes,5,opt,name=TaskType,proto3" json:"TaskType,omitempty"` // 任务类型
	Status        string `protobuf:"bytes,6,opt,name=Status,proto3" json:"Status,omitempty"`     // 任务状态
	ActivityId    string `protobuf:"bytes,7,opt,name=ActivityId,proto3" json:"ActivityId,omitempty"`
	StartTime     string `protobuf:"bytes,8,opt,name=StartTime,proto3" json:"StartTime,omitempty"`
	EndTime       string `protobuf:"bytes,9,opt,name=EndTime,proto3" json:"EndTime,omitempty"`
	TemplateName  string `protobuf:"bytes,10,opt,name=TemplateName,proto3" json:"TemplateName,omitempty"`
	// contains filtered or unexported fields
}

func (*JobOutput) Descriptor

func (*JobOutput) Descriptor() ([]byte, []int)

Deprecated: Use JobOutput.ProtoReflect.Descriptor instead.

func (*JobOutput) GetActivityId

func (x *JobOutput) GetActivityId() string

func (*JobOutput) GetCode

func (x *JobOutput) GetCode() string

func (*JobOutput) GetEndTime

func (x *JobOutput) GetEndTime() string

func (*JobOutput) GetFileMessageId

func (x *JobOutput) GetFileMessageId() string

func (*JobOutput) GetProperties

func (x *JobOutput) GetProperties() string

func (*JobOutput) GetStartTime

func (x *JobOutput) GetStartTime() string

func (*JobOutput) GetStatus

func (x *JobOutput) GetStatus() string

func (*JobOutput) GetTaskType

func (x *JobOutput) GetTaskType() string

func (*JobOutput) GetTemplateId

func (x *JobOutput) GetTemplateId() string

func (*JobOutput) GetTemplateName

func (x *JobOutput) GetTemplateName() string

func (*JobOutput) ProtoMessage

func (*JobOutput) ProtoMessage()

func (*JobOutput) ProtoReflect

func (x *JobOutput) ProtoReflect() protoreflect.Message

func (*JobOutput) Reset

func (x *JobOutput) Reset()

func (*JobOutput) String

func (x *JobOutput) String() string