natsmembership

README

go-natsmembership

Tools for process group membership using a nats transport

Documentation

Index

• type HeartbeatObserver
  • func NewHeartbeatObserver(nc *nats.Conn, opts ...HeartbeatObserverOpt) *HeartbeatObserver
  • func (h *HeartbeatObserver) Listen(ctx context.Context, natsSubject string) error
  • func (h *HeartbeatObserver) Members() []string
• type HeartbeatObserverOpt
  • func WithRollingWindow(d time.Duration) HeartbeatObserverOpt
• type HeartbeatPublisher
  • func NewHeartbeatPublisher(nc *nats.Conn, opts ...HeartbeatPublisherOpt) *HeartbeatPublisher
  • func (h *HeartbeatPublisher) Publish(ctx context.Context, natsSubject, memberName string) error
• type HeartbeatPublisherOpt
  • func WithMaxRetries(maxRetries int) HeartbeatPublisherOpt
  • func WithPublishInterval(interval time.Duration) HeartbeatPublisherOpt

Types

type HeartbeatObserver

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

func NewHeartbeatObserver

func NewHeartbeatObserver(nc *nats.Conn, opts ...HeartbeatObserverOpt) *HeartbeatObserver

func (*HeartbeatObserver) Listen

func (h *HeartbeatObserver) Listen(ctx context.Context, natsSubject string) error

func (*HeartbeatObserver) Members

func (h *HeartbeatObserver) Members() []string

type HeartbeatObserverOpt

type HeartbeatObserverOpt func(*HeartbeatObserver)

func WithRollingWindow

func WithRollingWindow(d time.Duration) HeartbeatObserverOpt

type HeartbeatPublisher

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

func NewHeartbeatPublisher

func NewHeartbeatPublisher(nc *nats.Conn, opts ...HeartbeatPublisherOpt) *HeartbeatPublisher

func (*HeartbeatPublisher) Publish

func (h *HeartbeatPublisher) Publish(ctx context.Context, natsSubject, memberName string) error

type HeartbeatPublisherOpt

type HeartbeatPublisherOpt func(*HeartbeatPublisher)

func WithMaxRetries

func WithMaxRetries(maxRetries int) HeartbeatPublisherOpt

func WithPublishInterval

func WithPublishInterval(interval time.Duration) HeartbeatPublisherOpt