safego

Documentation

Index

• Variables
• func Close[T any](ch chan T)
• func Insert[T any](ch chan<- T, value T) bool
• func Recovery(exit bool)
• type Execution
  • func Run(f func()) *Execution
  • func RunWithRestart(f func()) *Execution
  • func (exec *Execution) WithRestartTimeout(timeout time.Duration) *Execution
• type RecoverHandler

Variables

var DefaulSafegoLogger relec.Logger

Functions

func Close

func Close[T any](ch chan T)

func Insert

func Insert[T any](ch chan<- T, value T) bool

func Recovery

func Recovery(exit bool)

Types

type Execution

type Execution struct {
	// contains filtered or unexported fields
}

func Run

func Run(f func()) *Execution

Run runs a new goroutine and add panic handler (without restart)

func RunWithRestart

func RunWithRestart(f func()) *Execution

RunWithRestart run a new goroutine and add panic handler: write logs, wait 2 seconds and restart the goroutine

func (*Execution) WithRestartTimeout

func (exec *Execution) WithRestartTimeout(timeout time.Duration) *Execution

type RecoverHandler

type RecoverHandler func(value interface{})

var GlobalRecoverHandler RecoverHandler = func(value interface{}) {}