Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
*Options
// contains filtered or unexported fields
}
func (*Config) New ¶
func (c *Config) New() (*Controller, error)
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController( apiExtensionsClient apiextensionsclient.Interface, kcpClient kcpclient.Interface, clusterInformer clusterinformer.ClusterInformer, apiResourceImportInformer apiresourceinformer.APIResourceImportInformer, kubeconfig clientcmdapi.Config, resourcesToSync []string, syncerManagerImpl syncerManagerImpl, ) (*Controller, error)
func (*Controller) Prepare ¶
func (c *Controller) Prepare() (PreparedController, error)
type Options ¶
Options are the options for the cluster controller
func BindOptions ¶
BindOptions binds the cluster controller options to the flag set.
func DefaultOptions ¶
func DefaultOptions() *Options
DefaultOptions are the default options for the cluster controller.
func (*Options) Complete ¶
func (o *Options) Complete(kubeconfig clientcmdapi.Config, kcpSharedInformerFactory kcpexternalversions.SharedInformerFactory, crdSharedInformerFactory crdexternalversions.SharedInformerFactory, resourcesToSync []string) *Config
type PreparedController ¶
type PreparedController struct {
// contains filtered or unexported fields
}
func (*PreparedController) Start ¶
func (c *PreparedController) Start(ctx context.Context)
TODO(sttts): fix the many races due to unprotected field access and then increase worker count
Click to show internal directories.
Click to hide internal directories.