kubernetes

Documentation

Index

• func CheckInstallScheme(t *testing.T, c client.Client)
• func NewClient(t *testing.T) (client.Client, *rest.Config)
• type KubeActions
  • func NewKubeHelper(client client.Client, kubeClient kube.CLIClient) *KubeActions
  • func (ka *KubeActions) CheckDeploymentReplicas(ctx context.Context, prefix, namespace string, expectedReplicas int, ...) error
  • func (ka *KubeActions) GetElectedLeader(ctx context.Context, namespace, leaseName string, afterTime metav1.Time, ...) (string, error)
  • func (ka *KubeActions) ManageEgress(ctx context.Context, ip, namespace, policyName string, blockTraffic bool, ...) (*networkingv1.NetworkPolicy, error)
  • func (ka *KubeActions) MarkAsLeader(namespace, podName string)
  • func (ka *KubeActions) ScaleDeploymentAndWait(ctx context.Context, deploymentName, namespace string, replicas int32, ...) error
  • func (ka *KubeActions) ScaleEnvoyProxy(envoyProxyName, namespace string, replicas int32) error
  • func (ka *KubeActions) WaitForDeploymentReplicaCount(ctx context.Context, deploymentName, namespace string, replicas int32, ...) error

Functions

func CheckInstallScheme

func CheckInstallScheme(t *testing.T, c client.Client)

func NewClient

func NewClient(t *testing.T) (client.Client, *rest.Config)

Types

type KubeActions

type KubeActions struct {
	client.Client
	kube.CLIClient
}

func NewKubeHelper

func NewKubeHelper(client client.Client, kubeClient kube.CLIClient) *KubeActions

NewKubeHelper consolidates common Kubernetes operations, including deployments, traffic management, and log probing.

func (*KubeActions) CheckDeploymentReplicas

func (ka *KubeActions) CheckDeploymentReplicas(ctx context.Context, prefix, namespace string, expectedReplicas int, timeout time.Duration) error

func (*KubeActions) GetElectedLeader

func (ka *KubeActions) GetElectedLeader(ctx context.Context, namespace, leaseName string, afterTime metav1.Time, timeout time.Duration) (string, error)

func (*KubeActions) ManageEgress

func (ka *KubeActions) ManageEgress(ctx context.Context, ip, namespace, policyName string, blockTraffic bool, scope map[string]string) (*networkingv1.NetworkPolicy, error)

func (*KubeActions) MarkAsLeader

func (ka *KubeActions) MarkAsLeader(namespace, podName string)

func (*KubeActions) ScaleDeploymentAndWait

func (ka *KubeActions) ScaleDeploymentAndWait(ctx context.Context, deploymentName, namespace string, replicas int32, timeout time.Duration, prefix bool) error

func (*KubeActions) ScaleEnvoyProxy

func (ka *KubeActions) ScaleEnvoyProxy(envoyProxyName, namespace string, replicas int32) error

func (*KubeActions) WaitForDeploymentReplicaCount

func (ka *KubeActions) WaitForDeploymentReplicaCount(ctx context.Context, deploymentName, namespace string, replicas int32, timeout time.Duration, prefix bool) error