pool

Jun 29, 2026

Changes in this version

+ type Connection struct

+ DSN string

+ ReadOnly bool

+ type Option func(*Options)

+ func WithConnection(dsn string, readOnly bool) Option

+ func WithConnections(connections []Connection) Option

+ func WithDialectAdapter(adapter dialect.DialectAdapter) Option

+ func WithInsertBatchSize(insertBatchSize int) Option

+ func WithMaxIdle(_ int) Option

+ func WithMaxLifetime(maxLifetime time.Duration) Option

+ func WithMaxOpen(maxOpen int) Option

+ func WithPreferSimpleProtocol(preferSimpleProtocol bool) Option

+ func WithPreparedStatements(enabled bool) Option

+ func WithSkipDefaultTransaction(skipDefaultTransaction bool) Option

+ func WithTenancyProvider(prov tenancy.Provider) Option

+ func WithTraceConfig(traceConfig config.ConfigurationDatabaseTracing) Option

+ type Options struct

+ Connections []Connection

+ DialectAdapter dialect.DialectAdapter

+ InsertBatchSize int

+ MaxLifetime time.Duration

+ MaxOpen int

+ PreferSimpleProtocol bool

+ PreparedStatements bool

+ SkipDefaultTransaction bool

+ TenancyProvider tenancy.Provider

+ TenancyProviderSet bool

+ TraceConfig config.ConfigurationDatabaseTracing

+ type Pool interface

+ AddConnection func(ctx context.Context, opts ...Option) error

+ CanMigrate func() bool

+ Close func(ctx context.Context)

+ DB func(ctx context.Context, readOnly bool) *gorm.DB

+ Migrate func(ctx context.Context, migrationsDirPath string, migrations ...any) error

+ SaveMigration func(ctx context.Context, migrationPatches ...*migration.Patch) error

+ func NewPool(_ context.Context, opts ...Option) Pool