apiresource

Documentation

Index

• func GetClusterNameAndGVRIndexKey(clusterName logicalcluster.Name, gvr metav1.GroupVersionResource) string
• func NegotiatedAPIResourceAsOwnerReference(obj *apiresourcev1alpha1.NegotiatedAPIResource) metav1.OwnerReference
• type Controller
  • func NewController(crdClusterClient *apiextensionsclientset.Cluster, ...) (*Controller, error)
  • func (c *Controller) Start(ctx context.Context, numThreads int)
• type Options
  • func BindOptions(o *Options, fs *pflag.FlagSet) *Options
  • func DefaultOptions() *Options
  • func (o *Options) Validate() error

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 *apiextensionsclientset.Cluster,
	kcpClusterClient *kcpclient.Cluster,
	autoPublishNegotiatedAPIResource bool,
	negotiatedAPIResourceInformer apiresourceinformer.NegotiatedAPIResourceInformer,
	apiResourceImportInformer apiresourceinformer.APIResourceImportInformer,
	crdInformer crdinfomer.CustomResourceDefinitionInformer,
) (*Controller, error)

func (*Controller) Start

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

type Options

type Options struct {
	AutoPublishAPIs bool
	NumThreads      int
}

Options are the options for the cluster controller

func BindOptions

func BindOptions(o *Options, fs *pflag.FlagSet) *Options

BindOptions binds the apiresource controller options to the flag set.

func DefaultOptions

func DefaultOptions() *Options

DefaultOptions are the default options for the apiresource controller.

func (*Options) Validate

func (o *Options) Validate() error