postgres

type Config struct {
	Username string
	Password string
	Host     string
	Port     string
	Database string

	ConnAmount        *int32
	MinConnAmount     *int32
	MaxConnIdleTime   *time.Duration
	MaxConnLifetime   *time.Duration
	HealthCheckPeriod *time.Duration
	AcquireTimeout    time.Duration
	// contains filtered or unexported fields
}

type Handler func(ctx context.Context) error

type Migrator struct {
	// contains filtered or unexported fields
}

type Postgres interface {
	Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) pgx.Row
	Exec(ctx context.Context, query string, args ...interface{}) (commandTag pgconn.CommandTag, err error)

	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (Tx, error)

	Pool() *pgxpool.Pool

	Close()
}

type Tx interface {
	Begin(ctx context.Context) (pgx.Tx, error)

	Commit(ctx context.Context) error

	Rollback(ctx context.Context) error

	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
	SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
	LargeObjects() pgx.LargeObjects

	Prepare(ctx context.Context, name, sql string) (*pgconn.StatementDescription, error)

	Exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row

	Conn() *pgx.Conn
}

type TxManager interface {
	ReadCommitted(ctx context.Context, handler Handler) error
	RepeatableRead(ctx context.Context, retryAmount uint, handler Handler) error
	Serializable(ctx context.Context, retryAmount uint, handler Handler) error
}