resource

package

v0.9.4 Latest Latest Go to latest Published: Jan 27, 2024 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ViBiOh/kmux

Links

Open Source Insights

Documentation ¶

Index ¶

func GetPodSpec(ctx context.Context, kube client.Kube, resourceType, resourceName 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, resourceType, resourceName string) ([]v1.Pod, error)
func WatchPods(ctx context.Context, kube client.Kube, resourceType, resourceName string, ...) (watch.Interface, error)
type Lister
- func ListerFor(resourceType string) (Lister, error)
type PodFilter
- func GetPodsSelector(ctx context.Context, kube client.Kube, resourceType, resourceName string) (namespace string, options metav1.ListOptions, postListFilter PodFilter, ...)
type WrappedWatcher
- func (dw WrappedWatcher) ResultChan() <-chan watch.Event
- func (dw WrappedWatcher) Stop()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetPodSpec ¶ added in v0.8.0

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

func IsContainedSelected ¶ added in v0.8.0

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

func IsService ¶ added in v0.0.10

func IsService(name string) bool

func ListPods ¶ added in v0.0.7

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

func WatchPods ¶ added in v0.0.7

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

Types ¶

type Lister ¶

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

func ListerFor ¶

func ListerFor(resourceType string) (Lister, error)

type PodFilter ¶ added in v0.0.16

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

func GetPodsSelector ¶ added in v0.8.0

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

type WrappedWatcher ¶ added in v0.0.16

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

func (WrappedWatcher) ResultChan ¶ added in v0.0.16

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

func (WrappedWatcher) Stop ¶ added in v0.0.16

func (dw WrappedWatcher) Stop()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL