kubernetes

Documentation

Index

• Variables
• func FindEnvVar(pod v1.Pod, envName string) (*v1.EnvVar, error)
• func NewConfigLoader(kubeconfig, context string) clientcmd.ClientConfig
• type KubeClient
  • func NewClient(kubeconfig, context, namespace string) (config KubeClient, err error)
  • func NewClientFromCmd(cmd *cobra.Command) (KubeClient, error)
  • func (client KubeClient) Exec(ctx context.Context, pod v1.Pod, cmd string, stdin io.Reader, ...) error
  • func (client KubeClient) FilterPodList(pods *v1.PodList, queries []LabelQueryable) (foundPods []v1.Pod, err error)
  • func (client KubeClient) GetNamespacedPods(ctx context.Context) (*v1.PodList, error)
  • func (client KubeClient) GetPodsFiltered(ctx context.Context, queries []LabelQueryable) ([]v1.Pod, error)
  • func (client KubeClient) GetValueFromEnv(ctx context.Context, pod v1.Pod, envNames []string) (string, error)
  • func (client KubeClient) Namespaces() v1.NamespaceInterface
  • func (client KubeClient) Pods() v1.PodInterface
  • func (client KubeClient) Secrets() v1.SecretInterface
• type LabelQuery
  • func (query LabelQuery) FindPods(list *v1.PodList) (pods []v1.Pod, err error)
  • func (query LabelQuery) Matches(pod v1.Pod) bool
• type LabelQueryAnd
  • func (queries LabelQueryAnd) FindPods(list *v1.PodList) (pods []v1.Pod, err error)
  • func (queries LabelQueryAnd) Matches(pod v1.Pod) bool
• type LabelQueryable

Variables

var (
	ErrNoEnvNames           = errors.New("dialect does not contain any env names")
	ErrSecretDoesNotHaveKey = errors.New("secret does not have key")
)

var ErrEnvVarNotFound = errors.New("env var not found")

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

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

Functions

func FindEnvVar

func FindEnvVar(pod v1.Pod, envName string) (*v1.EnvVar, error)

func NewConfigLoader

func NewConfigLoader(kubeconfig, context string) clientcmd.ClientConfig

Types

type KubeClient

type KubeClient struct {
	ClientSet    kubernetes.Interface
	ClientConfig *rest.Config
	Namespace    string
}

func NewClient

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

func NewClientFromCmd

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

func (KubeClient) Exec

func (client KubeClient) Exec(ctx context.Context, pod v1.Pod, cmd string, stdin io.Reader, stdout, stderr io.Writer, tty bool, terminalSizeQueue remotecommand.TerminalSizeQueue, pingPeriod time.Duration) error

func (KubeClient) FilterPodList

func (client KubeClient) FilterPodList(pods *v1.PodList, queries []LabelQueryable) (foundPods []v1.Pod, err 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 []LabelQueryable) ([]v1.Pod, error)

func (KubeClient) GetValueFromEnv

func (client KubeClient) GetValueFromEnv(ctx context.Context, pod v1.Pod, envNames []string) (string, error)

func (KubeClient) Namespaces

func (client KubeClient) Namespaces() v1.NamespaceInterface

func (KubeClient) Pods

func (client KubeClient) Pods() v1.PodInterface

func (KubeClient) Secrets

func (client KubeClient) Secrets() v1.SecretInterface

type LabelQuery

type LabelQuery struct {
	Name  string
	Value string
}

func (LabelQuery) FindPods

func (query LabelQuery) FindPods(list *v1.PodList) (pods []v1.Pod, err error)

func (LabelQuery) Matches

func (query LabelQuery) Matches(pod v1.Pod) bool

type LabelQueryAnd

type LabelQueryAnd []LabelQuery

func (LabelQueryAnd) FindPods

func (queries LabelQueryAnd) FindPods(list *v1.PodList) (pods []v1.Pod, err error)

func (LabelQueryAnd) Matches

func (queries LabelQueryAnd) Matches(pod v1.Pod) bool

type LabelQueryable

type LabelQueryable interface {
	Matches(pod v1.Pod) bool
	FindPods(list *v1.PodList) ([]v1.Pod, error)
}