heartbeat

Documentation

Overview

Package heartbeat defines the heartbeat system that starts up along side the stream replicator. If configured it will send a heartbeat messages to the configured subjects on a configurable interval.

Index

• Constants
• type HeartBeat
  • func New(hbcfg *config.HeartBeat, replicatorName string, log *logrus.Entry) (*HeartBeat, error)
  • func (hb *HeartBeat) Run(ctx context.Context, wg *sync.WaitGroup) error
• type Subject

Constants

const (
	DefaultUpdateInterval = "10s"
	OriginatorHeader      = "Choria-SR-Originator"
	SubjectHeader         = "Choria-SR-Subject"
)

Types

type HeartBeat

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

func New

func New(hbcfg *config.HeartBeat, replicatorName string, log *logrus.Entry) (*HeartBeat, error)

New creates a new instance of the Heartbeat struct

func (*HeartBeat) Run

func (hb *HeartBeat) Run(ctx context.Context, wg *sync.WaitGroup) error

Run initializes a the jetstream connection and spawns a go routine for every configured subject that will publish a heartbeat message on the defined interval

type Subject

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