providers

Jan 2, 2026

Changes in this version

+ var ErrNotMongoDB = errors.New("not a MongoDB connection")

+ var ErrNotSQLDatabase = errors.New("not a SQL database")

+ type ConnectionConfig interface

+ BuildDSN func() (string, error)

+ GetConnMaxIdleTime func() *time.Duration

+ GetConnMaxLifetime func() *time.Duration

+ GetConnectTimeout func() time.Duration

+ GetDatabase func() string

+ GetEnableLogging func() bool

+ GetEnableMetrics func() bool

+ GetFilePath func() string

+ GetHost func() string

+ GetMaxIdleConns func() *int

+ GetMaxOpenConns func() *int

+ GetName func() string

+ GetPassword func() string

+ GetPort func() int

+ GetQueryTimeout func() time.Duration

+ GetReadPreference func() string

+ GetType func() string

+ GetUser func() string

+ type ConnectionStats struct

+ Connected bool

+ HealthCheckStatus string

+ Idle int

+ InUse int

+ LastHealthCheck time.Time

+ MaxIdleClosed int64

+ MaxLifetimeClosed int64

+ Name string

+ OpenConnections int

+ Type string

+ WaitCount int64

+ WaitDuration time.Duration

+ type MSSQLProvider struct

+ func NewMSSQLProvider() *MSSQLProvider

+ func (p *MSSQLProvider) Close() error

+ func (p *MSSQLProvider) Connect(ctx context.Context, cfg ConnectionConfig) error

+ func (p *MSSQLProvider) GetMongo() (*mongo.Client, error)

+ func (p *MSSQLProvider) GetNative() (*sql.DB, error)

+ func (p *MSSQLProvider) HealthCheck(ctx context.Context) error

+ func (p *MSSQLProvider) Stats() *ConnectionStats

+ type MongoProvider struct

+ func NewMongoProvider() *MongoProvider

+ func (p *MongoProvider) Close() error

+ func (p *MongoProvider) Connect(ctx context.Context, cfg ConnectionConfig) error

+ func (p *MongoProvider) GetMongo() (*mongo.Client, error)

+ func (p *MongoProvider) GetNative() (*sql.DB, error)

+ func (p *MongoProvider) HealthCheck(ctx context.Context) error

+ func (p *MongoProvider) Stats() *ConnectionStats

+ type NotificationHandler func(channel string, payload string)

+ type PostgresListener struct

+ func NewPostgresListener(cfg ConnectionConfig) *PostgresListener

+ func (l *PostgresListener) Channels() []string

+ func (l *PostgresListener) Close() error

+ func (l *PostgresListener) Connect(ctx context.Context) error

+ func (l *PostgresListener) IsConnected() bool

+ func (l *PostgresListener) Listen(channel string, handler NotificationHandler) error

+ func (l *PostgresListener) Notify(ctx context.Context, channel string, payload string) error

+ func (l *PostgresListener) Unlisten(channel string) error

+ type PostgresProvider struct

+ func NewPostgresProvider() *PostgresProvider

+ func (p *PostgresProvider) Close() error

+ func (p *PostgresProvider) Connect(ctx context.Context, cfg ConnectionConfig) error

+ func (p *PostgresProvider) GetListener(ctx context.Context) (*PostgresListener, error)

+ func (p *PostgresProvider) GetMongo() (*mongo.Client, error)

+ func (p *PostgresProvider) GetNative() (*sql.DB, error)

+ func (p *PostgresProvider) HealthCheck(ctx context.Context) error

+ func (p *PostgresProvider) Stats() *ConnectionStats

+ type Provider interface

+ Close func() error

+ Connect func(ctx context.Context, cfg ConnectionConfig) error

+ GetMongo func() (*mongo.Client, error)

+ GetNative func() (*sql.DB, error)

+ HealthCheck func(ctx context.Context) error

+ Stats func() *ConnectionStats

+ type SQLiteProvider struct

+ func NewSQLiteProvider() *SQLiteProvider

+ func (p *SQLiteProvider) Close() error

+ func (p *SQLiteProvider) Connect(ctx context.Context, cfg ConnectionConfig) error

+ func (p *SQLiteProvider) GetMongo() (*mongo.Client, error)

+ func (p *SQLiteProvider) GetNative() (*sql.DB, error)

+ func (p *SQLiteProvider) HealthCheck(ctx context.Context) error

+ func (p *SQLiteProvider) Stats() *ConnectionStats