postgres

Documentation

Index

• func NewConnection(ctx context.Context, dsn string) (*pgx.Conn, error)
• func NewQueries(conn *pgx.Conn) *db.Queries
• func NewSqlcIdempotencyRepository(queries *db.Queries) repositories.IdempotencyRepository
• func NewSqlcProductRepository(queries *db.Queries) repositories.ProductRepository
• func NewSqlcSellerRepository(queries *db.Queries) repositories.SellerRepository
• type SqlcIdempotencyRepository
  • func (r *SqlcIdempotencyRepository) Create(ctx context.Context, record *entities.IdempotencyRecord) (*entities.IdempotencyRecord, error)
  • func (r *SqlcIdempotencyRepository) FindByKey(ctx context.Context, key string) (*entities.IdempotencyRecord, error)
  • func (r *SqlcIdempotencyRepository) Update(ctx context.Context, record *entities.IdempotencyRecord) (*entities.IdempotencyRecord, error)
• type SqlcProductRepository
  • func (repo *SqlcProductRepository) Create(product *entities.ValidatedProduct) (*entities.Product, error)
  • func (repo *SqlcProductRepository) Delete(id uuid.UUID) error
  • func (repo *SqlcProductRepository) FindAll() ([]*entities.Product, error)
  • func (repo *SqlcProductRepository) FindById(id uuid.UUID) (*entities.Product, error)
  • func (repo *SqlcProductRepository) Update(product *entities.ValidatedProduct) (*entities.Product, error)
• type SqlcSellerRepository
  • func (repo *SqlcSellerRepository) Create(seller *entities.ValidatedSeller) (*entities.Seller, error)
  • func (repo *SqlcSellerRepository) Delete(id uuid.UUID) error
  • func (repo *SqlcSellerRepository) FindAll() ([]*entities.Seller, error)
  • func (repo *SqlcSellerRepository) FindById(id uuid.UUID) (*entities.Seller, error)
  • func (repo *SqlcSellerRepository) Update(seller *entities.ValidatedSeller) (*entities.Seller, error)

Functions

func NewConnection

func NewConnection(ctx context.Context, dsn string) (*pgx.Conn, error)

func NewQueries

func NewQueries(conn *pgx.Conn) *db.Queries

func NewSqlcIdempotencyRepository

func NewSqlcIdempotencyRepository(queries *db.Queries) repositories.IdempotencyRepository

func NewSqlcProductRepository

func NewSqlcProductRepository(queries *db.Queries) repositories.ProductRepository

func NewSqlcSellerRepository

func NewSqlcSellerRepository(queries *db.Queries) repositories.SellerRepository

Types

type SqlcIdempotencyRepository

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

func (*SqlcIdempotencyRepository) Create

func (r *SqlcIdempotencyRepository) Create(ctx context.Context, record *entities.IdempotencyRecord) (*entities.IdempotencyRecord, error)

func (*SqlcIdempotencyRepository) FindByKey

func (r *SqlcIdempotencyRepository) FindByKey(ctx context.Context, key string) (*entities.IdempotencyRecord, error)

func (*SqlcIdempotencyRepository) Update

func (r *SqlcIdempotencyRepository) Update(ctx context.Context, record *entities.IdempotencyRecord) (*entities.IdempotencyRecord, error)

type SqlcProductRepository

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

func (*SqlcProductRepository) Create

func (repo *SqlcProductRepository) Create(product *entities.ValidatedProduct) (*entities.Product, error)

func (*SqlcProductRepository) Delete

func (repo *SqlcProductRepository) Delete(id uuid.UUID) error

func (*SqlcProductRepository) FindAll

func (repo *SqlcProductRepository) FindAll() ([]*entities.Product, error)

func (*SqlcProductRepository) FindById

func (repo *SqlcProductRepository) FindById(id uuid.UUID) (*entities.Product, error)

func (*SqlcProductRepository) Update

func (repo *SqlcProductRepository) Update(product *entities.ValidatedProduct) (*entities.Product, error)

type SqlcSellerRepository

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

func (*SqlcSellerRepository) Create

func (repo *SqlcSellerRepository) Create(seller *entities.ValidatedSeller) (*entities.Seller, error)

func (*SqlcSellerRepository) Delete

func (repo *SqlcSellerRepository) Delete(id uuid.UUID) error

func (*SqlcSellerRepository) FindAll

func (repo *SqlcSellerRepository) FindAll() ([]*entities.Seller, error)

func (*SqlcSellerRepository) FindById

func (repo *SqlcSellerRepository) FindById(id uuid.UUID) (*entities.Seller, error)

func (*SqlcSellerRepository) Update

func (repo *SqlcSellerRepository) Update(seller *entities.ValidatedSeller) (*entities.Seller, error)