heartbeat

README

heartbeat

A simple NATS Heartbeat lib

Documentation

Index

• Constants
• type Handler
  • func NewHandler(id string, nc *nats.Conn, hos ...Option) *Handler
  • func (h *Handler) GetConsumers() []string
  • func (h *Handler) ListenForConsumers()
  • func (h *Handler) ListenForHeartbeatPublisher()
  • func (h *Handler) StartHeartbeatPublisher()
• type MetricsHandler
• type NilMetrics
  • func NewNilMetrics() *NilMetrics
  • func (m *NilMetrics) RecordConsumerRegistered(id string)
• type Option
  • func SetConsumerRegisterTopic(topic string) Option
  • func SetHeartbeatTickerTime(ti time.Duration) Option
  • func SetHeartbeatTopic(topic string) Option
  • func SetLogger(l logrus.FieldLogger) Option
  • func SetMetrics(m MetricsHandler) Option

Constants

const (
	PublisherTopic        = "peer-heartbeat"
	ConsumerRegisterTopic = "peer-consumer-register"
	TickerTime            = 30 * time.Second
)

Types

type Handler

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

func NewHandler

func NewHandler(id string, nc *nats.Conn, hos ...Option) *Handler

func (*Handler) GetConsumers

func (h *Handler) GetConsumers() []string

func (*Handler) ListenForConsumers

func (h *Handler) ListenForConsumers()

func (*Handler) ListenForHeartbeatPublisher

func (h *Handler) ListenForHeartbeatPublisher()

func (*Handler) StartHeartbeatPublisher

func (h *Handler) StartHeartbeatPublisher()

type MetricsHandler

type MetricsHandler interface {
	RecordConsumerRegistered(id string)
}

type NilMetrics

type NilMetrics struct {
}

func NewNilMetrics

func NewNilMetrics() *NilMetrics

func (*NilMetrics) RecordConsumerRegistered

func (m *NilMetrics) RecordConsumerRegistered(id string)

type Option

type Option func(h *Handler)

func SetConsumerRegisterTopic

func SetConsumerRegisterTopic(topic string) Option

func SetHeartbeatTickerTime

func SetHeartbeatTickerTime(ti time.Duration) Option

func SetHeartbeatTopic

func SetHeartbeatTopic(topic string) Option

func SetLogger

func SetLogger(l logrus.FieldLogger) Option

func SetMetrics

func SetMetrics(m MetricsHandler) Option