chi

Documentation

Index

• type ActionPlan
  • func NewActionPlan(old, new *v1.ClickHouseInstallation) *ActionPlan
  • func (ap *ActionPlan) GetNewHostsNum() int
  • func (ap *ActionPlan) GetRemovedHostsNum() int
  • func (ap *ActionPlan) IsNoChanges() bool
  • func (ap *ActionPlan) WalkAdded(clusterFunc func(cluster *v1.ChiCluster), shardFunc func(shard *v1.ChiShard), ...)
  • func (ap *ActionPlan) WalkRemoved(clusterFunc func(cluster *v1.ChiCluster), shardFunc func(shard *v1.ChiShard), ...)
• type Controller
  • func NewController(version string, chopConfigManager *config.Manager, ...) *Controller
  • func (c *Controller) GetChiByObjectMeta(objectMeta *meta.ObjectMeta) (*chiv1.ClickHouseInstallation, error)
  • func (c *Controller) ReconcileConfigMap(configMap *core.ConfigMap) error
  • func (c *Controller) ReconcileService(service *core.Service) error
  • func (c *Controller) ReconcileStatefulSet(newStatefulSet *apps.StatefulSet, host *chop.ChiHost) error
  • func (c *Controller) Run(ctx context.Context, threadiness int)
• type DropDns
  • func NewDropDns(initiator *v1.ObjectMeta) *DropDns
• type ReconcileChi
  • func NewReconcileChi(cmd string, old, new *chop.ClickHouseInstallation) *ReconcileChi
• type ReconcileChit
  • func NewReconcileChit(cmd string, old, new *chop.ClickHouseInstallationTemplate) *ReconcileChit
• type ReconcileChopConfig
  • func NewReconcileChopConfig(cmd string, old, new *chop.ClickHouseOperatorConfiguration) *ReconcileChopConfig

Types

type ActionPlan

type ActionPlan struct {
	// contains filtered or unexported fields
}

func NewActionPlan

func NewActionPlan(old, new *v1.ClickHouseInstallation) *ActionPlan

func (*ActionPlan) GetNewHostsNum

func (ap *ActionPlan) GetNewHostsNum() int

GetNewHostsNum - total number of hosts to be achieved

func (*ActionPlan) GetRemovedHostsNum

func (ap *ActionPlan) GetRemovedHostsNum() int

GetRemovedHostsNum - how many hosts would be removed

func (*ActionPlan) IsNoChanges

func (ap *ActionPlan) IsNoChanges() bool

IsNoChanges are there any changes

func (*ActionPlan) WalkAdded

func (ap *ActionPlan) WalkAdded(
	clusterFunc func(cluster *v1.ChiCluster),
	shardFunc func(shard *v1.ChiShard),
	hostFunc func(host *v1.ChiHost),
)

WalkAdded walk added hosts

func (*ActionPlan) WalkRemoved

func (ap *ActionPlan) WalkRemoved(
	clusterFunc func(cluster *v1.ChiCluster),
	shardFunc func(shard *v1.ChiShard),
	hostFunc func(host *v1.ChiHost),
)

WalkRemoved walk removed hosts

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller defines CRO controller

func NewController

func NewController(
	version string,
	chopConfigManager *config.Manager,
	chopClient chopclientset.Interface,
	kubeClient kube.Interface,
	chopInformerFactory chopinformers.SharedInformerFactory,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
) *Controller

NewController creates instance of Controller

func (*Controller) GetChiByObjectMeta

func (c *Controller) GetChiByObjectMeta(objectMeta *meta.ObjectMeta) (*chiv1.ClickHouseInstallation, error)

func (*Controller) ReconcileConfigMap

func (c *Controller) ReconcileConfigMap(configMap *core.ConfigMap) error

reconcileConfigMap reconciles core.ConfigMap

func (*Controller) ReconcileService

func (c *Controller) ReconcileService(service *core.Service) error

reconcileService reconciles core.Service

func (*Controller) ReconcileStatefulSet

func (c *Controller) ReconcileStatefulSet(newStatefulSet *apps.StatefulSet, host *chop.ChiHost) error

reconcileStatefulSet reconciles apps.StatefulSet

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, threadiness int)

Run syncs caches, starts workers

type DropDns

type DropDns struct {
	// contains filtered or unexported fields
}

func NewDropDns

func NewDropDns(initiator *v1.ObjectMeta) *DropDns

type ReconcileChi

type ReconcileChi struct {
	// contains filtered or unexported fields
}

func NewReconcileChi

func NewReconcileChi(cmd string, old, new *chop.ClickHouseInstallation) *ReconcileChi

type ReconcileChit

type ReconcileChit struct {
	// contains filtered or unexported fields
}

func NewReconcileChit

func NewReconcileChit(cmd string, old, new *chop.ClickHouseInstallationTemplate) *ReconcileChit

type ReconcileChopConfig

type ReconcileChopConfig struct {
	// contains filtered or unexported fields
}

func NewReconcileChopConfig

func NewReconcileChopConfig(cmd string, old, new *chop.ClickHouseOperatorConfiguration) *ReconcileChopConfig