clickhouse

package

v0.0.3 Latest Latest Go to latest Published: Mar 11, 2026 License: Apache-2.0 Imports: 43 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ClickHouse/clickhouse-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func SetupWithManager(mgr ctrl.Manager, log controllerutil.Logger, checker *upgrade.Checker) error
type ClusterController

Constants ¶

View Source

const (
	PortManagement   = 9001
	PortNative       = 9000
	PortNativeSecure = 9440
	PortHTTP         = 8123
	PortHTTPSecure   = 8443

	PortPrometheusScrape = 9363
	PortInterserver      = 9009

	ConfigPath               = "/etc/clickhouse-server/"
	ConfigDPath              = "config.d"
	ConfigFileName           = "config.yaml"
	UsersDPath               = "users.d"
	UsersFileName            = "users.yaml"
	ExtraConfigFileName      = "99-extra-config.yaml"
	ExtraUsersConfigFileName = "99-extra-users-config.yaml"
	ClientConfigPath         = "/etc/clickhouse-client/"
	ClientConfigFileName     = "config.yaml"

	TLSConfigPath       = "/etc/clickhouse-server/tls/"
	CABundleFilename    = "ca-bundle.crt"
	CertificateFilename = "clickhouse-server.crt"
	KeyFilename         = "clickhouse-server.key"
	CustomCAFilename    = "custom-ca.crt"

	LogPath = "/var/log/clickhouse-server/"

	DefaultClusterName       = "default"
	KeeperPathUsers          = "/clickhouse/access"
	KeeperPathUDF            = "/clickhouse/user_defined"
	KeeperPathDistributedDDL = "/clickhouse/task_queue/ddl"

	ContainerName          = "clickhouse-server"
	DefaultRevisionHistory = 10
	MaximalAffinityWeight  = 100

	InterserverUserName        = "interserver"
	OperatorManagementUsername = "operator"
	DefaultProfileName         = "default"

	EnvInterserverPassword = "CLICKHOUSE_INTERSERVER_PASSWORD"
	EnvDefaultUserPassword = "CLICKHOUSE_DEFAULT_USER_PASSWORD"
	EnvKeeperIdentity      = "CLICKHOUSE_KEEPER_IDENTITY"
	EnvClusterSecret       = "CLICKHOUSE_CLUSTER_SECRET"

	SecretKeyInterserverPassword = "interserver-password"
	SecretKeyManagementPassword  = "management-password"
	SecretKeyKeeperIdentity      = "keeper-identity"
	SecretKeyClusterSecret       = "cluster-secret"
)

Variables ¶

This section is empty.

Functions ¶

func SetupWithManager ¶

func SetupWithManager(mgr ctrl.Manager, log controllerutil.Logger, checker *upgrade.Checker) error

SetupWithManager sets up the controller with the Manager.

Types ¶

type ClusterController ¶

type ClusterController struct {
	client.Client

	Scheme   *runtime.Scheme
	Recorder events.EventRecorder
	Logger   controllerutil.Logger
	Webhook  webhookv1.ClickHouseClusterWebhook
	Checker  *upgrade.Checker
}

ClusterController reconciles a ClickHouseCluster object.

func (*ClusterController) GetClient ¶

func (cc *ClusterController) GetClient() client.Client

GetClient returns the K8S Client.

func (*ClusterController) GetRecorder ¶

func (cc *ClusterController) GetRecorder() events.EventRecorder

GetRecorder returns the KeeperCluster EventRecorder.

func (*ClusterController) GetScheme ¶

func (cc *ClusterController) GetScheme() *runtime.Scheme

GetScheme returns initialized with the Cluster Scheme.

func (*ClusterController) GetVersionChecker ¶ added in v0.0.3

func (cc *ClusterController) GetVersionChecker() *upgrade.Checker

GetVersionChecker returns the version upgrade Checker.

func (*ClusterController) Reconcile ¶

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

Source Files ¶

View all Source files

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