podutil

package

v0.7.2-v1.1.5 Latest Latest Go to latest Published: Jan 30, 2016 License: Apache-2.0 Imports: 12 Imported by: 0

Details

podutil contains utilities for reading, writing and filtering streams and lists of api.Pod objects.

This section is empty.

This section is empty.

func Annotate(meta *api.ObjectMeta, kv map[string]string)

Annotate safely copies annotation metadata from kv to meta.Annotations.

func Gunzip(gzipped []byte) <-chan *api.Pod

func Gzip(pods <-chan *api.Pod) ([]byte, error)

func List(pods <-chan *api.Pod) *api.PodList

List reads every pod from the pods chan and returns them all in an api.PodList

func ReadFromDir(dirpath string) (<-chan *api.Pod, <-chan error)

func Stream(list *api.PodList, err error) <-chan *api.Pod

Stream returns a chan of pods that yields each pod from the given list. No pods are yielded if err is non-nil.

func WriteToDir(pods <-chan *api.Pod, destDir string) error

type FilterFunc func(pod *api.Pod) (bool, error)

func Annotator(m map[string]string) FilterFunc

Annotator returns a filter that copies annotations from map m into a pod

func (filter FilterFunc) Do(in <-chan *api.Pod) <-chan *api.Pod

type Filters []FilterFunc