hostedcluster

Documentation

Index

• Constants
• Variables
• func GetControlPlaneOperatorImage(ctx context.Context, hc *hyperv1.HostedCluster, ...) (string, error)
• func HasBeenAvailable(hc *hyperv1.HostedCluster) bool
• func SetupWebhookWithManager(mgr ctrl.Manager) error
• type ClusterMachineApproverConfig
• type HostedClusterReconciler
  • func (r *HostedClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *HostedClusterReconciler) SetupWithManager(mgr ctrl.Manager, createOrUpdate upsert.CreateOrUpdateProvider) error
• type NodeClientCert
• type Webhook
  • func (webhook *Webhook) ValidateCreate(ctx context.Context, obj runtime.Object) error
  • func (webhook *Webhook) ValidateDelete(_ context.Context, obj runtime.Object) error
  • func (webhook *Webhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) error

Constants

const (
	HostedClusterAnnotation = "hypershift.openshift.io/cluster"
	// HasBeenAvailableAnnotation is an implementation detail to check if HC has ever been available.
	// This is useful for e.g. monitor duration from creation to available and avoid noise from condition flipping.
	HasBeenAvailableAnnotation = "hypershift.openshift.io/HasBeenAvailable"

	ImageStreamCAPI                        = "cluster-capi-controllers"
	ImageStreamAutoscalerImage             = "cluster-autoscaler"
	ImageStreamClusterMachineApproverImage = "cluster-machine-approver"
)

Variables

var (
	DeletionDurationMetricName = "hypershift_cluster_deletion_duration_seconds"

	GuestCloudResourcesDeletionDurationMetricName = "hypershift_cluster_guest_cloud_resources_deletion_duration_seconds"

	AvailableDurationName = "hypershift_cluster_available_duration_seconds"

	InitialRolloutDurationName = "hypershift_cluster_initial_rollout_duration_seconds"

	LimitedSupportEnabledName = "hypershift_cluster_limited_support_enabled"

	SilenceAlertsName = "hypershift_cluster_silence_alerts"

	ProxyName = "hypershift_cluster_proxy"
)

var NoopReconcile controllerutil.MutateFn = func() error { return nil }

NoopReconcile is just a default mutation function that does nothing.

Functions

func GetControlPlaneOperatorImage

func GetControlPlaneOperatorImage(ctx context.Context, hc *hyperv1.HostedCluster, releaseProvider releaseinfo.Provider, hypershiftOperatorImage string, pullSecret []byte) (string, error)

GetControlPlaneOperatorImage resolves the appropriate control plane operator image based on the following order of precedence (from most to least preferred):

1. The image specified by the ControlPlaneOperatorImageAnnotation on the HostedCluster resource itself
2. The hypershift image specified in the release payload indicated by the HostedCluster's release field
3. The hypershift-operator's own image for release versions 4.9 and 4.10
4. The registry.ci.openshift.org/hypershift/hypershift:4.8 image for release version 4.8

If no image can be found according to these rules, an error is returned.

func HasBeenAvailable

func HasBeenAvailable(hc *hyperv1.HostedCluster) bool

func SetupWebhookWithManager

func SetupWebhookWithManager(mgr ctrl.Manager) error

SetupWebhookWithManager sets up HostedCluster webhooks.

Types

type ClusterMachineApproverConfig

type ClusterMachineApproverConfig struct {
	NodeClientCert NodeClientCert `json:"nodeClientCert,omitempty"`
}

type HostedClusterReconciler

type HostedClusterReconciler struct {
	client.Client

	// ManagementClusterCapabilities can be asked for support of optional management cluster capabilities
	ManagementClusterCapabilities capabilities.CapabiltyChecker

	// HypershiftOperatorImage is the image used to deploy the control plane operator if
	// 1) There is no hypershift.openshift.io/control-plane-operator-image annotation on the HostedCluster and
	// 2) The OCP version being deployed is the latest version supported by Hypershift
	HypershiftOperatorImage string

	// ReleaseProvider looks up the OCP version for the release images in HostedClusters
	ReleaseProvider releaseinfo.ProviderWithRegistryOverrides

	// SetDefaultSecurityContext is used to configure Security Context for containers
	SetDefaultSecurityContext bool

	// Clock is used to determine the time in a testable way.
	Clock clock.WithTickerAndDelayedExecution

	EnableOCPClusterMonitoring bool

	EnableCIDebugOutput bool

	PrivatePlatform hyperv1.PlatformType

	OIDCStorageProviderS3BucketName string
	S3Client                        s3iface.S3API

	ImageMetadataProvider hyperutil.ImageMetadataProvider

	MetricsSet metrics.MetricsSet
	// contains filtered or unexported fields
}

HostedClusterReconciler reconciles a HostedCluster object

func (*HostedClusterReconciler) Reconcile

func (r *HostedClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HostedClusterReconciler) SetupWithManager

func (r *HostedClusterReconciler) SetupWithManager(mgr ctrl.Manager, createOrUpdate upsert.CreateOrUpdateProvider) error

type NodeClientCert

type NodeClientCert struct {
	Disabled bool `json:"disabled,omitempty"`
}

type Webhook

type Webhook struct{}

Webhook implements a validating webhook for HostedCluster.

func (*Webhook) ValidateCreate

func (webhook *Webhook) ValidateCreate(ctx context.Context, obj runtime.Object) error

ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type.

func (*Webhook) ValidateDelete

func (webhook *Webhook) ValidateDelete(_ context.Context, obj runtime.Object) error

ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type.

func (*Webhook) ValidateUpdate

func (webhook *Webhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) error

ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type.