heartbeat

Documentation

Index

• Variables
• type Heartbeater
  • func Start(sg *servergroup.ServerGroup) *Heartbeater
  • func (h *Heartbeater) GossipAdded(addr string)
  • func (h *Heartbeater) GossipDead(addr string)
  • func (h *Heartbeater) ListenReply(c *core.Core) func() protocol.AmAlive
  • func (h *Heartbeater) Stop()

Variables

var GossipNewsExpirationTime = time.Second * 10

Types

type Heartbeater

type Heartbeater struct {
	Sleep          time.Duration
	SleepOnFail    time.Duration
	Timeout        time.Duration
	TimeoutRetries time.Duration
	// contains filtered or unexported fields
}

Heartbeater is used to discover changes in the DB topology by using a ping-pong protocol Exported fields are used to configure various parameters

func Start

func Start(sg *servergroup.ServerGroup) *Heartbeater

Start a new heartbeater in the background and introduce the changes into sg It blocks until the first heartbeat of each server is served

func (*Heartbeater) GossipAdded

func (h *Heartbeater) GossipAdded(addr string)

func (*Heartbeater) GossipDead

func (h *Heartbeater) GossipDead(addr string)

func (*Heartbeater) ListenReply

func (h *Heartbeater) ListenReply(c *core.Core) func() protocol.AmAlive

ListenReply starts listening and repling to UDP heartbeat requests

func (*Heartbeater) Stop

func (h *Heartbeater) Stop()

Stop requesting and listening to heartbeats