features

package

v1.2.5 Latest Latest Go to latest Published: Jun 9, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation ¶

Index ¶

Constants
Variables
func CRDCompatibleVersion(operatorVersion string) (string, error)
func GetResourcesForVersion(version string) ([]string, bool)
func SupportedVersions() []string
func UnknownBackupPolicyFrequencyTypesPruner(crdSpec *apiextensionsv1.JSONSchemaProps, obj runtime.Object) error
type AtlasCRDs
- func NewAtlasCRDs(crdProvider crds.AtlasOperatorCRDProvider, version string) (*AtlasCRDs, error)
type FeatureValidator
type Patcher
- func NopPatcher() Patcher
type PatcherFunc
- func (pf PatcherFunc) Patch(crdSpec *apiextensionsv1.JSONSchemaProps, obj runtime.Object) error

Constants ¶

const (
	LatestOperatorMajorVersion = "2.15.0"

	ResourceVersion                     = "mongodb.com/atlas-resource-version"
	ResourceAtlasProject                = "atlas.mongodb.com_atlasprojects"
	ResourceAtlasDeployment             = "atlas.mongodb.com_atlasdeployments"
	ResourceAtlasDatabaseUser           = "atlas.mongodb.com_atlasdatabaseusers"
	ResourceAtlasBackupSchedule         = "atlas.mongodb.com_atlasbackupschedules"
	ResourceAtlasBackupPolicy           = "atlas.mongodb.com_atlasbackuppolicies"
	ResourceAtlasTeam                   = "atlas.mongodb.com_atlasteams"
	ResourceAtlasDataFederation         = "atlas.mongodb.com_atlasdatafederations"
	ResourceAtlasFederatedAuth          = "atlas.mongodb.com_atlasfederatedauths"
	ResourceAtlasStreamInstance         = "atlas.mongodb.com_atlasstreaminstances"
	ResourceAtlasStreamConnection       = "atlas.mongodb.com_atlasstreamconnections"
	ResourceAtlasBackupCompliancePolicy = "atlas.mongodb.com_atlasbackupcompliancepolicies"
	ResourceAtlasPrivateEndpoint        = "atlas.mongodb.com_atlasprivateendpoints"
	ResourceAtlasCustomRole             = "atlas.mongodb.com_atlascustomroles"
	ResourceAtlasIPAccessList           = "atlas.mongodb.com_atlasipaccesslists"
	ResourceAtlasNetworkContainer       = "atlas.mongodb.com_atlasnetworkcontainers"
	ResourceAtlasNetworkPeering         = "atlas.mongodb.com_atlasnetworkpeerings"
	ResourceAtlasThirdPartyIntegration  = "atlas.mongodb.com_atlasthirdpartyintegrations"
	ResourceAtlasOrgSettings            = "atlas.mongodb.com_atlasorgsettings"

	CRDTypeCurated   = "curated"
	CRDTypeGenerated = "generated"
)

Variables ¶

View Source

var (
	ErrVersionNotSupportedFmt    = "version '%s' is not supported"
	ErrDownloadResourceFailedFmt = "can not download resource '%s': %v"
	ErrDocumentIsEmpty           = errors.New("document is empty")
	ErrDocumentHasNoVersions     = errors.New("document contains no versions")
	ErrDocumentHasNoSchema       = errors.New("document contains no Schema")
	ErrDocumentHasNoSpec         = errors.New("document contains no Spec")
)

Functions ¶

func CRDCompatibleVersion ¶

func CRDCompatibleVersion(operatorVersion string) (string, error)

func GetResourcesForVersion ¶

func GetResourcesForVersion(version string) ([]string, bool)

func SupportedVersions ¶

func SupportedVersions() []string

func UnknownBackupPolicyFrequencyTypesPruner ¶

func UnknownBackupPolicyFrequencyTypesPruner(crdSpec *apiextensionsv1.JSONSchemaProps, obj runtime.Object) error

UnknownBackupPolicyFrequencyTypesPruner removes backup policy items from a backup policy with unknown frequency types. It inspects the CRD definition to determine supported frequency types.

Types ¶

type AtlasCRDs ¶

type AtlasCRDs struct {
	// contains filtered or unexported fields
}

func NewAtlasCRDs ¶

func NewAtlasCRDs(crdProvider crds.AtlasOperatorCRDProvider, version string) (*AtlasCRDs, error)

func (*AtlasCRDs) FeatureExist ¶

func (a *AtlasCRDs) FeatureExist(resourceName, featurePath string) bool

FeatureExist resourceName: one of SupportedResources featurePath: dot-separated string - path in CRD spec to check.

func (*AtlasCRDs) IsResourceSupported ¶

func (a *AtlasCRDs) IsResourceSupported(resourceName string) bool

func (*AtlasCRDs) Patch ¶

func (a *AtlasCRDs) Patch(obj runtime.Object) error

type FeatureValidator ¶

type FeatureValidator interface {
	IsResourceSupported(resourceName string) bool
	FeatureExist(resourceName, path string) bool
}

type Patcher ¶

type Patcher interface {
	Patch(crdSpec *apiextensionsv1.JSONSchemaProps, obj runtime.Object) error
}

Patcher is the type that is able to patch Kubernetes objects using a CRD specification.

func NopPatcher ¶

func NopPatcher() Patcher

NopPatcher does not patch anything.

type PatcherFunc ¶

type PatcherFunc func(crdSpec *apiextensionsv1.JSONSchemaProps, obj runtime.Object) error

PatcherFunc is a convenience function wrapper around Patcher.

func (PatcherFunc) Patch ¶

func (pf PatcherFunc) Patch(crdSpec *apiextensionsv1.JSONSchemaProps, obj runtime.Object) error

Source Files ¶

View all Source files

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