atlasproject

Documentation

Index

• Constants
• func AtlasInSync(atlas *mongodbatlas.EncryptionAtRest, spec *akov2.EncryptionAtRest) (bool, error)
• func DeleteAllNetworkPeers(ctx context.Context, groupID string, service admin.NetworkPeeringApi, ...) workflow.Result
• func DeleteAllPrivateEndpoints(ctx *workflow.Context, projectID string) workflow.Result
• func GetAllExistedNetworkPeer(ctx context.Context, peerService admin.NetworkPeeringApi, groupID string) ([]admin.BaseNetworkPeeringConnectionSettings, error)
• func IsEncryptionAtlasEmpty(atlas *mongodbatlas.EncryptionAtRest) bool
• func IsEncryptionSpecEmpty(spec *akov2.EncryptionAtRest) bool
• func SyncNetworkPeer(workflowCtx *workflow.Context, groupID string, ...) (workflow.Result, api.ConditionType)
• func UpdateStatuses(context context.Context, containerService admin.NetworkPeeringApi, ...) ([]status.AtlasNetworkPeer, error)
• type AtlasProjectReconciler
  • func NewAtlasProjectReconciler(mgr manager.Manager, predicates []predicate.Predicate, ...) *AtlasProjectReconciler
  • func (r *AtlasProjectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasProjectReconciler) SetupWithManager(mgr ctrl.Manager, skipNameValidation bool) error
• type CloudProviderIntegrationIdentifiable
  • func (cpa CloudProviderIntegrationIdentifiable) Identifier() interface{}
• type CustomRolesOperations
• type TeamDataContainer

Constants

const (
	StatusFailed      = "FAILED"
	StatusReady       = "AVAILABLE"
	StatusDeleting    = "DELETING"
	StatusTerminating = "TERMINATING"
)

const (
	ObjectIDRegex = "^([a-f0-9]{24})$"
)

Functions

func AtlasInSync

func AtlasInSync(atlas *mongodbatlas.EncryptionAtRest, spec *akov2.EncryptionAtRest) (bool, error)

func DeleteAllNetworkPeers

func DeleteAllNetworkPeers(ctx context.Context, groupID string, service admin.NetworkPeeringApi, logger *zap.SugaredLogger) workflow.Result

func DeleteAllPrivateEndpoints

func DeleteAllPrivateEndpoints(ctx *workflow.Context, projectID string) workflow.Result

func GetAllExistedNetworkPeer

func GetAllExistedNetworkPeer(ctx context.Context, peerService admin.NetworkPeeringApi, groupID string) ([]admin.BaseNetworkPeeringConnectionSettings, error)

func IsEncryptionAtlasEmpty

func IsEncryptionAtlasEmpty(atlas *mongodbatlas.EncryptionAtRest) bool

func IsEncryptionSpecEmpty

func IsEncryptionSpecEmpty(spec *akov2.EncryptionAtRest) bool

func SyncNetworkPeer

func SyncNetworkPeer(workflowCtx *workflow.Context, groupID string, peerStatuses []status.AtlasNetworkPeer, peerSpecs []akov2.NetworkPeer) (workflow.Result, api.ConditionType)

func UpdateStatuses

func UpdateStatuses(context context.Context, containerService admin.NetworkPeeringApi,
	peerStatuses []status.AtlasNetworkPeer, peersToUpdate []admin.BaseNetworkPeeringConnectionSettings, groupID string, logger *zap.SugaredLogger) ([]status.AtlasNetworkPeer, error)

Types

type AtlasProjectReconciler

type AtlasProjectReconciler struct {
	Client                      client.Client
	Log                         *zap.SugaredLogger
	Scheme                      *runtime.Scheme
	GlobalPredicates            []predicate.Predicate
	EventRecorder               record.EventRecorder
	AtlasProvider               atlas.Provider
	ObjectDeletionProtection    bool
	SubObjectDeletionProtection bool
	// contains filtered or unexported fields
}

AtlasProjectReconciler reconciles a AtlasProject object

func NewAtlasProjectReconciler

func NewAtlasProjectReconciler(
	mgr manager.Manager,
	predicates []predicate.Predicate,
	atlasProvider atlas.Provider,
	deletionProtection bool,
	logger *zap.Logger,
) *AtlasProjectReconciler

func (*AtlasProjectReconciler) Reconcile

func (r *AtlasProjectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*AtlasProjectReconciler) SetupWithManager

func (r *AtlasProjectReconciler) SetupWithManager(mgr ctrl.Manager, skipNameValidation bool) error

type CloudProviderIntegrationIdentifiable

type CloudProviderIntegrationIdentifiable akov2.CloudProviderIntegration

func (CloudProviderIntegrationIdentifiable) Identifier

func (cpa CloudProviderIntegrationIdentifiable) Identifier() interface{}

type CustomRolesOperations

type CustomRolesOperations struct {
	Create map[string]customroles.CustomRole
	Update map[string]customroles.CustomRole
	Delete map[string]customroles.CustomRole
}

type TeamDataContainer

type TeamDataContainer struct {
	ProjectTeam *akov2.Team
	Team        *akov2.AtlasTeam
	Context     *workflow.Context
}