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 Run go tools (build/test) with "-tags norecover" to disable panic recovery (useful for debugging/testing)

Index

• func GoOnce(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 goroutine; if it panics, logs the error and stack trace to the specified Errorer

Types

type ContextEndedChan

type ContextEndedChan chan struct{}

func GoForever

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

Runs f() in a 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)
}