controllers

package

Go to main page

Versions in this module

v1

v1.11.3

Jul 31, 2024

v1.11.2

Aug 2, 2023

v1.11.1

Jun 12, 2023

v1.11.0

May 16, 2023

v1.10.2

Apr 13, 2023

v1.10.1

Mar 13, 2023

v1.10.0

Feb 26, 2023

v1.9.0

Jan 12, 2023

v1.8.0

Nov 18, 2022

v1.7.0

Aug 26, 2022

v1.6.0

Jun 30, 2022

v1.5.0

Jun 3, 2022

v1.4.0

Apr 27, 2022

Changes in this version

+ type ApplyMethodType string

+ const AddNodeApplyMethod

+ const DelNodeApplyMethod

+ const PodRescheduleApplyMethod

+ type ClientRoutingLabelReconciler struct

+ ApplyMethod ApplyMethodType

+ PFacts *PodFacts

+ ScName string

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (c *ClientRoutingLabelReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type DrainNodeReconciler struct

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (s *DrainNodeReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type ObjReconcileModeType string

+ const ObjReconcileModeAll

+ const ObjReconcileModeIfNotFound

type ObjReconciler

+ Mode ObjReconcileModeType

type OnlineUpgradeReconciler

+ TransientSc *vapi.Subcluster

+ type RebalanceShardsReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ ScName string

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (s *RebalanceShardsReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

type ReconcileActor

+ func MakeClientRoutingLabelReconciler(vdbrecon *VerticaDBReconciler, vdb *vapi.VerticaDB, pfacts *PodFacts, ...) ReconcileActor

+ func MakeDrainNodeReconciler(vdbrecon *VerticaDBReconciler, vdb *vapi.VerticaDB, prunner cmds.PodRunner, ...) ReconcileActor

+ func MakeRebalanceShardsReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

type VerticaDBReconciler

+ ServiceAccountName string

v1.3.1

Mar 4, 2022

Changes in this version

+ const OperatorVersion131

v1.3.0

Feb 19, 2022

Changes in this version

+ const ClusterRestartOfflineMsgIndex

+ const ClusterShutdownOfflineMsgIndex

+ const CurOperatorVersion

+ const OperatorVersion100

+ const OperatorVersion110

+ const OperatorVersion120

+ const OperatorVersion130

+ const OperatorVersionLabel

+ const ReschedulePodsOfflineMsgIndex

+ const SubclusterLegacyNameLabel

+ const SubclusterNameLabel

+ const SubclusterSvcNameLabel

+ const SubclusterTransientLabel

+ const SubclusterTypeLabel

+ const VDBInstanceLabel

+ var OfflineUpgradeStatusMsgs = []string

type FindFlags

+ const FindSorted

+ type OfflineUpgradeReconciler struct

+ Finder SubclusterFinder

+ Log logr.Logger

+ Manager UpgradeManager

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (o *OfflineUpgradeReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type OnlineUpgradeReconciler struct

+ Finder SubclusterFinder

+ Log logr.Logger

+ Manager UpgradeManager

+ MsgIndex int

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ PrimaryImages []string

+ StatusMsgs []string

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (o *OnlineUpgradeReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

type ReconcileActor

+ func MakeOfflineUpgradeReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeOnlineUpgradeReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeUpgradeOperator120Reconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB) ReconcileActor

type RestartReconciler

+ RestartReadOnly bool

+ type UpgradeManager struct

+ ContinuingUpgrade bool

+ Finder SubclusterFinder

+ IsAllowedForUpgradePolicyFunc func(vdb *vapi.VerticaDB) bool

+ Log logr.Logger

+ StatusCondition vapi.VerticaDBConditionType

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func MakeUpgradeManager(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) *UpgradeManager

+ func (i *UpgradeManager) IsUpgradeNeeded(ctx context.Context) (bool, error)

+ type UpgradeOperator120Reconciler struct

+ Log logr.Logger

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (u *UpgradeOperator120Reconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

type VersionReconciler

+ EnforceUpgradePath bool

+ FindPodFunc func() (*PodFact, bool)

v1.2.0

Dec 22, 2021

Changes in this version

+ const AWSRegionParm

+ const AzureAccountKey

+ const AzureAccountName

+ const AzureBlobEndpoint

+ const AzureDefaultProtocol

+ const AzureSharedAccessSignature

+ const CommunalAccessKeyName

+ const CommunalSecretKeyName

+ const GCloudRegionParm

+ type AzureCredential struct

+ AccountKey string

+ AccountName string

+ BlobEndpoint string

+ SharedAccessSignature string

+ type AzureEndpointConfig struct

+ AccountName string

+ BlobEndpoint string

+ IsMultiAccountEndpoint bool

+ Protocol string

type ObjReconciler

+ VRec *VerticaDBReconciler

v1.1.0

Oct 25, 2021

Changes in this version

type FindFlags

+ const FindExisting

+ type ImageChangeReconciler struct

+ ContinuingImageChange bool

+ Finder SubclusterFinder

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (u *ImageChangeReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

type InstallReconciler

+ ATWriter atconf.Writer

type ObjReconciler

+ PatchImageAllowed bool

type ReconcileActor

+ func MakeImageChangeReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

type SubclusterFinder

+ func (m *SubclusterFinder) FindPods(ctx context.Context, flags FindFlags) (*corev1.PodList, error)

type UninstallReconciler

+ ATWriter atconf.Writer

v1.0.0

Aug 16, 2021

Changes in this version

+ const AdminToolsMapFile

+ const LicensingMountName

+ const LocalDataPVC

+ const OperatorName

+ const OperatorVersion

+ const PodInfoMountName

+ const PostDBCreateSQLFile

+ const RequeueWaitTimeInSeconds

+ const S3AccessKeyName

+ const S3SecretKeyName

+ const ServerContainer

+ const ServerContainerIndex

+ const StateUp

+ const SubclusterLabel

+ const SuperuserPasswordKey

+ const SuperuserPasswordPath

+ const SvcTypeLabel

+ type CreateDBReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (c *CreateDBReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type DBAddNodeReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (d *DBAddNodeReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type DBAddSubclusterReconciler struct

+ ATPod *PodFact

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (d *DBAddSubclusterReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type DBRemoveNodeReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (d *DBRemoveNodeReconciler) CollectPFacts(ctx context.Context) error

+ func (d *DBRemoveNodeReconciler) GetClient() client.Client

+ func (d *DBRemoveNodeReconciler) GetVDB() *vapi.VerticaDB

+ func (d *DBRemoveNodeReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type DBRemoveSubclusterReconciler struct

+ ATPod *PodFact

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (d *DBRemoveSubclusterReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type DatabaseInitializer interface

+ type FindFlags uint8

+ const FindAll

+ const FindInVdb

+ const FindNotInVdb

+ type GenericDatabaseInitializer struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (g *GenericDatabaseInitializer) ConstructAuthParms(ctx context.Context, atPod types.NamespacedName) (ctrl.Result, error)

+ func (g *GenericDatabaseInitializer) DestroyAuthParms(ctx context.Context, atPod types.NamespacedName) error

+ type InstallReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (d *InstallReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type ObjReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ Scheme *runtime.Scheme

+ Vdb *vapi.VerticaDB

+ func (o *ObjReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type PodFact struct

+ type PodFactDetail map[types.NamespacedName]*PodFact

+ type PodFacts struct

+ Detail PodFactDetail

+ NeedCollection bool

+ PRunner cmds.PodRunner

+ func MakePodFacts(cli client.Client, prunner cmds.PodRunner) PodFacts

+ func (p *PodFacts) Collect(ctx context.Context, vdb *vapi.VerticaDB) error

+ func (p *PodFacts) Invalidate()

+ type ReconcileActor interface

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

+ func MakeCreateDBReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeDBAddNodeReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeDBAddSubclusterReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeDBRemoveNodeReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeDBRemoveSubclusterReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeInstallReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeObjReconciler(cli client.Client, scheme *runtime.Scheme, log logr.Logger, ...) ReconcileActor

+ func MakeRestartReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeReviveDBReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeStatusReconciler(cli client.Client, scheme *runtime.Scheme, log logr.Logger, ...) ReconcileActor

+ func MakeUninstallReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ func MakeVersionReconciler(vdbrecon *VerticaDBReconciler, log logr.Logger, vdb *vapi.VerticaDB, ...) ReconcileActor

+ type RestartReconciler struct

+ ATPod types.NamespacedName

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

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

+ type ReviveDBReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

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

+ type ScaledownActor interface

+ CollectPFacts func(ctx context.Context) error

+ GetClient func() client.Client

+ GetVDB func() *vapi.VerticaDB

+ type StatusReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ Scheme *runtime.Scheme

+ Vdb *vapi.VerticaDB

+ func (s *StatusReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type SubclusterFinder struct

+ Subclusters map[string]*vapi.Subcluster

+ Vdb *vapi.VerticaDB

+ func MakeSubclusterFinder(cli client.Client, vdb *vapi.VerticaDB) SubclusterFinder

+ func (m *SubclusterFinder) FindServices(ctx context.Context, flags FindFlags) (*corev1.ServiceList, error)

+ func (m *SubclusterFinder) FindStatefulSets(ctx context.Context, flags FindFlags) (*appsv1.StatefulSetList, error)

+ func (m *SubclusterFinder) FindSubclusters(ctx context.Context, flags FindFlags) ([]*vapi.Subcluster, error)

+ type SubclustersSet map[string]bool

+ type UninstallReconciler struct

+ ExecPod types.NamespacedName

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (s *UninstallReconciler) CollectPFacts(ctx context.Context) error

+ func (s *UninstallReconciler) GetClient() client.Client

+ func (s *UninstallReconciler) GetVDB() *vapi.VerticaDB

+ func (s *UninstallReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type VersionReconciler struct

+ Log logr.Logger

+ PFacts *PodFacts

+ PRunner cmds.PodRunner

+ VRec *VerticaDBReconciler

+ Vdb *vapi.VerticaDB

+ func (v *VersionReconciler) Reconcile(ctx context.Context, req *ctrl.Request) (ctrl.Result, error)

+ type VerticaDBReconciler struct

+ Cfg *rest.Config

+ EVRec record.EventRecorder

+ Log logr.Logger

+ Scheme *runtime.Scheme

+ func (r *VerticaDBReconciler) GetSuperuserPassword(ctx context.Context, vdb *vapi.VerticaDB, log logr.Logger) (string, error)

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

+ func (r *VerticaDBReconciler) SetupWithManager(mgr ctrl.Manager) error

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