request

Documentation

Index

• Variables
• type ImpKillJobRequest
  • func (*ImpKillJobRequest) Descriptor() ([]byte, []int)
  • func (x *ImpKillJobRequest) GetJobId() string
  • func (*ImpKillJobRequest) ProtoMessage()
  • func (x *ImpKillJobRequest) ProtoReflect() protoreflect.Message
  • func (x *ImpKillJobRequest) Reset()
  • func (x *ImpKillJobRequest) String() string
• type ImpRetrieveJobRequest
  • func (*ImpRetrieveJobRequest) Descriptor() ([]byte, []int)
  • func (x *ImpRetrieveJobRequest) GetJobIds() []string
  • func (*ImpRetrieveJobRequest) ProtoMessage()
  • func (x *ImpRetrieveJobRequest) ProtoReflect() protoreflect.Message
  • func (x *ImpRetrieveJobRequest) Reset()
  • func (x *ImpRetrieveJobRequest) String() string
• type ImpSubmitJobRequest
  • func (*ImpSubmitJobRequest) Descriptor() ([]byte, []int)
  • func (x *ImpSubmitJobRequest) GetCallbackArgs() string
  • func (x *ImpSubmitJobRequest) GetCallbackContentType() string
  • func (x *ImpSubmitJobRequest) GetCallbackUri() string
  • func (x *ImpSubmitJobRequest) GetEnableLowPriority() string
  • func (x *ImpSubmitJobRequest) GetInputPath() *business.InputPath
  • func (x *ImpSubmitJobRequest) GetJob() *business.Job
  • func (x *ImpSubmitJobRequest) GetMultiInputs() []*business.Input
  • func (x *ImpSubmitJobRequest) GetOutputPath() *business.OutputPath
  • func (x *ImpSubmitJobRequest) GetParams() *business.Params
  • func (x *ImpSubmitJobRequest) GetTemplateId() string
  • func (*ImpSubmitJobRequest) ProtoMessage()
  • func (x *ImpSubmitJobRequest) ProtoReflect() protoreflect.Message
  • func (x *ImpSubmitJobRequest) Reset()
  • func (x *ImpSubmitJobRequest) String() string

Variables

var File_imp_request_request_imp_proto protoreflect.FileDescriptor

Types

type ImpKillJobRequest

type ImpKillJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"` // 工作流执行id
	// contains filtered or unexported fields
}

func (*ImpKillJobRequest) Descriptor

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

Deprecated: Use ImpKillJobRequest.ProtoReflect.Descriptor instead.

func (*ImpKillJobRequest) GetJobId

func (x *ImpKillJobRequest) GetJobId() string

func (*ImpKillJobRequest) ProtoMessage

func (*ImpKillJobRequest) ProtoMessage()

func (*ImpKillJobRequest) ProtoReflect

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

func (*ImpKillJobRequest) Reset

func (x *ImpKillJobRequest) Reset()

func (*ImpKillJobRequest) String

func (x *ImpKillJobRequest) String() string

type ImpRetrieveJobRequest

type ImpRetrieveJobRequest struct {
	JobIds []string `protobuf:"bytes,1,rep,name=JobIds,proto3" json:"JobIds,omitempty"` // 想获取的工作流执行记录列表
	// contains filtered or unexported fields
}

func (*ImpRetrieveJobRequest) Descriptor

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

Deprecated: Use ImpRetrieveJobRequest.ProtoReflect.Descriptor instead.

func (*ImpRetrieveJobRequest) GetJobIds

func (x *ImpRetrieveJobRequest) GetJobIds() []string

func (*ImpRetrieveJobRequest) ProtoMessage

func (*ImpRetrieveJobRequest) ProtoMessage()

func (*ImpRetrieveJobRequest) ProtoReflect

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

func (*ImpRetrieveJobRequest) Reset

func (x *ImpRetrieveJobRequest) Reset()

func (*ImpRetrieveJobRequest) String

func (x *ImpRetrieveJobRequest) String() string

type ImpSubmitJobRequest

type ImpSubmitJobRequest struct {
	InputPath           *business.InputPath  `protobuf:"bytes,1,opt,name=InputPath,proto3" json:"InputPath,omitempty"`                 // 输入文件info
	TemplateId          string               `protobuf:"bytes,2,opt,name=TemplateId,proto3" json:"TemplateId,omitempty"`               // 工作流模板id
	CallbackArgs        string               `protobuf:"bytes,3,opt,name=CallbackArgs,proto3" json:"CallbackArgs,omitempty"`           // 回调参数
	EnableLowPriority   string               `protobuf:"bytes,4,opt,name=EnableLowPriority,proto3" json:"EnableLowPriority,omitempty"` // 是否开启闲时任务, "true"/"false"
	Params              *business.Params     `protobuf:"bytes,5,opt,name=Params,proto3" json:"Params,omitempty"`                       // 任务执行参数
	OutputPath          *business.OutputPath `protobuf:"bytes,6,opt,name=OutputPath,proto3" json:"OutputPath,omitempty"`
	Job                 *business.Job        `protobuf:"bytes,7,opt,name=Job,proto3" json:"Job,omitempty"`
	CallbackUri         *string              `protobuf:"bytes,8,opt,name=CallbackUri,proto3,oneof" json:"CallbackUri,omitempty"`
	CallbackContentType *string              `protobuf:"bytes,9,opt,name=CallbackContentType,proto3,oneof" json:"CallbackContentType,omitempty"`
	MultiInputs         []*business.Input    `protobuf:"bytes,10,rep,name=MultiInputs,proto3" json:"MultiInputs,omitempty"` // 多输入
	// contains filtered or unexported fields
}

func (*ImpSubmitJobRequest) Descriptor

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

Deprecated: Use ImpSubmitJobRequest.ProtoReflect.Descriptor instead.

func (*ImpSubmitJobRequest) GetCallbackArgs

func (x *ImpSubmitJobRequest) GetCallbackArgs() string

func (*ImpSubmitJobRequest) GetCallbackContentType

func (x *ImpSubmitJobRequest) GetCallbackContentType() string

func (*ImpSubmitJobRequest) GetCallbackUri

func (x *ImpSubmitJobRequest) GetCallbackUri() string

func (*ImpSubmitJobRequest) GetEnableLowPriority

func (x *ImpSubmitJobRequest) GetEnableLowPriority() string

func (*ImpSubmitJobRequest) GetInputPath

func (x *ImpSubmitJobRequest) GetInputPath() *business.InputPath

func (*ImpSubmitJobRequest) GetJob

func (x *ImpSubmitJobRequest) GetJob() *business.Job

func (*ImpSubmitJobRequest) GetMultiInputs

func (x *ImpSubmitJobRequest) GetMultiInputs() []*business.Input

func (*ImpSubmitJobRequest) GetOutputPath

func (x *ImpSubmitJobRequest) GetOutputPath() *business.OutputPath

func (*ImpSubmitJobRequest) GetParams

func (x *ImpSubmitJobRequest) GetParams() *business.Params

func (*ImpSubmitJobRequest) GetTemplateId

func (x *ImpSubmitJobRequest) GetTemplateId() string

func (*ImpSubmitJobRequest) ProtoMessage

func (*ImpSubmitJobRequest) ProtoMessage()

func (*ImpSubmitJobRequest) ProtoReflect

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

func (*ImpSubmitJobRequest) Reset

func (x *ImpSubmitJobRequest) Reset()

func (*ImpSubmitJobRequest) String

func (x *ImpSubmitJobRequest) String() string