Documentation ¶
Overview ¶
Package server makes it easy to create a kubelet server for various contexts.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewHyperkubeServer ¶
NewHyperkubeServer creates a new hyperkube Server object that includes the description and flags.
func ProbeVolumePlugins ¶
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.