transferspg

Documentation

Index

• Variables
• type Repository
  • func NewRepository(pool *pgxpool.Pool) *Repository
  • func (r Repository) Create(ctx context.Context, transferInstance transfer.Transfer) (transfer.Transfer, error)
  • func (r Repository) Fetch(ctx context.Context) ([]transfer.Transfer, error)

Variables

var (
	ErrCreateTransfer = errors.New("failed to create transfer in db")
	ErrFetch          = errors.New("failed to fetch transfers from db")

	ErrScanningRows = errors.New("failed to scan rows returned from query")
)

Types

type Repository

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

func NewRepository

func NewRepository(pool *pgxpool.Pool) *Repository

func (Repository) Create

func (r Repository) Create(ctx context.Context, transferInstance transfer.Transfer) (transfer.Transfer, error)

func (Repository) Fetch

func (r Repository) Fetch(ctx context.Context) ([]transfer.Transfer, error)