util

Documentation

Index

• func MakeUnboundedChan[V any](sendCh chan<- V, log logger.Logger, bufferLimitWarning int) chan<- V
• func ReadTestConfig(testConfigFile string) (map[string]string, error)
• type Alerter
  • func NoopAlerter() Alerter

Functions

func MakeUnboundedChan

func MakeUnboundedChan[V any](sendCh chan<- V, log logger.Logger, bufferLimitWarning int) chan<- V

NOTE: please see https://github.com/goware/channel for an improved version of the below method.

converts a blocking unbuffered send channel into a non-blocking unbounded buffered one inspired by https://medium.com/capital-one-tech/building-an-unbounded-channel-in-go-789e175cd2cd

func ReadTestConfig

func ReadTestConfig(testConfigFile string) (map[string]string, error)

Types

type Alerter

type Alerter interface {
	Alert(ctx context.Context, format string, v ...interface{})
}

func NoopAlerter

func NoopAlerter() Alerter