k8s

Documentation

Index

• func CreateJobByCronJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• func CreateJobByGivenJobDefinition(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• func DeleteJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• func DeleteSecret(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• func GetCronJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...) *v1.CronJob
• func PrintJobLogs(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• func WaitForJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• func WaitForJobToFail(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• func WaitForJobToSucceed(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, ...)
• type ConfigmapCleaner
  • func NewConfigMapCleaner(configListManager Manager, configMapName string) *ConfigmapCleaner
  • func (c *ConfigmapCleaner) CleanRevocationList(ctx context.Context, hash string) error
• type Manager

Functions

func CreateJobByCronJob

func CreateJobByCronJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, cronJobName, jobName, namespace string)

func CreateJobByGivenJobDefinition

func CreateJobByGivenJobDefinition(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, jobName, namespace string, job *v1.Job)

func DeleteJob

func DeleteJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, jobName, namespace string)

func DeleteSecret

func DeleteSecret(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, secretName, namespace string)

func GetCronJob

func GetCronJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, cronJobName, namespace string) *v1.CronJob

func PrintJobLogs

func PrintJobLogs(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, jobName, namespace, containerName string, shouldJobFail bool)

func WaitForJob

func WaitForJob(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, jobName, namespace string, shouldFail bool)

func WaitForJobToFail

func WaitForJobToFail(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, jobName, namespace string)

func WaitForJobToSucceed

func WaitForJobToSucceed(t *testing.T, ctx context.Context, k8sClient *kubernetes.Clientset, jobName, namespace string)

Types

type ConfigmapCleaner

type ConfigmapCleaner struct {
	// contains filtered or unexported fields
}

func NewConfigMapCleaner

func NewConfigMapCleaner(configListManager Manager, configMapName string) *ConfigmapCleaner

func (*ConfigmapCleaner) CleanRevocationList

func (c *ConfigmapCleaner) CleanRevocationList(ctx context.Context, hash string) error

type Manager

type Manager interface {
	Get(ctx context.Context, name string, options metav1.GetOptions) (*v1.ConfigMap, error)
	Update(ctx context.Context, configMap *v1.ConfigMap, opts metav1.UpdateOptions) (*v1.ConfigMap, error)
}