clusterclaim

Documentation

Index

• Constants
• func NewClusterClaimSource(clusterInformers clusterv1alpha1informer.ClusterClaimInformer) source.Source
• type ClusterClaimEventHandler
  • func (e *ClusterClaimEventHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *ClusterClaimEventHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *ClusterClaimEventHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *ClusterClaimEventHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type ClusterClaimReconciler
  • func (r *ClusterClaimReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterClaimReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterClaimer
  • func (c *ClusterClaimer) List() ([]*clusterv1alpha1.ClusterClaim, error)
• type InfraConfig
• type ListClusterClaimsFunc

Constants

const (
	ClaimK8sID                   = "id.k8s.io"
	ClaimOpenshiftID             = "id.openshift.io"
	ClaimOpenshiftVersion        = "version.openshift.io"
	ClaimOpenshiftInfrastructure = "infrastructure.openshift.io"

	// ClaimControlPlaneTopology expresses the expectations for operands that normally run on control nodes of Openshift.
	// have 2 modes: `HighlyAvailable` and `SingleReplica`.
	ClaimControlPlaneTopology = "controlplanetopology.openshift.io"

	ClaimOCMConsoleURL  = "consoleurl.cluster.open-cluster-management.io"
	ClaimOCMRegion      = "region.open-cluster-management.io"
	ClaimOCMKubeVersion = "kubeversion.open-cluster-management.io"
	ClaimOCMPlatform    = "platform.open-cluster-management.io"
	ClaimOCMProduct     = "product.open-cluster-management.io"
)

const (
	PlatformAWS       = "AWS"
	PlatformGCP       = "GCP"
	PlatformAzure     = "Azure"
	PlatformIBM       = "IBM"
	PlatformIBMP      = "IBMPowerPlatform"
	PlatformIBMZ      = "IBMZPlatform"
	PlatformOpenStack = "OpenStack"
	PlatformVSphere   = "VSphere"
	// PlatformOther other (unable to auto detect)
	PlatformOther = "Other"
)

should be the type defined in infrastructure.config.openshift.io

const (
	ProductAKS       = "AKS"
	ProductEKS       = "EKS"
	ProductGKE       = "GKE"
	ProductICP       = "ICP"
	ProductIKS       = "IKS"
	ProductOpenShift = "OpenShift"
	ProductOSD       = "OpenShiftDedicated"
	// ProductOther other (unable to auto detect)
	ProductOther = "Other"
)

const (
	OCP3Version = "3"
)

Functions

func NewClusterClaimSource

func NewClusterClaimSource(clusterInformers clusterv1alpha1informer.ClusterClaimInformer) source.Source

NewClusterClaimSource returns an event source for cluster claims

Types

type ClusterClaimEventHandler

type ClusterClaimEventHandler struct{}

ClusterClaimEventHandler maps any event to an empty request

func (*ClusterClaimEventHandler) Create

func (e *ClusterClaimEventHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*ClusterClaimEventHandler) Delete

func (e *ClusterClaimEventHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*ClusterClaimEventHandler) Generic

func (e *ClusterClaimEventHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*ClusterClaimEventHandler) Update

func (e *ClusterClaimEventHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type ClusterClaimReconciler

type ClusterClaimReconciler struct {
	Log               logr.Logger
	ListClusterClaims ListClusterClaimsFunc
	ClusterClient     clusterclientset.Interface
	ClusterInformers  clusterv1alpha1informer.ClusterClaimInformer
}

ClusterClaimReconciler reconciles cluster claim objects

func (*ClusterClaimReconciler) Reconcile

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

func (*ClusterClaimReconciler) SetupWithManager

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

type ClusterClaimer

type ClusterClaimer struct {
	ClusterName    string
	HubClient      client.Client
	KubeClient     kubernetes.Interface
	ConfigV1Client openshiftclientset.Interface
}

func (*ClusterClaimer) List

func (c *ClusterClaimer) List() ([]*clusterv1alpha1.ClusterClaim, error)

type InfraConfig

type InfraConfig struct {
	InfraName string `json:"infraName,omitempty"`
}

type ListClusterClaimsFunc

type ListClusterClaimsFunc func() ([]*clusterv1alpha1.ClusterClaim, error)