keeper

package

v0.0.2 Latest Latest Go to latest Published: Feb 16, 2026 License: Apache-2.0 Imports: 39 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) error
type ClusterController

Constants ¶

View Source

const (
	FLWCommand = "mntr"

	ModeLeader     = "leader"
	ModeFollower   = "follower"
	ModeStandalone = "standalone"
)

View Source

const (
	PortNative           = 2181
	PortNativeSecure     = 2281
	PortPrometheusScrape = 9090
	PortInterserver      = 9234
	PortHTTPControl      = 9123

	QuorumConfigPath     = "/etc/clickhouse-keeper/"
	QuorumConfigFileName = "config.yaml"

	ConfigPath     = QuorumConfigPath + "config.d/"
	ConfigFileName = "00-config.yaml"

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

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

	StorageLogPath      = internal.KeeperDataPath + "/coordination/log/"
	StorageSnapshotPath = internal.KeeperDataPath + "/coordination/snapshots/"

	ContainerName          = "clickhouse-keeper"
	DefaultRevisionHistory = 10
)

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.KeeperClusterWebhook
}

ClusterController reconciles a KeeperCluster 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.

Source Files ¶

View all Source files

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