k8s_utils

Documentation

Overview

Copyright 2017 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• func GetPodLog(ctx context.Context, config *rest.Config, pod *corev1.Pod, ...) (string, error)
• func IsPodRunning(pod *corev1.Pod) bool
• func MergeTolerations(first, second []corev1.Toleration) []corev1.Toleration
• func ParseK8sObjects(y string) ([]runtime.Object, error)
• func PopNamespaceFromObjectList(objects []runtime.Object) (nsObject runtime.Object, otherObjects []runtime.Object)
• func RestartDaemonSet(ctx context.Context, cli client.Client, dsUpdate *appsv1.DaemonSet) error
• type KubeQuerySecretsMethod
  • func QuerySecrets(cli client.Client, opts ...client.ListOption) KubeQuerySecretsMethod
  • func QuerySecretsInNamespace(cli client.Client, namespace string) KubeQuerySecretsMethod

Functions

func GetPodLog

func GetPodLog(ctx context.Context, config *rest.Config, pod *corev1.Pod, containerName string) (string, error)

func IsPodRunning

func IsPodRunning(pod *corev1.Pod) bool

func MergeTolerations

func MergeTolerations(first, second []corev1.Toleration) []corev1.Toleration

func ParseK8sObjects

func ParseK8sObjects(y string) ([]runtime.Object, error)

func PopNamespaceFromObjectList

func PopNamespaceFromObjectList(objects []runtime.Object) (nsObject runtime.Object, otherObjects []runtime.Object)

func RestartDaemonSet

func RestartDaemonSet(ctx context.Context, cli client.Client, dsUpdate *appsv1.DaemonSet) error

RestartDaemonSet restarts all pods that belong to the daemonset

Types

type KubeQuerySecretsMethod

type KubeQuerySecretsMethod func(ctx context.Context) (*corev1.SecretList, error)

func QuerySecrets

func QuerySecrets(cli client.Client, opts ...client.ListOption) KubeQuerySecretsMethod

func QuerySecretsInNamespace

func QuerySecretsInNamespace(cli client.Client, namespace string) KubeQuerySecretsMethod