postgres

Sep 18, 2023

Changes in this version

+ func DeleteCreatedEntitiesAfterTest(db *gorm.DB) func()

+ func GenerateRandomString(n int) string

+ type Client struct

+ ConnectionString *string

+ Engine *gorm.DB

+ InstrumentationClient *instrumentation.Client

+ Logger *zap.Logger

+ MaxConnectionLifetime *time.Duration

+ MaxConnectionRetries *int

+ MaxConnectionRetryTimeout *time.Duration

+ MaxIdleConnections *int

+ MaxOpenConnections *int

+ QueryTimeout *time.Duration

+ RetrySleep *time.Duration

+ func New(options ...Option) (*Client, error)

+ func NewInMemoryTestDbClient(models ...any) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) ConfigureNewTxCleanupHandlerForUnitTests() *TestTxCleanupHandlerForUnitTests

+ func (c *Client) Validate() error

+ func (db *Client) PerformComplexTransaction(ctx context.Context, transaction CmplxTx) (interface{}, error)

+ func (db *Client) PerformTransaction(ctx context.Context, transaction Tx) error

+ type CmplxTx func(ctx context.Context, tx *gorm.DB) (interface{}, error)

+ type Option func(*Client)

+ func WithConnectionString(connectionString *string) Option

+ func WithInstrumentationClient(instrumentationClient *instrumentation.Client) Option

+ func WithLogger(logger *zap.Logger) Option

+ func WithMaxConnectionLifetime(maxConnectionLifetime *time.Duration) Option

+ func WithMaxConnectionRetries(retries *int) Option

+ func WithMaxConnectionRetryTimeout(timeout *time.Duration) Option

+ func WithMaxIdleConnections(maxIdleConnections *int) Option

+ func WithMaxOpenConnections(maxOpenConnections *int) Option

+ func WithQueryTimeout(timeout *time.Duration) Option

+ func WithRetrySleep(sleep *time.Duration) Option

+ type TestTxCleanupHandlerForUnitTests struct

+ Tx *gorm.DB

+ type Tx func(ctx context.Context, tx *gorm.DB) error