sources

package

Go to main page

Versions in this module

v3

v3.7.0

Jul 21, 2025

v3.6.0

Jul 16, 2025

Changes in this version

type Source

+ func (s Source) IsDefaultGroup() bool

v3.5.0

Jun 5, 2025

Changes in this version

type Source

+ func (s Source) Equal(s2 Source) bool

v3.4.0

May 23, 2025

v3.3.0

May 12, 2025

Changes in this version

+ const EnvAzureFlexible

+ const EnvAzureSingle

+ const EnvGoogle

+ const EnvUnknown

+ var NewConn = db.New

+ var NewConnWithConfig = db.NewWithConfig

+ func VersionToInt(version string) (v int)

type CmdOpts

+ CreateHelpers bool

+ type RuntimeInfo struct

+ ApproxDbSize int64

+ ExecEnv string

+ Extensions map[string]int

+ IsInRecovery bool

+ IsSuperuser bool

+ LastCheckedOn time.Time

+ RealDbname string

+ SystemIdentifier string

+ Version int

+ VersionStr string

type SourceConn

+ func (md *SourceConn) FetchApproxSize(ctx context.Context) (size int64)

+ func (md *SourceConn) FetchRuntimeInfo(ctx context.Context, forceRefetch bool) (err error)

+ func (md *SourceConn) FetchVersion(ctx context.Context, sql string) (version string, ver int, err error)

+ func (md *SourceConn) GetClusterIdentifier() string

+ func (md *SourceConn) GetMetricInterval(name string) float64

v3.2.0

Mar 25, 2025

Changes in this version

+ type SourceConn struct

+ Conn db.PgxPoolIface

+ ConnConfig *pgxpool.Config

+ func (md *SourceConn) Connect(ctx context.Context, opts CmdOpts) (err error)

+ func (md *SourceConn) DiscoverPlatform(ctx context.Context) (platform string)

+ func (md *SourceConn) FunctionExists(ctx context.Context, functionName string) (exists bool)

+ func (md *SourceConn) GetApproxSize(ctx context.Context) (size int64, err error)

+ func (md *SourceConn) GetDatabaseName() string

+ func (md *SourceConn) IsPostgresSource() bool

+ func (md *SourceConn) ParseConfig() (err error)

+ func (md *SourceConn) Ping(ctx context.Context) error

+ func (md *SourceConn) SetDatabaseName(name string)

+ type SourceConns []*SourceConn

+ func (mds SourceConns) GetMonitoredDatabase(DBUniqueName string) *SourceConn

+ func (mds SourceConns) SyncFromReader(r Reader) (newmds SourceConns, err error)

v3.1.0

Feb 13, 2025

Changes in this version

type MonitoredDatabase

+ func (md *MonitoredDatabase) ParseConfig() (err error)

type Sources

+ func (srcs Sources) Validate() (Sources, error)

v3.0.0

Dec 17, 2024

Changes in this version

+ var Kinds = []Kind

+ type CmdOpts struct

+ Groups []string

+ MaxParallelConnectionsPerDb int

+ MinDbSizeMB int64

+ Refresh int

+ Sources string

+ TryCreateListedExtsIfMissing string

+ type HostConfigAttrs struct

+ CAFile string

+ CertFile string

+ DcsEndpoints []string

+ DcsType string

+ KeyFile string

+ LogsGlobPath string

+ LogsMatchRegex string

+ Namespace string

+ Password string

+ PerMetricDisabledTimes []HostConfigPerMetricDisabledTimes

+ Scope string

+ Username string

+ type HostConfigPerMetricDisabledTimes struct

+ DisabledDays string

+ DisabledTimes []string

+ Metrics []string

+ type Kind string

+ const SourcePatroni

+ const SourcePatroniContinuous

+ const SourcePatroniNamespace

+ const SourcePgBouncer

+ const SourcePgPool

+ const SourcePostgres

+ const SourcePostgresContinuous

+ func (k Kind) IsValid() bool

+ type MonitoredDatabase struct

+ Conn db.PgxPoolIface

+ ConnConfig *pgxpool.Config

+ func ResolveDatabasesFromPatroni(ce Source) ([]*MonitoredDatabase, error)

+ func (md *MonitoredDatabase) Connect(ctx context.Context, opts CmdOpts) (err error)

+ func (md *MonitoredDatabase) GetDatabaseName() string

+ func (md *MonitoredDatabase) IsPostgresSource() bool

+ func (md *MonitoredDatabase) Ping(ctx context.Context) error

+ func (md *MonitoredDatabase) SetDatabaseName(name string)

+ type MonitoredDatabases []*MonitoredDatabase

+ func ResolveDatabasesFromPostgres(s Source) (resolvedDbs MonitoredDatabases, err error)

+ func (mds MonitoredDatabases) GetMonitoredDatabase(DBUniqueName string) *MonitoredDatabase

+ func (mds MonitoredDatabases) SyncFromReader(r Reader) (newmds MonitoredDatabases, err error)

+ type PatroniClusterMember struct

+ ConnURL string

+ Name string

+ Role string

+ Scope string

+ type Reader interface

+ GetSources func() (Sources, error)

+ type ReaderWriter interface

+ func NewPostgresSourcesReaderWriter(ctx context.Context, connstr string) (ReaderWriter, error)

+ func NewPostgresSourcesReaderWriterConn(ctx context.Context, conn db.PgxPoolIface) (ReaderWriter, error)

+ func NewYAMLSourcesReaderWriter(ctx context.Context, path string) (ReaderWriter, error)

+ type Source struct

+ ConnStr string

+ CustomTags map[string]string

+ ExcludePattern string

+ Group string

+ HostConfig HostConfigAttrs

+ IncludePattern string

+ IsEnabled bool

+ IsSuperuser bool

+ Kind Kind

+ Metrics map[string]float64

+ MetricsStandby map[string]float64

+ Name string

+ OnlyIfMaster bool

+ PresetMetrics string

+ PresetMetricsStandby string

+ func (s *Source) Clone() *Source

+ func (s *Source) GetDatabaseName() string

+ func (s Source) ResolveDatabases() (MonitoredDatabases, error)

+ type Sources []Source

+ func (srcs Sources) ResolveDatabases() (_ MonitoredDatabases, err error)

+ type Writer interface

+ DeleteSource func(string) error

+ UpdateSource func(md Source) error

+ WriteSources func(Sources) error

Other modules containing this package

github.com/cybertec-postgresql/pgwatch/v5

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