atlas

Documentation

Index

• Constants
• func DefaultListOptions(pageNum int) *mongodbatlas.ListOptions
• func NewClient(domain, publicKey, privateKey string) (*admin.APIClient, error)
• func TraversePages(reader PageReader, predicate PageItemPredicate) error
• type IPAccessListStatus
  • func CustomIPAccessListStatus(client *admin.APIClient) IPAccessListStatus
• type PageItemPredicate
• type PageReader
• type Paginated
  • func NewAtlasPaginated(response *mongodbatlas.Response, entities interface{}) Paginated
• type ProductionProvider
  • func NewProductionProvider(atlasDomain string, globalSecretRef client.ObjectKey, k8sClient client.Client) *ProductionProvider
  • func (p *ProductionProvider) Client(ctx context.Context, secretRef *client.ObjectKey, log *zap.SugaredLogger) (*mongodbatlas.Client, string, error)
  • func (p *ProductionProvider) IsCloudGov() bool
  • func (p *ProductionProvider) IsResourceSupported(resource akov2.AtlasCustomResource) bool
  • func (p *ProductionProvider) SdkClient(ctx context.Context, secretRef *client.ObjectKey, log *zap.SugaredLogger) (*admin.APIClient, string, error)
• type Provider

Constants

const (
	// Error codes that Atlas may return that we are concerned about
	GroupExistsAPIErrorCode = "GROUP_ALREADY_EXISTS"

	// The error that Atlas API returns if the GET request is sent to read the project that either doesn't exist
	// or the user doesn't have permissions for
	NotInGroup = "NOT_IN_GROUP"

	// Error indicates that the project is being removed while it still has clusters
	CannotCloseGroupActiveAtlasDeployment = "CANNOT_CLOSE_GROUP_ACTIVE_ATLAS_CLUSTERS"

	// Error indicates that the database user doesn't exist
	UsernameNotFound = "USERNAME_NOT_FOUND"

	// Error indicates that the cluster doesn't exist
	ClusterNotFound = "CLUSTER_NOT_FOUND"

	// ServerlessClusterNotFound indicates that the serverless cluster doesn't exist
	ServerlessInstanceNotFound = "SERVERLESS_INSTANCE_NOT_FOUND"

	// ServerlessClusterFromClusterAPI indicates that we are trying to access
	// a serverless instance from the cluster API, which is not allowed
	ServerlessInstanceFromClusterAPI = "CANNOT_USE_SERVERLESS_INSTANCE_IN_CLUSTER_API"

	// Resource not found
	ResourceNotFound = "RESOURCE_NOT_FOUND"

	// Instance for the passed {groupId, tenantName} pair does not exist
	DataFederationTenantNotFound = "DATA_FEDERATION_TENANT_NOT_FOUND_FOR_NAME"
)

Functions

func DefaultListOptions

func DefaultListOptions(pageNum int) *mongodbatlas.ListOptions

func NewClient

func NewClient(domain, publicKey, privateKey string) (*admin.APIClient, error)

func TraversePages

func TraversePages(reader PageReader, predicate PageItemPredicate) error

TraversePages reads page after page using 'reader' and applies the 'predicate' for each item on the page. Stops traversal when the 'predicate' returns true.

Types

type IPAccessListStatus

type IPAccessListStatus func(ctx context.Context, projectID, entryValue string) (string, error)

func CustomIPAccessListStatus

func CustomIPAccessListStatus(client *admin.APIClient) IPAccessListStatus

type PageItemPredicate

type PageItemPredicate func(entity interface{}) bool

PageItemPredicate is the function that processes single item on the page and returns true if no further processing needs to be done (usually it's the search logic)

type PageReader

type PageReader func(pageNum int) (Paginated, error)

PageReader is the function that reads a single page by its number

type Paginated

type Paginated interface {
	// HasNext returns if there are more pages
	HasNext() bool

	// Results returns the list of entities on a single page
	Results() []interface{}
}

Paginated is the general interface for a single page returned by Atlas api.

func NewAtlasPaginated

func NewAtlasPaginated(response *mongodbatlas.Response, entities interface{}) Paginated

type ProductionProvider

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

func NewProductionProvider

func NewProductionProvider(atlasDomain string, globalSecretRef client.ObjectKey, k8sClient client.Client) *ProductionProvider

func (*ProductionProvider) Client

func (p *ProductionProvider) Client(ctx context.Context, secretRef *client.ObjectKey, log *zap.SugaredLogger) (*mongodbatlas.Client, string, error)

func (*ProductionProvider) IsCloudGov

func (p *ProductionProvider) IsCloudGov() bool

func (*ProductionProvider) IsResourceSupported

func (p *ProductionProvider) IsResourceSupported(resource akov2.AtlasCustomResource) bool

func (*ProductionProvider) SdkClient

func (p *ProductionProvider) SdkClient(ctx context.Context, secretRef *client.ObjectKey, log *zap.SugaredLogger) (*admin.APIClient, string, error)

type Provider

type Provider interface {
	Client(ctx context.Context, secretRef *client.ObjectKey, log *zap.SugaredLogger) (*mongodbatlas.Client, string, error)
	SdkClient(ctx context.Context, secretRef *client.ObjectKey, log *zap.SugaredLogger) (*admin.APIClient, string, error)
	IsCloudGov() bool
	IsResourceSupported(resource akov2.AtlasCustomResource) bool
}