Documentation ¶
Index ¶
- Constants
- func Add(mgr manager.Manager) error
- func ParseXML(s interface{}) string
- type Cluster
- type Generator
- type ReconcileClickHouseCluster
- func (r *ReconcileClickHouseCluster) CheckDeletePVC(cc *clickhousev1.ClickHouseCluster) error
- func (r *ReconcileClickHouseCluster) CheckNonAllowedChanges(instance *clickhousev1.ClickHouseCluster) bool
- func (r *ReconcileClickHouseCluster) DeletePVCs(cc *clickhousev1.ClickHouseCluster) error
- func (r *ReconcileClickHouseCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)
- func (r *ReconcileClickHouseCluster) ScaleDownCluster(cc *clickhousev1.ClickHouseCluster) error
- type RemoteServers
- type Replica
- type Shard
- type Zookeeper
Constants ¶
View Source
const ( ClickHouseContainerName = "clickhouse" ClickHouseExporterContainerName = "exporter" InitContainerName = "clickhouse-init" )
View Source
const ( ClusterPhaseInitial = "Initializing" ClusterPhaseCreating = "Creating" ClusterPhaseUpdating = "Updating" ClusterPhaseRunning = "Running" ShardPhaseRunning = "Running" ShardPhaseInitial = "Initializing" ShardIDLabelKey = "shard-id" CreateByLabelKey = "created-by" ClusterLabelKey = "clickhouse-cluster" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Generator ¶
type Generator struct {
// contains filtered or unexported fields
}
func NewGenerator ¶
func NewGenerator(rcc *ReconcileClickHouseCluster, cc *clickhousev1.ClickHouseCluster) *Generator
func (*Generator) GenerateCommonConfigMap ¶
type ReconcileClickHouseCluster ¶
type ReconcileClickHouseCluster struct {
// contains filtered or unexported fields
}
ReconcileClickHouseCluster reconciles a ClickHouseCluster object
func (*ReconcileClickHouseCluster) CheckDeletePVC ¶
func (r *ReconcileClickHouseCluster) CheckDeletePVC(cc *clickhousev1.ClickHouseCluster) error
func (*ReconcileClickHouseCluster) CheckNonAllowedChanges ¶
func (r *ReconcileClickHouseCluster) CheckNonAllowedChanges(instance *clickhousev1.ClickHouseCluster) bool
CheckNonAllowedChanges - checks if there are some changes on CRD that are not allowed on statefulset If a non Allowed Changed is Find we won't Update associated kubernetes objects, but we will put back the old value and Patch the CRD with correct values
func (*ReconcileClickHouseCluster) DeletePVCs ¶
func (r *ReconcileClickHouseCluster) DeletePVCs(cc *clickhousev1.ClickHouseCluster) error
func (*ReconcileClickHouseCluster) ScaleDownCluster ¶
func (r *ReconcileClickHouseCluster) ScaleDownCluster(cc *clickhousev1.ClickHouseCluster) error
type RemoteServers ¶
type Zookeeper ¶
type Zookeeper struct {
Zookeeper *v1.ZookeeperConfig `xml:"zookeeper"`
}
Click to show internal directories.
Click to hide internal directories.