pro

package
v0.37.0-alpha.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 20, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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(licenseapi.VirtualClusterProDistroTranslatePatches)
}
View Source
var ApplyPatchesVirtualObject = func(_ *synccontext.SyncContext, _, _, _ client.Object, patches []config.TranslatePatch, _ bool) error {
	if len(patches) == 0 {
		return nil
	}

	return NewFeatureError(licenseapi.VirtualClusterProDistroTranslatePatches)
}
View Source
var BuildProSyncers = func(_ *synccontext.RegisterContext) ([]syncertypes.Object, error) {
	return []syncertypes.Object{}, nil
}
View Source
var ErrSnapshotCredentialsMalformed = errors.New("the platform returned snapshot credentials that could not be read")

ErrSnapshotCredentialsMalformed marks a response that arrived but could not be read. Terminal: the platform answered, so waiting only repeats the same answer.

View Source
var GetWithSyncedNamespacesTranslator = func(_ string, _ config.FromHostMappings) (translate.Translator, error) {
	return nil, NewFeatureError(licenseapi.SyncNamespacesTohost)
}
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 RegisterProControllers = func(*synccontext.ControllerContext) error {
	return nil
}
View Source
var ResolveSnapshotCredentials func(ctx context.Context) (*snapshotapi.Options, error)

ResolveSnapshotCredentials, when set by the pro runtime, pulls the snapshot storage credentials for a standalone, platform-connected tenant from the platform on demand, authenticated with the instance access key. Credentials are per instance (per auto-snapshot storage configuration), so no snapshot identifier is needed; the storage location comes from the snapshot request itself. The returned options carry only credentials and are used in memory only, never persisted in the tenant. It is nil in OSS-only builds (standalone auto-snapshots are a platform/pro feature), in which case the snapshot controller uses the options pushed alongside the request.

The caller classifies the error to decide retry-vs-fail, so wrap API status errors with %w and a response that cannot be read with ErrSnapshotCredentialsMalformed; both are terminal, anything else is retried. Options with no Type mean "not provisioned yet" and are retried without caching.

View Source
var SetStandaloneConstants = func(_ *config.VirtualClusterConfig) error {
	return nil
}

SetStandaloneConstants remaps global constant paths to the standalone data directory. Injected by vcluster-pro at startup; the noop default is never reached in practice because standalone requires the pro binary.

View Source
var SetupStandaloneRestore = func(_ *config.VirtualClusterConfig) (func() error, error) {
	return func() error { return nil }, nil
}

SetupStandaloneRestore allows vcluster-pro to adjust standalone restore state before the restore client opens the backing store and returns a rollback closure for failures that happen later in the restore flow. The noop default leaves OSS behavior unchanged.

View Source
var StartKonnectivity = func(ctx *synccontext.ControllerContext) error {

	if !ctx.Config.PrivateNodes.Enabled {
		return nil
	}

	return NewFeatureError(licenseapi.VirtualClusterProDistroPrivateNodes)
}
View Source
var StartPrivateNodesMode = func(ctx *synccontext.ControllerContext) error {

	if !ctx.Config.PrivateNodes.Enabled {
		return nil
	}

	return NewFeatureError(licenseapi.VirtualClusterProDistroPrivateNodes)
}
View Source
var StartStandalone = func(_ context.Context, _ *StandaloneOptions) error {
	return NewFeatureError(licenseapi.Standalone)
}
View Source
var SyncKubernetesServiceDedicated = func(ctx *synccontext.SyncContext) error {

	if !ctx.Config.PrivateNodes.Enabled {
		return nil
	}

	return NewFeatureError(licenseapi.VirtualClusterProDistroPrivateNodes)
}
View Source
var WithKonnectivity = func(ctx *synccontext.ControllerContext, handler http.Handler) http.Handler {
	return handler
}
View Source
var WriteKonnectivityEgressConfig = func() (string, error) {
	return "", NewFeatureError(licenseapi.VirtualClusterProDistroPrivateNodes)
}

Functions

func NewFeatureError added in v0.19.3

func NewFeatureError(featureName licenseapi.FeatureName) error

Types

type StandaloneOptions added in v0.26.0

type StandaloneOptions struct {
	Config string
}

type UpgradeOptions added in v0.26.0

type UpgradeOptions struct {
	KubernetesVersion string
	BinariesPath      string
	CNIBinariesPath   string
	BundleRepository  string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL