status

package
v2.3.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StateIDLE      = "IDLE"
	StateCREATING  = "CREATING"
	StateUPDATING  = "UPDATING"
	StateDELETING  = "DELETING"
	StateDELETED   = "DELETED"
	StateREPAIRING = "REPAIRING"
)
View Source 
const (
	CloudProviderIntegrationStatusNew                 = "NEW"
	CloudProviderIntegrationStatusCreated             = "CREATED"
	CloudProviderIntegrationStatusAuthorized          = "AUTHORIZED"
	CloudProviderIntegrationStatusDeAuthorize         = "DEAUTHORIZE"
	CloudProviderIntegrationStatusFailedToCreate      = "FAILED_TO_CREATE"
	CloudProviderIntegrationStatusFailedToAuthorize   = "FAILED_TO_AUTHORIZE"
	CloudProviderIntegrationStatusFailedToDeAuthorize = "FAILED_TO_DEAUTHORIZE"

	StatusFailed = "FAILED"
	StatusReady  = "READY"
)
View Source 
const (
	SearchIndexesNamesAreNotUnique = "SearchIndexesNamesAreNotUnique"
	SearchIndexesNotReady          = "SearchIndexesNotReady"
)
View Source 
const (
	SearchIndexStatusReady      = "Ready"
	SearchIndexStatusError      = "Error"
	SearchIndexStatusInProgress = "InProgress"
)

Variables

This section is empty.

Functions

func HasConditionType added in v2.3.0 

func HasConditionType(typ ConditionType, source []Condition) bool

func TransformRegionToID 

func TransformRegionToID(region string) string

TransformRegionToID makes the same ID from region and regionName fields for PE Connections to match them it leaves only characters which are letters or numbers starting from 2 it also makes a couple swaps and sorts the resulting string this function is a temporary work around caused by the empty "region" field in Atlas reply

Types

type AlertConfiguration 

type AlertConfiguration struct {
	// Unique identifier.
	ID string `json:"id,omitempty"`
	// ErrorMessage is massage if the alert configuration is in an incorrect state.
	ErrorMessage string `json:"errorMessage,omitempty"`
	// Unique identifier of the project that owns this alert configuration.
	GroupID string `json:"groupId,omitempty"`
	// ID of the alert configuration that triggered this alert.
	AlertConfigID string `json:"alertConfigId,omitempty"`
	// The type of event that will trigger an alert.
	EventTypeName string `json:"eventTypeName,omitempty"`
	// Timestamp in ISO 8601 date and time format in UTC when this alert configuration was created.
	Created string `json:"created,omitempty"`
	// The current state of the alert. Possible values are: TRACKING, OPEN, CLOSED, CANCELED
	Status string `json:"status,omitempty"`
	// The date through which the alert has been acknowledged. Will not be present if the alert has never been acknowledged.
	AcknowledgedUntil string `json:"acknowledgedUntil,omitempty"`
	// The comment left by the user who acknowledged the alert. Will not be present if the alert has never been acknowledged.
	AcknowledgementComment string `json:"acknowledgementComment,omitempty"`
	// The username of the user who acknowledged the alert. Will not be present if the alert has never been acknowledged.
	AcknowledgingUsername string `json:"acknowledgingUsername,omitempty"`
	// Timestamp in ISO 8601 date and time format in UTC when this alert configuration was last updated.
	Updated string `json:"updated,omitempty"`
	// When the alert was closed. Only present if the status is CLOSED.
	Resolved string `json:"resolved,omitempty"`
	// When the last notification was sent for this alert. Only present if notifications have been sent.
	LastNotified string `json:"lastNotified,omitempty"`
	// The hostname and port of each host to which the alert applies. Only present for alerts of type HOST, HOST_METRIC, and REPLICA_SET.
	HostnameAndPort string `json:"hostnameAndPort,omitempty"`
	// ID of the host to which the metric pertains. Only present for alerts of type HOST, HOST_METRIC, and REPLICA_SET.
	HostID string `json:"hostId,omitempty"`
	// Name of the replica set. Only present for alerts of type HOST, HOST_METRIC, BACKUP, and REPLICA_SET.
	ReplicaSetName string `json:"replicaSetName,omitempty"`
	// The name of the measurement whose value went outside the threshold. Only present if eventTypeName is set to OUTSIDE_METRIC_THRESHOLD.
	MetricName string `json:"metricName,omitempty"`
	// If omitted, the configuration is disabled.
	Enabled *bool `json:"enabled,omitempty"`
	// The ID of the cluster to which this alert applies. Only present for alerts of type BACKUP, REPLICA_SET, and CLUSTER.
	ClusterID string `json:"clusterId,omitempty"`
	// The name the cluster to which this alert applies. Only present for alerts of type BACKUP, REPLICA_SET, and CLUSTER.
	ClusterName string `json:"clusterName,omitempty"`
	// For alerts of the type BACKUP, the type of server being backed up.
	SourceTypeName string `json:"sourceTypeName,omitempty"`
	// CurrentValue represents current value of the metric that triggered the alert. Only present for alerts of type HOST_METRIC.
	CurrentValue *CurrentValue `json:"currentValue,omitempty"`
	// You can filter using the matchers array only when the EventTypeName specifies an event for a host, replica set, or sharded cluster.
	Matchers []Matcher `json:"matchers,omitempty"`
	// MetricThreshold  causes an alert to be triggered.
	MetricThreshold *MetricThreshold `json:"metricThreshold,omitempty"`
	// Threshold  causes an alert to be triggered.
	Threshold *Threshold `json:"threshold,omitempty"`
	// Notifications are sending when an alert condition is detected.
	Notifications []Notification `json:"notifications,omitempty"`
}

func NewFailedParseAlertConfigStatus 

func NewFailedParseAlertConfigStatus(errorMessage string, jsonSpec string) AlertConfiguration

func NewIncorrectAlertConfigStatus 

func NewIncorrectAlertConfigStatus(errorMessage string, alertConfig *admin.GroupAlertsConfig, logger *zap.SugaredLogger) AlertConfiguration

func ParseAlertConfiguration 

func ParseAlertConfiguration(alertConfiguration admin.GroupAlertsConfig, logger *zap.SugaredLogger) AlertConfiguration

func (*AlertConfiguration) DeepCopy 

func (in *AlertConfiguration) DeepCopy() *AlertConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AlertConfiguration.

func (*AlertConfiguration) DeepCopyInto 

func (in *AlertConfiguration) DeepCopyInto(out *AlertConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasBackupPolicyStatusOption 

type AtlasBackupPolicyStatusOption func(s *BackupPolicyStatus)

AtlasBackupPolicyStatusOption is the option that is applied to AtlasBackupPolicy Status

func AtlasBackupPolicySetScheduleID 

func AtlasBackupPolicySetScheduleID(ID string) AtlasBackupPolicyStatusOption

func AtlasBackupPolicyUnsetScheduleID 

func AtlasBackupPolicyUnsetScheduleID(ID string) AtlasBackupPolicyStatusOption

type AtlasBackupScheduleStatusOption 

type AtlasBackupScheduleStatusOption func(s *BackupScheduleStatus)

AtlasBackupScheduleStatusOption is the option that is applied to AtlasBackupSchedule Status

func AtlasBackupScheduleSetDeploymentID 

func AtlasBackupScheduleSetDeploymentID(ID string) AtlasBackupScheduleStatusOption

func AtlasBackupScheduleUnsetDeploymentID 

func AtlasBackupScheduleUnsetDeploymentID(ID string) AtlasBackupScheduleStatusOption

type AtlasDatabaseUserStatus 

type AtlasDatabaseUserStatus struct {
	Common `json:",inline"`

	// PasswordVersion is the 'ResourceVersion' of the password Secret that the Atlas Operator is aware of
	PasswordVersion string `json:"passwordVersion,omitempty"`

	// UserName is the current name of database user.
	UserName string `json:"name,omitempty"`
}

AtlasDatabaseUserStatus defines the observed state of AtlasProject

func (*AtlasDatabaseUserStatus) DeepCopy 

func (in *AtlasDatabaseUserStatus) DeepCopy() *AtlasDatabaseUserStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasDatabaseUserStatus.

func (*AtlasDatabaseUserStatus) DeepCopyInto 

func (in *AtlasDatabaseUserStatus) DeepCopyInto(out *AtlasDatabaseUserStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasDatabaseUserStatusOption 

type AtlasDatabaseUserStatusOption func(s *AtlasDatabaseUserStatus)

AtlasDatabaseUserStatusOption is the option that is applied to Atlas Project Status

func AtlasDatabaseUserNameOption 

func AtlasDatabaseUserNameOption(name string) AtlasDatabaseUserStatusOption

func AtlasDatabaseUserPasswordVersion 

func AtlasDatabaseUserPasswordVersion(passwordVersion string) AtlasDatabaseUserStatusOption

type AtlasDeploymentStatus 

type AtlasDeploymentStatus struct {
	Common `json:",inline"`

	// StateName is the current state of the cluster.
	// The possible states are: IDLE, CREATING, UPDATING, DELETING, DELETED, REPAIRING
	StateName string `json:"stateName,omitempty"`

	// MongoDBVersion is the version of MongoDB the cluster runs, in <major version>.<minor version> format.
	MongoDBVersion string `json:"mongoDBVersion,omitempty"`

	// ConnectionStrings is a set of connection strings that your applications use to connect to this cluster.
	ConnectionStrings *ConnectionStrings `json:"connectionStrings,omitempty"`

	ReplicaSets []ReplicaSet `json:"replicaSets,omitempty"`

	ServerlessPrivateEndpoints []ServerlessPrivateEndpoint `json:"serverlessPrivateEndpoints,omitempty"`

	CustomZoneMapping *CustomZoneMapping `json:"customZoneMapping,omitempty"`

	ManagedNamespaces []ManagedNamespace `json:"managedNamespaces,omitempty"`

	// MongoURIUpdated is a timestamp in ISO 8601 date and time format in UTC when the connection string was last updated.
	// The connection string changes if you update any of the other values.
	MongoURIUpdated string `json:"mongoURIUpdated,omitempty"`

	// SearchIndexes contains a list of search indexes statuses configured for a project
	SearchIndexes []DeploymentSearchIndexStatus `json:"searchIndexes,omitempty"`
}

AtlasDeploymentStatus defines the observed state of AtlasDeployment.

func (*AtlasDeploymentStatus) DeepCopy 

func (in *AtlasDeploymentStatus) DeepCopy() *AtlasDeploymentStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasDeploymentStatus.

func (*AtlasDeploymentStatus) DeepCopyInto 

func (in *AtlasDeploymentStatus) DeepCopyInto(out *AtlasDeploymentStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasDeploymentStatusOption 

type AtlasDeploymentStatusOption func(s *AtlasDeploymentStatus)

AtlasDeploymentStatusOption is the option that is applied to Atlas Deployment Status.

func AtlasDeploymentConnectionStringsOption 

func AtlasDeploymentConnectionStringsOption(connectionStrings *mongodbatlas.ConnectionStrings) AtlasDeploymentStatusOption

func AtlasDeploymentCustomZoneMappingOption 

func AtlasDeploymentCustomZoneMappingOption(czm *CustomZoneMapping) AtlasDeploymentStatusOption

func AtlasDeploymentManagedNamespacesOption 

func AtlasDeploymentManagedNamespacesOption(namespaces []ManagedNamespace) AtlasDeploymentStatusOption

func AtlasDeploymentMongoDBVersionOption 

func AtlasDeploymentMongoDBVersionOption(mongoDBVersion string) AtlasDeploymentStatusOption

func AtlasDeploymentMongoURIUpdatedOption 

func AtlasDeploymentMongoURIUpdatedOption(mongoURIUpdated string) AtlasDeploymentStatusOption

func AtlasDeploymentRemoveStatusesWithEmptyIDs added in v2.3.0 

func AtlasDeploymentRemoveStatusesWithEmptyIDs() AtlasDeploymentStatusOption

func AtlasDeploymentReplicaSet 

func AtlasDeploymentReplicaSet(replicas []ReplicaSet) AtlasDeploymentStatusOption

func AtlasDeploymentSPEOption 

func AtlasDeploymentSPEOption(pe []ServerlessPrivateEndpoint) AtlasDeploymentStatusOption

func AtlasDeploymentSetSearchIndexStatus added in v2.3.0 

func AtlasDeploymentSetSearchIndexStatus(indexStatus DeploymentSearchIndexStatus) AtlasDeploymentStatusOption

AtlasDeploymentSetSearchIndexStatus set the status for one SearchIndex

func AtlasDeploymentStateNameOption 

func AtlasDeploymentStateNameOption(stateName string) AtlasDeploymentStatusOption

func AtlasDeploymentUnsetSearchIndexStatus added in v2.3.0 

func AtlasDeploymentUnsetSearchIndexStatus(indexStatus DeploymentSearchIndexStatus) AtlasDeploymentStatusOption

AtlasDeploymentUnsetSearchIndexStatus removes the status for one SearchIndex

type AtlasFederatedAuthStatus 

type AtlasFederatedAuthStatus struct {
	Common `json:",inline"`
}

func (*AtlasFederatedAuthStatus) DeepCopy 

func (in *AtlasFederatedAuthStatus) DeepCopy() *AtlasFederatedAuthStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasFederatedAuthStatus.

func (*AtlasFederatedAuthStatus) DeepCopyInto 

func (in *AtlasFederatedAuthStatus) DeepCopyInto(out *AtlasFederatedAuthStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasFederatedAuthStatusOption 

type AtlasFederatedAuthStatusOption func(s *AtlasFederatedAuthStatus)

type AtlasNetworkPeer 

type AtlasNetworkPeer struct {
	// Unique identifier for NetworkPeer.
	ID string `json:"id"`
	// Cloud provider for which you want to retrieve a network peer.
	ProviderName provider.ProviderName `json:"providerName"`
	// Region for which you want to create the network peer. It isn't needed for GCP
	Region string `json:"region"`
	// Status of the network peer. Applicable only for AWS.
	StatusName string `json:"statusName,omitempty"`
	// Error state of the network peer. Applicable only for Azure.
	ErrorState string `json:"errorState,omitempty"`
	// Error state of the network peer. Applicable only for AWS.
	ErrorStateName string `json:"errorStateName,omitempty"`
	// Error state of the network peer. Applicable only for GCP.
	ErrorMessage string `json:"errorMessage,omitempty"`
	// Unique identifier of the network peer connection. Applicable only for AWS.
	ConnectionID string `json:"connectionId,omitempty"`
	// Status of the network peer. Applicable only for GCP and Azure.
	Status string `json:"status,omitempty"`
	// VPC is general purpose field for storing the name of the VPC.
	// VPC is vpcID for AWS, user networkName for GCP, and vnetName for Azure.
	VPC string `json:"vpc,omitempty"`
	// ProjectID of the user's vpc. Applicable only for GCP.
	GCPProjectID string `json:"gcpProjectId,omitempty"`
	// Atlas Network Name. Applicable only for GCP. It's needed to add network peer connection.
	AtlasNetworkName string `json:"atlasNetworkName,omitempty"`
	// ProjectID of Atlas container. Applicable only for GCP. It's needed to add network peer connection.
	AtlasGCPProjectID string `json:"atlasGcpProjectId,omitempty"`
	// ContainerID of Atlas network peer container.
	ContainerID string `json:"containerId,omitempty"`
}

func NewNetworkPeerStatus 

func NewNetworkPeerStatus(atlasPeer admin.BaseNetworkPeeringConnectionSettings, providerName provider.ProviderName, vpcName string, container admin.CloudProviderContainer) AtlasNetworkPeer

func (*AtlasNetworkPeer) DeepCopy 

func (in *AtlasNetworkPeer) DeepCopy() *AtlasNetworkPeer

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasNetworkPeer.

func (*AtlasNetworkPeer) DeepCopyInto 

func (in *AtlasNetworkPeer) DeepCopyInto(out *AtlasNetworkPeer)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AtlasNetworkPeer) GetStatus 

func (in *AtlasNetworkPeer) GetStatus() string

type AtlasProjectStatus 

type AtlasProjectStatus struct {
	Common `json:",inline"`

	// The ID of the Atlas Project
	// +optional
	ID string `json:"id,omitempty"`

	// The list of IP Access List entries that are expired due to 'deleteAfterDate' being less than the current date.
	// Note, that this field is updated by the Atlas Operator only after specification changes
	ExpiredIPAccessList []project.IPAccessList `json:"expiredIpAccessList,omitempty"`

	// The list of private endpoints configured for current project
	PrivateEndpoints []ProjectPrivateEndpoint `json:"privateEndpoints,omitempty"`

	// The list of network peers that are configured for current project
	NetworkPeers []AtlasNetworkPeer `json:"networkPeers,omitempty"`

	// AuthModes contains a list of configured authentication modes
	// "SCRAM" is default authentication method and requires a password for each user
	// "X509" signifies that self-managed X.509 authentication is configured
	AuthModes authmode.AuthModes `json:"authModes,omitempty"`

	// AlertConfigurations contains a list of alert configuration statuses
	AlertConfigurations []AlertConfiguration `json:"alertConfigurations,omitempty"`

	// CloudProviderIntegrations contains a list of configured cloud provider access roles. AWS support only
	CloudProviderIntegrations []CloudProviderIntegration `json:"cloudProviderIntegrations,omitempty"`

	// CustomRoles contains a list of custom roles statuses
	CustomRoles []CustomRole `json:"customRoles,omitempty"`

	// Teams contains a list of teams assignment statuses
	Teams []ProjectTeamStatus `json:"teams,omitempty"`

	// Prometheus contains the status for Prometheus integration
	// including the prometheusDiscoveryURL
	// +optional
	Prometheus *Prometheus `json:"prometheus,omitempty"`
}

AtlasProjectStatus defines the observed state of AtlasProject

func (*AtlasProjectStatus) DeepCopy 

func (in *AtlasProjectStatus) DeepCopy() *AtlasProjectStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasProjectStatus.

func (*AtlasProjectStatus) DeepCopyInto 

func (in *AtlasProjectStatus) DeepCopyInto(out *AtlasProjectStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasProjectStatusOption 

type AtlasProjectStatusOption func(s *AtlasProjectStatus)

AtlasProjectStatusOption is the option that is applied to Atlas Project Status

func AtlasProjectAddPrivateEndpointsOption added in v2.1.0 

func AtlasProjectAddPrivateEndpointsOption(privateEndpoints []ProjectPrivateEndpoint) AtlasProjectStatusOption

func AtlasProjectAuthModesOption 

func AtlasProjectAuthModesOption(authModes []authmode.AuthMode) AtlasProjectStatusOption

func AtlasProjectCloudIntegrationsOption added in v2.1.0 

func AtlasProjectCloudIntegrationsOption(cloudIntegrations []CloudProviderIntegration) AtlasProjectStatusOption

func AtlasProjectExpiredIPAccessOption 

func AtlasProjectExpiredIPAccessOption(lists []project.IPAccessList) AtlasProjectStatusOption

func AtlasProjectIDOption 

func AtlasProjectIDOption(id string) AtlasProjectStatusOption

func AtlasProjectPrometheusOption 

func AtlasProjectPrometheusOption(prometheus *Prometheus) AtlasProjectStatusOption

func AtlasProjectSetAlertConfigOption 

func AtlasProjectSetAlertConfigOption(alertConfigs *[]AlertConfiguration) AtlasProjectStatusOption

func AtlasProjectSetCustomRolesOption 

func AtlasProjectSetCustomRolesOption(customRoles *[]CustomRole) AtlasProjectStatusOption

func AtlasProjectSetNetworkPeerOption 

func AtlasProjectSetNetworkPeerOption(networkPeers *[]AtlasNetworkPeer) AtlasProjectStatusOption

func AtlasProjectSetPrivateEndpointsOption added in v2.1.0 

func AtlasProjectSetPrivateEndpointsOption(privateEndpoints []ProjectPrivateEndpoint) AtlasProjectStatusOption

func AtlasProjectSetTeamsOption 

func AtlasProjectSetTeamsOption(teams *[]ProjectTeamStatus) AtlasProjectStatusOption

type AtlasSearchIndexConfigStatus added in v2.3.0 

type AtlasSearchIndexConfigStatus struct {
	Common `json:",inline"`
}

func (*AtlasSearchIndexConfigStatus) DeepCopy added in v2.3.0 

func (in *AtlasSearchIndexConfigStatus) DeepCopy() *AtlasSearchIndexConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasSearchIndexConfigStatus.

func (*AtlasSearchIndexConfigStatus) DeepCopyInto added in v2.3.0 

func (in *AtlasSearchIndexConfigStatus) DeepCopyInto(out *AtlasSearchIndexConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasSearchIndexConfigStatusOption added in v2.3.0 

type AtlasSearchIndexConfigStatusOption func(s *AtlasSearchIndexConfigStatus)

type AtlasStreamConnectionStatus added in v2.3.0 

type AtlasStreamConnectionStatus struct {
	Common `json:",inline"`
	// List of instances using the connection configuration
	Instances []common.ResourceRefNamespaced `json:"instances,omitempty"`
}

func (*AtlasStreamConnectionStatus) DeepCopy added in v2.3.0 

func (in *AtlasStreamConnectionStatus) DeepCopy() *AtlasStreamConnectionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasStreamConnectionStatus.

func (*AtlasStreamConnectionStatus) DeepCopyInto added in v2.3.0 

func (in *AtlasStreamConnectionStatus) DeepCopyInto(out *AtlasStreamConnectionStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasStreamConnectionStatusOption added in v2.3.0 

type AtlasStreamConnectionStatusOption func(s *AtlasStreamConnectionStatus)

type AtlasStreamInstanceStatus added in v2.3.0 

type AtlasStreamInstanceStatus struct {
	Common `json:",inline"`
	// Unique 24-hexadecimal character string that identifies the instance
	ID string `json:"id,omitempty"`
	// List that contains the hostnames assigned to the stream instance.
	Hostnames []string `json:"hostnames,omitempty"`
	// List of connections configured in the stream instance.
	Connections []StreamConnection `json:"connections,omitempty"`
}

func (*AtlasStreamInstanceStatus) DeepCopy added in v2.3.0 

func (in *AtlasStreamInstanceStatus) DeepCopy() *AtlasStreamInstanceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AtlasStreamInstanceStatus.

func (*AtlasStreamInstanceStatus) DeepCopyInto added in v2.3.0 

func (in *AtlasStreamInstanceStatus) DeepCopyInto(out *AtlasStreamInstanceStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AtlasStreamInstanceStatusOption added in v2.3.0 

type AtlasStreamInstanceStatusOption func(s *AtlasStreamInstanceStatus)

func AtlasStreamInstanceAddConnection added in v2.3.0 

func AtlasStreamInstanceAddConnection(name string, ref common.ResourceRefNamespaced) AtlasStreamInstanceStatusOption

func AtlasStreamInstanceDetails added in v2.3.0 

func AtlasStreamInstanceDetails(ID string, hostnames []string) AtlasStreamInstanceStatusOption

func AtlasStreamInstanceRemoveConnection added in v2.3.0 

func AtlasStreamInstanceRemoveConnection(name string) AtlasStreamInstanceStatusOption

type AtlasTeamStatusOption 

type AtlasTeamStatusOption func(s *TeamStatus)

AtlasTeamStatusOption is the option that is applied to Atlas Project Status

func AtlasTeamSetID 

func AtlasTeamSetID(ID string) AtlasTeamStatusOption

func AtlasTeamSetProjects 

func AtlasTeamSetProjects(projects []TeamProject) AtlasTeamStatusOption

func AtlasTeamUnsetID 

func AtlasTeamUnsetID() AtlasTeamStatusOption

type BackupPolicyStatus 

type BackupPolicyStatus struct {
	Common `json:",inline"`

	// DeploymentID of the deployment using the backup policy
	BackupScheduleIDs []string `json:"backupScheduleIDs,omitempty"`
}

func (*BackupPolicyStatus) DeepCopy 

func (in *BackupPolicyStatus) DeepCopy() *BackupPolicyStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BackupPolicyStatus.

func (*BackupPolicyStatus) DeepCopyInto 

func (in *BackupPolicyStatus) DeepCopyInto(out *BackupPolicyStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BackupScheduleStatus 

type BackupScheduleStatus struct {
	Common `json:",inline"`

	DeploymentIDs []string `json:"deploymentID,omitempty"`
}

func (*BackupScheduleStatus) DeepCopy 

func (in *BackupScheduleStatus) DeepCopy() *BackupScheduleStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BackupScheduleStatus.

func (*BackupScheduleStatus) DeepCopyInto 

func (in *BackupScheduleStatus) DeepCopyInto(out *BackupScheduleStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CloudProviderIntegration added in v2.1.0 

type CloudProviderIntegration struct {
	AtlasAWSAccountArn         string         `json:"atlasAWSAccountArn,omitempty"`
	AtlasAssumedRoleExternalID string         `json:"atlasAssumedRoleExternalId"`
	AuthorizedDate             string         `json:"authorizedDate,omitempty"`
	CreatedDate                string         `json:"createdDate,omitempty"`
	FeatureUsages              []FeatureUsage `json:"featureUsages,omitempty"`
	IamAssumedRoleArn          string         `json:"iamAssumedRoleArn,omitempty"`
	ProviderName               string         `json:"providerName"`
	RoleID                     string         `json:"roleId,omitempty"`
	Status                     string         `json:"status,omitempty"`
	ErrorMessage               string         `json:"errorMessage,omitempty"`
}

func NewCloudProviderIntegration added in v2.1.0 

func NewCloudProviderIntegration(providerName, assumedRoleArn string) CloudProviderIntegration

func (*CloudProviderIntegration) DeepCopy added in v2.1.0 

func (in *CloudProviderIntegration) DeepCopy() *CloudProviderIntegration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudProviderIntegration.

func (*CloudProviderIntegration) DeepCopyInto added in v2.1.0 

func (in *CloudProviderIntegration) DeepCopyInto(out *CloudProviderIntegration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Common 

type Common struct {
	// Conditions is the list of statuses showing the current state of the Atlas Custom Resource
	Conditions []Condition `json:"conditions"`

	// ObservedGeneration indicates the generation of the resource specification that the Atlas Operator is aware of.
	// The Atlas Operator updates this field to the 'metadata.generation' as soon as it starts reconciliation of the resource.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
}

Common is the struct shared by all statuses in existing Custom Resources.

func (*Common) DeepCopy 

func (in *Common) DeepCopy() *Common

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Common.

func (*Common) DeepCopyInto 

func (in *Common) DeepCopyInto(out *Common)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (Common) GetConditions 

func (c Common) GetConditions() []Condition

func (Common) GetObservedGeneration 

func (c Common) GetObservedGeneration() int64

type Condition 

type Condition struct {
	// Type of Atlas Custom Resource condition.
	Type ConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status"`
	// Last time the condition transitioned from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// The reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// A human readable message indicating details about the transition.
	// +optional
	Message string `json:"message,omitempty"`
}

Condition describes the state of an Atlas Custom Resource at a certain point.

func EnsureConditionExists 

func EnsureConditionExists(condition Condition, source []Condition) []Condition

EnsureConditionExists adds or updates the condition in the copy of a 'source' slice

func FalseCondition 

func FalseCondition(conditionType ConditionType) Condition

FalseCondition returns the Condition that has the 'Status' set to 'false' and 'Type' to 'conditionType'. The reason and message can be provided optionally

func RemoveConditionIfExists 

func RemoveConditionIfExists(conditionType ConditionType, source []Condition) []Condition

func TrueCondition 

func TrueCondition(conditionType ConditionType) Condition

TrueCondition returns the Condition that has the 'Status' set to 'true' and 'Type' to 'conditionType'. It explicitly omits the 'Reason' and 'Message' fields.

func (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.

func (*Condition) DeepCopyInto 

func (in *Condition) DeepCopyInto(out *Condition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (Condition) WithMessageRegexp 

func (c Condition) WithMessageRegexp(msg string) Condition

func (Condition) WithReason 

func (c Condition) WithReason(reason string) Condition

type ConditionType 

type ConditionType string
const (
	ReadyType           ConditionType = "Ready"
	ValidationSucceeded ConditionType = "ValidationSucceeded"
)
const (
	ProjectReadyType                  ConditionType = "ProjectReady"
	IPAccessListReadyType             ConditionType = "IPAccessListReady"
	MaintenanceWindowReadyType        ConditionType = "MaintenanceWindowReady"
	PrivateEndpointServiceReadyType   ConditionType = "PrivateEndpointServiceReady"
	PrivateEndpointReadyType          ConditionType = "PrivateEndpointReady"
	NetworkPeerReadyType              ConditionType = "NetworkPeerReady"
	CloudProviderIntegrationReadyType ConditionType = "CloudProviderIntegrationReady"
	IntegrationReadyType              ConditionType = "ThirdPartyIntegrationReady"
	AlertConfigurationReadyType       ConditionType = "AlertConfigurationReady"
	EncryptionAtRestReadyType         ConditionType = "EncryptionAtRestReady"
	AuditingReadyType                 ConditionType = "AuditingReady"
	ProjectSettingsReadyType          ConditionType = "ProjectSettingsReady"
	ProjectCustomRolesReadyType       ConditionType = "ProjectCustomRolesReady"
	ProjectTeamsReadyType             ConditionType = "ProjectTeamsReady"
	SearchIndexesReadyType            ConditionType = "AtlasSearchIndexesReady"
)

AtlasProject condition types 

const (
	DeploymentReadyType                ConditionType = "DeploymentReady"
	ServerlessPrivateEndpointReadyType ConditionType = "ServerlessPrivateEndpointReady"
	ManagedNamespacesReadyType         ConditionType = "ManagedNamespacesReady"
	CustomZoneMappingReadyType         ConditionType = "CustomZoneMappingReady"
	SearchNodesReadyType               ConditionType = "SearchNodesReady"
)

AtlasDeployment condition types 

const (
	DataFederationReadyType   ConditionType = "DataFederationReady"
	DataFederationPEReadyType ConditionType = "DataFederationPrivateEndpointsReady"
)

Atlas Data Federation condition types 

const (
	FederatedAuthReadyType      ConditionType = "FederatedAuthReady"
	FederatedAuthRolesReadyType ConditionType = "RolesReady"
)

Atlas Federated Auth condition types 

const (
	StreamInstanceReadyType   ConditionType = "StreamInstanceReady"
	StreamConnectionReadyType ConditionType = "StreamConnectionReady"
)

Atlas Streams condition types 

const (
	DatabaseUserReadyType ConditionType = "DatabaseUserReady"
)

AtlasDatabaseUser condition types 

const (
	ResourceVersionStatus ConditionType = "ResourceVersionIsValid"
)

Generic condition type

type ConnectionStrings 

type ConnectionStrings struct {
	// Public mongodb:// connection string for this cluster.
	Standard string `json:"standard,omitempty"`

	// Public mongodb+srv:// connection string for this cluster.
	StandardSrv string `json:"standardSrv,omitempty"`

	// Private endpoint connection strings.
	// Each object describes the connection strings you can use to connect to this cluster through a private endpoint.
	// Atlas returns this parameter only if you deployed a private endpoint to all regions to which you deployed this cluster's nodes.
	PrivateEndpoint []PrivateEndpoint `json:"privateEndpoint,omitempty"`

	// Network-peering-endpoint-aware mongodb:// connection strings for each interface VPC endpoint you configured to connect to this cluster.
	// Atlas returns this parameter only if you created a network peering connection to this cluster.
	Private string `json:"private,omitempty"`

	// Network-peering-endpoint-aware mongodb+srv:// connection strings for each interface VPC endpoint you configured to connect to this cluster.
	// Atlas returns this parameter only if you created a network peering connection to this cluster.
	// Use this URI format if your driver supports it. If it doesn't, use connectionStrings.private.
	PrivateSrv string `json:"privateSrv,omitempty"`
}

ConnectionStrings contains configuration for applications use to connect to this cluster

func (*ConnectionStrings) DeepCopy 

func (in *ConnectionStrings) DeepCopy() *ConnectionStrings

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionStrings.

func (*ConnectionStrings) DeepCopyInto 

func (in *ConnectionStrings) DeepCopyInto(out *ConnectionStrings)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CurrentValue 

type CurrentValue struct {
	// The value of the metric.
	Number string `json:"number,omitempty"`
	// The units for the value. Depends on the type of metric.
	Units string `json:"units,omitempty"`
}

func (*CurrentValue) DeepCopy 

func (in *CurrentValue) DeepCopy() *CurrentValue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CurrentValue.

func (*CurrentValue) DeepCopyInto 

func (in *CurrentValue) DeepCopyInto(out *CurrentValue)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CustomRole 

type CustomRole struct {
	// Role name which is unique
	Name string `json:"name"`
	// The status of the given custom role (OK or FAILED)
	Status CustomRoleStatus `json:"status"`
	// The message when the custom role is in the FAILED status
	Error string `json:"error,omitempty"`
}

func (*CustomRole) DeepCopy 

func (in *CustomRole) DeepCopy() *CustomRole

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomRole.

func (*CustomRole) DeepCopyInto 

func (in *CustomRole) DeepCopyInto(out *CustomRole)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CustomRoleStatus 

type CustomRoleStatus string
const (
	CustomRoleStatusOK     CustomRoleStatus = "OK"
	CustomRoleStatusFailed CustomRoleStatus = "FAILED"
)

type CustomZoneMapping 

type CustomZoneMapping struct {
	CustomZoneMapping     map[string]string `json:"customZoneMapping,omitempty"`
	ZoneMappingState      string            `json:"zoneMappingState,omitempty"`
	ZoneMappingErrMessage string            `json:"zoneMappingErrMessage,omitempty"`
}

func (*CustomZoneMapping) DeepCopy 

func (in *CustomZoneMapping) DeepCopy() *CustomZoneMapping

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomZoneMapping.

func (*CustomZoneMapping) DeepCopyInto 

func (in *CustomZoneMapping) DeepCopyInto(out *CustomZoneMapping)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataFederationStatus 

type DataFederationStatus struct {
	Common `json:",inline"`

	// MongoDBVersion is the version of MongoDB the cluster runs, in <major version>.<minor version> format.
	MongoDBVersion string `json:"mongoDBVersion,omitempty"`
}

func (*DataFederationStatus) DeepCopy 

func (in *DataFederationStatus) DeepCopy() *DataFederationStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataFederationStatus.

func (*DataFederationStatus) DeepCopyInto 

func (in *DataFederationStatus) DeepCopyInto(out *DataFederationStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataFederationStatusOption 

type DataFederationStatusOption func(s *DataFederationStatus)

type DeploymentSearchIndexStatus added in v2.3.0 

type DeploymentSearchIndexStatus struct {
	Name    string      `json:"name"`
	ID      string      `json:"ID"`
	Status  IndexStatus `json:"status"`
	Message string      `json:"message"`
}

func NewDeploymentSearchIndexStatus added in v2.3.0 

func NewDeploymentSearchIndexStatus(status IndexStatus, options ...IndexStatusOption) DeploymentSearchIndexStatus

func (*DeploymentSearchIndexStatus) DeepCopy added in v2.3.0 

func (in *DeploymentSearchIndexStatus) DeepCopy() *DeploymentSearchIndexStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeploymentSearchIndexStatus.

func (*DeploymentSearchIndexStatus) DeepCopyInto added in v2.3.0 

func (in *DeploymentSearchIndexStatus) DeepCopyInto(out *DeploymentSearchIndexStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Endpoint 

type Endpoint struct {
	// Unique identifier of the private endpoint.
	EndpointID string `json:"endpointId,omitempty"`

	// Cloud provider to which you deployed the private endpoint. Atlas returns AWS or AZURE.
	ProviderName string `json:"providerName,omitempty"`

	// Region to which you deployed the private endpoint.
	Region string `json:"region,omitempty"`

	// Private IP address of the private endpoint network interface you created in your Azure VNet.
	// +optional
	IP string `json:"ip,omitempty"`
}

Endpoint through which you connect to Atlas

func (*Endpoint) DeepCopy 

func (in *Endpoint) DeepCopy() *Endpoint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Endpoint.

func (*Endpoint) DeepCopyInto 

func (in *Endpoint) DeepCopyInto(out *Endpoint)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FeatureUsage 

type FeatureUsage struct {
	FeatureType string `json:"featureType,omitempty"`
	FeatureID   string `json:"featureId,omitempty"`
}

func (*FeatureUsage) DeepCopy 

func (in *FeatureUsage) DeepCopy() *FeatureUsage

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FeatureUsage.

func (*FeatureUsage) DeepCopyInto 

func (in *FeatureUsage) DeepCopyInto(out *FeatureUsage)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GCPEndpoint 

type GCPEndpoint struct {
	Status       string `json:"status"`
	EndpointName string `json:"endpointName"`
	IPAddress    string `json:"ipAddress"`
}

func (*GCPEndpoint) DeepCopy 

func (in *GCPEndpoint) DeepCopy() *GCPEndpoint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCPEndpoint.

func (*GCPEndpoint) DeepCopyInto 

func (in *GCPEndpoint) DeepCopyInto(out *GCPEndpoint)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IndexStatus added in v2.3.0 

type IndexStatus string

type IndexStatusOption added in v2.3.0 

type IndexStatusOption func(status *DeploymentSearchIndexStatus)

+k8s:deepcopy-gen=false

func WithID added in v2.3.0 

func WithID(id string) IndexStatusOption

func WithMsg added in v2.3.0 

func WithMsg(msg string) IndexStatusOption

func WithName added in v2.3.0 

func WithName(name string) IndexStatusOption

type ManagedNamespace 

type ManagedNamespace struct {
	Db                     string `json:"db"` //nolint:stylecheck // not changing this as is a breaking change
	Collection             string `json:"collection"`
	CustomShardKey         string `json:"customShardKey,omitempty"`
	NumInitialChunks       int    `json:"numInitialChunks,omitempty"`
	IsCustomShardKeyHashed *bool  `json:"isCustomShardKeyHashed,omitempty"` // Flag that specifies whether the custom shard key for the collection is hashed.
	IsShardKeyUnique       *bool  `json:"isShardKeyUnique,omitempty"`       // Flag that specifies whether the underlying index enforces a unique constraint.
	Status                 string `json:"status,omitempty"`
	PresplitHashedZones    *bool  `json:"presplitHashedZones,omitempty"`
	ErrMessage             string `json:"errMessage,omitempty"`
}

func NewCreatedManagedNamespaceStatus 

func NewCreatedManagedNamespaceStatus(namespace mongodbatlas.ManagedNamespace) ManagedNamespace

func NewFailedToCreateManagedNamespaceStatus 

func NewFailedToCreateManagedNamespaceStatus(namespace mongodbatlas.ManagedNamespace, err error) ManagedNamespace

func (*ManagedNamespace) DeepCopy 

func (in *ManagedNamespace) DeepCopy() *ManagedNamespace

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedNamespace.

func (*ManagedNamespace) DeepCopyInto 

func (in *ManagedNamespace) DeepCopyInto(out *ManagedNamespace)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Matcher 

type Matcher struct {
	// Name of the field in the target object to match on.
	FieldName string `json:"fieldName,omitempty"`
	// The operator to test the field’s value.
	Operator string `json:"operator,omitempty"`
	// Value to test with the specified operator.
	Value string `json:"value,omitempty"`
}

func (*Matcher) DeepCopy 

func (in *Matcher) DeepCopy() *Matcher

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Matcher.

func (*Matcher) DeepCopyInto 

func (in *Matcher) DeepCopyInto(out *Matcher)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MetricThreshold 

type MetricThreshold struct {
	// Name of the metric to check.
	MetricName string `json:"metricName,omitempty"`
	// Operator to apply when checking the current metric value against the threshold value.
	Operator string `json:"operator,omitempty"`
	// Threshold value outside which an alert will be triggered.
	Threshold string `json:"threshold"`
	// The units for the threshold value.
	Units string `json:"units,omitempty"`
	// This must be set to AVERAGE. Atlas computes the current metric value as an average.
	Mode string `json:"mode,omitempty"`
}

func MetricThresholdFromAtlas 

func MetricThresholdFromAtlas(threshold *admin.ServerlessMetricThreshold) *MetricThreshold

func (*MetricThreshold) DeepCopy 

func (in *MetricThreshold) DeepCopy() *MetricThreshold

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetricThreshold.

func (*MetricThreshold) DeepCopyInto 

func (in *MetricThreshold) DeepCopyInto(out *MetricThreshold)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Notification 

type Notification struct {
	// Slack API token or Bot token. Populated for the SLACK notifications type. If the token later becomes invalid, Atlas sends an email to the project owner and eventually removes the token.
	APIToken string `json:"apiToken,omitempty"`
	// Slack channel name. Populated for the SLACK notifications type.
	ChannelName string `json:"channelName,omitempty"`
	// Datadog API Key. Found in the Datadog dashboard. Populated for the DATADOG notifications type.
	DatadogAPIKey string `json:"datadogApiKey,omitempty"`
	// Region that indicates which API URL to use
	DatadogRegion string `json:"datadogRegion,omitempty"`
	// Number of minutes to wait after an alert condition is detected before sending out the first notification.
	DelayMin *int `json:"delayMin,omitempty"`
	// Email address to which alert notifications are sent. Populated for the EMAIL notifications type.
	EmailAddress string `json:"emailAddress,omitempty"`
	// Flag indicating if email notifications should be sent. Populated for ORG, GROUP, and USER notifications types.
	EmailEnabled *bool `json:"emailEnabled,omitempty"`
	// The Flowdock personal API token. Populated for the FLOWDOCK notifications type. If the token later becomes invalid, Atlas sends an email to the project owner and eventually removes the token.
	FlowdockAPIToken string `json:"flowdockApiToken,omitempty"`
	// Flowdock flow namse in lower-case letters.
	FlowName string `json:"flowName,omitempty"`
	// Number of minutes to wait between successive notifications for unacknowledged alerts that are not resolved.
	IntervalMin int `json:"intervalMin,omitempty"`
	// Mobile number to which alert notifications are sent. Populated for the SMS notifications type.
	MobileNumber string `json:"mobileNumber,omitempty"`
	// Opsgenie API Key. Populated for the OPS_GENIE notifications type. If the key later becomes invalid, Atlas sends an email to the project owner and eventually removes the token.
	OpsGenieAPIKey string `json:"opsGenieApiKey,omitempty"`
	// Region that indicates which API URL to use.
	OpsGenieRegion string `json:"opsGenieRegion,omitempty"`
	// Flowdock organization name in lower-case letters. This is the name that appears after www.flowdock.com/app/ in the URL string. Populated for the FLOWDOCK notifications type.
	OrgName string `json:"orgName,omitempty"`
	// PagerDuty service key. Populated for the PAGER_DUTY notifications type. If the key later becomes invalid, Atlas sends an email to the project owner and eventually removes the key.
	ServiceKey string `json:"serviceKey,omitempty"`
	// Flag indicating if text message notifications should be sent. Populated for ORG, GROUP, and USER notifications types.
	SMSEnabled *bool `json:"smsEnabled,omitempty"`
	// Unique identifier of a team.
	TeamID string `json:"teamId,omitempty"`
	// Label for the team that receives this notification.
	TeamName string `json:"teamName,omitempty"`
	// Type of alert notification.
	TypeName string `json:"typeName,omitempty"`
	// Name of the Atlas user to which to send notifications. Only a user in the project that owns the alert configuration is allowed here. Populated for the USER notifications type.
	Username string `json:"username,omitempty"`
	// VictorOps API key. Populated for the VICTOR_OPS notifications type. If the key later becomes invalid, Atlas sends an email to the project owner and eventually removes the key.
	VictorOpsAPIKey string `json:"victorOpsApiKey,omitempty"`
	// VictorOps routing key. Populated for the VICTOR_OPS notifications type. If the key later becomes invalid, Atlas sends an email to the project owner and eventually removes the key.
	VictorOpsRoutingKey string `json:"victorOpsRoutingKey,omitempty"`
	// The following roles grant privileges within a project.
	Roles []string `json:"roles,omitempty"`
}

func NotificationFromAtlas 

func NotificationFromAtlas(notification admin.AlertsNotificationRootForGroup) Notification

func (*Notification) DeepCopy 

func (in *Notification) DeepCopy() *Notification

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Notification.

func (*Notification) DeepCopyInto 

func (in *Notification) DeepCopyInto(out *Notification)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Option 

type Option interface{}

Option is the function that is applied to the status field of an Atlas Custom Resource. This is the way to handle some random data that need to be written to status.

type PrivateEndpoint 

type PrivateEndpoint struct {
	// Private-endpoint-aware mongodb:// connection string for this private endpoint.
	ConnectionString string `json:"connectionString,omitempty"`

	// Private endpoint through which you connect to Atlas when you use connectionStrings.privateEndpoint[n].connectionString or connectionStrings.privateEndpoint[n].srvConnectionString.
	Endpoints []Endpoint `json:"endpoints,omitempty"`

	// Private-endpoint-aware mongodb+srv:// connection string for this private endpoint.
	SRVConnectionString string `json:"srvConnectionString,omitempty"`

	// Type of MongoDB process that you connect to with the connection strings
	//
	// Atlas returns:
	//
	// • MONGOD for replica sets, or
	//
	// • MONGOS for sharded clusters
	Type string `json:"type,omitempty"`
}

PrivateEndpoint connection strings. Each object describes the connection strings you can use to connect to this cluster through a private endpoint. Atlas returns this parameter only if you deployed a private endpoint to all regions to which you deployed this cluster's nodes.

func (*PrivateEndpoint) DeepCopy 

func (in *PrivateEndpoint) DeepCopy() *PrivateEndpoint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrivateEndpoint.

func (*PrivateEndpoint) DeepCopyInto 

func (in *PrivateEndpoint) DeepCopyInto(out *PrivateEndpoint)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ProjectPrivateEndpoint 

type ProjectPrivateEndpoint struct {
	// Unique identifier for AWS or AZURE Private Link Connection.
	ID string `json:"id,omitempty"`
	// Cloud provider for which you want to retrieve a private endpoint service. Atlas accepts AWS or AZURE.
	Provider provider.ProviderName `json:"provider"`
	// Cloud provider region for which you want to create the private endpoint service.
	Region string `json:"region"`
	// Name of the AWS or Azure Private Link Service that Atlas manages.
	ServiceName string `json:"serviceName,omitempty"`
	// Unique identifier of the Azure Private Link Service (for AWS the same as ID).
	ServiceResourceID string `json:"serviceResourceId,omitempty"`
	// Unique identifier of the AWS or Azure Private Link Interface Endpoint.
	InterfaceEndpointID string `json:"interfaceEndpointId,omitempty"`
	// Unique alphanumeric and special character strings that identify the service attachments associated with the GCP Private Service Connect endpoint service.
	ServiceAttachmentNames []string `json:"serviceAttachmentNames,omitempty"`
	// Collection of individual GCP private endpoints that comprise your network endpoint group.
	Endpoints []GCPEndpoint `json:"endpoints,omitempty"`
}

func (*ProjectPrivateEndpoint) DeepCopy 

func (in *ProjectPrivateEndpoint) DeepCopy() *ProjectPrivateEndpoint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProjectPrivateEndpoint.

func (*ProjectPrivateEndpoint) DeepCopyInto 

func (in *ProjectPrivateEndpoint) DeepCopyInto(out *ProjectPrivateEndpoint)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (ProjectPrivateEndpoint) Identifier 

func (pe ProjectPrivateEndpoint) Identifier() interface{}

type ProjectTeamStatus 

type ProjectTeamStatus struct {
	ID      string                       `json:"id,omitempty"`
	TeamRef common.ResourceRefNamespaced `json:"teamRef"`
}

func (*ProjectTeamStatus) DeepCopy 

func (in *ProjectTeamStatus) DeepCopy() *ProjectTeamStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProjectTeamStatus.

func (*ProjectTeamStatus) DeepCopyInto 

func (in *ProjectTeamStatus) DeepCopyInto(out *ProjectTeamStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Prometheus 

type Prometheus struct {
	// +optional
	Scheme string `json:"scheme,omitempty"`
	// +optional
	DiscoveryURL string `json:"prometheusDiscoveryURL,omitempty"`
}

func (*Prometheus) DeepCopy 

func (in *Prometheus) DeepCopy() *Prometheus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Prometheus.

func (*Prometheus) DeepCopyInto 

func (in *Prometheus) DeepCopyInto(out *Prometheus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Reader 

type Reader interface {
	// GetStatus returns the status of the object.
	GetStatus() Status
}

type ReplicaSet 

type ReplicaSet struct {
	ID       string `json:"id"`
	ZoneName string `json:"zoneName,omitempty"`
}

func (*ReplicaSet) DeepCopy 

func (in *ReplicaSet) DeepCopy() *ReplicaSet

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicaSet.

func (*ReplicaSet) DeepCopyInto 

func (in *ReplicaSet) DeepCopyInto(out *ReplicaSet)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ServerlessPrivateEndpoint 

type ServerlessPrivateEndpoint struct {
	// ID is the identifier of the Serverless PrivateLink Service.
	ID string `json:"_id,omitempty"`
	// CloudProviderEndpointID is the identifier of the cloud provider endpoint.
	CloudProviderEndpointID string `json:"cloudProviderEndpointId,omitempty"`
	// Name is the name of the Serverless PrivateLink Service. Should be unique.
	Name string `json:"name,omitempty"`
	// EndpointServiceName is the name of the PrivateLink endpoint service in AWS. Returns null while the endpoint service is being created.
	EndpointServiceName string `json:"endpointServiceName,omitempty"`
	// ErrorMessage is the error message if the Serverless PrivateLink Service failed to create or connect.
	ErrorMessage string `json:"errorMessage,omitempty"`
	// Status of the AWS Serverless PrivateLink connection.
	Status string `json:"status,omitempty"`
	// ProviderName is human-readable label that identifies the cloud provider. Values include AWS or AZURE.
	ProviderName string `json:"providerName,omitempty"`
	// PrivateEndpointIPAddress is the IPv4 address of the private endpoint in your Azure VNet that someone added to this private endpoint service.
	PrivateEndpointIPAddress string `json:"privateEndpointIpAddress,omitempty"`
	// PrivateLinkServiceResourceID is the root-relative path that identifies the Azure Private Link Service that MongoDB Cloud manages. MongoDB Cloud returns null while it creates the endpoint service.
	PrivateLinkServiceResourceID string `json:"privateLinkServiceResourceId,omitempty"`
}

func (*ServerlessPrivateEndpoint) DeepCopy 

func (in *ServerlessPrivateEndpoint) DeepCopy() *ServerlessPrivateEndpoint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessPrivateEndpoint.

func (*ServerlessPrivateEndpoint) DeepCopyInto 

func (in *ServerlessPrivateEndpoint) DeepCopyInto(out *ServerlessPrivateEndpoint)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Status 

type Status interface {
	GetConditions() []Condition

	GetObservedGeneration() int64
}

Status is a generic status for any Custom Resource managed by Atlas Operator

type StreamConnection added in v2.3.0 

type StreamConnection struct {
	// Human-readable label that uniquely identifies the stream connection
	Name string `json:"name,omitempty"`
	// Reference for the resource that contains connection configuration
	ResourceRef common.ResourceRefNamespaced `json:"resourceRef,omitempty"`
}

func (*StreamConnection) DeepCopy added in v2.3.0 

func (in *StreamConnection) DeepCopy() *StreamConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConnection.

func (*StreamConnection) DeepCopyInto added in v2.3.0 

func (in *StreamConnection) DeepCopyInto(out *StreamConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TeamProject 

type TeamProject struct {
	// Unique identifier of the project inside atlas
	ID string `json:"id"`
	// Name given to the project
	Name string `json:"name"`
}

func (*TeamProject) DeepCopy 

func (in *TeamProject) DeepCopy() *TeamProject

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TeamProject.

func (*TeamProject) DeepCopyInto 

func (in *TeamProject) DeepCopyInto(out *TeamProject)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TeamStatus 

type TeamStatus struct {
	Common `json:",inline"`

	// ID of the team
	ID string `json:"id,omitempty"`
	// List of projects which the team is assigned
	Projects []TeamProject `json:"projects,omitempty"`
}

func (*TeamStatus) DeepCopy 

func (in *TeamStatus) DeepCopy() *TeamStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TeamStatus.

func (*TeamStatus) DeepCopyInto 

func (in *TeamStatus) DeepCopyInto(out *TeamStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Threshold 

type Threshold struct {
	// Operator to apply when checking the current metric value against the threshold value. it accepts the following values: GREATER_THAN, LESS_THAN
	Operator string `json:"operator,omitempty"`
	// The units for the threshold value
	Units string `json:"units,omitempty"`
	// Threshold value outside which an alert will be triggered.
	Threshold string `json:"threshold,omitempty"`
}

func ThresholdFromAtlas 

func ThresholdFromAtlas(threshold *admin.GreaterThanRawThreshold) *Threshold

func (*Threshold) DeepCopy 

func (in *Threshold) DeepCopy() *Threshold

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Threshold.

func (*Threshold) DeepCopyInto 

func (in *Threshold) DeepCopyInto(out *Threshold)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Writer 

type Writer interface {
	// UpdateStatus allows to do the update of the status of an Atlas Custom resource.
	UpdateStatus(conditions []Condition, option ...Option)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.