heart

Apr 27, 2020

Changes in this version

+ var Debug = func(v ...interface{})

+ var ErrDead = errors.New("no heartbeat replied")

+ type AtomicTime struct

+ func (t *AtomicTime) Get() int64

+ func (t *AtomicTime) Set(time time.Time)

+ func (t *AtomicTime) Time() time.Time

+ type Pacemaker struct

+ EchoBeat AtomicTime

+ Heartrate time.Duration

+ Pace func() error

+ SentBeat AtomicTime

+ func NewPacemaker(heartrate time.Duration, pacer func() error) *Pacemaker

+ func (p *Pacemaker) Dead() bool

+ func (p *Pacemaker) Echo()

+ func (p *Pacemaker) StartAsync(wg *sync.WaitGroup) (death chan error)

+ func (p *Pacemaker) Stop()