Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var AddRemoteNodePortSANs = func(_ context.Context, _, _ string, _ kubernetes.Interface) error {
return nil
}
View Source
var ApplyPatchesHostObject = func(_ *synccontext.SyncContext, _, _, _ client.Object, patches []config.TranslatePatch, _ bool) error {
if len(patches) == 0 {
return nil
}
return NewFeatureError("translate patches")
}
View Source
var ApplyPatchesVirtualObject = func(_ *synccontext.SyncContext, _, _, _ client.Object, patches []config.TranslatePatch, _ bool) error {
if len(patches) == 0 {
return nil
}
return NewFeatureError("translate patches")
}
View Source
var BuildProSyncers = func(_ *synccontext.RegisterContext) ([]syncertypes.Object, error) {
return []syncertypes.Object{}, nil
}
View Source
var ConfigureExternalDatabase = func(_ context.Context, _ string, _ *config.VirtualClusterConfig, _ bool) (string, *etcd.Certificates, error) {
return "", nil, NewFeatureError("external database")
}
View Source
var ExchangeControlPlaneClient = func(controllerCtx *synccontext.ControllerContext) (client.Client, error) {
return controllerCtx.WorkloadNamespaceClient, nil
}
View Source
var GetRemoteClient = func(vConfig *config.VirtualClusterConfig) (*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
}
if vConfig.Experimental.IsolatedControlPlane.Enabled {
return nil, "", "", nil, "", "", NewFeatureError(string(licenseapi.VirtualClusterProDistroIsolatedControlPlane))
}
return inClusterConfig, currentNamespace, vConfig.ControlPlaneService, inClusterConfig, currentNamespace, vConfig.ControlPlaneService, nil
}
View Source
var InitDNSServiceSyncing = func(_ *config.VirtualClusterConfig) specialservices.Interface {
return specialservices.NewDefaultServiceSyncer()
}
View Source
var InitProControllerContext = func(_ *synccontext.ControllerContext) error {
return nil
}
View Source
var LicenseFeatures = func() map[string]bool {
return make(map[string]bool)
}
LicenseFeatures returns a map of featureName: enabled / disabled
View Source
var LicenseInit = func(_ context.Context, _ *config.VirtualClusterConfig) error {
return nil
}
LicenseInit is used to initialize the license loader
View Source
var LicenseStart = func(_ *synccontext.ControllerContext) error {
return nil
}
LicenseStart is used to start license loader
View Source
var NewImporter = func(_ synccontext.Mapper) syncertypes.Importer {
return &noopImporter{}
}
View Source
var NewPhysicalClient = func(_ *config.VirtualClusterConfig) client.NewClientFunc {
return pluginhookclient.NewPhysicalPluginClientFactory(blockingcacheclient.NewCacheClient)
}
View Source
var NewVirtualClient = func(_ *config.VirtualClusterConfig) client.NewClientFunc {
return pluginhookclient.NewVirtualPluginClientFactory(blockingcacheclient.NewCacheClient)
}
View Source
var RegisterProControllers = func(*synccontext.ControllerContext) error {
return nil
}
View Source
var StartEmbeddedEtcd = func(_ context.Context, _, _, _ string, _ int, _ string, _, _ bool) error {
return NewFeatureError("embedded etcd")
}
View Source
var StartIntegratedCoreDNS = func(_ *synccontext.ControllerContext) error {
return NewFeatureError("integrated core dns")
}
View Source
var SyncNoopSyncerEndpoints = func(_ *synccontext.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 NewFeatureError ¶ added in v0.19.3
func NewFeatureError(featureName string) error
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.