task

package module

Go to main page

Versions in this module

v0

v0.2.4

Apr 28, 2024

Changes in this version

type Task

+ func (t Task) Defer(f func()) Task

+ func (t Task) Micro() func()

+ func (t Task) Post(f func(error)) Task

+ func (t Task) Pre(f func()) Task

v0.2.3

Apr 17, 2024

Changes in this version

+ var ErrOneHasDone = errors.New("another task has been done")

+ type ErrOthers struct

+ func (e ErrOthers) As(v interface{}) bool

+ func (e ErrOthers) Error() string

+ func (e ErrOthers) Is(err error) bool

+ func (e ErrOthers) Unwrap() error

v0.2.2

Apr 17, 2024

v0.2.1

Apr 15, 2024

v0.2.0

Apr 14, 2024

Changes in this version

type Task

+ func (t Task) Tiny() error

v0.1.2

Apr 9, 2024

v0.1.1

Apr 9, 2024

v0.1.0

Dec 29, 2023

Changes in this version

+ var ErrOnce = errors.New("the task can only be executed once.")

+ func IgnoreErrs(errorList ...error) func(error) error

+ func OnlyErrs(errorList ...error) func(error) error

type CtxMod

+ func Timeout(dur time.Duration) CtxMod

type Task

+ func CopyBuffer(dst io.Writer, src io.ReadCloser, buf []byte) Task

+ func First(tasks ...Task) Task

+ func Micro(f func()) Task

+ func Tiny(f func() error) Task

+ func (t Task) Exec() error

+ func (t Task) Go(ctx context.Context) <-chan error

+ func (t Task) GoWithChan(ctx context.Context, ch chan<- error)

+ func (t Task) HandleErr(f func(error) error) Task

+ func (t Task) HandleErrWithContext(f func(context.Context, error) error) Task

+ func (t Task) IgnoreErr() Task

+ func (t Task) IgnoreErrs(errorList ...error) Task

+ func (t Task) Loop() Task

+ func (t Task) Once() Task

+ func (t Task) OnlyErrs(errorList ...error) Task

+ func (t Task) Retry() Task

+ func (t Task) RetryN(n int) Task

+ func (t Task) Timed(dur time.Duration) Task

+ func (t Task) TimedDone(dur time.Duration) Task

+ func (t Task) TimedDoneF(f func(time.Duration) time.Duration) Task

+ func (t Task) TimedF(f func(time.Duration) time.Duration) Task

+ func (t Task) TimedFail(dur time.Duration) Task

+ func (t Task) TimedFailF(f func(time.Duration) time.Duration) Task

+ func (t Task) With(modder CtxMod) Task

v0.0.1

Aug 14, 2023

Changes in this version

+ func Sleep(ctx context.Context, timeout time.Duration) error

+ type CtxMod func(context.Context) (context.Context, func())

+ func WithTimeout(dur time.Duration) CtxMod

+ type Func func(context.Context) error

+ func (t Func) Helper() Helper

+ func (t Func) Run(ctx context.Context) error

+ type Helper struct

+ func Copy(dst io.Writer, src io.ReadCloser) Helper

+ func F(f func(context.Context) error) Helper

+ func FromServer(start func() error, stop func()) Helper

+ func HTTPServer(s *http.Server, shutdown ...CtxMod) Helper

+ func Iter(tasks ...Task) Helper

+ func IterF(tasks ...func(context.Context) error) Helper

+ func Skip(tasks ...Task) Helper

+ func SkipF(tasks ...func(context.Context) error) Helper

+ func T(t Task) Helper

+ func Wait(tasks ...Task) Helper

+ func WaitF(tasks ...func(context.Context) error) Helper

+ func (t Helper) Go(ctx context.Context) <-chan error

+ func (t Helper) GoWithChan(ctx context.Context, ch chan<- error)

+ func (t Helper) HandleErr(f func(error) error) Helper

+ func (t Helper) IgnoreErr() Helper

+ func (t Helper) Loop() Helper

+ func (t Helper) Retry() Helper

+ func (t Helper) RetryN(n int) Helper

+ func (t Helper) Timed(dur time.Duration) Helper

+ func (t Helper) TimedDone(dur time.Duration) Helper

+ func (t Helper) TimedDoneF(f func(time.Duration) time.Duration) Helper

+ func (t Helper) TimedF(f func(time.Duration) time.Duration) Helper

+ func (t Helper) TimedFail(dur time.Duration) Helper

+ func (t Helper) TimedFailF(f func(time.Duration) time.Duration) Helper

+ func (t Helper) With(modder CtxMod) Helper

+ type Task interface

+ Run func(context.Context) error

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