server

Documentation

Overview

Package server makes it easy to create a kubelet server for various contexts.

Index

• func NewHyperkubeServer() *hyperkube.Server
• func ProbeVolumePlugins() []volume.Plugin
• func RunKubelet(kcfg *KubeletConfig)
• func SimpleRunKubelet(client *client.Client, etcdClient tools.EtcdClient, ...)
• type KubeletConfig
• type KubeletServer
  • func NewKubeletServer() *KubeletServer
  • func (s *KubeletServer) AddFlags(fs *pflag.FlagSet)
  • func (s *KubeletServer) Run(_ []string) error

Functions

func NewHyperkubeServer

func NewHyperkubeServer() *hyperkube.Server

NewHyperkubeServer creates a new hyperkube Server object that includes the description and flags.

func ProbeVolumePlugins

func ProbeVolumePlugins() []volume.Plugin

ProbeVolumePlugins collects all volume plugins into an easy to use list.

func RunKubelet

func RunKubelet(kcfg *KubeletConfig)

RunKubelet is responsible for setting up and running a kubelet. It is used in three different applications:

1 Integration tests
2 Kubelet binary
3 Standalone 'kubernetes' binary

Eventually, #2 will be replaced with instances of #3

func SimpleRunKubelet

func SimpleRunKubelet(client *client.Client,
	etcdClient tools.EtcdClient,
	dockerClient dockertools.DockerInterface,
	hostname, rootDir, manifestURL, address string,
	port uint,
	masterServiceNamespace string,
	volumePlugins []volume.Plugin)

SimpleRunKubelet is a simple way to start a Kubelet talking to dockerEndpoint, using an etcdClient. Under the hood it calls RunKubelet (below)

Types

type KubeletConfig

type KubeletConfig struct {
	EtcdClient              tools.EtcdClient
	KubeClient              *client.Client
	DockerClient            dockertools.DockerInterface
	CAdvisorPort            uint
	Address                 util.IP
	AllowPrivileged         bool
	HostnameOverride        string
	RootDirectory           string
	ConfigFile              string
	ManifestURL             string
	FileCheckFrequency      time.Duration
	HTTPCheckFrequency      time.Duration
	Hostname                string
	PodInfraContainerImage  string
	SyncFrequency           time.Duration
	RegistryPullQPS         float64
	RegistryBurst           int
	MinimumGCAge            time.Duration
	MaxContainerCount       int
	ClusterDomain           string
	ClusterDNS              util.IP
	EnableServer            bool
	EnableDebuggingHandlers bool
	Port                    uint
	Runonce                 bool
	MasterServiceNamespace  string
	VolumePlugins           []volume.Plugin
}

KubeletConfig is all of the parameters necessary for running a kubelet. TODO: This should probably be merged with KubeletServer. The extra object is a consequence of refactoring.

type KubeletServer

type KubeletServer struct {
	Config                  string
	SyncFrequency           time.Duration
	FileCheckFrequency      time.Duration
	HTTPCheckFrequency      time.Duration
	ManifestURL             string
	EnableServer            bool
	Address                 util.IP
	Port                    uint
	HostnameOverride        string
	PodInfraContainerImage  string
	DockerEndpoint          string
	EtcdServerList          util.StringList
	EtcdConfigFile          string
	RootDirectory           string
	AllowPrivileged         bool
	RegistryPullQPS         float64
	RegistryBurst           int
	RunOnce                 bool
	EnableDebuggingHandlers bool
	MinimumGCAge            time.Duration
	MaxContainerCount       int
	AuthPath                string
	CAdvisorPort            uint
	OOMScoreAdj             int
	APIServerList           util.StringList
	ClusterDomain           string
	MasterServiceNamespace  string
	ClusterDNS              util.IP
	ReallyCrashForTesting   bool
}

KubeletServer encapsulates all of the parameters necessary for starting up a kubelet. These can either be set via command line or directly.

func NewKubeletServer

func NewKubeletServer() *KubeletServer

NewKubeletServer will create a new KubeletServer with default values.

func (*KubeletServer) AddFlags

func (s *KubeletServer) AddFlags(fs *pflag.FlagSet)

AddFlags adds flags for a specific KubeletServer to the specified FlagSet

func (*KubeletServer) Run

func (s *KubeletServer) Run(_ []string) error

Run runs the specified KubeletServer. This should never exit.