common

package
v0.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 22, 2024 License: Apache-2.0, Apache-2.0 Imports: 53 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GitRefContextKey = ContextKey("gitRef")
)

Variables

View Source 
var (
	CleanableObjects = []client.Object{
		&v1.Pod{},
		&appsv1.Deployment{},
		&appsv1.DaemonSet{},
		&policyv1.PodDisruptionBudget{},
		&v1.PersistentVolumeClaim{},
		&v1.PersistentVolume{},
		&storagev1.StorageClass{},
		&corev1beta1.NodePool{},
		&v1.LimitRange{},
		&schedulingv1.PriorityClass{},
		&v1.Node{},
		&corev1beta1.NodeClaim{},
	}
)

Functions

func NewClient 

func NewClient(ctx context.Context, config *rest.Config) client.Client

func NewConfig 

func NewConfig() *rest.Config

func NodeNames 

func NodeNames(nodes []*v1.Node) []string

Types

type ContextKey 

type ContextKey string

type Environment 

type Environment struct {
	context.Context

	Client     client.Client
	Config     *rest.Config
	KubeClient kubernetes.Interface
	Monitor    *Monitor

	StartingNodeCount int
	// contains filtered or unexported fields
}

func NewEnvironment 

func NewEnvironment(t *testing.T) *Environment

func (*Environment) AfterEach 

func (env *Environment) AfterEach()

func (*Environment) BeforeEach 

func (env *Environment) BeforeEach()

nolint:gocyclo

func (*Environment) Cleanup 

func (env *Environment) Cleanup()

func (*Environment) CleanupObjects 

func (env *Environment) CleanupObjects(cleanableObjects ...client.Object)

func (*Environment) ConsistentlyExpectNodeCount 

func (env *Environment) ConsistentlyExpectNodeCount(comparator string, count int, duration string) []*v1.Node

func (*Environment) EventuallyExpectAvgUtilization 

func (env *Environment) EventuallyExpectAvgUtilization(resource v1.ResourceName, comparator string, value float64)

func (*Environment) EventuallyExpectCordonedNodeCount 

func (env *Environment) EventuallyExpectCordonedNodeCount(comparator string, count int) []*v1.Node

func (*Environment) EventuallyExpectCordonedNodeCountLegacy 

func (env *Environment) EventuallyExpectCordonedNodeCountLegacy(comparator string, count int) []*v1.Node

func (*Environment) EventuallyExpectCreatedNodeClaimCount 

func (env *Environment) EventuallyExpectCreatedNodeClaimCount(comparator string, count int) []*corev1beta1.NodeClaim

func (*Environment) EventuallyExpectCreatedNodeCount 

func (env *Environment) EventuallyExpectCreatedNodeCount(comparator string, count int) []*v1.Node

func (*Environment) EventuallyExpectDeletedNodeCount 

func (env *Environment) EventuallyExpectDeletedNodeCount(comparator string, count int) []*v1.Node

func (*Environment) EventuallyExpectDeletedNodeCountWithSelector 

func (env *Environment) EventuallyExpectDeletedNodeCountWithSelector(comparator string, count int, selector labels.Selector) []*v1.Node

func (*Environment) EventuallyExpectHealthy 

func (env *Environment) EventuallyExpectHealthy(pods ...*v1.Pod)

func (*Environment) EventuallyExpectHealthyPodCount 

func (env *Environment) EventuallyExpectHealthyPodCount(selector labels.Selector, numPods int)

func (*Environment) EventuallyExpectHealthyPodCountWithTimeout 

func (env *Environment) EventuallyExpectHealthyPodCountWithTimeout(timeout time.Duration, selector labels.Selector, numPods int)

func (*Environment) EventuallyExpectHealthyWithTimeout 

func (env *Environment) EventuallyExpectHealthyWithTimeout(timeout time.Duration, pods ...*v1.Pod)

func (*Environment) EventuallyExpectInitializedNodeCount 

func (env *Environment) EventuallyExpectInitializedNodeCount(comparator string, count int) []*v1.Node

func (*Environment) EventuallyExpectKarpenterRestarted 

func (env *Environment) EventuallyExpectKarpenterRestarted()

func (*Environment) EventuallyExpectMinUtilization 

func (env *Environment) EventuallyExpectMinUtilization(resource v1.ResourceName, comparator string, value float64)

func (*Environment) EventuallyExpectNodeClaimsReady 

func (env *Environment) EventuallyExpectNodeClaimsReady(nodeClaims ...*corev1beta1.NodeClaim)

func (*Environment) EventuallyExpectNodeCount 

func (env *Environment) EventuallyExpectNodeCount(comparator string, count int) []*v1.Node

func (*Environment) EventuallyExpectNodeCountWithSelector 

func (env *Environment) EventuallyExpectNodeCountWithSelector(comparator string, count int, selector labels.Selector) []*v1.Node

func (*Environment) EventuallyExpectNodesUncordonedLegacyWithTimeout 

func (env *Environment) EventuallyExpectNodesUncordonedLegacyWithTimeout(timeout time.Duration, nodes ...*v1.Node)

func (*Environment) EventuallyExpectNodesUncordonedWithTimeout 

func (env *Environment) EventuallyExpectNodesUncordonedWithTimeout(timeout time.Duration, nodes ...*v1.Node)

func (*Environment) EventuallyExpectNotFound 

func (env *Environment) EventuallyExpectNotFound(objects ...client.Object)

func (*Environment) EventuallyExpectNotFoundAssertion 

func (env *Environment) EventuallyExpectNotFoundAssertion(objects ...client.Object) AsyncAssertion

func (*Environment) EventuallyExpectPendingPodCount 

func (env *Environment) EventuallyExpectPendingPodCount(selector labels.Selector, numPods int)

func (*Environment) EventuallyExpectRollout 

func (env *Environment) EventuallyExpectRollout(name, namespace string)

func (*Environment) EventuallyExpectUniqueNodeNames 

func (env *Environment) EventuallyExpectUniqueNodeNames(selector labels.Selector, uniqueNames int)

func (*Environment) ExpectActiveKarpenterPod 

func (env *Environment) ExpectActiveKarpenterPod() *v1.Pod

func (*Environment) ExpectActiveKarpenterPodName 

func (env *Environment) ExpectActiveKarpenterPodName() string

func (*Environment) ExpectCABundle 

func (env *Environment) ExpectCABundle() string

func (*Environment) ExpectCleanCluster 

func (env *Environment) ExpectCleanCluster()

func (*Environment) ExpectConfigMapDataOverridden 

func (env *Environment) ExpectConfigMapDataOverridden(key types.NamespacedName, data ...map[string]string) (changed bool)

func (*Environment) ExpectConfigMapDataReplaced 

func (env *Environment) ExpectConfigMapDataReplaced(key types.NamespacedName, data ...map[string]string) (changed bool)

func (*Environment) ExpectConfigMapExists 

func (env *Environment) ExpectConfigMapExists(key types.NamespacedName) *v1.ConfigMap

func (*Environment) ExpectCreated 

func (env *Environment) ExpectCreated(objects ...client.Object)

func (*Environment) ExpectCreatedNodeCount 

func (env *Environment) ExpectCreatedNodeCount(comparator string, count int) []*v1.Node

func (*Environment) ExpectCreatedOrUpdated 

func (env *Environment) ExpectCreatedOrUpdated(objects ...client.Object)

func (*Environment) ExpectDaemonSetEnvironmentVariableUpdated 

func (env *Environment) ExpectDaemonSetEnvironmentVariableUpdated(obj client.ObjectKey, name, value string, containers ...string)

func (*Environment) ExpectDeleted 

func (env *Environment) ExpectDeleted(objects ...client.Object)

func (*Environment) ExpectExists 

func (env *Environment) ExpectExists(obj client.Object)

func (*Environment) ExpectKarpenterLeaseOwnerChanged 

func (env *Environment) ExpectKarpenterLeaseOwnerChanged()

func (*Environment) ExpectKarpenterPods 

func (env *Environment) ExpectKarpenterPods() []*v1.Pod

func (*Environment) ExpectNoCrashes 

func (env *Environment) ExpectNoCrashes()

func (*Environment) ExpectPodsMatchingSelector 

func (env *Environment) ExpectPodsMatchingSelector(selector labels.Selector) []*v1.Pod

func (*Environment) ExpectSettings 

func (env *Environment) ExpectSettings() (res []v1.EnvVar)

func (*Environment) ExpectSettingsOverridden 

func (env *Environment) ExpectSettingsOverridden(vars ...v1.EnvVar)

func (*Environment) ExpectSettingsRemoved 

func (env *Environment) ExpectSettingsRemoved(vars ...v1.EnvVar)

func (*Environment) ExpectSettingsReplaced 

func (env *Environment) ExpectSettingsReplaced(vars ...v1.EnvVar)

func (*Environment) ExpectUpdated 

func (env *Environment) ExpectUpdated(objects ...client.Object)

func (*Environment) GetDaemonSetCount 

func (env *Environment) GetDaemonSetCount(np *corev1beta1.NodePool) int

func (*Environment) GetNode 

func (env *Environment) GetNode(nodeName string) v1.Node

func (*Environment) Stop 

func (env *Environment) Stop()

type Monitor 

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

Monitor is used to monitor the cluster state during a running test

func NewMonitor 

func NewMonitor(ctx context.Context, kubeClient client.Client) *Monitor

func (*Monitor) AvgUtilization 

func (m *Monitor) AvgUtilization(resource v1.ResourceName) float64

func (*Monitor) CreatedNodeCount 

func (m *Monitor) CreatedNodeCount() int

CreatedNodeCount returns the number of nodes created since the last reset

func (*Monitor) CreatedNodes 

func (m *Monitor) CreatedNodes() []*v1.Node

CreatedNodes returns the nodes that have been created since the last reset (essentially Nodes - NodesAtReset)

func (*Monitor) DeletedNodes 

func (m *Monitor) DeletedNodes() []*v1.Node

DeletedNodes returns the nodes that have been deleted since the last reset (essentially NodesAtReset - Nodes)

func (*Monitor) MinUtilization 

func (m *Monitor) MinUtilization(resource v1.ResourceName) float64

func (*Monitor) NodeCount 

func (m *Monitor) NodeCount() int

NodeCount returns the current number of nodes

func (*Monitor) NodeCountAtReset 

func (m *Monitor) NodeCountAtReset() int

NodeCountAtReset returns the number of nodes that were running when the monitor was last reset, typically at the beginning of a test

func (*Monitor) Nodes 

func (m *Monitor) Nodes() []*v1.Node

Nodes returns all the nodes on the cluster

func (*Monitor) NodesAtReset 

func (m *Monitor) NodesAtReset() []*v1.Node

NodesAtReset returns a slice of nodes that the monitor saw at the last reset

func (*Monitor) PendingPods 

func (m *Monitor) PendingPods(selector labels.Selector) []*v1.Pod

PendingPods returns the number of pending pods matching the given selector

func (*Monitor) PendingPodsCount 

func (m *Monitor) PendingPodsCount(selector labels.Selector) int

func (*Monitor) Reset 

func (m *Monitor) Reset()

Reset resets the cluster monitor prior to running a test.

func (*Monitor) RestartCount 

func (m *Monitor) RestartCount() map[string]int

RestartCount returns the containers and number of restarts for that container for all containers in the pods in the given namespace

func (*Monitor) RunningPods 

func (m *Monitor) RunningPods(selector labels.Selector) []*v1.Pod

RunningPods returns the number of running pods matching the given selector

func (*Monitor) RunningPodsCount 

func (m *Monitor) RunningPodsCount(selector labels.Selector) int

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.