apiresource

Documentation

Index

• Constants
• func GetClusterNameAndGVRIndexKey(clusterName logicalcluster.Name, gvr metav1.GroupVersionResource) string
• func NegotiatedAPIResourceAsOwnerReference(obj *apiresourcev1alpha1.NegotiatedAPIResource) metav1.OwnerReference
• type Controller
  • func NewController(crdClusterClient kcpapiextensionsclientset.ClusterInterface, ...) (*Controller, error)
  • func (c *Controller) Start(ctx context.Context, numThreads int)

Constants

const ControllerName = "kcp-apiresource"

Functions

func GetClusterNameAndGVRIndexKey

func GetClusterNameAndGVRIndexKey(clusterName logicalcluster.Name, gvr metav1.GroupVersionResource) string

func NegotiatedAPIResourceAsOwnerReference

func NegotiatedAPIResourceAsOwnerReference(obj *apiresourcev1alpha1.NegotiatedAPIResource) metav1.OwnerReference

Types

type Controller

type Controller struct {
	AutoPublishNegotiatedAPIResource bool
	// contains filtered or unexported fields
}

func NewController

func NewController(
	crdClusterClient kcpapiextensionsclientset.ClusterInterface,
	kcpClusterClient kcpclientset.ClusterInterface,
	autoPublishNegotiatedAPIResource bool,
	negotiatedAPIResourceInformer apiresourceinformer.NegotiatedAPIResourceClusterInformer,
	apiResourceImportInformer apiresourceinformer.APIResourceImportClusterInformer,
	crdInformer kcpapiextensionsv1informers.CustomResourceDefinitionClusterInformer,
) (*Controller, error)

func (*Controller) Start

func (c *Controller) Start(ctx context.Context, numThreads int)