srv

Documentation

Index

• Constants
• func NewServer(addr string, grafanaAddr string, controllerNamespace string, ...) *http.Server
• type AppVersionNamespace
• type Edge
• type EdgeResp
• type Node
• type Server
  • func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

Constants

const (
	RPS         = `sum(irate(request_total%s[%s])) by (app)`
	SUCCESSRATE = `sum(irate(response_total%s[%s])) by (app) / sum(irate(response_total%s[%s])) by (app)`

	DEBUG2 = `` /* 153-byte string literal not displayed */
	DEBUG3 = `histogram_quantile(0.5, sum(irate(response_latency_ms_bucket{direction="inbound"}[30s])) by (le,app))`

	IncomingIdentityQuery = `count(response_total{deployment!="", direction="inbound"}) by (deployment, app, version, client_id, namespace, no_tls_reason)`
	OutgoingIdentityQuery = `` /* 142-byte string literal not displayed */
)

Functions

func NewServer

func NewServer(
	addr string,
	grafanaAddr string,
	controllerNamespace string,
	clusterDomain string,
	reload bool,
	uuid string,
	apiClient api.Client,
	k8sAPI *k8s.KubernetesAPI,
) *http.Server

NewServer returns an initialized `http.Server`, configured to listen on an address, render templates, and serve static assets, for a given Linkerd control plane.

Types

type AppVersionNamespace

type AppVersionNamespace string

type Edge

type Edge struct {
	FromNamespace string             `json:"fromNamespace"`
	FromApp       string             `json:"fromApp"`
	FromVersion   string             `json:"fromVersion"`
	ToNamespace   string             `json:"toNamespace"`
	ToApp         string             `json:"toApp"`
	ToVersion     string             `json:"toVersion"`
	Stats         map[string]float64 `json:"stats,omitempty"`
}

type EdgeResp

type EdgeResp struct {
	Nodes     []Node `json:"nodes"`
	Edges     []Edge `json:"edges,omitempty"`
	Integrity string `json:"integrity"`
}

type Node

type Node struct {
	App       string             `json:"app"`
	Version   string             `json:"version"`
	Namespace string             `json:"namespace"`
	Stats     map[string]float64 `json:"stats,omitempty"`
}

type Server

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

Server encapsulates the code for talking with prometheus

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

this is called by the HTTP server to actually respond to a request