advancedcluster

Documentation

Index

• Constants
• Variables
• func AddIDsToReplicationSpecs(replicationSpecs []admin.ReplicationSpec20240805, ...) []admin.ReplicationSpec20240805
• func CreateStateChangeConfig(ctx context.Context, connV2 *admin.APIClient, projectID, name string, ...) retry.StateChangeConf
• func DataSource() *schema.Resource
• func DeleteStateChangeConfig(ctx context.Context, connV2 *admin.APIClient, projectID, name string, ...) retry.StateChangeConf
• func FlattenAdvancedReplicationSpecsOldSDK(ctx context.Context, apiObjects []admin20240530.ReplicationSpec, ...) ([]map[string]any, error)
• func FormatMongoDBMajorVersion(val any) string
• func GetDiskSizeGBFromReplicationSpec(cluster *admin.ClusterDescription20240805) float64
• func HashCodeString(s string) int
• func HashFunctionForKeyValuePair(v any) int
• func IsChangeStreamOptionsMinRequiredMajorVersion(input *string) bool
• func IsSharedTier(instanceSize string) bool
• func MigrateBIConnectorConfig(rawState map[string]any) map[string]any
• func PluralDataSource() *schema.Resource
• func Resource() *schema.Resource
• func ResourceClusterListAdvancedRefreshFunc(ctx context.Context, projectID string, clustersAPI admin.ClustersApi) retry.StateRefreshFunc
• func ResourceV0() *schema.Resource
• func SchemaAdvancedConfig() *schema.Schema
• func SchemaAdvancedConfigDS() *schema.Schema
• func SchemaConnectionStrings() *schema.Schema
• func SyncAutoScalingConfigs(replicationSpecs *[]admin.ReplicationSpec20240805)
• func UpgradeRefreshFunc(ctx context.Context, name, projectID string, client admin.ClustersApi) retry.StateRefreshFunc
• type ReplicationSpecSDKModel

Constants

const (
	ErrorClusterSetting            = "error setting `%s` for MongoDB Cluster (%s): %s"
	ErrorAdvancedConfRead          = "error reading Advanced Configuration Option form MongoDB Cluster (%s): %s"
	ErrorClusterAdvancedSetting    = "error setting `%s` for MongoDB ClusterAdvanced (%s): %s"
	ErrorAdvancedClusterListStatus = "error awaiting MongoDB ClusterAdvanced List IDLE: %s"
	ErrorOperationNotPermitted     = "error operation not permitted"

	DeprecationOldSchemaAction = "" /* 206-byte string literal not displayed */
)

Variables

var (
	DSTagsSchema = schema.Schema{
		Type:     schema.TypeSet,
		Computed: true,
		Elem: &schema.Resource{
			Schema: map[string]*schema.Schema{
				"key": {
					Type:     schema.TypeString,
					Computed: true,
				},
				"value": {
					Type:     schema.TypeString,
					Computed: true,
				},
			},
		},
	}
	RSTagsSchema = schema.Schema{
		Type:     schema.TypeSet,
		Optional: true,
		Elem: &schema.Resource{
			Schema: map[string]*schema.Schema{
				"key": {
					Type:     schema.TypeString,
					Required: true,
				},
				"value": {
					Type:     schema.TypeString,
					Required: true,
				},
			},
		},
	}
)

var DeprecationMsgOldSchema = fmt.Sprintf("%s %s", constant.DeprecationParam, DeprecationOldSchemaAction)

Functions

func AddIDsToReplicationSpecs

func AddIDsToReplicationSpecs(replicationSpecs []admin.ReplicationSpec20240805, zoneToReplicationSpecsIDs map[string][]string) []admin.ReplicationSpec20240805

func CreateStateChangeConfig

func CreateStateChangeConfig(ctx context.Context, connV2 *admin.APIClient, projectID, name string, timeout time.Duration) retry.StateChangeConf

func DataSource

func DataSource() *schema.Resource

func DeleteStateChangeConfig

func DeleteStateChangeConfig(ctx context.Context, connV2 *admin.APIClient, projectID, name string, timeout time.Duration) retry.StateChangeConf

func FlattenAdvancedReplicationSpecsOldSDK

func FlattenAdvancedReplicationSpecsOldSDK(ctx context.Context, apiObjects []admin20240530.ReplicationSpec, zoneNameToZoneIDs map[string]string, rootDiskSizeGB float64, tfMapObjects []any,
	d *schema.ResourceData, connV2 *admin.APIClient) ([]map[string]any, error)

func FormatMongoDBMajorVersion

func FormatMongoDBMajorVersion(val any) string

func GetDiskSizeGBFromReplicationSpec

func GetDiskSizeGBFromReplicationSpec(cluster *admin.ClusterDescription20240805) float64

GetDiskSizeGBFromReplicationSpec obtains the diskSizeGB value by looking into the electable spec of the first replication spec. Independent storage size scaling is not supported (CLOUDP-201331), meaning all electable/analytics/readOnly configs in all replication specs are the same.

func HashCodeString

func HashCodeString(s string) int

HashCodeString hashes a string to a unique hashcode.

crc32 returns a uint32, but for our use we need and non negative integer. Here we cast to an integer and invert it if the result is negative.

func HashFunctionForKeyValuePair

func HashFunctionForKeyValuePair(v any) int

func IsChangeStreamOptionsMinRequiredMajorVersion

func IsChangeStreamOptionsMinRequiredMajorVersion(input *string) bool

func IsSharedTier

func IsSharedTier(instanceSize string) bool

func MigrateBIConnectorConfig

func MigrateBIConnectorConfig(rawState map[string]any) map[string]any

func PluralDataSource

func PluralDataSource() *schema.Resource

func Resource

func Resource() *schema.Resource

func ResourceClusterListAdvancedRefreshFunc

func ResourceClusterListAdvancedRefreshFunc(ctx context.Context, projectID string, clustersAPI admin.ClustersApi) retry.StateRefreshFunc

func ResourceV0

func ResourceV0() *schema.Resource

func SchemaAdvancedConfig

func SchemaAdvancedConfig() *schema.Schema

func SchemaAdvancedConfigDS

func SchemaAdvancedConfigDS() *schema.Schema

func SchemaConnectionStrings

func SchemaConnectionStrings() *schema.Schema

func SyncAutoScalingConfigs

func SyncAutoScalingConfigs(replicationSpecs *[]admin.ReplicationSpec20240805)

Having the following considerations: - Existing replication specs can have the autoscaling values present in the state with default values even if not defined in the config (case when cluster is imported) - API expects autoScaling and analyticsAutoScaling aligned cross all region configs in the PATCH request This function is needed to avoid errors if a new replication spec is added, ensuring the PATCH request will have the auto scaling aligned with other replication specs when not present in config.

func UpgradeRefreshFunc

func UpgradeRefreshFunc(ctx context.Context, name, projectID string, client admin.ClustersApi) retry.StateRefreshFunc

Types

type ReplicationSpecSDKModel

type ReplicationSpecSDKModel interface {
	admin20240530.ReplicationSpec | admin.ReplicationSpec20240805
}