messages

Documentation

Index

• Constants
• type NatsErrorCounter
  • func NewNatsErrorCounter() *NatsErrorCounter
  • func (c *NatsErrorCounter) HandleNatsError(conn *nats.Conn, sub *nats.Subscription, err error)

Constants

const VizierConnectedChannel = "VizierConnected"

VizierConnectedChannel is the channel to listen to be notified of Viziers connecting. The message passed along this channel is of type px.cloud.messages.VizierConnected.

Types

type NatsErrorCounter

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

NatsErrorCounter is a counter for NATS errors.

func NewNatsErrorCounter

func NewNatsErrorCounter() *NatsErrorCounter

NewNatsErrorCounter creates a new counter for NATS errors.

func (*NatsErrorCounter) HandleNatsError

func (c *NatsErrorCounter) HandleNatsError(conn *nats.Conn, sub *nats.Subscription, err error)

HandleNatsError handles the Nats error by logging and tracking metrics.