repository

Documentation

Index

• type PGRepository
  • func NewPGRepository(cfg *PGRepositoryConfig) (*PGRepository, error)
  • func (repo *PGRepository) Delete(ctx context.Context, f *model.ProfessionFilter) ([]*model.Profession, error)
  • func (repo *PGRepository) Fetch(ctx context.Context, cfg *profession.FetchConfig) ([]*model.Profession, int, error)
  • func (repo *PGRepository) GetAssociatedQualifications(ctx context.Context, ids ...int) (map[int][]*model.Qualification, error)
  • func (repo *PGRepository) Store(ctx context.Context, input *model.ProfessionInput) (*model.Profession, error)
  • func (repo *PGRepository) UpdateMany(ctx context.Context, f *model.ProfessionFilter, input *model.ProfessionInput) ([]*model.Profession, error)
• type PGRepositoryConfig

Types

type PGRepository

type PGRepository struct {
	*pg.DB
}

func NewPGRepository

func NewPGRepository(cfg *PGRepositoryConfig) (*PGRepository, error)

func (*PGRepository) Delete

func (repo *PGRepository) Delete(ctx context.Context, f *model.ProfessionFilter) ([]*model.Profession, error)

func (*PGRepository) Fetch

func (repo *PGRepository) Fetch(ctx context.Context, cfg *profession.FetchConfig) ([]*model.Profession, int, error)

func (*PGRepository) GetAssociatedQualifications

func (repo *PGRepository) GetAssociatedQualifications(
	ctx context.Context,
	ids ...int,
) (map[int][]*model.Qualification, error)

func (*PGRepository) Store

func (repo *PGRepository) Store(ctx context.Context, input *model.ProfessionInput) (*model.Profession, error)

func (*PGRepository) UpdateMany

func (repo *PGRepository) UpdateMany(ctx context.Context, f *model.ProfessionFilter, input *model.ProfessionInput) ([]*model.Profession, error)

type PGRepositoryConfig

type PGRepositoryConfig struct {
	DB *pg.DB
}