runnable

Feb 8, 2026

Changes in this version

+ func Schedule(runnable Runnable, specs ...ScheduleSpec) *schedule

+ type ManagerRegistry interface

+ Register func(runners ...Runnable) ManagerRegistry

+ RegisterService func(services ...Runnable) ManagerRegistry

+ type ScheduleSpec func(lastStart, now time.Time) time.Time

+ func DailyAt(hour, minute int) ScheduleSpec

+ func Hourly() ScheduleSpec

+ func HourlyAt(minute int) ScheduleSpec

Mar 25, 2024

Changes in this version

type Runnable

+ func Noop() Runnable

Jul 30, 2023

Changes in this version

+ func Log(self any, format string, args ...any)

type RecoverRunner

+ func (w *RecoverRunner) RunnableName() string

+ func (w *RecoverRunner) RunnableUnwrap() any

type Runnable

+ func CloserCtx(c interface{ ... }) Runnable

+ func CloserCtxErr(c interface{ ... }) Runnable

+ func CloserErr(c interface{ ... }) Runnable

May 16, 2022

Changes in this version

+ type AppManager interface

+ Add func(runnable Runnable, dependencies ...Runnable)

+ Build func() Runnable

+ func NewManager(opts ...ManagerOption) AppManager

type Logger

+ Printf func(format string, args ...interface{})

+ type ManagerOption func(*manager)

+ func ManagerShutdownTimeout(dur time.Duration) ManagerOption

type Runnable

+ func Every(runnable Runnable, period time.Duration) Runnable

Apr 15, 2022

Changes in this version

+ func ContextValues(parent context.Context) context.Context

Apr 10, 2022

Changes in this version

+ func SetLogger(l Logger)

Jul 12, 2020

Changes in this version

+ type RestartOption func(*restartConfig)

+ func RestartCrashDelayFn(fn func(int) time.Duration) RestartOption

+ func RestartCrashLimit(times int) RestartOption

+ func RestartDelay(times time.Duration) RestartOption

+ func RestartLimit(times int) RestartOption

Jul 9, 2020

Changes in this version

+ func RunFunc(fn RunnableFunc)

type Runnable

+ func Func(fn RunnableFunc) Runnable

+ type RunnableFunc func(context.Context) error

May 19, 2020

Changes in this version

+ func Manager(options *ManagerOptions) *managerBuilder

+ func Run(runner Runnable)

+ type CloserOptions struct

+ Delay time.Duration

+ type ManagerOptions struct

+ ShutdownTimeout time.Duration

type Runnable

+ func Closer(object io.Closer, opts *CloserOptions) Runnable

+ type RunnableError struct

+ func (e *RunnableError) Error() string

+ func (e *RunnableError) Unwrap() error

Jan 6, 2020

Changes in this version

type Runnable

+ func HTTPServer(server ServerWithShutdown) Runnable

+ type ServerWithShutdown interface

+ ListenAndServe func() error

+ Shutdown func(ctx context.Context) error

Dec 26, 2019

Changes in this version

+ type RunnableCleanup interface

+ Cleanup func(context.Context) error

+ type RunnableInit interface

+ Init func(context.Context) error

+ type RunnableInitCleanup interface

+ Cleanup func(context.Context) error

+ Init func(context.Context) error

Dec 17, 2019

Changes in this version

+ func RunGroup(runners ...Runnable)

+ type PeriodicOptions struct

+ Period time.Duration

type Runnable

+ func Periodic(opts PeriodicOptions, runnable Runnable) Runnable

Dec 11, 2019

Changes in this version

+ type GroupRunner struct

+ ShutdownTimeout time.Duration

+ func Group(runnables ...Runnable) *GroupRunner

+ func (g *GroupRunner) Run(ctx context.Context) error

+ type Logger interface

+ Debugf func(format string, args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type PanicError struct

+ func (e *PanicError) Error() string

+ func (e *PanicError) Unwrap() error

+ type RecoverRunner struct

+ func (r *RecoverRunner) Run(ctx context.Context) (err error)

+ type RestartOptions struct

+ BackoffSleep time.Duration

+ CrashBackoffSleep time.Duration

+ CrashLimit int

+ RestartLimit int

+ type Runnable interface

+ Run func(context.Context) error

+ func Recover(runnable Runnable) Runnable

+ func Restart(opts RestartOptions, runnable Runnable) Runnable

+ func Signal(runnable Runnable, signals ...os.Signal) Runnable