resource

Documentation

Index

• func GetPodSpec(ctx context.Context, kube client.Kube, kind, name string) (v1.PodSpec, error)
• func IsContainedSelected(container v1.Container, filter *regexp.Regexp) bool
• func IsService(name string) bool
• func ListPods(ctx context.Context, kube client.Kube, kind, name string) ([]v1.Pod, error)
• func WatchPods(ctx context.Context, kube client.Kube, kind, name string, ...) (watch.Interface, error)
• type Lister
  • func ListerFor(kind string) (Lister, error)
• type PodFilter
  • func GetPodsSelector(ctx context.Context, kube client.Kube, kind, name string) (namespace string, options metav1.ListOptions, postListFilter PodFilter, ...)
• type WrappedWatcher
  • func (dw WrappedWatcher) ResultChan() <-chan watch.Event
  • func (dw WrappedWatcher) Stop()

Functions

func GetPodSpec

func GetPodSpec(ctx context.Context, kube client.Kube, kind, name string) (v1.PodSpec, error)

func IsContainedSelected

func IsContainedSelected(container v1.Container, filter *regexp.Regexp) bool

func IsService

func IsService(name string) bool

func ListPods

func ListPods(ctx context.Context, kube client.Kube, kind, name string) ([]v1.Pod, error)

func WatchPods

func WatchPods(ctx context.Context, kube client.Kube, kind, name string, labelSelector map[string]string, dryRun bool) (watch.Interface, error)

Types

type Lister

type Lister func(context.Context, client.Kube, string) ([]string, error)

func ListerFor

func ListerFor(kind string) (Lister, error)

type PodFilter

type PodFilter func(context.Context, client.Kube, v1.Pod) bool

func GetPodsSelector

func GetPodsSelector(ctx context.Context, kube client.Kube, kind, name string) (namespace string, options metav1.ListOptions, postListFilter PodFilter, err error)

type WrappedWatcher

type WrappedWatcher struct {
	// contains filtered or unexported fields
}

func (WrappedWatcher) ResultChan

func (dw WrappedWatcher) ResultChan() <-chan watch.Event

func (WrappedWatcher) Stop

func (dw WrappedWatcher) Stop()