healthcheck

Documentation

Overview

Package healthcheck provides tools for serving kube-proxy healthchecks.

Index

• type FakeServiceHealthServer
  • func (fake FakeServiceHealthServer) SyncEndpoints(_ map[types.NamespacedName]int) error
  • func (fake FakeServiceHealthServer) SyncServices(_ map[types.NamespacedName]uint16) error
• type ProxierHealthServer
  • func NewProxierHealthServer(addr string, healthTimeout time.Duration, recorder record.EventRecorder, ...) *ProxierHealthServer
  • func (hs *ProxierHealthServer) QueuedUpdate()
  • func (hs *ProxierHealthServer) Run()
  • func (hs *ProxierHealthServer) Updated()
• type ProxierHealthUpdater
• type ServiceHealthServer
  • func NewFakeServiceHealthServer() ServiceHealthServer
  • func NewServiceHealthServer(hostname string, recorder record.EventRecorder) ServiceHealthServer

Types

type FakeServiceHealthServer

type FakeServiceHealthServer struct{}

FakeServiceHealthServer is a fake ServiceHealthServer for test programs

func (FakeServiceHealthServer) SyncEndpoints

func (fake FakeServiceHealthServer) SyncEndpoints(_ map[types.NamespacedName]int) error

SyncEndpoints is part of ServiceHealthServer

func (FakeServiceHealthServer) SyncServices

func (fake FakeServiceHealthServer) SyncServices(_ map[types.NamespacedName]uint16) error

SyncServices is part of ServiceHealthServer

type ProxierHealthServer

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

ProxierHealthServer returns 200 "OK" by default. It verifies that the delay between QueuedUpdate() calls and Updated() calls never exceeds healthTimeout.

func NewProxierHealthServer

func NewProxierHealthServer(addr string, healthTimeout time.Duration, recorder record.EventRecorder, nodeRef *v1.ObjectReference) *ProxierHealthServer

NewProxierHealthServer returns a proxier health http server.

func (*ProxierHealthServer) QueuedUpdate

func (hs *ProxierHealthServer) QueuedUpdate()

QueuedUpdate updates the lastQueued timestamp.

func (*ProxierHealthServer) Run

func (hs *ProxierHealthServer) Run()

Run starts the healthz http server and returns.

func (*ProxierHealthServer) Updated

func (hs *ProxierHealthServer) Updated()

Updated updates the lastUpdated timestamp.

type ProxierHealthUpdater

type ProxierHealthUpdater interface {
	// QueuedUpdate should be called when the proxier receives a Service or Endpoints
	// event containing information that requires updating service rules.
	QueuedUpdate()

	// Updated should be called when the proxier has successfully updated the service
	// rules to reflect the current state.
	Updated()
}

ProxierHealthUpdater allows callers to update healthz timestamp only.

type ServiceHealthServer

type ServiceHealthServer interface {
	// Make the new set of services be active.  Services that were open before
	// will be closed.  Services that are new will be opened.  Service that
	// existed and are in the new set will be left alone.  The value of the map
	// is the healthcheck-port to listen on.
	SyncServices(newServices map[types.NamespacedName]uint16) error
	// Make the new set of endpoints be active.  Endpoints for services that do
	// not exist will be dropped.  The value of the map is the number of
	// endpoints the service has on this node.
	SyncEndpoints(newEndpoints map[types.NamespacedName]int) error
}

ServiceHealthServer serves HTTP endpoints for each service name, with results based on the endpoints. If there are 0 endpoints for a service, it returns a 503 "Service Unavailable" error (telling LBs not to use this node). If there are 1 or more endpoints, it returns a 200 "OK".

func NewFakeServiceHealthServer

func NewFakeServiceHealthServer() ServiceHealthServer

NewFakeServiceHealthServer allocates a new fake service healthcheck server manager

func NewServiceHealthServer

func NewServiceHealthServer(hostname string, recorder record.EventRecorder) ServiceHealthServer

NewServiceHealthServer allocates a new service healthcheck server manager