Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

database

package

Go to main page

Versions in this module

v1

v1.0.3

Aug 21, 2025

v1.0.2

Aug 20, 2025

Changes in this version

+ type CheckDetail struct

+ Description string

+ Duration time.Duration

+ Error string

+ Name string

+ Status HealthStatus

+ type Config struct

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ ConnectionTimeout time.Duration

+ DatabaseMode DatabaseMode

+ DatabaseSchema string

+ DatabaseURL string

+ EnableFallback bool

+ EnableHealthChecks bool

+ EnableMetrics bool

+ EnableRetryLogic bool

+ EnableSlowQueryLog bool

+ FallbackDatabaseURL string

+ HealthCheckInterval time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

+ MaxRetryAttempts int

+ RetryBackoffDuration time.Duration

+ ServiceName string

+ SlowQueryThreshold time.Duration

+ func DefaultConfig() *Config

+ type ConnectionManager struct

+ func GetInstance(config *Config) (*ConnectionManager, error)

+ func NewConnectionManager(config *Config) (*ConnectionManager, error)

+ func (cm *ConnectionManager) Close() error

+ func (cm *ConnectionManager) ExecuteInSchema(schema string, query string, args ...interface{}) (*sql.Rows, error)

+ func (cm *ConnectionManager) ExecuteWithMetrics(query string, args ...interface{}) (*sql.Rows, error)

+ func (cm *ConnectionManager) GetDB() *sql.DB

+ func (cm *ConnectionManager) GetHealthStatus() map[string]interface{}

+ func (cm *ConnectionManager) GetQueryHistory() []QueryMetric

+ func (cm *ConnectionManager) ResetMetrics()

+ func (cm *ConnectionManager) Transaction(fn func(*sql.Tx) error) error

+ type ConnectionMetrics struct

+ ActiveConnections int64

+ ConnectionErrors map[string]int64

+ FailedConnections int64

+ FallbackUsed int64

+ HealthCheckFailures int64

+ LastError string

+ LastErrorTime time.Time

+ QueryHistory []QueryMetric

+ QueryTime time.Duration

+ RecoveryAttempts int64

+ SchemaQueries map[string]int64

+ SlowQueries int64

+ TotalConnections int64

+ type DatabaseMode string

+ const ModeMulti

+ const ModeSingle

+ type DefaultLogger struct

+ func (dl *DefaultLogger) Debugf(format string, args ...interface{})

+ func (dl *DefaultLogger) Error(msg string)

+ func (dl *DefaultLogger) Info(msg string)

+ func (dl *DefaultLogger) Warn(msg string)

+ func (dl *DefaultLogger) WithField(key string, value interface{}) Logger

+ type FallbackConfig struct

+ AlertWebhookURL string

+ AutoRecoveryEnabled bool

+ EnableAutoFallback bool

+ EnableNotifications bool

+ FailureThreshold int

+ FallbackTimeout time.Duration

+ HealthCheckInterval time.Duration

+ MaxRetryAttempts int

+ NotificationChannels []string

+ RecoveryCheckInterval time.Duration

+ RecoveryConfidence float64

+ RetryBackoffMultiplier float64

+ func DefaultFallbackConfig() *FallbackConfig

+ type FallbackManager struct

+ func NewFallbackManager(config *Config, logger Logger) (*FallbackManager, error)

+ func (fm *FallbackManager) ForceRecovery() error

+ func (fm *FallbackManager) GetCurrentMode() DatabaseMode

+ func (fm *FallbackManager) GetMetrics() *FallbackMetrics

+ func (fm *FallbackManager) IsInFallbackMode() bool

+ func (fm *FallbackManager) SetAlertCallback(callback func(string, error))

+ func (fm *FallbackManager) SetPrimaryDB(db *sql.DB)

+ func (fm *FallbackManager) Stop()

+ type FallbackMetrics struct

+ AlertsSent int64

+ FailedRecoveries int64

+ FallbackActivations int64

+ FallbackDuration map[string]time.Duration

+ HealthCheckFailures map[string]int64

+ LastFallbackTime time.Time

+ LastRecoveryTime time.Time

+ RecoveryAttempts int64

+ SuccessfulRecoveries int64

+ TimeInFallbackMode time.Duration

+ type HealthCheckResult struct

+ Checks []CheckDetail

+ Details interface{}

+ Error string

+ ResponseTime time.Duration

+ Service string

+ Severity Severity

+ Status HealthStatus

+ Suggestions []string

+ Timestamp time.Time

+ type HealthChecker struct

+ func NewHealthChecker(config *Config) *HealthChecker

+ func (hc *HealthChecker) CheckAllServices(ctx context.Context) ([]*HealthCheckResult, error)

+ func (hc *HealthChecker) CheckDatabase(ctx context.Context, db *sql.DB, serviceName string) *HealthCheckResult

+ func (hc *HealthChecker) CheckWithRetry(ctx context.Context, db *sql.DB, serviceName string, maxRetries int) *HealthCheckResult

+ func (hc *HealthChecker) GenerateHealthReport(ctx context.Context) (HealthReport, error)

+ func (hc *HealthChecker) GetMetrics() *HealthMetrics

+ func (hc *HealthChecker) GetOverallHealth(results []*HealthCheckResult) (HealthStatus, Severity)

+ type HealthMetrics struct

+ AverageCheckTime time.Duration

+ CheckDurations []time.Duration

+ FailedChecks int64

+ HealthTrends map[string][]HealthPoint

+ LastCheckTime time.Time

+ ServiceFailures map[string]int64

+ SuccessfulChecks int64

+ TotalChecks int64

+ type HealthPoint struct

+ Duration time.Duration

+ Status HealthStatus

+ Timestamp time.Time

+ type HealthReport struct

+ DatabaseMode string

+ Metrics *HealthMetrics

+ OverallHealth HealthStatus

+ OverallSeverity Severity

+ Recommendations []string

+ Services []*HealthCheckResult

+ Summary HealthSummary

+ Timestamp time.Time

+ type HealthStatus string

+ const HealthStatusDegraded

+ const HealthStatusHealthy

+ const HealthStatusUnhealthy

+ const HealthStatusUnknown

+ const HealthStatusWarning

+ type HealthSummary struct

+ DegradedServices int

+ HealthyServices int

+ TotalServices int

+ UnhealthyServices int

+ WarningServices int

+ type Logger interface

+ Debugf func(format string, args ...interface{})

+ Error func(msg string)

+ Info func(msg string)

+ Warn func(msg string)

+ WithField func(key string, value interface{}) Logger

+ type QueryMetric struct

+ Duration time.Duration

+ Error string

+ Query string

+ Success bool

+ Timestamp time.Time

+ type RLSStatus struct

+ DatabaseName string

+ PolicyCount int

+ RLSEnabled bool

+ TableName string

+ type Severity string

+ const SeverityCritical

+ const SeverityHigh

+ const SeverityInfo

+ const SeverityLow

+ const SeverityMedium

+ type TenantCache struct

+ func NewTenantCache(ttl time.Duration, maxSize int) *TenantCache

+ func (tc *TenantCache) Get(key string) (string, bool)

+ func (tc *TenantCache) Set(key, tenantID string)

+ type TenantCacheEntry struct

+ LastUsed time.Time

+ SetTime time.Time

+ TenantID string

+ UseCount int64

+ type TenantConfig struct

+ CacheTTL time.Duration

+ DefaultTenantID string

+ EnableAuditLog bool

+ EnableCaching bool

+ EnableMetrics bool

+ EnableSecurityChecks bool

+ EnableValidation bool

+ MaxConcurrentTenants int

+ TenantTimeout time.Duration

+ func DefaultTenantConfig() *TenantConfig

+ type TenantContextManager struct

+ func NewTenantContextManager(db *sqlx.DB, logger Logger, config *TenantConfig) *TenantContextManager

+ func (tcm *TenantContextManager) ClearTenantContext(ctx context.Context) error

+ func (tcm *TenantContextManager) GetCacheStats() map[string]interface{}

+ func (tcm *TenantContextManager) GetConfig() *TenantConfig

+ func (tcm *TenantContextManager) GetCurrentTenant(ctx context.Context) (string, error)

+ func (tcm *TenantContextManager) GetMetrics() *TenantMetrics

+ func (tcm *TenantContextManager) GetTenantStats(ctx context.Context, tenantID string, tables []string) ([]TenantStats, error)

+ func (tcm *TenantContextManager) HealthCheck(ctx context.Context) error

+ func (tcm *TenantContextManager) ResetMetrics()

+ func (tcm *TenantContextManager) SetTenantContext(ctx context.Context, tenantID string) error

+ func (tcm *TenantContextManager) TenantAwareExec(ctx context.Context, tenantID, query string, args ...interface{}) (sql.Result, error)

+ func (tcm *TenantContextManager) TenantAwareQuery(ctx context.Context, tenantID, query string, args ...interface{}) (*sql.Rows, error)

+ func (tcm *TenantContextManager) ValidateTenantAccess(ctx context.Context, tenantID, resourceTable, resourceID string) (bool, error)

+ func (tcm *TenantContextManager) VerifyRLSStatus(ctx context.Context) ([]RLSStatus, error)

+ func (tcm *TenantContextManager) WithTenantContext(ctx context.Context, tenantID string, fn func(context.Context) error) error

+ type TenantMetrics struct

+ ActiveTenants map[string]time.Time

+ AverageGetTime time.Duration

+ AverageSetTime time.Duration

+ CacheHits int64

+ CacheMisses int64

+ LastOperation time.Time

+ OperationHistory []TenantOperation

+ SecurityViolations int64

+ TenantClears int64

+ TenantGets int64

+ TenantOperations map[string]int64

+ TenantSets int64

+ ValidationFailures int64

+ type TenantOperation struct

+ Duration time.Duration

+ Error string

+ Success bool

+ TenantID string

+ Timestamp time.Time

+ Type string

+ type TenantStats struct

+ Count int

+ LastUpdated time.Time

+ Size int64

+ Table string

+ TenantID string

v1.0.1

Aug 10, 2025

v1.0.0

Aug 10, 2025

Changes in this version

+ type GormLogger struct

+ func NewGormLogger(logger logger.Logger) *GormLogger

+ func (gl *GormLogger) Error(ctx context.Context, msg string, data ...interface{})

+ func (gl *GormLogger) Info(ctx context.Context, msg string, data ...interface{})

+ func (gl *GormLogger) LogMode(level gormlogger.LogLevel) gormlogger.Interface

+ func (gl *GormLogger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)

+ func (gl *GormLogger) Warn(ctx context.Context, msg string, data ...interface{})

+ type PostgresClient struct

+ func NewPostgresClient(opts PostgresOptions) (*PostgresClient, error)

+ func (pc *PostgresClient) Close() error

+ func (pc *PostgresClient) GetDB() *gorm.DB

+ func (pc *PostgresClient) GetSQLDB() *sql.DB

+ func (pc *PostgresClient) HealthCheck() observability.HealthCheck

+ func (pc *PostgresClient) Stats() sql.DBStats

+ func (pc *PostgresClient) Transaction(ctx context.Context, fn func(*gorm.DB) error) error

+ func (pc *PostgresClient) WithContext(ctx context.Context) *gorm.DB

+ type PostgresOptions struct

+ Config config.DatabaseConfig

+ Logger logger.Logger

+ Models []interface{}

+ type Repository struct

+ func NewRepository(db *gorm.DB, logger logger.Logger) *Repository

+ func (r *Repository) Create(ctx context.Context, model interface{}) error

+ func (r *Repository) Delete(ctx context.Context, model interface{}, id interface{}) error

+ func (r *Repository) GetByID(ctx context.Context, model interface{}, id interface{}) error

+ func (r *Repository) Update(ctx context.Context, model interface{}) error

v0

v0.1.0

Aug 4, 2025