management

Documentation

Index

• Variables
• type ClientMetrics
  • func NewClientMetrics(id server.ConnectorId, registerer prometheus.Registerer) *ClientMetrics
• type ConnectionMetrics
  • func NewConnectionMetrics(registerer prometheus.Registerer, variant string) *ConnectionMetrics
• type ConnectionStates
• type ConnectorEnabledClientMetrics
  • func NewConnectorEnabledClientMetrics(connectorIds []server.ConnectorId, registerer prometheus.Registerer) ConnectorEnabledClientMetrics
• type Management
  • func New(s *settings.Settings, connectorIds []server.ConnectorId, ...) (*Management, error)
  • func (this *Management) CollectClientStarted(connector server.ConnectorId) func()
  • func (this *Management) CollectContext(ctx *lctx.Context)
  • func (this *Management) CollectUpstreamStarted() func()
  • func (this *Management) Init(stop support.Channel) error
  • func (this *Management) ServeHTTP(resp http.ResponseWriter, req *http.Request)
• type Metrics
  • func NewMetrics(connectorIds []server.ConnectorId, rulesRepository rules.Repository) *Metrics
  • func (this *Metrics) CollectClientStarted(connector server.ConnectorId) func()
  • func (this *Metrics) CollectContext(ctx *context.Context)
  • func (this *Metrics) CollectUpstreamStarted() func()
  • func (this *Metrics) ServeHTTP(resp http.ResponseWriter, req *http.Request)
• type RequestMetrics
  • func NewRequestMetrics(registerer prometheus.Registerer, variant string, buckets []float64) *RequestMetrics
• type RequestStates
• type RulesMetrics
  • func NewRulesMetrics(registerer prometheus.Registerer, rulesRepository rules.Repository) *RulesMetrics
• type UpstreamMetrics
  • func NewUpstreamMetrics(registerer prometheus.Registerer) *UpstreamMetrics

Variables

var (
	MetricsLabelNames = []string{
		"client_status",
		"client_status_summary",
		"upstream_status",
		"upstream_status_summary",
		"rule",
	}
)

Types

type ClientMetrics

type ClientMetrics struct {
	Request     *RequestMetrics
	Connections *ConnectionMetrics
}

func NewClientMetrics

func NewClientMetrics(id server.ConnectorId, registerer prometheus.Registerer) *ClientMetrics

type ConnectionMetrics

type ConnectionMetrics struct {
	New    prometheus.GaugeFunc
	Active prometheus.GaugeFunc
	Idle   prometheus.GaugeFunc

	Current prometheus.GaugeFunc
	Total   prometheus.GaugeFunc

	Source *ConnectionStates
}

func NewConnectionMetrics

func NewConnectionMetrics(registerer prometheus.Registerer, variant string) *ConnectionMetrics

type ConnectionStates

type ConnectionStates struct {
	New    uint64
	Active uint64
	Idle   uint64

	Current uint64
	Total   uint64
	Max     uint64
}

type ConnectorEnabledClientMetrics

type ConnectorEnabledClientMetrics map[server.ConnectorId]*ClientMetrics

func NewConnectorEnabledClientMetrics

func NewConnectorEnabledClientMetrics(connectorIds []server.ConnectorId, registerer prometheus.Registerer) ConnectorEnabledClientMetrics

type Management

type Management struct {
	Metrics *Metrics
	Logger  log.Logger
	// contains filtered or unexported fields
}

func New

func New(s *settings.Settings, connectorIds []server.ConnectorId, rulesRepository rules.Repository, logger log.Logger) (*Management, error)

func (*Management) CollectClientStarted

func (this *Management) CollectClientStarted(connector server.ConnectorId) func()

func (*Management) CollectContext

func (this *Management) CollectContext(ctx *lctx.Context)

func (*Management) CollectUpstreamStarted

func (this *Management) CollectUpstreamStarted() func()

func (*Management) Init

func (this *Management) Init(stop support.Channel) error

func (*Management) ServeHTTP

func (this *Management) ServeHTTP(resp http.ResponseWriter, req *http.Request)

type Metrics

type Metrics struct {
	Client   ConnectorEnabledClientMetrics
	Upstream *UpstreamMetrics
	Rules    *RulesMetrics

	Registry *prometheus.Registry
	Handler  http.Handler
}

func NewMetrics

func NewMetrics(connectorIds []server.ConnectorId, rulesRepository rules.Repository) *Metrics

func (*Metrics) CollectClientStarted

func (this *Metrics) CollectClientStarted(connector server.ConnectorId) func()

func (*Metrics) CollectContext

func (this *Metrics) CollectContext(ctx *context.Context)

func (*Metrics) CollectUpstreamStarted

func (this *Metrics) CollectUpstreamStarted() func()

func (*Metrics) ServeHTTP

func (this *Metrics) ServeHTTP(resp http.ResponseWriter, req *http.Request)

type RequestMetrics

type RequestMetrics struct {
	DurationSeconds *prometheus.HistogramVec
	Total           *prometheus.CounterVec

	Current prometheus.GaugeFunc

	Source *RequestStates
}

func NewRequestMetrics

func NewRequestMetrics(registerer prometheus.Registerer, variant string, buckets []float64) *RequestMetrics

type RequestStates

type RequestStates struct {
	Current uint64
}

type RulesMetrics

type RulesMetrics struct {
	Total   prometheus.GaugeFunc
	Sources prometheus.GaugeFunc
	// contains filtered or unexported fields
}

func NewRulesMetrics

func NewRulesMetrics(registerer prometheus.Registerer, rulesRepository rules.Repository) *RulesMetrics

type UpstreamMetrics

type UpstreamMetrics struct {
	Request *RequestMetrics
}

func NewUpstreamMetrics

func NewUpstreamMetrics(registerer prometheus.Registerer) *UpstreamMetrics