test_helpers

Documentation

Index

• Variables
• type Ping
• type PingChan
  • func (p PingChan) Load(err error) (ifrit.Runner, bool)
  • func (p PingChan) Run(sigChan <-chan os.Signal, ready chan<- struct{}) error
• type SignalRecoder
  • func NewSignalRecorder(exitSignals ...os.Signal) *SignalRecoder
  • func (r *SignalRecoder) Load(err error) (ifrit.Runner, bool)
  • func (r *SignalRecoder) ReceivedSignals() []os.Signal
  • func (r *SignalRecoder) Run(sigChan <-chan os.Signal, ready chan<- struct{}) error

Variables

var NoReadyExitedNormally = errors.New("no ready exited normally")

var NoReadyRunner = ifrit.RunFunc(func(sigChan <-chan os.Signal, ready chan<- struct{}) error {
	return NoReadyExitedNormally
})

NoReadyRunner exits without closing the ready chan

var PingerExitedFromPing = errors.New("pinger exited with a ping")

var PingerExitedFromSignal = errors.New("pinger exited with a signal")

Types

type Ping

type Ping struct{}

type PingChan

type PingChan chan Ping

PingChan stops when you send it a single Ping

func (PingChan) Load

func (p PingChan) Load(err error) (ifrit.Runner, bool)

func (PingChan) Run

func (p PingChan) Run(sigChan <-chan os.Signal, ready chan<- struct{}) error

type SignalRecoder

type SignalRecoder struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SignalRecoder records all signals received, and exits on a set of signals.

func NewSignalRecorder

func NewSignalRecorder(exitSignals ...os.Signal) *SignalRecoder

func (*SignalRecoder) Load

func (r *SignalRecoder) Load(err error) (ifrit.Runner, bool)

func (*SignalRecoder) ReceivedSignals

func (r *SignalRecoder) ReceivedSignals() []os.Signal

func (*SignalRecoder) Run

func (r *SignalRecoder) Run(sigChan <-chan os.Signal, ready chan<- struct{}) error