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 Lake
  • func NewLake[T any](ctx context.Context, buffer int, exec func(one T) (exit bool, err error)) *Lake[T]
  • func (l *Lake[T]) NewStream() *Stream[T]
  • func (l *Lake[T]) Stats() string
  • func (l *Lake[T]) Wait() error
• type RecoverHandler
• type Stream
  • func (ch *Stream[T]) Close()
  • func (ch *Stream[T]) Insert(value T)

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 Lake

type Lake[T any] struct {
	// contains filtered or unexported fields
}

func NewLake

func NewLake[T any](ctx context.Context, buffer int, exec func(one T) (exit bool, err error)) *Lake[T]

func (*Lake[T]) NewStream

func (l *Lake[T]) NewStream() *Stream[T]

func (*Lake[T]) Stats

func (l *Lake[T]) Stats() string

func (*Lake[T]) Wait

func (l *Lake[T]) Wait() error

type RecoverHandler

type RecoverHandler func(value interface{})

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

type Stream

type Stream[T any] struct {
	// contains filtered or unexported fields
}

func (*Stream[T]) Close

func (ch *Stream[T]) Close()

func (*Stream[T]) Insert

func (ch *Stream[T]) Insert(value T)