workchain

README

workchain

Installation

go get -u github.com/no-src/workchain

Documentation

Index

• type CondFunc
  • func (cf CondFunc) Loop() CondFunc
• type DoFunc
• type Work
  • func NewWork(do func(ctx context.Context) error) *Work
  • func WorkChain(works ...*Work) *Work
  • func WorkRing(works ...*Work) *Work
  • func (w *Work) Do(ctx context.Context) error
  • func (w *Work) WithCond(cond CondFunc) *Work

Types

type CondFunc

type CondFunc func(ctx context.Context) (bool, context.Context, error)

func (CondFunc) Loop

func (cf CondFunc) Loop() CondFunc

type DoFunc

type DoFunc func(ctx context.Context) error

type Work

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

func NewWork

func NewWork(do func(ctx context.Context) error) *Work

func WorkChain

func WorkChain(works ...*Work) *Work

func WorkRing

func WorkRing(works ...*Work) *Work

func (*Work) Do

func (w *Work) Do(ctx context.Context) error

func (*Work) WithCond

func (w *Work) WithCond(cond CondFunc) *Work