diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index 81ef79c62a4..d9ea3bae930 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -19,7 +19,6 @@ package kubelet import ( "encoding/json" "fmt" - "io" "io/ioutil" "log" "math/rand" @@ -442,32 +441,6 @@ func (kl *Kubelet) extractFromDir(name string) ([]api.ContainerManifest, error) return manifests, nil } -func (kl *Kubelet) extractMultipleFromReader(reader io.Reader) ([]api.ContainerManifest, error) { - var manifests []api.ContainerManifest - data, err := ioutil.ReadAll(reader) - if err != nil { - log.Printf("Couldn't read from reader: %v", err) - return manifests, err - } - if err = kl.ExtractYAMLData(data, &manifests); err != nil { - return manifests, err - } - return manifests, nil -} - -func (kl *Kubelet) extractSingleFromReader(reader io.Reader) (api.ContainerManifest, error) { - var manifest api.ContainerManifest - data, err := ioutil.ReadAll(reader) - if err != nil { - log.Printf("Couldn't read from reader: %v", err) - return manifest, err - } - if err = kl.ExtractYAMLData(data, &manifest); err != nil { - return manifest, err - } - return manifest, nil -} - // Watch a file or direcory of files for changes to the set of pods that // should run on this Kubelet. func (kl *Kubelet) WatchFiles(config_path string, updateChannel chan<- manifestUpdate) {