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
- API
  
  Reference documentation for the pkg.go.dev API
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

rerun

package module

Go to main page

Versions in this module

v0

v0.2.0

Jul 4, 2026

Changes in this version

+ var ErrEngineClosed = errors.New("rerun: engine is shut down")

+ var ErrRunExists = errors.New("rerun: run already exists")

+ var ErrSeqConflict = errors.New("rerun: journal sequence conflict")

type Engine

+ func (e *Engine) Redrive(ctx context.Context, runID string) error

+ func (e *Engine) Shutdown(ctx context.Context) error

type Opt

+ func WithStoreTimeout(d time.Duration) Opt

type Run

+ Input []byte

type Status

+ const Stuck

v0.1.1

Jul 2, 2026

v0.1.0

Jul 2, 2026

Changes in this version

+ func DoTimeout[T any](w *W, tag string, d time.Duration, fn func(context.Context) (T, error)) (T, error)

+ func Do[T any](w *W, tag string, fn func(context.Context) (T, error)) (T, error)

+ func ExpBackoff(base, max time.Duration) func(int) time.Duration

+ func FixedBackoff(d time.Duration) func(int) time.Duration

+ func Input[T any](w *W) (T, error)

+ func Result[T any](ctx context.Context, e *Engine, runID string) (T, error)

+ func Retry[T any](w *W, tag string, p RetryPolicy, fn func(context.Context) (T, error)) (T, error)

+ func Return[T any](w *W, v T)

+ func Sleep(w *W, d time.Duration) error

+ func Version(w *W, changeID string, min, max int) int

+ func Wait[T any](w *W, name string) (T, error)

+ type Canceller interface

+ CancelRequested func(ctx context.Context, runID string) (bool, error)

+ RequestCancel func(ctx context.Context, runID string) error

+ type Clock interface

+ After func(d time.Duration) <-chan time.Time

+ Now func() time.Time

+ type Codec interface

+ Marshal func(v any) ([]byte, error)

+ Unmarshal func(data []byte, v any) error

+ type Engine struct

+ func New(s Store, opts ...Opt) *Engine

+ func (e *Engine) Cancel(ctx context.Context, runID string) error

+ func (e *Engine) Deliver(ctx context.Context, runID, name string, payload any) error

+ func (e *Engine) Handle(name string, fn Func)

+ func (e *Engine) Recover(ctx context.Context) error

+ func (e *Engine) Start(ctx context.Context, workflow, runID string, in ...any) error

+ type Func func(w *W) error

+ type Guarder interface

+ Acquire func(ctx context.Context, runID string) (release io.Closer, acquired bool, err error)

+ type Log struct

+ At time.Time

+ Err string

+ Payload []byte

+ Seq int

+ Tag string

+ type Observer interface

+ OnFinish func(runID string, s Status)

+ OnStart func(r Run)

+ OnStep func(runID string, l Log)

+ type Opt func(*Engine)

+ func WithCancelPoll(d time.Duration) Opt

+ func WithClock(c Clock) Opt

+ func WithCodec(c Codec) Opt

+ func WithObserver(o Observer) Opt

+ type Reader interface

+ Incomplete func(ctx context.Context) ([]Run, error)

+ LoadLogs func(ctx context.Context, runID string) ([]Log, error)

+ type RetryPolicy struct

+ Backoff func(attempt int) time.Duration

+ MaxAttempts int

+ type Run struct

+ Created time.Time

+ ID string

+ Status Status

+ Workflow string

+ type Signaler interface

+ PopSignal func(ctx context.Context, runID, name string) (payload []byte, ok bool, err error)

+ PushSignal func(ctx context.Context, runID, name string, payload []byte) error

+ type Status int

+ const Cancelled

+ const Done

+ const Failed

+ const Pending

+ const Running

+ func (s Status) String() string

+ type StepError struct

+ Msg string

+ Tag string

+ func (e *StepError) Error() string

+ type Store interface

+ type W struct

+ RunID string

+ type Writer interface

+ Append func(ctx context.Context, runID string, l Log) error

+ Create func(ctx context.Context, r Run) error

+ Finish func(ctx context.Context, runID string, s Status) error