Add missing kubelet godoc
This commit is contained in:
		| @@ -236,6 +236,8 @@ type KubeletDeps struct { | |||||||
| 	TLSOptions        *server.TLSOptions | 	TLSOptions        *server.TLSOptions | ||||||
| } | } | ||||||
|  |  | ||||||
|  | // makePodSourceConfig creates a config.PodConfig from the given | ||||||
|  | // KubeletConfiguration or returns an error. | ||||||
| func makePodSourceConfig(kubeCfg *componentconfig.KubeletConfiguration, kubeDeps *KubeletDeps, nodeName string) (*config.PodConfig, error) { | func makePodSourceConfig(kubeCfg *componentconfig.KubeletConfiguration, kubeDeps *KubeletDeps, nodeName string) (*config.PodConfig, error) { | ||||||
| 	manifestURLHeader := make(http.Header) | 	manifestURLHeader := make(http.Header) | ||||||
| 	if kubeCfg.ManifestURLHeader != "" { | 	if kubeCfg.ManifestURLHeader != "" { | ||||||
| @@ -1321,6 +1323,8 @@ func makePortMappings(container *api.Container) (ports []kubecontainer.PortMappi | |||||||
| 	return | 	return | ||||||
| } | } | ||||||
|  |  | ||||||
|  | // GeneratePodHostNameAndDomain creates a hostname and domain name for a pod, | ||||||
|  | // given that pod's spec and annotations or returns an error. | ||||||
| func (kl *Kubelet) GeneratePodHostNameAndDomain(pod *api.Pod) (string, string, error) { | func (kl *Kubelet) GeneratePodHostNameAndDomain(pod *api.Pod) (string, string, error) { | ||||||
| 	// TODO(vmarmol): Handle better. | 	// TODO(vmarmol): Handle better. | ||||||
| 	// Cap hostname at 63 chars (specification is 64bytes which is 63 chars and the null terminating char). | 	// Cap hostname at 63 chars (specification is 64bytes which is 63 chars and the null terminating char). | ||||||
| @@ -1415,7 +1419,8 @@ func (kl *Kubelet) GenerateRunContainerOptions(pod *api.Pod, container *api.Cont | |||||||
|  |  | ||||||
| var masterServices = sets.NewString("kubernetes") | var masterServices = sets.NewString("kubernetes") | ||||||
|  |  | ||||||
| // getServiceEnvVarMap makes a map[string]string of env vars for services a pod in namespace ns should see | // getServiceEnvVarMap makes a map[string]string of env vars for services a | ||||||
|  | // pod in namespace ns should see. | ||||||
| func (kl *Kubelet) getServiceEnvVarMap(ns string) (map[string]string, error) { | func (kl *Kubelet) getServiceEnvVarMap(ns string) (map[string]string, error) { | ||||||
| 	var ( | 	var ( | ||||||
| 		serviceMap = make(map[string]api.Service) | 		serviceMap = make(map[string]api.Service) | ||||||
| @@ -2789,6 +2794,8 @@ func (kl *Kubelet) convertStatusToAPIStatus(pod *api.Pod, podStatus *kubecontain | |||||||
| 	return &apiPodStatus | 	return &apiPodStatus | ||||||
| } | } | ||||||
|  |  | ||||||
|  | // convertToAPIContainerStatuses converts the given internal container | ||||||
|  | // statuses into API container statuses. | ||||||
| func (kl *Kubelet) convertToAPIContainerStatuses(pod *api.Pod, podStatus *kubecontainer.PodStatus, previousStatus []api.ContainerStatus, containers []api.Container, hasInitContainers, isInitContainer bool) []api.ContainerStatus { | func (kl *Kubelet) convertToAPIContainerStatuses(pod *api.Pod, podStatus *kubecontainer.PodStatus, previousStatus []api.ContainerStatus, containers []api.Container, hasInitContainers, isInitContainer bool) []api.ContainerStatus { | ||||||
| 	convertContainerStatus := func(cs *kubecontainer.ContainerStatus) *api.ContainerStatus { | 	convertContainerStatus := func(cs *kubecontainer.ContainerStatus) *api.ContainerStatus { | ||||||
| 		cid := cs.ID.String() | 		cid := cs.ID.String() | ||||||
| @@ -3051,6 +3058,8 @@ func isSyncPodWorthy(event *pleg.PodLifecycleEvent) bool { | |||||||
| 	return event.Type != pleg.ContainerRemoved | 	return event.Type != pleg.ContainerRemoved | ||||||
| } | } | ||||||
|  |  | ||||||
|  | // parseResourceList parses the given configuration map into an API | ||||||
|  | // ResourceList or returns an error. | ||||||
| func parseResourceList(m utilconfig.ConfigurationMap) (api.ResourceList, error) { | func parseResourceList(m utilconfig.ConfigurationMap) (api.ResourceList, error) { | ||||||
| 	rl := make(api.ResourceList) | 	rl := make(api.ResourceList) | ||||||
| 	for k, v := range m { | 	for k, v := range m { | ||||||
| @@ -3072,6 +3081,9 @@ func parseResourceList(m utilconfig.ConfigurationMap) (api.ResourceList, error) | |||||||
| 	return rl, nil | 	return rl, nil | ||||||
| } | } | ||||||
|  |  | ||||||
|  | // ParseReservation parses the given kubelet- and system- reservations | ||||||
|  | // configuration maps into an internal Reservation instance or returns an | ||||||
|  | // error. | ||||||
| func ParseReservation(kubeReserved, systemReserved utilconfig.ConfigurationMap) (*kubetypes.Reservation, error) { | func ParseReservation(kubeReserved, systemReserved utilconfig.ConfigurationMap) (*kubetypes.Reservation, error) { | ||||||
| 	reservation := new(kubetypes.Reservation) | 	reservation := new(kubetypes.Reservation) | ||||||
| 	if rl, err := parseResourceList(kubeReserved); err != nil { | 	if rl, err := parseResourceList(kubeReserved); err != nil { | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user
	 Paul Morie
					Paul Morie