reqserving

package
v0.1.72 Latest Latest
Warning

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

Go to latest
Published: Jan 13, 2026 License: Apache-2.0 Imports: 47 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// Namespace constants
	PlaceholderNamespace = "hypershift-request-serving-node-placeholders"

	// Timeout constants
	DefaultVerificationTimeout = 10 * time.Minute
	ComplexVerificationTimeout = 15 * time.Minute
	DefaultPollingInterval     = 30 * time.Second

	// Label constants
	ControlPlaneNodeLabel = "hypershift.openshift.io/control-plane"
)
View Source
const (
	KASGoMemLimitEnvVar = "GOMEMLIMIT"
)

Variables

This section is empty.

Functions

func ConfigureClusterAutoscaler

func ConfigureClusterAutoscaler(ctx context.Context, client crclient.Client, dryRunOpts *DryRunOptions) error

func ConfigureClusterSizingConfiguration

func ConfigureClusterSizingConfiguration(ctx context.Context, dryRunOpts *DryRunOptions) error

func ConfigureControlPlaneMachineSets

func ConfigureControlPlaneMachineSets(ctx context.Context, client crclient.Client, dryRunOpts *DryRunOptions) error

func ConfigureMachineHealthCheck

func ConfigureMachineHealthCheck(ctx context.Context, client crclient.Client, dryRunOpts *DryRunOptions) error

func ConfigureManagementCluster

func ConfigureManagementCluster(ctx context.Context, dryRunOpts *DryRunOptions) error

func EnsureVPAOperatorInstalled added in v0.1.71

func EnsureVPAOperatorInstalled(ctx context.Context, t interface {
	Helper()
	Logf(string, ...any)
}, c crclient.Client) error

EnsureVPAOperatorInstalled installs (or verifies) the VPA via OLM. It ensures: - Namespace openshift-vertical-pod-autoscaler exists - OperatorGroup exists - Subscription to redhat-operators on stable channel exists - CRD verticalpodautoscalers.autoscaling.k8s.io is served - vpa-recommender-default deployment is Available - VerticalPodAutoscalerController 'default' is configured with:

  • spec.recommendationOnly=true
  • spec.deploymentOverrides.recommender.container.args set for e2e test requirements

func InferAWSAvailabilityZones

func InferAWSAvailabilityZones(ctx context.Context) ([]string, error)

InferAWSAvailabilityZones inspects the management cluster worker MachineSets and infers the set of AWS availability zones present in the cluster. It returns a sorted list of unique zones.

func InferBaseDomain

func InferBaseDomain(ctx context.Context, awsCredentialsFile string) (string, error)

InferBaseDomain inspects the management cluster DNS resource and infers the base domain.

func VerifyRequestServingCPEffects

func VerifyRequestServingCPEffects(ctx context.Context, hc *hyperv1.HostedCluster) error

VerifyRequestServingCPEffects verifies that the request serving control plane has the values specified in the clustersizingconfiguration applied to its pods.

func VerifyRequestServingEnvironment

func VerifyRequestServingEnvironment(ctx context.Context) error

func VerifyRequestServingNodeAllocation

func VerifyRequestServingNodeAllocation(ctx context.Context, hc *hyperv1.HostedCluster) error

VerifyRequestServingNodeAllocation verifies that request serving nodes are properly allocated to the HostedCluster with correct labels, taints, and cross-AZ distribution.

func VerifyRequestServingPlaceholderConfigMaps

func VerifyRequestServingPlaceholderConfigMaps(ctx context.Context, hc *hyperv1.HostedCluster) error

VerifyRequestServingPlaceholderConfigMaps verifies that placeholder ConfigMaps are properly created and contain correct cluster identification data for request serving node allocation tracking.

func VerifyRequestServingPodDistribution

func VerifyRequestServingPodDistribution(ctx context.Context, hc *hyperv1.HostedCluster) error

VerifyRequestServingPodDistribution verifies that only the correct request serving pods are scheduled on request serving nodes with expected replica counts and proper labeling.

func VerifyRequestServingPodLabels

func VerifyRequestServingPodLabels(ctx context.Context, hc *hyperv1.HostedCluster) error

VerifyRequestServingPodLabels verifies that request serving pods do not have the hypershift.openshift.io/need-management-kas-access=true label.

func WaitForControlPlaneWorkloadsReady

func WaitForControlPlaneWorkloadsReady(ctx context.Context, hc *hyperv1.HostedCluster) error

WaitForControlPlaneWorkloadsReady waits until all control plane Deployments and StatefulSets in the control plane namespace are successfully rolled out and ready.

func WaitForHostedClusterSizeLabel

func WaitForHostedClusterSizeLabel(ctx context.Context, g Gomega, mgtClient crclient.Client, hostedCluster *hyperv1.HostedCluster, size string)

WaitForHostedClusterSizeLabel waits for the hosted cluster to have the expected size label

Types

type DryRunOptions

type DryRunOptions struct {
	Dir string
}

Jump to

Keyboard shortcuts

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