k8s

Documentation

Index

• func AssertCronjobNotPresent(c *clients.Clients, cronJobName, namespace string)
• func AssertCronjobPresent(c *clients.Clients, cronJobName, namespace string)
• func AssertIfDefaultCronjobExists(c *clients.Clients, namespace string)
• func AssertPrunerCronjobWithContainer(c *clients.Clients, namespace, num string)
• func CreateCronJob(c *clients.Clients, args []string, schedule, namespace string)
• func DeleteCronJob(c *clients.Clients, name, ns string) error
• func DeleteDeployment(cs *clients.Clients, ns string, deploymentName string) error
• func Get(ctx context.Context, gr schema.GroupVersionResource, clients *clients.Clients, ...) (*unstructured.Unstructured, error)
• func GetCronjobNameWithSchedule(c *clients.Clients, namespace, schedule string) string
• func GetGroupVersionResource(gr schema.GroupVersionResource, discovery discovery.DiscoveryInterface) (*schema.GroupVersionResource, error)
• func GetPrivilegedSCC(cs *clients.Clients) (*secv1.SecurityContextConstraints, error)
• func GetWarningEvents(c *clients.Clients, namespace string) (string, error)
• func NewClientSet() (*clients.Clients, string, func())
• func ValidateDeploymentDeletion(cs *clients.Clients, ns string, deployments ...string)
• func ValidateDeployments(cs *clients.Clients, ns string, deployments ...string)
• func ValidateSCCAdded(cs *clients.Clients, ns, sa string)
• func ValidateSCCRemoved(cs *clients.Clients, ns, sa string)
• func ValidateTektonInstallersetNames(c *clients.Clients)
• func ValidateTektonInstallersetStatus(c *clients.Clients)
• func VerifyNamespaceExists(ctx context.Context, kc *clients.KubeClient, ns string)
• func VerifyNoServiceAccount(ctx context.Context, kc *clients.KubeClient, sa, ns string)
• func VerifyServiceAccountExists(ctx context.Context, kc *clients.KubeClient, sa, ns string)
• func WaitForDeployment(ctx context.Context, kc kubernetes.Interface, namespace, name string, ...) error
• func WaitForDeploymentDeletion(cs *clients.Clients, namespace, name string) error
• func WaitForServiceAccount(cs *clients.Clients, ns, targetSA string) *corev1.ServiceAccount
• func Watch(ctx context.Context, gr schema.GroupVersionResource, clients *clients.Clients, ...) (watch.Interface, error)

Functions

func AssertCronjobNotPresent

func AssertCronjobNotPresent(c *clients.Clients, cronJobName, namespace string)

func AssertCronjobPresent

func AssertCronjobPresent(c *clients.Clients, cronJobName, namespace string)

func AssertIfDefaultCronjobExists

func AssertIfDefaultCronjobExists(c *clients.Clients, namespace string)

func AssertPrunerCronjobWithContainer

func AssertPrunerCronjobWithContainer(c *clients.Clients, namespace, num string)

func CreateCronJob

func CreateCronJob(c *clients.Clients, args []string, schedule, namespace string)

func DeleteCronJob

func DeleteCronJob(c *clients.Clients, name, ns string) error

func DeleteDeployment

func DeleteDeployment(cs *clients.Clients, ns string, deploymentName string) error

func Get

func Get(ctx context.Context, gr schema.GroupVersionResource, clients *clients.Clients, objname, ns string, op metav1.GetOptions) (*unstructured.Unstructured, error)

func GetCronjobNameWithSchedule

func GetCronjobNameWithSchedule(c *clients.Clients, namespace, schedule string) string

func GetGroupVersionResource

func GetGroupVersionResource(gr schema.GroupVersionResource, discovery discovery.DiscoveryInterface) (*schema.GroupVersionResource, error)

func GetPrivilegedSCC

func GetPrivilegedSCC(cs *clients.Clients) (*secv1.SecurityContextConstraints, error)

func GetWarningEvents

func GetWarningEvents(c *clients.Clients, namespace string) (string, error)

func NewClientSet

func NewClientSet() (*clients.Clients, string, func())

NewClientSet is a setup function which helps you 1. to create clientSet instance to `client` 2. to create a namespace with random name

func ValidateDeploymentDeletion

func ValidateDeploymentDeletion(cs *clients.Clients, ns string, deployments ...string)

func ValidateDeployments

func ValidateDeployments(cs *clients.Clients, ns string, deployments ...string)

func ValidateSCCAdded

func ValidateSCCAdded(cs *clients.Clients, ns, sa string)

func ValidateSCCRemoved

func ValidateSCCRemoved(cs *clients.Clients, ns, sa string)

func ValidateTektonInstallersetNames

func ValidateTektonInstallersetNames(c *clients.Clients)

func ValidateTektonInstallersetStatus

func ValidateTektonInstallersetStatus(c *clients.Clients)

func VerifyNamespaceExists

func VerifyNamespaceExists(ctx context.Context, kc *clients.KubeClient, ns string)

func VerifyNoServiceAccount

func VerifyNoServiceAccount(ctx context.Context, kc *clients.KubeClient, sa, ns string)

func VerifyServiceAccountExists

func VerifyServiceAccountExists(ctx context.Context, kc *clients.KubeClient, sa, ns string)

func WaitForDeployment

func WaitForDeployment(ctx context.Context, kc kubernetes.Interface, namespace, name string, replicas int, retryInterval, timeout time.Duration) error

func WaitForDeploymentDeletion

func WaitForDeploymentDeletion(cs *clients.Clients, namespace, name string) error

WaitForDeploymentDeletion checks to see if a given deployment is deleted the function returns an error if the given deployment is not deleted within the timeout

func WaitForServiceAccount

func WaitForServiceAccount(cs *clients.Clients, ns, targetSA string) *corev1.ServiceAccount

WaitForServiceAccount checks if service account created

func Watch

func Watch(ctx context.Context, gr schema.GroupVersionResource, clients *clients.Clients, ns string, op metav1.ListOptions) (watch.Interface, error)

Watch func helps you to watch on dynamic resources