kubernetes

Documentation

Index

• Variables
• func FilterPodList(pods []v1.Pod, query filter.Filter) []v1.Pod
• func NewConfigLoader(kubeconfig, context string) clientcmd.ClientConfig
• type ConfigLookup
• type ConfigLookups
  • func (c ConfigLookups) Search(ctx context.Context, client KubeClient, pod corev1.Pod) (string, error)
• type ExecOptions
• type KubeClient
  • func NewClient(kubeconfig, context, namespace string) (KubeClient, error)
  • func NewClientFromCmd(cmd *cobra.Command) (KubeClient, error)
  • func (client KubeClient) ConfigMaps() v1.ConfigMapInterface
  • func (client KubeClient) Exec(ctx context.Context, opt ExecOptions) error
  • func (client KubeClient) GetNamespacedPods(ctx context.Context) (*v1.PodList, error)
  • func (client KubeClient) GetPodsFiltered(ctx context.Context, queries filter.Filter) ([]v1.Pod, error)
  • func (client KubeClient) Jobs() batchv1.JobInterface
  • func (client *KubeClient) MinServerVersion(wantMajor, wantMinor int) (bool, error)
  • func (client KubeClient) Namespaces() v1.NamespaceInterface
  • func (client KubeClient) NetworkPolicies() networkingv1.NetworkPolicyInterface
  • func (client KubeClient) Pods() v1.PodInterface
  • func (client KubeClient) Secrets() v1.SecretInterface
• type LookupEnv
  • func (e LookupEnv) GetValue(ctx context.Context, client KubeClient, pod corev1.Pod) (string, error)
• type LookupNop
  • func (l LookupNop) GetValue(_ context.Context, _ KubeClient, _ corev1.Pod) (string, error)
• type LookupVolumeSecret
  • func (f LookupVolumeSecret) GetValue(ctx context.Context, client KubeClient, pod corev1.Pod) (string, error)

Variables

var (
	ErrNoEnvNames              = errors.New("dialect does not contain any env names")
	ErrEnvNoExist              = errors.New("env is not set")
	ErrSecretDoesNotHaveKey    = errors.New("secret does not have key")
	ErrConfigMapDoesNotHaveKey = errors.New("config map does not have key")
)

var ErrInvalidVersion = errors.New("invalid version")

var ErrNoPods = errors.New("no pods in namespace")

var ErrPodNotFound = errors.New("no pods with matching label")

var ErrVolumeNoExist = errors.New("volume does not exist")

Functions

func FilterPodList

func FilterPodList(pods []v1.Pod, query filter.Filter) []v1.Pod

func NewConfigLoader

func NewConfigLoader(kubeconfig, context string) clientcmd.ClientConfig

Types

type ConfigLookup

type ConfigLookup interface {
	GetValue(ctx context.Context, client KubeClient, pod corev1.Pod) (string, error)
}

type ConfigLookups

type ConfigLookups []ConfigLookup

func (ConfigLookups) Search

func (c ConfigLookups) Search(ctx context.Context, client KubeClient, pod corev1.Pod) (string, error)

type ExecOptions

type ExecOptions struct {
	Pod            v1.Pod
	Container      string
	Cmd            string
	Stdin          io.Reader
	Stdout, Stderr io.Writer
	TTY            bool
	SizeQueue      remotecommand.TerminalSizeQueue
	DisablePing    bool
}

type KubeClient

type KubeClient struct {
	ClientSet    kubernetes.Interface
	ClientConfig *rest.Config
	Discovery    *discovery.DiscoveryClient
	Context      string
	Namespace    string
}

func NewClient

func NewClient(kubeconfig, context, namespace string) (KubeClient, error)

func NewClientFromCmd

func NewClientFromCmd(cmd *cobra.Command) (KubeClient, error)

func (KubeClient) ConfigMaps

func (client KubeClient) ConfigMaps() v1.ConfigMapInterface

func (KubeClient) Exec

func (client KubeClient) Exec(ctx context.Context, opt ExecOptions) error

func (KubeClient) GetNamespacedPods

func (client KubeClient) GetNamespacedPods(ctx context.Context) (*v1.PodList, error)

func (KubeClient) GetPodsFiltered

func (client KubeClient) GetPodsFiltered(ctx context.Context, queries filter.Filter) ([]v1.Pod, error)

func (KubeClient) Jobs

func (client KubeClient) Jobs() batchv1.JobInterface

func (*KubeClient) MinServerVersion

func (client *KubeClient) MinServerVersion(wantMajor, wantMinor int) (bool, error)

func (KubeClient) Namespaces

func (client KubeClient) Namespaces() v1.NamespaceInterface

func (KubeClient) NetworkPolicies

func (client KubeClient) NetworkPolicies() networkingv1.NetworkPolicyInterface

func (KubeClient) Pods

func (client KubeClient) Pods() v1.PodInterface

func (KubeClient) Secrets

func (client KubeClient) Secrets() v1.SecretInterface

type LookupEnv

type LookupEnv []string

func (LookupEnv) GetValue

func (e LookupEnv) GetValue(ctx context.Context, client KubeClient, pod corev1.Pod) (string, error)

type LookupNop

type LookupNop struct{}

func (LookupNop) GetValue

func (l LookupNop) GetValue(_ context.Context, _ KubeClient, _ corev1.Pod) (string, error)

type LookupVolumeSecret

type LookupVolumeSecret struct {
	Name string
	Key  string
}

func (LookupVolumeSecret) GetValue

func (f LookupVolumeSecret) GetValue(ctx context.Context, client KubeClient, pod corev1.Pod) (string, error)