Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

runnable

package module

Go to main page

Versions in this module

v0

v0.1.0

May 13, 2026

Changes in this version

+ func Publish(ctx context.Context, event any)

+ type Adapter func(next RunFunc) RunFunc

+ type DrainStartedEvent struct

+ Timeout time.Duration

+ type DrainTimedOutEvent struct

type Option

+ func WithAdapters(adapters ...Adapter) Option

+ func WithPublisher(p Publisher) Option

+ type PanicRecoveredEvent struct

+ Recovered any

+ Stack []byte

+ type Publisher interface

+ Publish func(event any)

+ func PublisherFrom(ctx context.Context) Publisher

+ type Publishers []Publisher

+ func (ps Publishers) Publish(event any)

+ type RetryEvent struct

+ Attempt int

+ Err error

+ type RunFunc func(ctx context.Context) error

v0.0.3

Nov 28, 2024

Changes in this version

+ type NoopReporter struct

+ func (*NoopReporter) Report(ctx context.Context, rec interface{})

type Option

+ func WithRecoverer(reporter RecoveryReporter, stackPrinter StackPrinter) Option

+ type RecoveryReporter interface

+ Report func(ctx context.Context, rec interface{})

+ type StackPrinter interface

+ Print func(ctx context.Context, callstack []byte)

v0.0.2

Apr 26, 2024

Changes in this version

type Option

+ func WithStatus(id string, store *StatusStore) Option

+ type Status struct

+ EndTime *time.Time

+ LastError error

+ Restarts int

+ Running bool

+ StartTime time.Time

+ type StatusMap map[string]Status

+ type StatusStore struct

+ func NewStatusStore() *StatusStore

+ func (s *StatusStore) Get() StatusMap

v0.0.1

Apr 25, 2024

Changes in this version

+ const ResetNever

+ var ErrAlreadyRunning = fmt.Errorf("already running")

+ var ErrNotRunning = fmt.Errorf("not running")

+ type Option interface

+ func WithRetry(maxRetries int, resetAfter time.Duration) Option

+ func WithStats(id string, stats *Stats) Option

+ type Runnable interface

+ IsRunning func() bool

+ Run func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ func New(runFunc func(ctx context.Context) error, options ...Option) Runnable

+ func NewGroup(runners ...Runnable) Runnable

+ type RunnableStatsView struct

+ EndTime *time.Time

+ LastError error

+ Restarts int

+ Running bool

+ StartTime time.Time

+ type Stats struct

+ func NewStats() *Stats

+ func (s *Stats) Get() StatsView

+ type StatsView struct

+ Runnable map[string]RunnableStatsView