Skip to content

cluster

import "vault-plugin-database-clickhouse/internal/cluster"

Package cluster resolves ClickHouse cluster names for ON CLUSTER DDL.

When Vault config sets cluster, that name is used. Otherwise names are read from system.clusters and internal/cluster/choose applies single-or-error rules.

Index

Variables

var (
    // ErrEmptyCluster is returned when system.clusters has no rows and cluster is unset.
    ErrEmptyCluster = choose.ErrEmptyCluster
    // ErrAmbiguousCluster is returned when multiple clusters exist and cluster is unset.
    ErrAmbiguousCluster = choose.ErrAmbiguousCluster
)

func Discover

func Discover(ctx context.Context, db *sql.DB) ([]string, error)

Discover returns distinct cluster names from system.clusters.

func Resolve

func Resolve(ctx context.Context, db *sql.DB, configured string) (string, error)

Resolve returns the cluster name using configured override or discovery.

Generated by gomarkdoc