heartbeat

Sep 22, 2020

Changes in this version

+ const CurrentConsumersTopic

type Handler

+ func (h *Handler) Close()

type Option

+ func SetCurrentConsumersTopic(topic string) Option

Sep 22, 2020

Changes in this version

+ const MetricsTimeout

type Option

+ func SetMetricsTimeout(t time.Duration) Option

Sep 13, 2020

Changes in this version

type MetricsHandler

+ ResetConsumerRegistered func()

type NilMetrics

+ func (m *NilMetrics) ResetConsumerRegistered()

Sep 13, 2020

Changes in this version

+ type MetricsHandler interface

+ RecordConsumerRegistered func(id string)

+ type NilMetrics struct

+ func NewNilMetrics() *NilMetrics

+ func (m *NilMetrics) RecordConsumerRegistered(id string)

type Option

+ func SetMetrics(m MetricsHandler) Option

Aug 31, 2020

Changes in this version

+ const ConsumerRegisterTopic

+ const PublisherTopic

+ const TickerTime

+ type Handler struct

+ 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 Option func(h *Handler)

+ func SetConsumerRegisterTopic(topic string) Option

+ func SetHeartbeatTickerTime(ti time.Duration) Option

+ func SetHeartbeatTopic(topic string) Option

+ func SetLogger(l logrus.FieldLogger) Option