burner

Documentation

Index

• Variables
• func CleanupNamespaceResourcesUsingGVR(ctx context.Context, objects []object, namespacesToDelete []string, ...)
• func CleanupNamespaces(ctx context.Context, l metav1.ListOptions, cleanupWait bool)
• func CleanupNonNamespacedResources(ctx context.Context, l metav1.ListOptions, cleanupWait bool)
• func CleanupNonNamespacedResourcesUsingGVR(ctx context.Context, executorList []Executor, cleanupWait bool)
• func RetryWithExponentialBackOff(fn wait.ConditionFunc, duration time.Duration, factor, jitter float64, ...) error
• func Run(configSpec config.Spec, prometheusClients []*prometheus.Prometheus, ...) (int, error)
• func VerifyContainerRegistry(restConfig *rest.Config) bool
• type Executor
  • func (ex *Executor) RunCreateJob(iterationStart, iterationEnd int, waitListNamespaces *[]string)
  • func (ex *Executor) RunCreateJobWithChurn()
  • func (ex *Executor) RunDeleteJob()
  • func (ex *Executor) RunPatchJob()
  • func (ex *Executor) Verify() bool
• type NestedPod

Variables

var ClientSet *kubernetes.Clientset

var DynamicClient dynamic.Interface

Functions

func CleanupNamespaceResourcesUsingGVR

func CleanupNamespaceResourcesUsingGVR(ctx context.Context, objects []object, namespacesToDelete []string, jobName string)

Cleanup resources specific to kube-burner with in a given list of namespaces

func CleanupNamespaces

func CleanupNamespaces(ctx context.Context, l metav1.ListOptions, cleanupWait bool)

CleanupNamespaces deletes namespaces with the given selector

func CleanupNonNamespacedResources

func CleanupNonNamespacedResources(ctx context.Context, l metav1.ListOptions, cleanupWait bool)

Cleanup non-namespaced resources with the given selector

func CleanupNonNamespacedResourcesUsingGVR

func CleanupNonNamespacedResourcesUsingGVR(ctx context.Context, executorList []Executor, cleanupWait bool)

Cleanup non-namespaced resources using executor list

func RetryWithExponentialBackOff

func RetryWithExponentialBackOff(fn wait.ConditionFunc, duration time.Duration, factor, jitter float64, timeout time.Duration) error

RetryWithExponentialBackOff a utility for retrying the given function with exponential backoff.

func Run

func Run(configSpec config.Spec, prometheusClients []*prometheus.Prometheus, alertMs []*alerting.AlertManager, indexer *indexers.Indexer, timeout time.Duration, metadata map[string]interface{}) (int, error)

func VerifyContainerRegistry

func VerifyContainerRegistry(restConfig *rest.Config) bool

Verifies container registry and reports its status

Types

type Executor

type Executor struct {
	config.Job
	// contains filtered or unexported fields
}

Executor contains the information required to execute a job

func (*Executor) RunCreateJob

func (ex *Executor) RunCreateJob(iterationStart, iterationEnd int, waitListNamespaces *[]string)

RunCreateJob executes a creation job

func (*Executor) RunCreateJobWithChurn

func (ex *Executor) RunCreateJobWithChurn()

RunCreateJobWithChurn executes a churn creation job

func (*Executor) RunDeleteJob

func (ex *Executor) RunDeleteJob()

RunDeleteJob executes a deletion job

func (*Executor) RunPatchJob

func (ex *Executor) RunPatchJob()

RunPatchJob executes a patch job

func (*Executor) Verify

func (ex *Executor) Verify() bool

Verify verifies the number of created objects

type NestedPod

type NestedPod struct {
	// Spec represents the object spec
	Spec struct {
		Template struct {
			corev1.PodSpec `json:"spec"`
		} `json:"template"`
	} `json:"spec"`
}

NestedPod represents a pod nested in a higher level object such as deployment or a daemonset