metrics

Documentation

Index

• func Middlewares() moleculer.Middlewares
• type TransportMetricsCollector
  • func NewTransportMetricsCollector(broker *moleculer.BrokerDelegates, transport transit.Transport) *TransportMetricsCollector
  • func (tmc *TransportMetricsCollector) EmitBufferPoolEvent(eventType string, size int, details map[string]interface{})
  • func (tmc *TransportMetricsCollector) EmitConnectionEvent(eventType string, nodeID string, details map[string]interface{})
  • func (tmc *TransportMetricsCollector) EmitTransportMetrics()
  • func (tmc *TransportMetricsCollector) StartPeriodicCollection(interval time.Duration)

Functions

func Middlewares

func Middlewares() moleculer.Middlewares

Middleware create a metrics middleware

Types

type TransportMetricsCollector

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

TransportMetricsCollector collects and emits transport-specific metrics

func NewTransportMetricsCollector

func NewTransportMetricsCollector(broker *moleculer.BrokerDelegates, transport transit.Transport) *TransportMetricsCollector

NewTransportMetricsCollector creates a new transport metrics collector

func (*TransportMetricsCollector) EmitBufferPoolEvent

func (tmc *TransportMetricsCollector) EmitBufferPoolEvent(eventType string, size int, details map[string]interface{})

EmitBufferPoolEvent emits buffer pool related events

func (*TransportMetricsCollector) EmitConnectionEvent

func (tmc *TransportMetricsCollector) EmitConnectionEvent(eventType string, nodeID string, details map[string]interface{})

EmitConnectionEvent emits connection-related events

func (*TransportMetricsCollector) EmitTransportMetrics

func (tmc *TransportMetricsCollector) EmitTransportMetrics()

EmitTransportMetrics emits transport metrics as events

func (*TransportMetricsCollector) StartPeriodicCollection

func (tmc *TransportMetricsCollector) StartPeriodicCollection(interval time.Duration)

StartPeriodicCollection starts periodic collection of transport metrics