server

Documentation

Index

• func NewGetHealthzHandler(s *Server) GetHealthzHandler
• func NewGetStatusHandler(s *Server) GetStatusHandler
• func NewHealthNode(elem *models.NodeElement) healthNode
• func NewPutStatusProbeHandler(s *Server) PutStatusProbeHandler
• type Config
• type Server
  • func NewServer(config Config) (*Server, error)
  • func (s *Server) DumpUptime() string
  • func (s *Server) FetchStatusResponse() (*healthModels.HealthStatusResponse, error)
  • func (s *Server) GetStatusResponse() *healthModels.HealthStatusResponse
  • func (s *Server) Serve() (err error)
  • func (s *Server) Shutdown()

Functions

func NewGetHealthzHandler

func NewGetHealthzHandler(s *Server) GetHealthzHandler

NewGetHealthzHandler handles health requests.

func NewGetStatusHandler

func NewGetStatusHandler(s *Server) GetStatusHandler

NewGetStatusHandler handles requests for cached connectivity status.

func NewHealthNode

func NewHealthNode(elem *models.NodeElement) healthNode

NewHealthNode creates a new node structure based on the specified model.

func NewPutStatusProbeHandler

func NewPutStatusProbeHandler(s *Server) PutStatusProbeHandler

NewPutStatusProbeHandler handles requests for connectivity probes.

Types

type Config

type Config struct {
	Debug         bool
	CiliumURI     string
	ProbeInterval time.Duration
	ProbeDeadline time.Duration
	HTTPPathPort  int
}

Config stores the configuration data for a cilium-health server.

type Server

type Server struct {
	healthApi.Server  // Server to provide cilium-health API
	*ciliumPkg.Client // Client to "GET /healthz" on cilium daemon
	Config

	// The lock protects against read and write access to the IP->Node map,
	// the list of statuses as most recently seen, and the last time a
	// probe was conducted.
	lock.RWMutex
	// contains filtered or unexported fields
}

Server is the cilium-health daemon that is in charge of performing health and connectivity checks periodically, and serving the cilium-health API.

func NewServer

func NewServer(config Config) (*Server, error)

NewServer creates a server to handle health requests.

func (*Server) DumpUptime

func (s *Server) DumpUptime() string

DumpUptime returns the time that this server has been running.

func (*Server) FetchStatusResponse

func (s *Server) FetchStatusResponse() (*healthModels.HealthStatusResponse, error)

FetchStatusResponse updates the cluster with the latest set of nodes, runs a synchronous probe across the cluster, updates the connectivity cache and returns the results.

func (*Server) GetStatusResponse

func (s *Server) GetStatusResponse() *healthModels.HealthStatusResponse

GetStatusResponse returns the most recent cluster connectivity status.

func (*Server) Serve

func (s *Server) Serve() (err error)

Serve spins up the following goroutines:

• HTTP API Server: Responder to the health API "/hello" message
• Prober: Periodically run pings across the cluster at a configured interval and update the server's connectivity status cache.
• Unix API Server: Handle all health API requests over a unix socket.

Callers should first defer the Server.Shutdown(), then call Serve().

func (*Server) Shutdown

func (s *Server) Shutdown()

Shutdown server and clean up resources