util

type AtomicBool ¶

type AtomicBool interface {
	Set(bool) bool
	Get() bool
}

func NewAtomicBool(val bool) AtomicBool

type Duration ¶ added in v0.49.0

type Duration struct {
	time.Duration
}

Duration is a serializable version version of a time.Duration it supports setting in yaml & json via: - string: 10s - float32/64, int/32/64: 10 (nanoseconds)

func (d Duration) MarshalJSON() ([]byte, error)

func (d Duration) MarshalYAML() ([]byte, error)

func (d *Duration) UnmarshalJSON(b []byte) error

func (d *Duration) UnmarshalText(text []byte) error

func (d *Duration) UnmarshalYAML(unmarshal func(interface{}) error) error

type ScheduledExecutor ¶

type ScheduledExecutor interface {
	Start()
	Stop()
}

func NewScheduledExecutor(period time.Duration, cb func()) ScheduledExecutor