metrics

Documentation

Index

• Variables
• func EmitAPIRequest(ctx context.Context, log *zap.Logger, fields []zapcore.Field, ...)
• func EmitBootstrapPeersConnected(ctx context.Context, host host.Host, bootstrapPeers map[peer.ID]bool)
• func EmitMLSSentGroupMessage(ctx context.Context, log *zap.Logger, msg *queries.GroupMessage)
• func EmitMLSSentWelcomeMessage(ctx context.Context, log *zap.Logger, msg *queries.WelcomeMessage)
• func EmitPeersByProtocol(ctx context.Context, host host.Host)
• func EmitPublishedEnvelope(ctx context.Context, log *zap.Logger, env *proto.Envelope)
• func EmitQuery(ctx context.Context, req *proto.QueryRequest, results int, err error, ...)
• func EmitRatelimiterBucketsSize(ctx context.Context, name string, size int)
• func EmitRatelimiterDeletedEntries(ctx context.Context, name string, count int)
• func EmitStoredMessages(ctx context.Context, db *sql.DB, logger *zap.Logger)
• func EmitSubscribeTopics(ctx context.Context, log *zap.Logger, topics int)
• func EmitSubscriptionChange(ctx context.Context, log *zap.Logger, delta int)
• func EmitUnsubscribeTopics(ctx context.Context, log *zap.Logger, topics int)
• type Server
  • func NewMetricsServer(ctx context.Context, address string, port int, log *zap.Logger, ...) (*Server, error)
  • func (s *Server) Close() error

Variables

var BootstrapPeers = prometheus.NewGauge(
	prometheus.GaugeOpts{
		Name: "xmtp_bootstrap_peers",
		Help: "Percentage of bootstrap peers connected",
	},
)

var PeersByProto = prometheus.NewGaugeVec(
	prometheus.GaugeOpts{
		Name: "xmtp_peers_by_proto",
		Help: "Count of peers by protocol",
	},
	[]string{"protocol"},
)

var StoredMessages = prometheus.NewGauge(
	prometheus.GaugeOpts{
		Name: "xmtp_stored_messages",
		Help: "Count of stored messages",
	},
)

Functions

func EmitAPIRequest

func EmitAPIRequest(ctx context.Context, log *zap.Logger, fields []zapcore.Field, duration time.Duration)

func EmitBootstrapPeersConnected

func EmitBootstrapPeersConnected(ctx context.Context, host host.Host, bootstrapPeers map[peer.ID]bool)

func EmitMLSSentGroupMessage

func EmitMLSSentGroupMessage(ctx context.Context, log *zap.Logger, msg *queries.GroupMessage)

func EmitMLSSentWelcomeMessage

func EmitMLSSentWelcomeMessage(ctx context.Context, log *zap.Logger, msg *queries.WelcomeMessage)

func EmitPeersByProtocol

func EmitPeersByProtocol(ctx context.Context, host host.Host)

func EmitPublishedEnvelope

func EmitPublishedEnvelope(ctx context.Context, log *zap.Logger, env *proto.Envelope)

func EmitQuery

func EmitQuery(ctx context.Context, req *proto.QueryRequest, results int, err error, duration time.Duration)

func EmitRatelimiterBucketsSize

func EmitRatelimiterBucketsSize(ctx context.Context, name string, size int)

func EmitRatelimiterDeletedEntries

func EmitRatelimiterDeletedEntries(ctx context.Context, name string, count int)

func EmitStoredMessages

func EmitStoredMessages(ctx context.Context, db *sql.DB, logger *zap.Logger)

func EmitSubscribeTopics

func EmitSubscribeTopics(ctx context.Context, log *zap.Logger, topics int)

func EmitSubscriptionChange

func EmitSubscriptionChange(ctx context.Context, log *zap.Logger, delta int)

func EmitUnsubscribeTopics

func EmitUnsubscribeTopics(ctx context.Context, log *zap.Logger, topics int)

Types

type Server

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

func NewMetricsServer

func NewMetricsServer(ctx context.Context, address string, port int, log *zap.Logger, reg *prometheus.Registry) (*Server, error)

func (*Server) Close

func (s *Server) Close() error