admin

Documentation

Index

• type ReverseProxy
  • func NewReverseProxy(logger log.Logger) *ReverseProxy
  • func (p *ReverseProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Server
  • func NewServer(clusterState *cluster.State, registry *prometheus.Registry, ...) *Server
  • func (s *Server) AddStatus(route string, handler status.Handler)
  • func (s *Server) Serve(ln net.Listener) error
  • func (s *Server) SetReady(ready bool)
  • func (s *Server) Shutdown(ctx context.Context) error

Types

type ReverseProxy

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

func NewReverseProxy

func NewReverseProxy(logger log.Logger) *ReverseProxy

func (*ReverseProxy) ServeHTTP

func (p *ReverseProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Server

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

Server is the admin HTTP server, which exposes endpoints for metrics, health and inspecting the node status.

func NewServer

func NewServer(
	clusterState *cluster.State,
	registry *prometheus.Registry,
	verifier auth.Verifier,
	tlsConfig *tls.Config,
	logger log.Logger,
) *Server

func (*Server) AddStatus

func (s *Server) AddStatus(route string, handler status.Handler)

func (*Server) Serve

func (s *Server) Serve(ln net.Listener) error

func (*Server) SetReady

func (s *Server) SetReady(ready bool)

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

Shutdown attempts to gracefully shutdown the server by waiting for pending requests to complete.