pro

Documentation

Index

• Variables
• func NewFeatureError(featureName string) error

Variables

var AddRemoteNodePortSANs = func(_ context.Context, _, _ string, _ kubernetes.Interface) error {
	return nil
}

var ApplyPatchesHostObject = func(_ *synccontext.SyncContext, _, _, _ client.Object, patches []config.TranslatePatch, _ bool) error {
	if len(patches) == 0 {
		return nil
	}

	return NewFeatureError("translate patches")
}

var ApplyPatchesVirtualObject = func(_ *synccontext.SyncContext, _, _, _ client.Object, patches []config.TranslatePatch, _ bool) error {
	if len(patches) == 0 {
		return nil
	}

	return NewFeatureError("translate patches")
}

var BuildProSyncers = func(_ *synccontext.RegisterContext) ([]syncertypes.Object, error) {
	return []syncertypes.Object{}, nil
}

var ConfigureExternalDatabase = func(_ context.Context, _ *config.VirtualClusterConfig) (string, *etcd.Certificates, error) {
	return "", nil, NewFeatureError("external database")
}

var ConnectToPlatform = func(context.Context, *config.VirtualClusterConfig) (func(mgr manager.Manager) error, error) {
	return func(_ manager.Manager) error { return nil }, nil
}

var ExchangeControlPlaneClient = func(controllerCtx *synccontext.ControllerContext) (client.Client, error) {
	return controllerCtx.WorkloadNamespaceClient, nil
}

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
}

var InitDNSServiceSyncing = func(_ *config.VirtualClusterConfig) specialservices.Interface {
	return specialservices.NewDefaultServiceSyncer()
}

var InitProControllerContext = func(_ *synccontext.ControllerContext) error {
	return nil
}

var LicenseFeatures = func() map[string]bool {
	return make(map[string]bool)
}

LicenseFeatures is used to retrieve all enabled features

var LicenseInit = func(_ context.Context, _ *config.VirtualClusterConfig) error {
	return nil
}

LicenseInit is used to initialize the license reader

var NewImporter = func(_ synccontext.Mapper) syncertypes.Importer {
	return &noopImporter{}
}

var NewPhysicalClient = func(_ *config.VirtualClusterConfig) client.NewClientFunc {
	return pluginhookclient.NewPhysicalPluginClientFactory(blockingcacheclient.NewCacheClient)
}

var NewVirtualClient = func(_ *config.VirtualClusterConfig) client.NewClientFunc {
	return pluginhookclient.NewVirtualPluginClientFactory(blockingcacheclient.NewCacheClient)
}

var RegisterProControllers = func(*synccontext.ControllerContext) error {
	return nil
}

var StartEmbeddedEtcd = func(_ context.Context, _, _, _ string, _ int, _ string) error {
	return NewFeatureError("embedded etcd")
}

var StartIntegratedCoreDNS = func(_ *synccontext.ControllerContext) error {
	return NewFeatureError("integrated core dns")
}

var SyncNoopSyncerEndpoints = func(_ *synccontext.ControllerContext, _ types.NamespacedName, _ client.Client, _ types.NamespacedName, _ string) error {
	return NewFeatureError("noop syncer")
}

var SyncRemoteEndpoints = func(_ context.Context, _ types.NamespacedName, _ client.Client, _ types.NamespacedName, _ client.Client) error {
	return NewFeatureError(string(licenseapi.VirtualClusterProDistroIsolatedControlPlane))
}

Functions

func NewFeatureError

func NewFeatureError(featureName string) error