heartbeat

Documentation

Index

• type Heartbeater
  • func NewHeartbeater(p Pinger) *Heartbeater
  • func (m *Heartbeater) Run(ctx context.Context)
• type Pinger

Types

type Heartbeater

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

Heartbeater sends pings to the platform.

func NewHeartbeater

func NewHeartbeater(p Pinger) *Heartbeater

NewHeartbeater creates a new heartbeater using the given Pinger.

func (*Heartbeater) Run

func (m *Heartbeater) Run(ctx context.Context)

Run runs the Heartbeater. This is a blocking method.

type Pinger

type Pinger interface {
	Ping(ctx context.Context) error
}

Pinger can ping the platform.