processor

package

v1.0.1 Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 1 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/alibaba/schedulerx-worker-go

Links

Open Source Insights

Documentation ¶

Index ¶

type BroadcastProcessor
type InstanceStatus
type MapJobProcessor
type MapReduceJobProcessor
type Option
type ProcessResult
- func NewProcessResult(opts ...Option) *ProcessResult
type Processor

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BroadcastProcessor ¶ added in v0.0.2

type BroadcastProcessor interface {
	Processor
	PreProcess(ctx *jobcontext.JobContext) error
	PostProcess(ctx *jobcontext.JobContext) (*ProcessResult, error)
}

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
	InstanceStatusSkipped       InstanceStatus = 12
	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 MapJobProcessor ¶ added in v0.0.2

type MapJobProcessor interface {
	Processor
	Map(jobCtx *jobcontext.JobContext, taskList []interface{}, taskName string) (*ProcessResult, error)
	Kill(jobCtx *jobcontext.JobContext) error
}

type MapReduceJobProcessor ¶ added in v0.0.2

type MapReduceJobProcessor interface {
	MapJobProcessor
	Reduce(jobCtx *jobcontext.JobContext) (*ProcessResult, error)
	RunReduceIfFail(jobCtx *jobcontext.JobContext) bool
}

type Option ¶

type Option func(*ProcessResult)

func WithFailed ¶ added in v0.0.2

func WithFailed() Option

func WithResult ¶

func WithResult(result string) Option

func WithStatus ¶

func WithStatus(status InstanceStatus) Option

func WithSucceed ¶ added in v0.0.2

func WithSucceed() 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) SetFailed ¶ added in v0.0.2

func (pr *ProcessResult) SetFailed()

func (*ProcessResult) SetResult ¶

func (pr *ProcessResult) SetResult(result string)

func (*ProcessResult) SetStatus ¶

func (pr *ProcessResult) SetStatus(status InstanceStatus)

func (*ProcessResult) SetSucceed ¶ added in v0.0.2

func (pr *ProcessResult) SetSucceed()

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)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
jobcontext
mapjob
bizsubtask
taskstatus

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL