postgres

Documentation

Index

• func NewConnection(ctx context.Context, cfg config.Postgres) (*pgx.Conn, error)
• type TransactionsRepository
  • func NewTransactionRepository(conn *pgx.Conn) *TransactionsRepository
  • func (r TransactionsRepository) SaveTransaction(ctx context.Context, tx entities.Transaction) (vos.TransactionID, error)

Functions

func NewConnection

func NewConnection(ctx context.Context, cfg config.Postgres) (*pgx.Conn, error)

NewConnection sets up a new connection with migrations

Types

type TransactionsRepository

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

TransactionsRepository is the repository of transactions

func NewTransactionRepository

func NewTransactionRepository(conn *pgx.Conn) *TransactionsRepository

NewTransactionRepository returns a transaction repository

func (TransactionsRepository) SaveTransaction

func (r TransactionsRepository) SaveTransaction(ctx context.Context, tx entities.Transaction) (vos.TransactionID, error)

SaveTransaction saves the transaction on DB, returning its auto generated ID in case of success