Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ctxroutines

package module

Go to main page

Versions in this module

v0

v0.0.4

Dec 17, 2022

Changes in this version

type Runner

+ func WithPostCancel(r Runner, cb func()) Runner

+ func WithPostRun(r Runner, cb func(error)) Runner

+ func WithPreCancel(r Runner, cb func()) Runner

+ func WithPreRun(r Runner, cb func()) Runner

v0.0.3

Dec 17, 2022

Changes in this version

+ type ErrSignalReceived struct

+ func (s ErrSignalReceived) Error() string

type Runner

+ func SignalRunner(sig ...os.Signal) Runner

+ func Skip(rs ...Runner) Runner

v0.0.2

Dec 10, 2022

Changes in this version

type Runner

+ func NonInterruptRunner(f func() error) Runner

v0.0.1

Dec 9, 2022

Changes in this version

+ func CancelAll(rs ...Runner) context.CancelFunc

+ func CancelOnSignal(r Runner, sig ...os.Signal) (err error)

+ func IsCanceled(r Runner) bool

+ func Run(rs ...Runner) (err []error)

+ type CounterFunc func(uint64) error

+ type NoCancelRunner func() error

+ func (f NoCancelRunner) Cancel()

+ func (f NoCancelRunner) Context() context.Context

+ func (f NoCancelRunner) Run() error

+ type RecordedRunner interface

+ Count func() uint64

+ func Counter(f CounterFunc) RecordedRunner

+ func Recorded(r Runner) (ret RecordedRunner)

+ type Runner interface

+ Cancel func()

+ Context func() context.Context

+ Run func() error

+ func AnyErr(rs ...Runner) (ret Runner)

+ func CTXRunner(f func(context.Context) error) Runner

+ func CTXRunnerWith(ctx context.Context, f func(context.Context) error) Runner

+ func FirstErr(rs ...Runner) (ret Runner)

+ func FromRunner(r Runner, f func() error) Runner

+ func FuncRunner(cancel context.CancelFunc, f func() error) Runner

+ func Loop(r Runner) (ret Runner)

+ func NewRunner(ctx context.Context, cancel context.CancelFunc, f func() error) Runner

+ func NoLessThan(dur time.Duration, f Runner) Runner

+ func OnceFailedWithin(dur time.Duration, f Runner) (ret Runner)

+ func OnceSuccessWithin(dur time.Duration, f Runner) (ret Runner)

+ func OnceWithin(dur time.Duration, f Runner) (ret Runner)

+ func RatelimitRunner(l *rate.Limiter, r Runner) (ret Runner)

+ func Retry(r Runner) (ret Runner)

+ func RetryWithCB(r Runner, cb func(error)) (ret Runner)

+ func RetryWithChan(r Runner, ch chan<- error) (ret Runner)

+ func RunAtLeast(dur time.Duration, f Runner) (ret Runner)

+ func RunAtLeastFailed(dur time.Duration, f Runner) (ret Runner)

+ func RunAtLeastSuccess(dur time.Duration, f Runner) (ret Runner)

+ func SomeErr(rs ...Runner) (ret Runner)

+ func TilErr(r Runner) (ret Runner)

+ func TryAtMost(n uint64, f Runner) (ret Runner)

+ type StatefulRunner interface

+ IsRunning func() bool

+ Lock func() (release func())

+ TryRun func() (err error, ran bool)

+ func NewStatefulRunner(f Runner) (ret StatefulRunner)