conexecutor

Documentation

Index

• Variables
• type CeOption
  • func WithCeConcurrency(con int) CeOption
• type CeOptions
• type ConExecutor
  • func NewConExecutor(optList ...CeOption) *ConExecutor
  • func (ce *ConExecutor) DoJob(fJob JobFunc, in interface{}, out interface{}, sync bool, jo ...JobOption) error
  • func (ce *ConExecutor) Init()
  • func (ce *ConExecutor) IsRunning() bool
  • func (ce *ConExecutor) Start()
  • func (ce *ConExecutor) Stop()
• type ConExecutorStatus
• type JobFunc
• type JobInfo
  • func (job *JobInfo) Execute() error
• type JobOption
  • func WithJobContext(ctx context.Context) JobOption
  • func WithJobName(name string) JobOption
  • func WithJobParam(key string, value string) JobOption
• type JobOptions

Variables

var (
	//ErrFlowNotFound = errors.New("Flow not found\n")
	ErrNotRunning  = errors.New("ConExecutor not running\n")
	ErrJobNoHandle = errors.New("Job with no handle function\n")
)

Types

type CeOption

type CeOption func(*CeOptions)

func WithCeConcurrency

func WithCeConcurrency(con int) CeOption

type CeOptions

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

并行执行器的Options

type ConExecutor

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

并行执行器

func NewConExecutor

func NewConExecutor(optList ...CeOption) *ConExecutor

func (*ConExecutor) DoJob

func (ce *ConExecutor) DoJob(fJob JobFunc, in interface{}, out interface{}, sync bool, jo ...JobOption) error

sync 为true 时， 表示 同步方式执行任务，但任务优先级与异步方式的job一致，也需要等到 并发控制允许时才能执行

func (*ConExecutor) Init

func (ce *ConExecutor) Init()

func (*ConExecutor) IsRunning

func (ce *ConExecutor) IsRunning() bool

func (*ConExecutor) Start

func (ce *ConExecutor) Start()

func (*ConExecutor) Stop

func (ce *ConExecutor) Stop()

type ConExecutorStatus

type ConExecutorStatus int32

const (
	ECeStatusInit      ConExecutorStatus = 0
	ECeStatusWaitStart ConExecutorStatus = 1
	ECeStatusRunning   ConExecutorStatus = 2
	ECeStatusWaitStop  ConExecutorStatus = 3
	ECeStatusStop      ConExecutorStatus = 4
)

type JobFunc

type JobFunc func(in interface{}, out interface{}, o *JobOptions) error

type JobInfo

type JobInfo struct {
	Options *JobOptions // Job参数
	// contains filtered or unexported fields
}

func (*JobInfo) Execute

func (job *JobInfo) Execute() error

type JobOption

type JobOption func(*JobOptions)

func WithJobContext

func WithJobContext(ctx context.Context) JobOption

func WithJobName

func WithJobName(name string) JobOption

func WithJobParam

func WithJobParam(key string, value string) JobOption

type JobOptions

type JobOptions struct {
	Name   string
	Params map[string]string
	Ctx    context.Context
}