connectionsecret

Documentation

Index

• Constants
• func AddCredentialsToConnectionURL(connURL, userName, password string) (string, error)
• func CreateOrUpdateConnectionSecrets(ctx *workflow.Context, k8sClient client.Client, recorder record.EventRecorder, ...) workflow.Result
• func Ensure(ctx context.Context, client client.Client, ...) (string, error)
• func FillPrivateConnStrings(connStrings *mongodbatlas.ConnectionStrings, data *ConnectionData)
• func GetAllServerless(ctx *workflow.Context, projectID string) ([]*mongodbatlas.Cluster, error)
• func IsCloudGovDomain(ctx *workflow.Context) bool
• func ListByDeploymentName(ctx context.Context, k8sClient client.Client, ...) ([]corev1.Secret, error)
• func ListByUserName(ctx context.Context, k8sClient client.Client, ...) ([]corev1.Secret, error)
• func RemoveStaleSecretsByUserName(ctx context.Context, k8sClient client.Client, projectID, userName string, ...) error
• type ConnectionData
• type PrivateLinkConnURLs

Constants

const (
	ProjectLabelKey string = "atlas.mongodb.com/project-id"
	ClusterLabelKey string = "atlas.mongodb.com/cluster-name"
	TypeLabelKey           = "atlas.mongodb.com/type"
	CredLabelVal           = "credentials"
)

const ConnectionSecretsEnsuredEvent = "ConnectionSecretsEnsured"

Functions

func AddCredentialsToConnectionURL

func AddCredentialsToConnectionURL(connURL, userName, password string) (string, error)

func CreateOrUpdateConnectionSecrets

func CreateOrUpdateConnectionSecrets(ctx *workflow.Context, k8sClient client.Client, recorder record.EventRecorder, project akov2.AtlasProject, dbUser akov2.AtlasDatabaseUser) workflow.Result

func Ensure

func Ensure(ctx context.Context, client client.Client, namespace, projectName, projectID, clusterName string, data ConnectionData) (string, error)

Ensure creates or updates the connection Secret for the specific cluster and db user. Returns the name of the Secret created.

func FillPrivateConnStrings

func FillPrivateConnStrings(connStrings *mongodbatlas.ConnectionStrings, data *ConnectionData)

func GetAllServerless

func GetAllServerless(ctx *workflow.Context, projectID string) ([]*mongodbatlas.Cluster, error)

func IsCloudGovDomain

func IsCloudGovDomain(ctx *workflow.Context) bool

func ListByDeploymentName

func ListByDeploymentName(ctx context.Context, k8sClient client.Client, namespace, projectID, clusterName string) ([]corev1.Secret, error)

ListByDeploymentName returns all secrets in the specified namespace that have labels for 'projectID' and 'clusterName'

func ListByUserName

func ListByUserName(ctx context.Context, k8sClient client.Client, namespace, projectID, userName string) ([]corev1.Secret, error)

ListByUserName returns all secrets in the specified namespace that have label for 'projectID' and data for 'userName'

func RemoveStaleSecretsByUserName

func RemoveStaleSecretsByUserName(ctx context.Context, k8sClient client.Client, projectID, userName string, user akov2.AtlasDatabaseUser, log *zap.SugaredLogger) error

RemoveStaleSecretsByUserName removes the stale secrets when the database user name changes (as it's used as a part of Secret name)

Types

type ConnectionData

type ConnectionData struct {
	DBUserName      string
	Password        string
	ConnURL         string
	SrvConnURL      string
	PrivateConnURLs []PrivateLinkConnURLs
}

type PrivateLinkConnURLs

type PrivateLinkConnURLs struct {
	PvtConnURL      string
	PvtSrvConnURL   string
	PvtShardConnURL string
}