heartbeat

type Options ¶

type Options struct {
	Timeout    time.Duration
	Self       netservice.Instance
	Registries []netservice.Instance
}

type PokeLooper ¶

type PokeLooper interface {
	Loop()
}

func NewLooper(
	interval time.Duration,
	index store.Index,
	statter statsd.Statter,
	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(options Options) Sender