Documentation

Overview

    Package healthcheck provides tools for serving kube-proxy healthchecks.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    This section is empty.

    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 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()
          
          	// Run starts the healthz HTTP server and blocks until it exits.
          	Run() error
          }

            ProxierHealthUpdater allows callers to update healthz timestamp only.

            func NewProxierHealthServer

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

              NewProxierHealthServer returns a proxier health http server.

              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