Versions in this module Expand all Collapse all v0 v0.0.2 Feb 16, 2026 Changes in this version + func CapturePodLogs(ctx context.Context, config *rest.Config, namespace, pod string) error + func GetFreePort() (int, error) + func GetNonEmptyLines(output string) []string + func GetProjectDir() (string, error) + func InstallCertManager(ctx context.Context) error + func InstallPrometheusOperator(ctx context.Context) error + func LoadImageToKindClusterWithName(ctx context.Context, name string) error + func Run(cmd *exec.Cmd) ([]byte, error) + func SetupCA(ctx context.Context, k8sClient client.Client, namespace string, suffix uint32) + func UninstallPrometheusOperator(ctx context.Context) + func WaitReplicaCount(ctx context.Context, k8sClient client.Client, namespace, app string, ...) error + type ClickHouseClient struct + func NewClickHouseClient(ctx context.Context, config *rest.Config, cr *v1.ClickHouseCluster, ...) (*ClickHouseClient, error) + func (c *ClickHouseClient) CheckDefaultDatabasesReplicated(ctx context.Context) error + func (c *ClickHouseClient) CheckRead(ctx context.Context, order int) error + func (c *ClickHouseClient) CheckWrite(ctx context.Context, order int) error + func (c *ClickHouseClient) Close() + func (c *ClickHouseClient) CreateDatabase(ctx context.Context) error + func (c *ClickHouseClient) QueryRow(ctx context.Context, query string, result any) error + type ForwardedCluster struct + PodToAddr map[*corev1.Pod]string + func NewForwardedCluster(ctx context.Context, config *rest.Config, namespace, app string, port uint16) (*ForwardedCluster, error) + func (c *ForwardedCluster) Close() + type KeeperClient struct + func NewKeeperClient(ctx context.Context, config *rest.Config, cr *v1.KeeperCluster) (*KeeperClient, error) + func (c *KeeperClient) CheckRead(order int) error + func (c *KeeperClient) CheckWrite(order int) error + func (c *KeeperClient) Close()
Go to main page