postgres

package

v0.4.0 Latest Latest Go to latest Published: Jul 5, 2026 License: MIT Imports: 23 Imported by: 0

Details

This section is empty.

This section is empty.

func NewPoolConfig(cfg config.Database) (*pgxpool.Config, error)

func NewUserRepository(db *TxManager) ports.UserRepository

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

func NewCardBrandRepository(db *TxManager) *CardBrandRepository

func (r *CardBrandRepository) CreateCardBrand(
	ctx context.Context,
	name string,
) (*entity.CardBrand, error)

func (r *CardBrandRepository) DeleteCardBrand(
	ctx context.Context,
	id uuid.UUID,
) (*entity.CardBrand, error)

func (r *CardBrandRepository) GetCardBrandByID(
	ctx context.Context,
	id uuid.UUID,
) (*entity.CardBrand, error)

func (r *CardBrandRepository) ListCardBrands(
	ctx context.Context,
	opts ports.ListCardBrandFilterOptions,
) ([]entity.CardBrand, error)

func (r *CardBrandRepository) UpdateCardBrand(
	ctx context.Context,
	opts ports.UpdateCardBrandOptions,
) (*entity.CardBrand, error)

type TxManager struct {
	ConnPool *pgxpool.Pool
}

func (b TxManager) Close()

func (b TxManager) Exec(
	ctx context.Context,
	query string,
	args ...any,
) (pgconn.CommandTag, error)

func (b TxManager) Query(
	ctx context.Context,
	query string,
	args ...any,
) (pgx.Rows, error)

func (b TxManager) QueryRow(ctx context.Context, query string, args ...any) pgx.Row

func (b TxManager) SendBatch(ctx context.Context, batch *pgx.Batch) pgx.BatchResults

func (b TxManager) WithTx(ctx context.Context, f domain.TransactionFunc) error

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

func (r *UserRepository) Create(ctx context.Context, logtoUserID string) (*entity.User, error)

func (r *UserRepository) ExistsByLogtoUserID(ctx context.Context, logtoUserID string) (bool, error)

func (r *UserRepository) GetByID(ctx context.Context, id uuid.UUID) (*entity.User, error)

func (r *UserRepository) GetByLogtoUserID(ctx context.Context, logtoUserID string) (*entity.User, error)