burner

Documentation

Index

• Variables
• func CleanupNamespaceResourcesUsingGVR(ctx context.Context, obj object, namespace string, labelSelector string)
• func CleanupNamespacesUsingGVR(ctx context.Context, ex Executor, namespacesToDelete []string)
• func CleanupNonNamespacedResourcesUsingGVR(ctx context.Context, object object, labelSelector string)
• func RetryWithExponentialBackOff(fn wait.ConditionFunc, duration time.Duration, factor, jitter float64, ...) error
• func Run(configSpec config.Spec, kubeClientProvider *config.KubeClientProvider, ...) (int, error)
• 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) RunReadJob(iterationStart, iterationEnd int)
  • func (ex *Executor) Verify() bool
• type NestedPod

Variables

var ClientSet kubernetes.Interface

var DynamicClient dynamic.Interface

Functions

func CleanupNamespaceResourcesUsingGVR

func CleanupNamespaceResourcesUsingGVR(ctx context.Context, obj object, namespace string, labelSelector string)

func CleanupNamespacesUsingGVR

func CleanupNamespacesUsingGVR(ctx context.Context, ex Executor, namespacesToDelete []string)

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

func CleanupNonNamespacedResourcesUsingGVR

func CleanupNonNamespacedResourcesUsingGVR(ctx context.Context, object object, labelSelector string)

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, kubeClientProvider *config.KubeClientProvider, metricsScraper metrics.Scraper, timeout time.Duration) (int, error)

Runs the with the given configuration and metrics scraper, with the specified timeout. Returns: - error code - error

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) RunReadJob

func (ex *Executor) RunReadJob(iterationStart, iterationEnd int)

RunReadJob executes a reading 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