nodepool

Documentation

Index

• Constants
• func FindStatusCondition(conditions []hyperv1.NodePoolCondition, conditionType string) *hyperv1.NodePoolCondition
• func GetHostedClusterByName(ctx context.Context, c client.Client, namespace, name string) (*hyperv1.HostedCluster, error)
• func IBMPowerVSImage(namespace, name string) *capipowervs.IBMPowerVSImage
• func IgnitionUserDataSecret(namespace, name, payloadInputHash string) *corev1.Secret
• func MachineDeploymentComplete(deployment *capiv1.MachineDeployment) bool
• func MustAsset(name string) string
• func PerformanceProfileConfigMap(namespace, name, nodePoolName string) *corev1.ConfigMap
• func SetStatusCondition(conditions *[]hyperv1.NodePoolCondition, ...)
• func TokenSecret(namespace, name, payloadInputHash string) *corev1.Secret
• func TunedConfigMap(namespace, name string) *corev1.ConfigMap
• type CPOCapabilities
• type MirrorConfig
• type NodePoolReconciler
  • func (r *NodePoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodePoolReconciler) SetPerformanceProfileConditions(ctx context.Context, logger logr.Logger, nodePool *hyperv1.NodePool, ...) error
  • func (r *NodePoolReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NotReadyError

Constants

const (
	EC2VolumeDefaultSize int64  = 16
	EC2VolumeDefaultType string = "gp3"

	// QualifiedNameMaxLength is the maximal name length allowed for k8s object
	// https://github.com/kubernetes/kubernetes/blob/957c9538670b5f7ead2c9ba9ceb9de081d66caa4/staging/src/k8s.io/apimachinery/pkg/util/validation/validation.go#L34
	QualifiedNameMaxLength = 63
)

const (
	TokenSecretTokenGenerationTime       = "hypershift.openshift.io/last-token-generation-time"
	TokenSecretReleaseKey                = "release"
	TokenSecretTokenKey                  = "token"
	TokenSecretPullSecretHashKey         = "pull-secret-hash"
	TokenSecretHCConfigurationHashKey    = "hc-configuration-hash"
	TokenSecretAdditionalTrustBundleKey  = "additional-trust-bundle-hash"
	TokenSecretConfigKey                 = "config"
	TokenSecretAnnotation                = "hypershift.openshift.io/ignition-config"
	TokenSecretIgnitionReachedAnnotation = "hypershift.openshift.io/ignition-reached"
	TokenSecretNodePoolUpgradeType       = "hypershift.openshift.io/node-pool-upgrade-type"

	PerformanceProfileConfigMapLabel                 = "hypershift.openshift.io/performanceprofile-config"
	NodeTuningGeneratedPerformanceProfileStatusLabel = "hypershift.openshift.io/nto-generated-performance-profile-status"
	ContainerRuntimeConfigConfigMapLabel             = "hypershift.openshift.io/containerruntimeconfig-config"
)

Functions

func FindStatusCondition

func FindStatusCondition(conditions []hyperv1.NodePoolCondition, conditionType string) *hyperv1.NodePoolCondition

FindStatusCondition finds the conditionType in conditions.

func GetHostedClusterByName

func GetHostedClusterByName(ctx context.Context, c client.Client, namespace, name string) (*hyperv1.HostedCluster, error)

GetHostedClusterByName finds and return a HostedCluster object using the specified params.

func IBMPowerVSImage

func IBMPowerVSImage(namespace, name string) *capipowervs.IBMPowerVSImage

func IgnitionUserDataSecret

func IgnitionUserDataSecret(namespace, name, payloadInputHash string) *corev1.Secret

func MachineDeploymentComplete

func MachineDeploymentComplete(deployment *capiv1.MachineDeployment) bool

MachineDeploymentComplete considers a MachineDeployment to be complete once all of its desired replicas are updated and available, and no old machines are running.

func MustAsset

func MustAsset(name string) string

func PerformanceProfileConfigMap

func PerformanceProfileConfigMap(namespace, name, nodePoolName string) *corev1.ConfigMap

func SetStatusCondition

func SetStatusCondition(conditions *[]hyperv1.NodePoolCondition, newCondition hyperv1.NodePoolCondition)

SetStatusCondition sets the corresponding condition in conditions to newCondition. conditions must be non-nil.

1. if the condition of the specified type already exists (all fields of the existing condition are updated to newCondition, LastTransitionTime is set to now if the new status differs from the old status)
2. if a condition of the specified type does not exist (LastTransitionTime is set to now() if unset, and newCondition is appended)

func TokenSecret

func TokenSecret(namespace, name, payloadInputHash string) *corev1.Secret

func TunedConfigMap

func TunedConfigMap(namespace, name string) *corev1.ConfigMap

Types

type CPOCapabilities

type CPOCapabilities struct {
	DecompressAndDecodeConfig     bool
	CreateDefaultAWSSecurityGroup bool
}

type MirrorConfig

type MirrorConfig struct {
	*corev1.ConfigMap
	Labels map[string]string
}

MirrorConfig holds the information needed to mirror a config object to HCP namespace

type NodePoolReconciler

type NodePoolReconciler struct {
	client.Client

	ReleaseProvider releaseinfo.Provider
	upsert.CreateOrUpdateProvider
	HypershiftOperatorImage string
	ImageMetadataProvider   supportutil.ImageMetadataProvider
	KubevirtInfraClients    kvinfra.KubevirtInfraClientMap
	// contains filtered or unexported fields
}

func (*NodePoolReconciler) Reconcile

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

func (*NodePoolReconciler) SetPerformanceProfileConditions

func (r *NodePoolReconciler) SetPerformanceProfileConditions(ctx context.Context, logger logr.Logger, nodePool *hyperv1.NodePool, controlPlaneNamespace string, toDelete bool) error

SetPerformanceProfileConditions checks for performance profile status updates, and reflects them in the nodepool status conditions

func (*NodePoolReconciler) SetupWithManager

func (r *NodePoolReconciler) SetupWithManager(mgr ctrl.Manager) error

type NotReadyError

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