supervised

Documentation

Overview

Package supervised provides basic supervision abilities for running goroutines, namely making sure that panics are not swallowed and that long-running goroutines are restarted if they crash

Index

• func GoOnce(errorer Errorer, f func())
• func Recover(errorer Errorer, f func())
• type ContextEndedChan
  • func GoForever(ctx context.Context, logger Errorer, f func()) ContextEndedChan
• type Errorer

Functions

func GoOnce

func GoOnce(errorer Errorer, f func())

Runs f() in a new goroutine; if it panics, logs the error and stack trace to the specified Errorer

func Recover

func Recover(errorer Errorer, f func())

Runs f() on the original goroutine; if it panics, logs the error and stack trace to the specified Errorer Very similar to GoOnce except doesn't start a new goroutine

Types

type ContextEndedChan

type ContextEndedChan chan struct{}

func GoForever

func GoForever(ctx context.Context, logger Errorer, f func()) ContextEndedChan

Runs f() in a new goroutine; if it panics, logs the error and stack trace to the specified Errorer If the provided Context isn't closed, re-runs f() Returns a channel that is closed when the goroutine has quit due to context ending

type Errorer

type Errorer interface {
	Error(message string, fields ...*log.Field)
}