processor

Documentation

Index

• type InstanceStatus
  • func (status InstanceStatus) Descriptor() string
  • func (status InstanceStatus) EnDescriptor() string
  • func (status InstanceStatus) IsFinished() bool
• type Option
  • func WithIsSucceed(isSucceed bool) Option
  • func WithResult(result string) Option
  • func WithStatus(status InstanceStatus) Option
• type ProcessResult
  • func NewProcessResult(opts ...Option) *ProcessResult
  • func (pr *ProcessResult) Result() string
  • func (pr *ProcessResult) SetResult(result string)
  • func (pr *ProcessResult) SetStatus(status InstanceStatus)
  • func (pr *ProcessResult) Status() InstanceStatus
  • func (pr *ProcessResult) String() string
• type Processor

Types

type InstanceStatus

type InstanceStatus int32

const (
	InstanceStatusUnknown       InstanceStatus = 0
	InstanceStatusWaiting       InstanceStatus = 1
	InstanceStatusReady         InstanceStatus = 2
	InstanceStatusRunning       InstanceStatus = 3
	InstanceStatusSucceed       InstanceStatus = 4
	InstanceStatusFailed        InstanceStatus = 5
	InstanceStatusKilled        InstanceStatus = 6
	InstanceStatusPaused        InstanceStatus = 7
	InstanceStatusSubmitted     InstanceStatus = 8
	InstanceStatusRejected      InstanceStatus = 9
	InstanceStatusAccepted      InstanceStatus = 10
	InstanceStatusPartialFailed InstanceStatus = 11
	InstanceStatusRemoved       InstanceStatus = 99
)

func (InstanceStatus) Descriptor

func (status InstanceStatus) Descriptor() string

func (InstanceStatus) EnDescriptor

func (status InstanceStatus) EnDescriptor() string

func (InstanceStatus) IsFinished

func (status InstanceStatus) IsFinished() bool

type Option

type Option func(*ProcessResult)

func WithIsSucceed

func WithIsSucceed(isSucceed bool) Option

func WithResult

func WithResult(result string) Option

func WithStatus

func WithStatus(status InstanceStatus) Option

type ProcessResult

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

func NewProcessResult

func NewProcessResult(opts ...Option) *ProcessResult

func (*ProcessResult) Result

func (pr *ProcessResult) Result() string

func (*ProcessResult) SetResult

func (pr *ProcessResult) SetResult(result string)

func (*ProcessResult) SetStatus

func (pr *ProcessResult) SetStatus(status InstanceStatus)

func (*ProcessResult) Status

func (pr *ProcessResult) Status() InstanceStatus

func (*ProcessResult) String

func (pr *ProcessResult) String() string

type Processor

type Processor interface {
	Process(ctx *jobcontext.JobContext) (*ProcessResult, error)
}