vkubelet

Documentation

Index

• func InstrumentHandler(h http.Handler) http.Handler
• func KubeletServerStart(p providers.Provider, l net.Listener, cert, key string)
• func MetricsServerStart(p providers.Provider, l net.Listener)
• func MetricsSummaryHandler(p providers.Provider) http.Handler
• func NotFound(w http.ResponseWriter, r *http.Request)
• func NotImplemented(w http.ResponseWriter, r *http.Request)
• func PodHandler(p providers.Provider) http.Handler
• type APIConfig
• type Config
• type Server
  • func New(ctx context.Context, cfg Config) (s *Server, retErr error)
  • func (s *Server) Run(ctx context.Context) error
  • func (s *Server) Stop()

Functions

func InstrumentHandler

func InstrumentHandler(h http.Handler) http.Handler

InstrumentHandler wraps an http.Handler and injects instrumentation into the request context.

func KubeletServerStart

func KubeletServerStart(p providers.Provider, l net.Listener, cert, key string)

KubeletServerStart starts the virtual kubelet HTTP server.

func MetricsServerStart

func MetricsServerStart(p providers.Provider, l net.Listener)

MetricsServerStart starts an HTTP server on the provided addr for serving the kubelset summary stats API.

func MetricsSummaryHandler

func MetricsSummaryHandler(p providers.Provider) http.Handler

MetricsSummaryHandler creates an http handler for serving pod metrics.

If the passed in provider does not implement providers.PodMetricsProvider, it will create handlers that just serves http.StatusNotImplemented

func NotFound

func NotFound(w http.ResponseWriter, r *http.Request)

NotFound provides a handler for cases where the requested endpoint doesn't exist

func NotImplemented

func NotImplemented(w http.ResponseWriter, r *http.Request)

NotImplemented provides a handler for cases where a provider does not implement a given API

func PodHandler

func PodHandler(p providers.Provider) http.Handler

PodHandler creates an http handler for interacting with pods/containers.

Types

type APIConfig

type APIConfig struct {
	CertPath string
	KeyPath  string
	Addr     string
}

APIConfig is used to configure the API server of the virtual kubelet.

type Config

type Config struct {
	APIConfig       APIConfig
	Client          *kubernetes.Clientset
	MetricsAddr     string
	Namespace       string
	NodeName        string
	Provider        providers.Provider
	ResourceManager *manager.ResourceManager
	Taint           *corev1.Taint
	PodSyncWorkers  int
}

Config is used to configure a new server.

type Server

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

Server masquarades itself as a kubelet and allows for the virtual node to be backed by non-vm/node providers.

func New

func New(ctx context.Context, cfg Config) (s *Server, retErr error)

New creates a new virtual-kubelet server.

func (*Server) Run

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

Run starts the server, registers it with Kubernetes and begins watching/reconciling the cluster. Run will block until Stop is called or a SIGINT or SIGTERM signal is received.

func (*Server) Stop

func (s *Server) Stop()

Stop shutsdown the server. It does not shutdown pods assigned to the virtual node.