monitoring

Documentation

Index

• Constants
• Variables
• func GetStatusServiceConfig() (name, namespace string, err error)
• func IsNoDataError(err error) bool
• type Collector
  • func NewBPFCollector() (Collector, error)
  • func NewFRRCollector() (Collector, error)
  • func NewNetlinkCollector() (Collector, error)
• type DasSchiffNetworkOperatorCollector
  • func NewDasSchiffNetworkOperatorCollector(collectorConfig map[string]bool) (*DasSchiffNetworkOperatorCollector, error)
  • func (n DasSchiffNetworkOperatorCollector) Collect(ch chan<- prometheus.Metric)
  • func (DasSchiffNetworkOperatorCollector) Describe(ch chan<- *prometheus.Desc)
• type Endpoint
  • func NewEndpoint(k8sClient client.Client, frrcli FRRClient, svcName, svcNamespace string) *Endpoint
  • func (e *Endpoint) CreateMux() *http.ServeMux
  • func (e *Endpoint) QueryAll(w http.ResponseWriter, r *http.Request)
  • func (e *Endpoint) ShowBGP(w http.ResponseWriter, r *http.Request)
  • func (e *Endpoint) ShowBGPSummary(w http.ResponseWriter, r *http.Request)
  • func (e *Endpoint) ShowEVPN(w http.ResponseWriter, r *http.Request)
  • func (e *Endpoint) ShowRoute(w http.ResponseWriter, r *http.Request)
• type FRRClient

Constants

const (
	StatusSvcNameEnv      = "STATUS_SVC_NAME"
	StatusSvcNamespaceEnv = "STATUS_SVC_NAMESPACE"
)

Variables

var ErrNoData = errors.New("collector returned no data")

ErrNoData indicates the collector found no data to collect, but had no other error.

Functions

func GetStatusServiceConfig

func GetStatusServiceConfig() (name, namespace string, err error)

GetStatusServiceConfig gets status service's name and namespace from the environment.

func IsNoDataError

func IsNoDataError(err error) bool

Types

type Collector

type Collector interface {
	// Get new metrics and expose them via prometheus registry.
	Update(ch chan<- prometheus.Metric) error
}

Collector is the interface a collector has to implement.

func NewBPFCollector

func NewBPFCollector() (Collector, error)

func NewFRRCollector

func NewFRRCollector() (Collector, error)

NewFRRCollector returns a new Collector exposing buddyinfo stats.

func NewNetlinkCollector

func NewNetlinkCollector() (Collector, error)

NewNetlinkCollector returns a new Collector exposing buddyinfo stats.

type DasSchiffNetworkOperatorCollector

type DasSchiffNetworkOperatorCollector struct {
	Collectors map[string]Collector
}

DasSchiffNetworkOperatorCollector implements the prometheus.Collector interface.

func NewDasSchiffNetworkOperatorCollector

func NewDasSchiffNetworkOperatorCollector(collectorConfig map[string]bool) (*DasSchiffNetworkOperatorCollector, error)

NewDasSchiffNetworkOperatorCollector creates a new DasSchiffNetworkOperatorCollector.

func (DasSchiffNetworkOperatorCollector) Collect

func (n DasSchiffNetworkOperatorCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (DasSchiffNetworkOperatorCollector) Describe

func (DasSchiffNetworkOperatorCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface.

type Endpoint

type Endpoint struct {
	logr.Logger
	// contains filtered or unexported fields
}

func NewEndpoint

func NewEndpoint(k8sClient client.Client, frrcli FRRClient, svcName, svcNamespace string) *Endpoint

NewEndpoint creates new endpoint object.

func (*Endpoint) CreateMux

func (e *Endpoint) CreateMux() *http.ServeMux

CreateMux configures HTTP handlers.

func (*Endpoint) QueryAll

func (e *Endpoint) QueryAll(w http.ResponseWriter, r *http.Request)

QueryAll - when called, will pass the request to all nodes and return their responses.

func (*Endpoint) ShowBGP

func (e *Endpoint) ShowBGP(w http.ResponseWriter, r *http.Request)

ShowBGP returns a result of show bgp command. show bgp (vrf <vrf>) ipv4/ipv6 unicast <input> (longer-prefixes). show bgp vrf <all|vrf> summary.

func (*Endpoint) ShowBGPSummary

func (e *Endpoint) ShowBGPSummary(w http.ResponseWriter, r *http.Request)

ShowBGPSummary returns result of show bgp vrf <all|vrf> summary command.

func (*Endpoint) ShowEVPN

func (e *Endpoint) ShowEVPN(w http.ResponseWriter, r *http.Request)

ShowEVPN returns result of show evpn command. show evpn vni json. show evpn rmac vni <all|vrf>. show evpn mac vni <all|vrf>. show evpn next-hops vni <all|vrf> json.

func (*Endpoint) ShowRoute

func (e *Endpoint) ShowRoute(w http.ResponseWriter, r *http.Request)

ShowRoute returns result of show ip/ipv6 route command. show ip/ipv6 route (vrf <vrf>) <input> (longer-prefixes).

type FRRClient

type FRRClient interface {
	ExecuteWithJSON(args []string) []byte
}