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 Option
  • func SetConsumerRegisterTopic(topic string) Option
  • func SetHeartbeatTickerTime(ti time.Duration) Option
  • func SetHeartbeatTopic(topic string) Option
  • func SetLogger(l logrus.FieldLogger) 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 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