kubernetes/pkg/kubelet/config/file.go

type podEventType …

const podAdd …

const podModify …

const podDelete …

const eventBufferLen …

type watchEvent …

type sourceFile …

// NewSourceFile watches a config file for changes.
func NewSourceFile(path string, nodeName types.NodeName, period time.Duration, updates chan<- interface{ … }

func newSourceFile(path string, nodeName types.NodeName, period time.Duration, updates chan<- interface{ … }

func (s *sourceFile) run() { … }

func (s *sourceFile) applyDefaults(pod *api.Pod, source string) error { … }

func (s *sourceFile) listConfig() error { … }

// Get as many pod manifests as we can from a directory. Return an error if and only if something
// prevented us from reading anything at all. Do not return an error if only some files
// were problematic.
func (s *sourceFile) extractFromDir(name string) ([]*v1.Pod, error) { … }

// extractFromFile parses a file for Pod configuration information.
func (s *sourceFile) extractFromFile(filename string) (pod *v1.Pod, err error) { … }

func (s *sourceFile) replaceStore(pods ...*v1.Pod) (err error) { … }