Documentation
¶
Index ¶
- type AtlasDeploymentsService
- type Cluster
- func (c *Cluster) GetConnection() *status.ConnectionStrings
- func (c *Cluster) GetCustomResource() *akov2.AtlasDeployment
- func (c *Cluster) GetMongoDBVersion() string
- func (c *Cluster) GetName() string
- func (c *Cluster) GetProjectID() string
- func (c *Cluster) GetReplicaSet() []status.ReplicaSet
- func (c *Cluster) GetState() string
- func (c *Cluster) IsServerless() bool
- func (c *Cluster) IsTenant() bool
- type Connection
- type Deployment
- type Endpoint
- type PrivateEndpoint
- type ProductionAtlasDeployments
- func (ds *ProductionAtlasDeployments) ClusterExists(ctx context.Context, projectID, clusterName string) (bool, error)
- func (ds *ProductionAtlasDeployments) ClusterWithProcessArgs(ctx context.Context, cluster *Cluster) error
- func (ds *ProductionAtlasDeployments) CreateDeployment(ctx context.Context, deployment Deployment) (Deployment, error)
- func (ds *ProductionAtlasDeployments) DeleteDeployment(ctx context.Context, deployment Deployment) error
- func (ds *ProductionAtlasDeployments) DeploymentIsReady(ctx context.Context, projectID, deploymentName string) (bool, error)
- func (ds *ProductionAtlasDeployments) GetDeployment(ctx context.Context, projectID, name string) (Deployment, error)
- func (ds *ProductionAtlasDeployments) ListClusterNames(ctx context.Context, projectID string) ([]string, error)
- func (ds *ProductionAtlasDeployments) ListDeploymentConnections(ctx context.Context, projectID string) ([]Connection, error)
- func (ds *ProductionAtlasDeployments) UpdateDeployment(ctx context.Context, deployment Deployment) (Deployment, error)
- func (ds *ProductionAtlasDeployments) UpdateProcessArgs(ctx context.Context, cluster *Cluster) error
- type Serverless
- func (s *Serverless) GetConnection() *status.ConnectionStrings
- func (s *Serverless) GetCustomResource() *akov2.AtlasDeployment
- func (s *Serverless) GetMongoDBVersion() string
- func (s *Serverless) GetName() string
- func (s *Serverless) GetProjectID() string
- func (s *Serverless) GetReplicaSet() []status.ReplicaSet
- func (s *Serverless) GetState() string
- func (s *Serverless) IsServerless() bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AtlasDeploymentsService ¶
type AtlasDeploymentsService interface { ListClusterNames(ctx context.Context, projectID string) ([]string, error) ListDeploymentConnections(ctx context.Context, projectID string) ([]Connection, error) ClusterExists(ctx context.Context, projectID, clusterName string) (bool, error) DeploymentIsReady(ctx context.Context, projectID, deploymentName string) (bool, error) GetDeployment(ctx context.Context, projectID, name string) (Deployment, error) CreateDeployment(ctx context.Context, deployment Deployment) (Deployment, error) UpdateDeployment(ctx context.Context, deployment Deployment) (Deployment, error) DeleteDeployment(ctx context.Context, deployment Deployment) error ClusterWithProcessArgs(ctx context.Context, cluster *Cluster) error UpdateProcessArgs(ctx context.Context, cluster *Cluster) error }
type Cluster ¶ added in v2.5.0
type Cluster struct { *akov2.AdvancedDeploymentSpec ProjectID string State string MongoDBVersion string Connection *status.ConnectionStrings ProcessArgs *akov2.ProcessArgs ReplicaSet []status.ReplicaSet // contains filtered or unexported fields }
func ComputeChanges ¶ added in v2.5.0
func (*Cluster) GetConnection ¶ added in v2.5.0
func (c *Cluster) GetConnection() *status.ConnectionStrings
func (*Cluster) GetCustomResource ¶ added in v2.5.0
func (c *Cluster) GetCustomResource() *akov2.AtlasDeployment
func (*Cluster) GetMongoDBVersion ¶ added in v2.5.0
func (*Cluster) GetProjectID ¶ added in v2.5.0
func (*Cluster) GetReplicaSet ¶ added in v2.5.0
func (c *Cluster) GetReplicaSet() []status.ReplicaSet
func (*Cluster) IsServerless ¶ added in v2.5.0
type Connection ¶
type Deployment ¶ added in v2.5.0
type Deployment interface { GetName() string GetProjectID() string GetCustomResource() *akov2.AtlasDeployment GetState() string GetMongoDBVersion() string GetConnection() *status.ConnectionStrings GetReplicaSet() []status.ReplicaSet IsServerless() bool }
func NewDeployment ¶ added in v2.5.0
func NewDeployment(projectID string, atlasDeployment *akov2.AtlasDeployment) Deployment
type PrivateEndpoint ¶
type ProductionAtlasDeployments ¶
type ProductionAtlasDeployments struct {
// contains filtered or unexported fields
}
func NewAtlasDeployments ¶ added in v2.5.0
func NewAtlasDeployments(clusterService admin.ClustersApi, serverlessAPI admin.ServerlessInstancesApi, isGov bool) *ProductionAtlasDeployments
func NewAtlasDeploymentsService ¶
func NewAtlasDeploymentsService(ctx context.Context, provider atlas.Provider, secretRef *types.NamespacedName, log *zap.SugaredLogger, isGov bool) (*ProductionAtlasDeployments, error)
func (*ProductionAtlasDeployments) ClusterExists ¶
func (*ProductionAtlasDeployments) ClusterWithProcessArgs ¶ added in v2.5.0
func (ds *ProductionAtlasDeployments) ClusterWithProcessArgs(ctx context.Context, cluster *Cluster) error
func (*ProductionAtlasDeployments) CreateDeployment ¶ added in v2.5.0
func (ds *ProductionAtlasDeployments) CreateDeployment(ctx context.Context, deployment Deployment) (Deployment, error)
func (*ProductionAtlasDeployments) DeleteDeployment ¶ added in v2.5.0
func (ds *ProductionAtlasDeployments) DeleteDeployment(ctx context.Context, deployment Deployment) error
func (*ProductionAtlasDeployments) DeploymentIsReady ¶
func (*ProductionAtlasDeployments) GetDeployment ¶ added in v2.5.0
func (ds *ProductionAtlasDeployments) GetDeployment(ctx context.Context, projectID, name string) (Deployment, error)
func (*ProductionAtlasDeployments) ListClusterNames ¶
func (*ProductionAtlasDeployments) ListDeploymentConnections ¶
func (ds *ProductionAtlasDeployments) ListDeploymentConnections(ctx context.Context, projectID string) ([]Connection, error)
func (*ProductionAtlasDeployments) UpdateDeployment ¶ added in v2.5.0
func (ds *ProductionAtlasDeployments) UpdateDeployment(ctx context.Context, deployment Deployment) (Deployment, error)
func (*ProductionAtlasDeployments) UpdateProcessArgs ¶ added in v2.5.0
func (ds *ProductionAtlasDeployments) UpdateProcessArgs(ctx context.Context, cluster *Cluster) error
type Serverless ¶ added in v2.5.0
type Serverless struct { *akov2.ServerlessSpec ProjectID string State string MongoDBVersion string Connection *status.ConnectionStrings // contains filtered or unexported fields }
func (*Serverless) GetConnection ¶ added in v2.5.0
func (s *Serverless) GetConnection() *status.ConnectionStrings
func (*Serverless) GetCustomResource ¶ added in v2.5.0
func (s *Serverless) GetCustomResource() *akov2.AtlasDeployment
func (*Serverless) GetMongoDBVersion ¶ added in v2.5.0
func (s *Serverless) GetMongoDBVersion() string
func (*Serverless) GetName ¶ added in v2.5.0
func (s *Serverless) GetName() string
func (*Serverless) GetProjectID ¶ added in v2.5.0
func (s *Serverless) GetProjectID() string
func (*Serverless) GetReplicaSet ¶ added in v2.5.0
func (s *Serverless) GetReplicaSet() []status.ReplicaSet
func (*Serverless) GetState ¶ added in v2.5.0
func (s *Serverless) GetState() string
func (*Serverless) IsServerless ¶ added in v2.5.0
func (s *Serverless) IsServerless() bool
Click to show internal directories.
Click to hide internal directories.