util

Documentation

Index

• func AssertPanic(t *testing.T)
• func CheckEnvForArray(name string, a []string) []string
• func CheckEnvForValue(name string, v string) string
• func ErrEq(x error) gomock.Matcher
• func GetSystemConcurrency() (concurrency int)
• func IsNil(i interface{}) bool
• func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration) error
• type ConfigWatcher
  • func NewConfigWatcher(eventHandler ConfigWatcherEventHandler) (c *ConfigWatcher, err error)
  • func (c *ConfigWatcher) StopWatch() (err error)
  • func (c *ConfigWatcher) WatchConfigFile(configFile string) (err error)
• type ConfigWatcherEventHandler

Functions

func AssertPanic

func AssertPanic(t *testing.T)

func CheckEnvForArray

func CheckEnvForArray(name string, a []string) []string

func CheckEnvForValue

func CheckEnvForValue(name string, v string) string

func ErrEq

func ErrEq(x error) gomock.Matcher

func GetSystemConcurrency

func GetSystemConcurrency() (concurrency int)

func IsNil

func IsNil(i interface{}) bool

func WaitTimeout

func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration) error

Types

type ConfigWatcher

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

func NewConfigWatcher

func NewConfigWatcher(eventHandler ConfigWatcherEventHandler) (c *ConfigWatcher, err error)

func (*ConfigWatcher) StopWatch

func (c *ConfigWatcher) StopWatch() (err error)

func (*ConfigWatcher) WatchConfigFile

func (c *ConfigWatcher) WatchConfigFile(configFile string) (err error)

type ConfigWatcherEventHandler

type ConfigWatcherEventHandler interface {
	OnConfigModified()
}