burner

package

v0.0.7 Latest Latest Go to latest Published: Mar 21, 2024 License: Apache-2.0 Imports: 45 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vishnuchalla/kube-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
type NestedPod

Constants ¶

This section is empty.

Variables ¶

View Source

var ClientSet kubernetes.Interface

View Source

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
types

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL