liveness

Documentation

Index

• type Liveness
  • func NewLiveness(timeSource clock.TimeSource, ttl time.Duration, broadcastShutdownFn func()) *Liveness
  • func (l *Liveness) IsAlive() bool
  • func (l *Liveness) MarkAlive()
  • func (l *Liveness) Start()
  • func (l *Liveness) Stop()

Types

type Liveness

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

func NewLiveness

func NewLiveness(timeSource clock.TimeSource, ttl time.Duration, broadcastShutdownFn func()) *Liveness

NewLiveness creates a Liveness daemon that calls the broadcastShutdownFn if it does not receive MarkAlive() within ttl NOTE: livesness needs to be stopped explicitly to avoid go routine leak

func (*Liveness) IsAlive

func (l *Liveness) IsAlive() bool

func (*Liveness) MarkAlive

func (l *Liveness) MarkAlive()

func (*Liveness) Start

func (l *Liveness) Start()

func (*Liveness) Stop

func (l *Liveness) Stop()

Stop ONLY shuts down liveness does not block on broadcastShutdownFn