The highest tagged major version is v5.

backingstore

package

v1.2.0 Latest Latest Go to latest Published: Sep 26, 2019 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/noobaa/noobaa-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func CheckPhase(backStore *nbv1.BackingStore)
func Cmd() *cobra.Command
func CmdCreate() *cobra.Command
func CmdCreateAWSS3() *cobra.Command
func CmdCreateAzureBlob() *cobra.Command
func CmdCreateGoogleCloudStorage() *cobra.Command
func CmdCreatePVPool() *cobra.Command
func CmdCreateS3Compatible() *cobra.Command
func CmdDelete() *cobra.Command
func CmdList() *cobra.Command
func CmdReconcile() *cobra.Command
func CmdStatus() *cobra.Command
func GetBackingStoreSecret(bs *nbv1.BackingStore) *corev1.SecretReference
func GetBackingStoreTargetBucket(bs *nbv1.BackingStore) string
func RunCreateAWSS3(cmd *cobra.Command, args []string)
func RunCreateAzureBlob(cmd *cobra.Command, args []string)
func RunCreateGoogleCloudStorage(cmd *cobra.Command, args []string)
func RunCreatePVPool(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 WaitReady(backStore *nbv1.BackingStore) bool
type Reconciler
- func NewReconciler(req types.NamespacedName, client client.Client, scheme *runtime.Scheme, ...) *Reconciler
- func (r *Reconciler) FinalizeDeletion() error
- func (r *Reconciler) MakeExternalConnectionParams() (*nb.AddExternalConnectionParams, error)
- func (r *Reconciler) ReadSystemInfo() error
- func (r *Reconciler) Reconcile() (reconcile.Result, error)
- func (r *Reconciler) ReconcileDeletion() error
- func (r *Reconciler) ReconcileExternalConnection() error
- func (r *Reconciler) ReconcilePhaseVerifying() error
- func (r *Reconciler) ReconcilePhases() error
- func (r *Reconciler) ReconcilePool() error
- func (r *Reconciler) SetPhase(phase nbv1.BackingStorePhase, reason string, message string)
- func (r *Reconciler) UpdateStatus()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckPhase ¶ added in v1.2.0

func CheckPhase(backStore *nbv1.BackingStore)

CheckPhase prints the phase and reason for it

func Cmd ¶

func Cmd() *cobra.Command

Cmd returns a CLI command

func CmdCreateAWSS3 ¶ added in v1.2.0

func CmdCreateAWSS3() *cobra.Command

CmdCreateAWSS3 returns a CLI command

func CmdCreateAzureBlob ¶ added in v1.2.0

func CmdCreateAzureBlob() *cobra.Command

CmdCreateAzureBlob returns a CLI command

func CmdCreateGoogleCloudStorage ¶ added in v1.2.0

func CmdCreateGoogleCloudStorage() *cobra.Command

CmdCreateGoogleCloudStorage returns a CLI command

func CmdCreatePVPool ¶ added in v1.2.0

func CmdCreatePVPool() *cobra.Command

CmdCreatePVPool returns a CLI command

func CmdCreateS3Compatible ¶ added in v1.2.0

func CmdCreateS3Compatible() *cobra.Command

CmdCreateS3Compatible returns a CLI command

func CmdStatus ¶ added in v1.2.0

func CmdStatus() *cobra.Command

CmdStatus returns a CLI command

func GetBackingStoreSecret ¶ added in v1.2.0

func GetBackingStoreSecret(bs *nbv1.BackingStore) *corev1.SecretReference

GetBackingStoreSecret returns the secret reference of the backing store if it is relevant to the type

func GetBackingStoreTargetBucket ¶ added in v1.2.0

func GetBackingStoreTargetBucket(bs *nbv1.BackingStore) string

GetBackingStoreTargetBucket returns the target bucket of the backing store if it is relevant to the type

func RunCreateAWSS3 ¶ added in v1.2.0

func RunCreateAWSS3(cmd *cobra.Command, args []string)

RunCreateAWSS3 runs a CLI command

func RunCreateAzureBlob ¶ added in v1.2.0

func RunCreateAzureBlob(cmd *cobra.Command, args []string)

RunCreateAzureBlob runs a CLI command

func RunCreateGoogleCloudStorage ¶ added in v1.2.0

func RunCreateGoogleCloudStorage(cmd *cobra.Command, args []string)

RunCreateGoogleCloudStorage runs a CLI command

func RunCreatePVPool ¶ added in v1.2.0

func RunCreatePVPool(cmd *cobra.Command, args []string)

RunCreatePVPool runs a CLI command

func RunCreateS3Compatible ¶ added in v1.2.0

func RunCreateS3Compatible(cmd *cobra.Command, args []string)

RunCreateS3Compatible runs a CLI command

func RunStatus ¶ added in v1.2.0

func RunStatus(cmd *cobra.Command, args []string)

RunStatus runs a CLI command

func WaitReady ¶ added in v1.2.0

func WaitReady(backStore *nbv1.BackingStore) bool

WaitReady waits until the system phase changes to ready by the operator

Types ¶

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

	BackingStore *nbv1.BackingStore
	NooBaa       *nbv1.NooBaa
	Secret       *corev1.Secret

	SystemInfo             *nb.SystemInfo
	ExternalConnectionInfo *nb.ExternalConnectionInfo
	PoolInfo               *nb.PoolInfo

	AddExternalConnectionParams *nb.AddExternalConnectionParams
	CreateCloudPoolParams       *nb.CreateCloudPoolParams
	CreateHostsPoolParams       *nb.CreateHostsPoolParams
}

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 backing store

func (*Reconciler) FinalizeDeletion ¶

func (r *Reconciler) FinalizeDeletion() error

FinalizeDeletion removed the finalizer and updates in order to let the backing-store get reclaimed by kubernetes

func (*Reconciler) MakeExternalConnectionParams ¶

func (r *Reconciler) MakeExternalConnectionParams() (*nb.AddExternalConnectionParams, error)

MakeExternalConnectionParams translates the backing store spec and secret, to noobaa api structures to be used for creating/updating external connetion and pool

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() error

ReconcileDeletion handles the deletion of a backing-store using the noobaa api

func (*Reconciler) ReconcileExternalConnection ¶

func (r *Reconciler) ReconcileExternalConnection() error

ReconcileExternalConnection handles the external connection using noobaa api

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) ReconcilePool ¶

func (r *Reconciler) ReconcilePool() error

ReconcilePool handles the pool using noobaa api

func (*Reconciler) SetPhase ¶

func (r *Reconciler) SetPhase(phase nbv1.BackingStorePhase, reason string, message string)

SetPhase updates the status phase and conditions

func (*Reconciler) UpdateStatus ¶

func (r *Reconciler) UpdateStatus()

UpdateStatus updates the backing store status in kubernetes from the memory

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL