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.
Click to show internal directories.
Click to hide internal directories.