heartbeat

Documentation

Index

• type PokeLooper
  • func NewLooper(interval time.Duration, index store.Index, emitter stats.Sender, sender Sender) PokeLooper
• type Sender
  • func NewSender(self netservice.Instance, registryClient registry.Client, emitter stats.Sender) Sender

Types

type PokeLooper

type PokeLooper interface {
	Loop()
}

func NewLooper

func NewLooper(
	interval time.Duration,
	index store.Index,
	emitter stats.Sender,
	sender Sender,
) PokeLooper

type Sender

type Sender interface {
	Send(int, int) error
}

A Sender is used to send heartbeat status updates to the registry.

func NewSender

func NewSender(
	self netservice.Instance,
	registryClient registry.Client,
	emitter stats.Sender,
) Sender