task

Documentation

Index

• type CatchFn
• type Controller
• type DefaultProgressReporter
  • func (inst *DefaultProgressReporter) HandleCancel(f ProgressControlHandlerFn)
  • func (inst *DefaultProgressReporter) HandlePause(f ProgressControlHandlerFn)
  • func (inst *DefaultProgressReporter) HandleResume(f ProgressControlHandlerFn)
  • func (inst *DefaultProgressReporter) Report(p *Progress)
  • func (inst *DefaultProgressReporter) Update(p *Progress)
• type DefaultProgressReporterFactory
  • func (inst *DefaultProgressReporterFactory) Create() ProgressReporter
• type Executor
  • func DefaultExecutor() Executor
• type FinallyFn
• type Progress
• type ProgressControlHandlerFn
• type ProgressReporter
  • func GetProgressReporter(ctx context.Context) (ProgressReporter, error)
• type ProgressReporterFactory
• type ProgressReporterHolder
  • func GetProgressReporterHolder(ctx context.Context) (*ProgressReporterHolder, error)
  • func (inst *ProgressReporterHolder) GetFactory() ProgressReporterFactory
  • func (inst *ProgressReporterHolder) GetReporter() (ProgressReporter, error)
  • func (inst *ProgressReporterHolder) SetFactory(f ProgressReporterFactory)
  • func (inst *ProgressReporterHolder) SetReporter(r ProgressReporter)
• type Promise
  • func NewPromise(fn PromiseFn) Promise
  • func NewPromiseWithExecutor(executor Executor, fn PromiseFn) Promise
• type PromiseFn
• type RejectFn
• type ResolveFn
• type Runnable
• type State
• type Status
• type ThenFn

Types

type CatchFn

type CatchFn func(err error)

CatchFn 是 Catch 方法的回调函数

type Controller

type Controller interface {
	Pause() error
	Resume() error
	Cancel() error
	GetState() State
	GetStatus() Status
	GetError() error
	GetProgress() map[string]*Progress
}

Controller 任务控制器(用户端接口)

type DefaultProgressReporter

type DefaultProgressReporter struct {
}

func (*DefaultProgressReporter) HandleCancel

func (inst *DefaultProgressReporter) HandleCancel(f ProgressControlHandlerFn)

func (*DefaultProgressReporter) HandlePause

func (inst *DefaultProgressReporter) HandlePause(f ProgressControlHandlerFn)

func (*DefaultProgressReporter) HandleResume

func (inst *DefaultProgressReporter) HandleResume(f ProgressControlHandlerFn)

func (*DefaultProgressReporter) Report

func (inst *DefaultProgressReporter) Report(p *Progress)

func (*DefaultProgressReporter) Update

func (inst *DefaultProgressReporter) Update(p *Progress)

type DefaultProgressReporterFactory

type DefaultProgressReporterFactory struct {
}

func (*DefaultProgressReporterFactory) Create

func (inst *DefaultProgressReporterFactory) Create() ProgressReporter

type Executor

type Executor interface {
	Execute(r Runnable)
}

Executor 接口表示一个任务的执行者

func DefaultExecutor

func DefaultExecutor() Executor

DefaultExecutor 创建一个默认的任务的执行者

type FinallyFn

type FinallyFn func()

FinallyFn 是操作完成（成功|失败）的处理函数

type Progress

type Progress struct {
	TaskID  string // 任务ID
	Name    string // 项目名称(ID)
	Title   string // 标题
	Unit    string // 单位
	Message string // 描述当前进度的消息

	Value     int64 // 当前值
	ValueMin  int64 // 最小值
	ValueMax  int64 // 最大值
	TimeBegin int64 // 开始时间
	TimeEnd   int64 // 结束时间

	// Done      bool // 是否已完成 (已废弃，用 State)
	// Cancelled bool // 是否已取消（已废弃，用 Statue）
	State  State  // 过程中的状态
	Status Status // 最终状态
}

Progress 进度对象

type ProgressControlHandlerFn

type ProgressControlHandlerFn func(reporter ProgressReporter) error

ProgressControlHandlerFn 进度控制处理函数

type ProgressReporter

type ProgressReporter interface {
	Report(p *Progress)

	// Update 更新状态 state|status
	Update(p *Progress)

	HandleCancel(f ProgressControlHandlerFn)
	HandlePause(f ProgressControlHandlerFn)
	HandleResume(f ProgressControlHandlerFn)
}

ProgressReporter 进度报告者（服务端接口）

func GetProgressReporter

func GetProgressReporter(ctx context.Context) (ProgressReporter, error)

GetProgressReporter 取报告者

type ProgressReporterFactory

type ProgressReporterFactory interface {
	Create() ProgressReporter
}

ProgressReporterFactory 进度报告者工厂

type ProgressReporterHolder

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

ProgressReporterHolder 报告者管理器

func GetProgressReporterHolder

func GetProgressReporterHolder(ctx context.Context) (*ProgressReporterHolder, error)

GetProgressReporterHolder 取报告者管理器

func (*ProgressReporterHolder) GetFactory

func (inst *ProgressReporterHolder) GetFactory() ProgressReporterFactory

GetFactory 获取报告者工厂

func (*ProgressReporterHolder) GetReporter

func (inst *ProgressReporterHolder) GetReporter() (ProgressReporter, error)

GetReporter 获取报告者

func (*ProgressReporterHolder) SetFactory

func (inst *ProgressReporterHolder) SetFactory(f ProgressReporterFactory)

SetFactory 设置报告者工厂

func (*ProgressReporterHolder) SetReporter

func (inst *ProgressReporterHolder) SetReporter(r ProgressReporter)

SetReporter 设置报告者

type Promise

type Promise interface {
	Then(fn ThenFn) Promise
	Catch(fn CatchFn) Promise
	Finally(fn FinallyFn) Promise
}

Promise 对象用于表示一个异步操作的最终完成 (或失败)及其结果值。

func NewPromise

func NewPromise(fn PromiseFn) Promise

NewPromise 新建一个 Promise 对象的实例

func NewPromiseWithExecutor

func NewPromiseWithExecutor(executor Executor, fn PromiseFn) Promise

NewPromiseWithExecutor 新建一个 Promise 对象的实例, 并使用指定的 Executor 执行

type PromiseFn

type PromiseFn func(resolve ResolveFn, reject RejectFn)

PromiseFn 是任务的执行过程

type RejectFn

type RejectFn func(err error)

RejectFn 是操作失败的处理函数

type ResolveFn

type ResolveFn func(result interface{})

ResolveFn 操作成功的处理函数

type Runnable

type Runnable interface {
	// Run 在当前协程上执行任务
	Run()
}

Runnable 一个简单而纯粹的任务入口

type State

type State int

State 表示任务执行过程中的某个状态

const (
	StateStarting   State = 1
	StateStarted    State = 2
	StateRunning    State = 3
	StatePaused     State = 4
	StateCancelling State = 5
	StateStopping   State = 6
	StateStopped    State = 7
)

定义任务过程中的状态

type Status

type Status uint

Status 表示任务的最终状态

const (
	StatusOK        Status = 200
	StatusCancelled Status = 300
	StatusFail      Status = 500
)

定义任务的最终状态

type ThenFn

type ThenFn func(result interface{})

ThenFn 是 Then 方法的回调函数