Documentation ¶
Index ¶
- func CheckPhase(namespaceStore *nbv1.NamespaceStore)
- func Cmd() *cobra.Command
- func CmdCreate() *cobra.Command
- func CmdCreateAWSS3() *cobra.Command
- func CmdCreateAzureBlob() *cobra.Command
- func CmdCreateIBMCos() *cobra.Command
- func CmdCreateNSFS() *cobra.Command
- func CmdCreateS3Compatible() *cobra.Command
- func CmdDelete() *cobra.Command
- func CmdList() *cobra.Command
- func CmdReconcile() *cobra.Command
- func CmdStatus() *cobra.Command
- func GetNamespaceStoreSecret(bs *nbv1.NamespaceStore) *corev1.SecretReference
- func GetNamespaceStoreTargetBucket(bs *nbv1.NamespaceStore) string
- func RunCreateAWSS3(cmd *cobra.Command, args []string)
- func RunCreateAzureBlob(cmd *cobra.Command, args []string)
- func RunCreateIBMCos(cmd *cobra.Command, args []string)
- func RunCreateNSFS(cmd *cobra.Command, args []string)
- func RunCreateS3Compatible(cmd *cobra.Command, args []string)
- func RunDelete(cmd *cobra.Command, args []string)
- func RunList(cmd *cobra.Command, args []string)
- func RunReconcile(cmd *cobra.Command, args []string)
- func RunStatus(cmd *cobra.Command, args []string)
- func ValidateNamespaceStore(nsStore *nbv1.NamespaceStore) error
- func WaitReady(namespaceStore *nbv1.NamespaceStore) bool
- type ModeInfo
- type Reconciler
- func (r *Reconciler) FinalizeDeletion() error
- func (r *Reconciler) LoadNamespaceStoreSecret() error
- func (r *Reconciler) MakeExternalConnectionParams() (*nb.AddExternalConnectionParams, error)
- func (r *Reconciler) Own(obj metav1.Object)
- func (r *Reconciler) ReadSystemInfo() error
- func (r *Reconciler) Reconcile() (reconcile.Result, error)
- func (r *Reconciler) ReconcileDeletion(systemFound bool) error
- func (r *Reconciler) ReconcileExternalConnection() error
- func (r *Reconciler) ReconcileNamespaceStore() error
- func (r *Reconciler) ReconcilePhaseConnecting() error
- func (r *Reconciler) ReconcilePhaseCreating() error
- func (r *Reconciler) ReconcilePhaseVerifying() error
- func (r *Reconciler) ReconcilePhases() error
- func (r *Reconciler) SetPhase(phase nbv1.NamespaceStorePhase, reason string, message string)
- func (r *Reconciler) UpdateStatus() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckPhase ¶
func CheckPhase(namespaceStore *nbv1.NamespaceStore)
CheckPhase prints the phase and reason for it
func CmdCreateAzureBlob ¶
CmdCreateAzureBlob returns a CLI command
func CmdCreateS3Compatible ¶
CmdCreateS3Compatible returns a CLI command
func GetNamespaceStoreSecret ¶
func GetNamespaceStoreSecret(bs *nbv1.NamespaceStore) *corev1.SecretReference
GetNamespaceStoreSecret returns the secret reference of the namespace store if it is relevant to the type
func GetNamespaceStoreTargetBucket ¶
func GetNamespaceStoreTargetBucket(bs *nbv1.NamespaceStore) string
GetNamespaceStoreTargetBucket returns the target bucket of the namespace store if it is relevant to the type
func RunCreateAWSS3 ¶
RunCreateAWSS3 runs a CLI command
func RunCreateAzureBlob ¶
RunCreateAzureBlob runs a CLI command
func RunCreateIBMCos ¶
RunCreateIBMCos runs a CLI command
func RunCreateNSFS ¶
RunCreateNSFS runs a CLI command
func RunCreateS3Compatible ¶
RunCreateS3Compatible runs a CLI command
func RunReconcile ¶
RunReconcile runs a CLI command
func ValidateNamespaceStore ¶
func ValidateNamespaceStore(nsStore *nbv1.NamespaceStore) error
ValidateNamespaceStore validates namespacestore configuration
func WaitReady ¶
func WaitReady(namespaceStore *nbv1.NamespaceStore) bool
WaitReady waits until the system phase changes to ready by the operator
Types ¶
type ModeInfo ¶
type ModeInfo struct { Phase nbv1.NamespaceStorePhase Severity string }
ModeInfo holds local information for a namespace store mode.
type Reconciler ¶
type Reconciler struct { Request types.NamespacedName Client client.Client Scheme *runtime.Scheme Ctx context.Context Logger *logrus.Entry Recorder record.EventRecorder NBClient nb.Client NamespaceStore *nbv1.NamespaceStore NooBaa *nbv1.NooBaa Secret *corev1.Secret ServiceAccount *corev1.ServiceAccount SystemInfo *nb.SystemInfo ExternalConnectionInfo *nb.ExternalConnectionInfo NamespaceResourceinfo *nb.NamespaceResourceInfo AddExternalConnectionParams *nb.AddExternalConnectionParams CreateNamespaceResourceParams *nb.CreateNamespaceResourceParams }
Reconciler is the context for loading or reconciling a noobaa system
func NewReconciler ¶
func NewReconciler( req types.NamespacedName, client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, ) *Reconciler
NewReconciler initializes a reconciler to be used for loading or reconciling a namespace store
func (*Reconciler) FinalizeDeletion ¶
func (r *Reconciler) FinalizeDeletion() error
FinalizeDeletion removed the finalizer and updates in order to let the namespace-store get reclaimed by kubernetes
func (*Reconciler) LoadNamespaceStoreSecret ¶
func (r *Reconciler) LoadNamespaceStoreSecret() error
LoadNamespaceStoreSecret loads the secret to the reconciler struct
func (*Reconciler) MakeExternalConnectionParams ¶
func (r *Reconciler) MakeExternalConnectionParams() (*nb.AddExternalConnectionParams, error)
MakeExternalConnectionParams translates the namespace store spec and secret, to noobaa api structures to be used for creating/updating external connetion and namespace store
func (*Reconciler) Own ¶
func (r *Reconciler) Own(obj metav1.Object)
Own sets the object owner references to the namespacestore
func (*Reconciler) ReadSystemInfo ¶
func (r *Reconciler) ReadSystemInfo() error
ReadSystemInfo loads the information from the noobaa system api, and prepares the structures to reconcile
func (*Reconciler) Reconcile ¶
func (r *Reconciler) Reconcile() (reconcile.Result, error)
Reconcile reads that state of the cluster for a System object, and makes changes based on the state read and what is in the System.Spec. The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
func (*Reconciler) ReconcileDeletion ¶
func (r *Reconciler) ReconcileDeletion(systemFound bool) error
ReconcileDeletion handles the deletion of a namespace-store using the noobaa api
func (*Reconciler) ReconcileExternalConnection ¶
func (r *Reconciler) ReconcileExternalConnection() error
ReconcileExternalConnection handles the external connection using noobaa api
func (*Reconciler) ReconcileNamespaceStore ¶
func (r *Reconciler) ReconcileNamespaceStore() error
ReconcileNamespaceStore handles the namespace store using noobaa api
func (*Reconciler) ReconcilePhaseConnecting ¶
func (r *Reconciler) ReconcilePhaseConnecting() error
ReconcilePhaseConnecting checks that we have the system and secret needed to reconcile
func (*Reconciler) ReconcilePhaseCreating ¶
func (r *Reconciler) ReconcilePhaseCreating() error
ReconcilePhaseCreating checks that we have the system and secret needed to reconcile
func (*Reconciler) ReconcilePhaseVerifying ¶
func (r *Reconciler) ReconcilePhaseVerifying() error
ReconcilePhaseVerifying checks that we have the system and secret needed to reconcile
func (*Reconciler) ReconcilePhases ¶
func (r *Reconciler) ReconcilePhases() error
ReconcilePhases runs the reconcile flow and populates System.Status.
func (*Reconciler) SetPhase ¶
func (r *Reconciler) SetPhase(phase nbv1.NamespaceStorePhase, reason string, message string)
SetPhase updates the status phase and conditions
func (*Reconciler) UpdateStatus ¶
func (r *Reconciler) UpdateStatus() error
UpdateStatus updates the namespace store status in kubernetes from the memory