clickhouse

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 16, 2026 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

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

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

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

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

Variables

This section is empty.

Functions

func SetupWithManager

func SetupWithManager(mgr ctrl.Manager, log controllerutil.Logger) 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
}

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) 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.

Jump to

Keyboard shortcuts

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