atlasdeployment

Documentation

Index

• Constants
• type AtlasDeploymentReconciler
  • func NewAtlasDeploymentReconciler(mgr manager.Manager, predicates []predicate.Predicate, ...) *AtlasDeploymentReconciler
  • func (r *AtlasDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasDeploymentReconciler) SetupWithManager(mgr ctrl.Manager, skipNameValidation bool) error
• type NamespaceDiff

Constants

const (
	IndexTypeVector = "vectorSearch"
	IndexTypeSearch = "search"
)

const (
	SPEStatusDeleting  = "DELETING"
	SPEStatusReserved  = "RESERVED"
	SPEStatusAvailable = "AVAILABLE"
)

Status transitions: RESERVATION_REQUESTED -> RESERVED -> INITIATING -> AVAILABLE -> DELETING I assume FAILED state can be reach from any other state transition

const FreeTier = "M0"

const (
	IndexStatusActive = "READY"
)

Types

type AtlasDeploymentReconciler

type AtlasDeploymentReconciler 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
}

AtlasDeploymentReconciler reconciles an AtlasDeployment object

func NewAtlasDeploymentReconciler

func NewAtlasDeploymentReconciler(
	mgr manager.Manager,
	predicates []predicate.Predicate,
	atlasProvider atlas.Provider,
	deletionProtection bool,
	independentSyncPeriod time.Duration,
	logger *zap.Logger,
) *AtlasDeploymentReconciler

func (*AtlasDeploymentReconciler) Reconcile

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

func (*AtlasDeploymentReconciler) SetupWithManager

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

type NamespaceDiff

type NamespaceDiff struct {
	ToCreate       []akov2.ManagedNamespace
	ToDelete       []akov2.ManagedNamespace
	ToUpdateStatus []akov2.ManagedNamespace
}