database

Documentation

Index

• func NewEmailTemplateRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.EmailTemplateRepository
• func NewOAuthRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.OAuthRepository
• func NewPaymentRepository(q *dbgen.Queries, db repositories.ConnectionPool) repositories.PaymentRepository
• func NewPool(ctx context.Context, connString string) (repositories.ConnectionPool, error)
• func NewSubscriptionRepository(q *dbgen.Queries, db repositories.ConnectionPool) repositories.SubscriptionRepository
• func NewUserRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.UserRepository
• func NewVerificationCodeRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.VerificationCodeRepository
• type Pool
• type TransactionManager
  • func NewTransactionManager(pool repositories.ConnectionPool) *TransactionManager
  • func (tm *TransactionManager) ExecuteInTransaction(ctx context.Context, fn func(tx pgx.Tx) error) error
  • func (tm *TransactionManager) GetTx(ctx context.Context) (pgx.Tx, error)

Functions

func NewEmailTemplateRepository

func NewEmailTemplateRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.EmailTemplateRepository

func NewOAuthRepository

func NewOAuthRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.OAuthRepository

func NewPaymentRepository

func NewPaymentRepository(q *dbgen.Queries, db repositories.ConnectionPool) repositories.PaymentRepository

func NewPool

func NewPool(ctx context.Context, connString string) (repositories.ConnectionPool, error)

func NewSubscriptionRepository

func NewSubscriptionRepository(q *dbgen.Queries, db repositories.ConnectionPool) repositories.SubscriptionRepository

func NewUserRepository

func NewUserRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.UserRepository

func NewVerificationCodeRepository

func NewVerificationCodeRepository(queries *dbgen.Queries, db repositories.ConnectionPool) repositories.VerificationCodeRepository

Types

type Pool

type Pool struct {
	*pgxpool.Pool
}

type TransactionManager

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

TransactionManager handles database transactions

func NewTransactionManager

func NewTransactionManager(pool repositories.ConnectionPool) *TransactionManager

func (*TransactionManager) ExecuteInTransaction

func (tm *TransactionManager) ExecuteInTransaction(ctx context.Context, fn func(tx pgx.Tx) error) error

ExecuteInTransaction executes a function within a transaction

func (*TransactionManager) GetTx

func (tm *TransactionManager) GetTx(ctx context.Context) (pgx.Tx, error)

GetTx returns a transaction that can be passed to repositories