Documentation
¶
Index ¶
- Variables
- func AddProFlags(flags *pflag.FlagSet, options *options.VirtualClusterOptions)
- func NewFeatureError(featureName string) error
- func ParseExtraHooks(valHooks, mutHooks []string) ([]admissionregistrationv1.ValidatingWebhookConfiguration, ...)
- func ValidateProOptions(options *options.VirtualClusterOptions) error
Constants ¶
This section is empty.
Variables ¶
View Source
var AddRemoteNodePortSANs = func(_ context.Context, _, _ string, _ kubernetes.Interface) error {
return nil
}
View Source
var ExchangeControlPlaneClient = func(controllerCtx *options.ControllerContext, _ string, _ *rest.Config) (client.Client, error) {
return controllerCtx.CurrentNamespaceClient, nil
}
View Source
var GetRemoteClient = func(options *options.VirtualClusterOptions) (*rest.Config, string, string, *rest.Config, string, string, error) {
inClusterConfig := ctrl.GetConfigOrDie()
inClusterConfig.QPS = 40
inClusterConfig.Burst = 80
inClusterConfig.Timeout = 0
currentNamespace, err := clienthelper.CurrentNamespace()
if err != nil {
return nil, "", "", nil, "", "", err
}
proOptions := options.ProOptions
if proOptions.RemoteKubeConfig == "" {
return inClusterConfig, currentNamespace, options.ServiceName, inClusterConfig, currentNamespace, options.ServiceName, nil
}
return nil, "", "", nil, "", "", NewFeatureError(string(licenseapi.VirtualClusterProDistroIsolatedControlPlane))
}
View Source
var InitDNSServiceSyncing = func(_ *options.VirtualClusterOptions) specialservices.Interface {
return specialservices.NewDefaultServiceSyncer()
}
View Source
var InitProControllerContext = func(_ *options.ControllerContext) error {
return nil
}
View Source
var LicenseFeatures = func() map[string]bool {
return make(map[string]bool)
}
LicenseFeatures is used to retrieve all enabled features
View Source
var LicenseInit = func(_ context.Context, _ *rest.Config, _, _ string) error {
return nil
}
LicenseInit is used to initialize the license reader
View Source
var NewPhysicalClient = func(_ *options.VirtualClusterOptions) client.NewClientFunc {
return pluginhookclient.NewPhysicalPluginClientFactory(blockingcacheclient.NewCacheClient)
}
View Source
var NewVirtualClient = func(_ *options.VirtualClusterOptions) client.NewClientFunc {
return pluginhookclient.NewVirtualPluginClientFactory(blockingcacheclient.NewCacheClient)
}
View Source
var StartEmbeddedEtcd = func(_ context.Context, _, _, _ string, _ int, _ string) error {
return NewFeatureError("embedded etcd")
}
View Source
var StartIntegratedCoreDNS = func(_ *options.ControllerContext) error {
return NewFeatureError("integrated core dns")
}
View Source
var SyncNoopSyncerEndpoints = func(_ *options.ControllerContext, _ types.NamespacedName, _ client.Client, _ types.NamespacedName, _ string) error {
return NewFeatureError("noop syncer")
}
View Source
var SyncRemoteEndpoints = func(_ context.Context, _ types.NamespacedName, _ client.Client, _ types.NamespacedName, _ client.Client) error {
return NewFeatureError(string(licenseapi.VirtualClusterProDistroIsolatedControlPlane))
}
Functions ¶
func AddProFlags ¶ added in v0.19.3
func AddProFlags(flags *pflag.FlagSet, options *options.VirtualClusterOptions)
func NewFeatureError ¶ added in v0.19.3
func NewFeatureError(featureName string) error
func ParseExtraHooks ¶ added in v0.19.3
func ParseExtraHooks(valHooks, mutHooks []string) ([]admissionregistrationv1.ValidatingWebhookConfiguration, []admissionregistrationv1.MutatingWebhookConfiguration, error)
func ValidateProOptions ¶ added in v0.19.3
func ValidateProOptions(options *options.VirtualClusterOptions) error
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.