cnpg

Jan 5, 2026

Changes in this version

+ const CNPGAPIGroup

+ const CNPGAPIVersion

+ const CNPGClusterLabel

+ const CNPGParametersPath

+ const CNPGResourceName

+ const ConfigApplyMaxRetries

+ const ConfigApplyRetryDelay

+ const DEFAULT_CONFIG_KEY

+ const DEFAULT_CONTAINER_NAME

+ const MaxWaitTimeClusterHealthy

+ const MinTimeSinceFailover

+ const PollIntervalClusterHealthy

+ var CNPGManagedParameters = map[string]bool

+ func Collectors(pool *pgxpool.Pool, kubeClient kubernetes.Client, clusterName string, ...) []agent.MetricCollector

+ func ConvertToCNPGFormat(name string, value string, knobConfig *agent.PGConfigRow) string

+ func ConvertWithUnit(value, unit string) string

+ func DetectConfigFromConfigFile() bool

+ func DetectConfigFromEnv() bool

+ func IsCNPGManagedParameter(name string) bool

+ func NormalizeValue(value string) string

+ type CNPGAdapter struct

+ Config Config

+ GuardrailSettings guardrails.Config

+ K8sClient kubernetes.Client

+ PGDriver *pgxpool.Pool

+ PGVersion string

+ State *State

+ func CreateCNPGAdapter() (*CNPGAdapter, error)

+ func (adapter *CNPGAdapter) ApplyConfig(proposedConfig *agent.ProposedConfigResponse) error

+ func (adapter *CNPGAdapter) CheckForFailover(ctx context.Context) error

+ func (adapter *CNPGAdapter) CheckRestartRequired(ctx context.Context, changedParams map[string]string) (bool, []string, error)

+ func (adapter *CNPGAdapter) GetActiveConfig() (agent.ConfigArraySchema, error)

+ func (adapter *CNPGAdapter) GetCurrentConfig(ctx context.Context) (map[string]string, error)

+ func (adapter *CNPGAdapter) GetMetrics() ([]metrics.FlatValue, error)

+ func (adapter *CNPGAdapter) GetSystemInfo() ([]metrics.FlatValue, error)

+ func (adapter *CNPGAdapter) Guardrails() *guardrails.Signal

+ func (adapter *CNPGAdapter) HandleFailoverDetected(ctx context.Context, failoverErr *FailoverDetectedError) error

+ type Config struct

+ ClusterName string

+ ContainerName string

+ KubeconfigPath string

+ Namespace string

+ PodName string

+ func ConfigFromViper() (Config, error)

+ type FailoverDetectedError struct

+ Message string

+ NewPrimary string

+ OldPrimary string

+ func (e *FailoverDetectedError) Error() string

+ type State struct

+ LastAppliedConfig time.Time

+ LastFailoverTime time.Time

+ LastGuardrailCheck time.Time

+ LastKnownPrimary string

+ func (s *State) CancelOperations()

+ func (s *State) CreateOperationsContext()

+ func (s *State) GetLastKnownPrimary() string

+ func (s *State) GetOperationsContext() context.Context

+ func (s *State) SetLastFailoverTime(t time.Time)

+ func (s *State) SetLastKnownPrimary(primaryPod string)

+ func (s *State) TimeSinceLastFailover() time.Duration

+ func (s *State) TimeSinceLastGuardrailCheck() time.Duration

+ func (s *State) UpdateLastAppliedConfig()

+ func (s *State) UpdateLastGuardrailCheck()