Documentation
¶
Index ¶
- Constants
- func NewDropReplicaOptions() *dropReplicaOptions
- func NewDropReplicaOptionsArr(opts ...*dropReplicaOptions) (res dropReplicaOptionsArr)
- func NewMigrateTableOptions() *migrateTableOptions
- func NewMigrateTableOptionsArr(opts ...*migrateTableOptions) (res migrateTableOptionsArr)
- func ShouldEnqueue(cr *api.ClickHouseInstallation) bool
- type Controller
- func (c *Controller) GetCR(obj meta.Object) (*api.ClickHouseInstallation, error)
- func (c *Controller) OnStatefulSetCreateFailed(ctx context.Context, host *api.Host) common.ErrorCRUD
- func (c *Controller) OnStatefulSetUpdateFailed(ctx context.Context, rollbackStatefulSet *apps.StatefulSet, host *api.Host, ...) common.ErrorCRUD
- func (c *Controller) Run(ctx context.Context)
- type Skip
- type VersionOptions
Constants ¶
View Source
const FinalizerName = "finalizer.clickhouseinstallation.altinity.com"
FinalizerName specifies name of the finalizer to be used with CHI
Variables ¶
This section is empty.
Functions ¶
func NewDropReplicaOptions ¶
func NewDropReplicaOptions() *dropReplicaOptions
func NewDropReplicaOptionsArr ¶
func NewDropReplicaOptionsArr(opts ...*dropReplicaOptions) (res dropReplicaOptionsArr)
NewDropReplicaOptionsArr creates new dropReplicaOptions array
func NewMigrateTableOptions ¶
func NewMigrateTableOptions() *migrateTableOptions
func NewMigrateTableOptionsArr ¶
func NewMigrateTableOptionsArr(opts ...*migrateTableOptions) (res migrateTableOptionsArr)
NewMigrateTableOptionsArr creates new migrateTableOptions array
func ShouldEnqueue ¶
func ShouldEnqueue(cr *api.ClickHouseInstallation) bool
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller defines CRO controller
func NewController ¶
func NewController( chopClient chopClientSet.Interface, extClient apiExtensions.Interface, kubeClient kube.Interface, chopInformerFactory chopInformers.SharedInformerFactory, kubeInformerFactory kubeInformers.SharedInformerFactory, ) *Controller
NewController creates instance of Controller
func (*Controller) GetCR ¶
func (c *Controller) GetCR(obj meta.Object) (*api.ClickHouseInstallation, error)
GetCR gets CR by any object that is either a CR itself or has labels referencing a CR
func (*Controller) OnStatefulSetCreateFailed ¶
func (c *Controller) OnStatefulSetCreateFailed(ctx context.Context, host *api.Host) common.ErrorCRUD
OnStatefulSetCreateFailed handles situation when StatefulSet create failed on k8s level
func (*Controller) OnStatefulSetUpdateFailed ¶
func (c *Controller) OnStatefulSetUpdateFailed(ctx context.Context, rollbackStatefulSet *apps.StatefulSet, host *api.Host, kubeSTS interfaces.IKubeSTS) common.ErrorCRUD
OnStatefulSetUpdateFailed handles situation when StatefulSet update failed in k8s level It can try to revert StatefulSet to its previous version, specified in rollbackStatefulSet
func (*Controller) Run ¶
func (c *Controller) Run(ctx context.Context)
Run syncs caches, starts workers
type VersionOptions ¶
type VersionOptions struct {
Skip
}
Source Files
¶
- const.go
- controller-config-map.go
- controller-deleter.go
- controller-discoverer.go
- controller-getter.go
- controller-pdb.go
- controller-secret.go
- controller-service.go
- controller-status.go
- controller.go
- version-options.go
- worker-app-version.go
- worker-boilerplate.go
- worker-config-map.go
- worker-deleter.go
- worker-migrator.go
- worker-monitoring.go
- worker-pdb.go
- worker-reconciler-chi.go
- worker-reconciler-chit.go
- worker-reconciler-helper.go
- worker-secret.go
- worker-service.go
- worker-statefulset-rollback.go
- worker-status-helpers.go
- worker-wait-exclude-include-restart.go
- worker-zk-integration.go
- worker.go
Directories
Click to show internal directories.
Click to hide internal directories.