Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var AddRemoteNodePortSANs = func(_ context.Context, _, _ string, _ kubernetes.Interface) error { return nil }
View Source
var ApplyIstioPatches = func(_ *synccontext.SyncContext, _, _, _ client.Object) 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 GetNamespaceMapper = func(_ *synccontext.RegisterContext, _ synccontext.Mapper) (synccontext.Mapper, error) { return nil, NewFeatureError("namespace toHost syncing") }
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 GetWithSyncedNamespacesTranslator = func(_ string, _ config.FromHostMappings) (translate.Translator, error) { return nil, NewFeatureError("namespace toHost syncing") }
View Source
var InitDNSServiceSyncing = func(_ *config.VirtualClusterConfig) specialservices.Interface { return specialservices.NewDefaultServiceSyncer() }
View Source
var InitProControllerContext = func(_ *synccontext.ControllerContext) error { return nil }
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, _ kubernetes.Interface, _ string, _ int, _ string, _ bool, _ []string, _ bool) error { return NewFeatureError("embedded etcd") }
View Source
var StartIntegratedCoreDNS = func(_ *synccontext.ControllerContext) error { return NewFeatureError("integrated core dns") }
View Source
var StartKonnectivity = func(_ context.Context, vConfig *config.VirtualClusterConfig) error { if !vConfig.PrivateNodes.Enabled { return nil } return NewFeatureError("private nodes") }
View Source
var StartPrivateNodesMode = func(ctx *synccontext.ControllerContext) error { if !ctx.Config.PrivateNodes.Enabled { return nil } return NewFeatureError("private nodes") }
View Source
var StartStandalone = func(_ context.Context, _ *StandaloneOptions) error { return NewFeatureError("private nodes standalone") }
View Source
var SyncKubernetesServiceDedicated = func(ctx *synccontext.SyncContext) error { if !ctx.Config.PrivateNodes.Enabled { return nil } return NewFeatureError("private nodes") }
View Source
var SyncRemoteEndpoints = func(_ context.Context, _ types.NamespacedName, _ client.Client, _ types.NamespacedName, _ client.Client) error { return NewFeatureError(string(licenseapi.VirtualClusterProDistroIsolatedControlPlane)) }
View Source
var UpgradeNode = func(_ context.Context, _ *UpgradeOptions) error { return NewFeatureError("private nodes") }
View Source
var WriteKonnectivityEgressConfig = func() (string, error) { return "", NewFeatureError("private nodes") }
Functions ¶
func NewFeatureError ¶ added in v0.19.3
Types ¶
type StandaloneOptions ¶ added in v0.26.0
type StandaloneOptions struct {
Config string
}
Click to show internal directories.
Click to hide internal directories.