pro

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

Variables

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

var ExchangeControlPlaneClient = func(controllerCtx *options.ControllerContext, _ string, _ *rest.Config) (client.Client, error) {
	return controllerCtx.CurrentNamespaceClient, nil
}

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))
}

var InitDNSServiceSyncing = func(_ *options.VirtualClusterOptions) specialservices.Interface {
	return specialservices.NewDefaultServiceSyncer()
}

var InitProControllerContext = func(_ *options.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, _ *rest.Config, _, _ string) error {
	return nil
}

LicenseInit is used to initialize the license reader

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

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

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

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

var SyncNoopSyncerEndpoints = func(_ *options.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 AddProFlags

func AddProFlags(flags *pflag.FlagSet, options *options.VirtualClusterOptions)

func NewFeatureError

func NewFeatureError(featureName string) error

func ParseExtraHooks

func ParseExtraHooks(valHooks, mutHooks []string) ([]admissionregistrationv1.ValidatingWebhookConfiguration, []admissionregistrationv1.MutatingWebhookConfiguration, error)

func ValidateProOptions

func ValidateProOptions(options *options.VirtualClusterOptions) error