kubernetes

package

Go to main page

Versions in this module

v1

v1.15.22

Feb 12, 2024

v1.5.28

Apr 29, 2024

v1.5.27

Apr 18, 2024

v1.5.26

Apr 1, 2024

v1.5.25

Mar 7, 2024

Changes in this version

+ const ShortRetryAttempts

+ const ShortRetryDelay

v1.5.24

Feb 16, 2024

v1.5.23

Feb 16, 2024

v1.5.22

Feb 12, 2024

v1.5.21

Feb 9, 2024

v1.5.20

Jan 25, 2024

Changes in this version

+ const PrivilegedDaemonSetPath

+ const PrivilegedLabelSelector

+ const PrivilegedNamespace

+ func RestartKubeProxyService(ctx context.Context, clientset *kubernetes.Clientset, ...) error

v1.5.19

Jan 19, 2024

v1.5.18

Jan 15, 2024

Changes in this version

+ func DeploymentExists(ctx context.Context, deploymentsClient typedappsv1.DeploymentInterface, ...) (bool, error)

+ func GetDeploymentAvailableReplicas(ctx context.Context, deploymentsClient typedappsv1.DeploymentInterface, ...) (int32, error)

v1.5.17

Dec 15, 2023

v1.5.16

Nov 21, 2023

v1.5.15

Nov 16, 2023

v1.5.14

Nov 8, 2023

v1.5.13

Sep 26, 2023

v1.5.12

Sep 25, 2023

Changes in this version

+ func MustCreateOrUpdatePod(ctx context.Context, podI typedcorev1.PodInterface, pod corev1.Pod) error

+ func MustParsePod(path string) (corev1.Pod, error)

v0

v0.1.0

Nov 20, 2023

Changes in this version

+ const DelegatedSubnetIDLabel

+ const DeleteRetryAttempts

+ const DeleteRetryDelay

+ const EnvInstallCNS

+ const RetryAttempts

+ const RetryDelay

+ const SubnetNameLabel

+ var ErrNoCNSScenarioDefined = errors.New("no CNSScenario set to true as env var")

+ var ErrPathNotFound = errors.New("failed to get the absolute path to directory")

+ var ErrUnsupportedCNSScenario = errors.New("unsupported CNS scenario")

+ var Kubeconfig = flag.String("test-kubeconfig", filepath.Join(homedir.HomeDir(), ".kube", "config"), ...)

+ func AddNodeLabels(ctx context.Context, nodes corev1.NodeInterface, nodeName string, ...) (*apiv1.Node, error)

+ func CreateLabelSelector(key string, selector *string) string

+ func ExecCmdOnPod(ctx context.Context, clientset *kubernetes.Clientset, ...) ([]byte, error)

+ func ExportLogsByLabelSelector(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ func GetImageString(url, image, version string) string

+ func GetNodeList(ctx context.Context, clientset *kubernetes.Clientset) (*corev1.NodeList, error)

+ func GetNodeListByLabelSelector(ctx context.Context, clientset *kubernetes.Clientset, labelSelector string) (*corev1.NodeList, error)

+ func GetPodsByNode(ctx context.Context, clientset *kubernetes.Clientset, ...) (*corev1.PodList, error)

+ func GetPodsIpsByNode(ctx context.Context, clientset *kubernetes.Clientset, ...) ([]string, error)

+ func HasWindowsNodes(ctx context.Context, clientset *kubernetes.Clientset) (bool, error)

+ func InstallCNSDaemonset(ctx context.Context, clientset *kubernetes.Clientset, logDir string) (func() error, error)

+ func InstallIPMasqAgent(ctx context.Context, clientset *kubernetes.Clientset) error

+ func Int32ToPtr(i int32) *int32

+ func MustCreateDaemonset(ctx context.Context, daemonsets typedappsv1.DaemonSetInterface, ...)

+ func MustCreateDeployment(ctx context.Context, deployments typedappsv1.DeploymentInterface, ...)

+ func MustCreateNamespace(ctx context.Context, clienset *kubernetes.Clientset, namespace string)

+ func MustDeleteDaemonset(ctx context.Context, daemonsets typedappsv1.DaemonSetInterface, ...)

+ func MustDeleteDeployment(ctx context.Context, deployments typedappsv1.DeploymentInterface, ...)

+ func MustDeleteNamespace(ctx context.Context, clienset *kubernetes.Clientset, namespace string)

+ func MustDeletePod(ctx context.Context, podI typedcorev1.PodInterface, pod corev1.Pod)

+ func MustGetClientset() *kubernetes.Clientset

+ func MustGetRestConfig() *rest.Config

+ func MustLabelSwiftNodes(ctx context.Context, clientset *kubernetes.Clientset, ...)

+ func MustParseDaemonSet(path string) appsv1.DaemonSet

+ func MustParseDeployment(path string) appsv1.Deployment

+ func MustRestartDaemonset(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ func MustScaleDeployment(ctx context.Context, deploymentsClient typedappsv1.DeploymentInterface, ...)

+ func MustSetUpClusterRBAC(ctx context.Context, clientset *kubernetes.Clientset, ...) func()

+ func MustSetUpRBAC(ctx context.Context, clientset *kubernetes.Clientset, ...)

+ func MustSetupConfigMap(ctx context.Context, clientset *kubernetes.Clientset, configMapPath string)

+ func MustUpdateReplica(ctx context.Context, deploymentsClient typedappsv1.DeploymentInterface, ...)

+ func NamespaceExists(ctx context.Context, clientset *kubernetes.Clientset, namespace string) (bool, error)

+ func ParseImageString(s string) (url, image, version string)

+ func RestartCNSDaemonset(ctx context.Context, clientset *kubernetes.Clientset) error

+ func WaitForDeploymentToDelete(ctx context.Context, deploymentsClient typedappsv1.DeploymentInterface, ...) error

+ func WaitForPodDaemonset(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ func WaitForPodDeployment(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ func WaitForPodsDelete(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ func WaitForPodsRunning(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ type CNSScenario string

+ const EnvInstallAzilium

+ const EnvInstallAzureCNIOverlay

+ const EnvInstallAzureVnet

+ const EnvInstallDualStackOverlay

+ const EnvInstallOverlay

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