executor

Documentation

Index

• type Executor
  • func New(ctx context.Context, name string) *Executor
  • func Newf(ctx context.Context, format string, args ...interface{}) *Executor
  • func (exec *Executor) Cancel()
  • func (exec *Executor) CancelAndWait() error
  • func (exec *Executor) Go(f func(context.Context) error)
  • func (exec *Executor) GoCancelable(f func(context.Context) error) func()
  • func (exec *Executor) Wait() error
• type ExecutorLike
• type Serial
  • func NewSerial(ctx context.Context) *Serial
  • func (s *Serial) Go(f func(context.Context) error)
  • func (s *Serial) GoCancelable(f func(context.Context) error) func()
  • func (s *Serial) Wait() error

Types

type Executor

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

func New

func New(ctx context.Context, name string) *Executor

func Newf

func Newf(ctx context.Context, format string, args ...interface{}) *Executor

func (*Executor) Cancel

func (exec *Executor) Cancel()

func (*Executor) CancelAndWait

func (exec *Executor) CancelAndWait() error

func (*Executor) Go

func (exec *Executor) Go(f func(context.Context) error)

func (*Executor) GoCancelable

func (exec *Executor) GoCancelable(f func(context.Context) error) func()

func (*Executor) Wait

func (exec *Executor) Wait() error

type ExecutorLike

type ExecutorLike interface {
	Go(func(context.Context) error)
	GoCancelable(func(context.Context) error) func()
	Wait() error
	CancelAndWait() error
}

type Serial

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

func NewSerial

func NewSerial(ctx context.Context) *Serial

func (*Serial) Go

func (s *Serial) Go(f func(context.Context) error)

func (*Serial) GoCancelable

func (s *Serial) GoCancelable(f func(context.Context) error) func()

func (*Serial) Wait

func (s *Serial) Wait() error