postgres

Documentation

Index

• type PgxRepository
  • func NewPgxRepositoryWithPool(pool *pgxv5Pool.Pool) *PgxRepository
  • func (r *PgxRepository) CreateCCLFFile(ctx context.Context, cclfFile models.CCLFFile) (uint, error)
  • func (r *PgxRepository) CreateCCLFFileTx(ctx context.Context, tx pgxv5.Tx, cclfFile models.CCLFFile) (uint, error)
  • func (r *PgxRepository) GetCCLFFileExistsByName(ctx context.Context, name string) (bool, error)
  • func (r *PgxRepository) GetCCLFFileExistsByNameTx(ctx context.Context, tx pgxv5.Tx, name string) (bool, error)
  • func (r *PgxRepository) UpdateCCLFFileImportStatus(ctx context.Context, fileID uint, importStatus string) error
  • func (r *PgxRepository) UpdateCCLFFileImportStatusTx(ctx context.Context, tx pgxv5.Tx, fileID uint, importStatus string) error
• type Repository
  • func NewRepository(db *sql.DB) *Repository
  • func NewRepositoryTx(tx *sql.Tx) *Repository
  • func (r *Repository) CreateACO(ctx context.Context, aco models.ACO) error
  • func (r *Repository) CreateCCLFFile(ctx context.Context, cclfFile models.CCLFFile) (uint, error)
  • func (r *Repository) CreateJob(ctx context.Context, j models.Job) (uint, error)
  • func (r *Repository) CreateSuppression(ctx context.Context, suppression optout.OptOutRecord) error
  • func (r *Repository) CreateSuppressionFile(ctx context.Context, suppressionFile optout.OptOutFile) (uint, error)
  • func (r *Repository) GetACOByCMSID(ctx context.Context, cmsID string) (*models.ACO, error)
  • func (r *Repository) GetACOByClientID(ctx context.Context, clientID string) (*models.ACO, error)
  • func (r *Repository) GetACOByUUID(ctx context.Context, uuid uuid.UUID) (*models.ACO, error)
  • func (r *Repository) GetCCLFBeneficiaries(ctx context.Context, cclfFileID uint, ignoredMBIs []string) ([]*models.CCLFBeneficiary, error)
  • func (r *Repository) GetCCLFBeneficiaryMBIs(ctx context.Context, cclfFileID uint) ([]string, error)
  • func (r *Repository) GetCCLFFileByID(ctx context.Context, ID uint) (*models.CCLFFile, error)
  • func (r *Repository) GetCCLFFileExistsByName(ctx context.Context, name string) (bool, error)
  • func (r *Repository) GetJobByID(ctx context.Context, jobID uint) (*models.Job, error)
  • func (r *Repository) GetJobKey(ctx context.Context, jobID uint, fileName string) (*models.JobKey, error)
  • func (r *Repository) GetJobKeys(ctx context.Context, jobID uint) ([]*models.JobKey, error)
  • func (r *Repository) GetJobs(ctx context.Context, acoID uuid.UUID, statuses ...models.JobStatus) ([]*models.Job, error)
  • func (r *Repository) GetJobsByUpdateTimeAndStatus(ctx context.Context, lowerBound, upperBound time.Time, ...) ([]*models.Job, error)
  • func (r *Repository) GetLatestCCLFFile(ctx context.Context, cmsID string, cclfNum int, importStatus string, ...) (*models.CCLFFile, error)
  • func (r *Repository) GetSuppressedMBIs(ctx context.Context, lookbackDays int, upperBound time.Time) ([]string, error)
  • func (r *Repository) UpdateACO(ctx context.Context, acoUUID uuid.UUID, fieldsAndValues map[string]interface{}) error
  • func (r *Repository) UpdateCCLFFileImportStatus(ctx context.Context, fileID uint, importStatus string) error
  • func (r *Repository) UpdateJob(ctx context.Context, j models.Job) error
  • func (r *Repository) UpdateSuppressionFileImportStatus(ctx context.Context, fileID uint, importStatus string) error

Types

type PgxRepository

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

PgxRepository provides repository methods that work with pgx transactions

func NewPgxRepositoryWithPool

func NewPgxRepositoryWithPool(pool *pgxv5Pool.Pool) *PgxRepository

NewPgxRepositoryWithPool creates a new pgx repository instance with a connection pool

func (*PgxRepository) CreateCCLFFile

func (r *PgxRepository) CreateCCLFFile(ctx context.Context, cclfFile models.CCLFFile) (uint, error)

CreateCCLFFile creates a CCLF file record using the repository's pool

func (*PgxRepository) CreateCCLFFileTx

func (r *PgxRepository) CreateCCLFFileTx(ctx context.Context, tx pgxv5.Tx, cclfFile models.CCLFFile) (uint, error)

CreateCCLFFileTx creates a CCLF file record using pgx transaction

func (*PgxRepository) GetCCLFFileExistsByName

func (r *PgxRepository) GetCCLFFileExistsByName(ctx context.Context, name string) (bool, error)

GetCCLFFileExistsByName checks if a CCLF file exists by name using the repository's pool

func (*PgxRepository) GetCCLFFileExistsByNameTx

func (r *PgxRepository) GetCCLFFileExistsByNameTx(ctx context.Context, tx pgxv5.Tx, name string) (bool, error)

GetCCLFFileExistsByNameTx checks if a CCLF file exists by name using pgx transaction

func (*PgxRepository) UpdateCCLFFileImportStatus

func (r *PgxRepository) UpdateCCLFFileImportStatus(ctx context.Context, fileID uint, importStatus string) error

UpdateCCLFFileImportStatus updates the import status of a CCLF file using the repository's pool

func (*PgxRepository) UpdateCCLFFileImportStatusTx

func (r *PgxRepository) UpdateCCLFFileImportStatusTx(ctx context.Context, tx pgxv5.Tx, fileID uint, importStatus string) error

UpdateCCLFFileImportStatusTx updates the import status of a CCLF file using pgx transaction

type Repository

type Repository struct {
	database.Queryable
	database.Executable
}

func NewRepository

func NewRepository(db *sql.DB) *Repository

func NewRepositoryTx

func NewRepositoryTx(tx *sql.Tx) *Repository

func (*Repository) CreateACO

func (r *Repository) CreateACO(ctx context.Context, aco models.ACO) error

func (*Repository) CreateCCLFFile

func (r *Repository) CreateCCLFFile(ctx context.Context, cclfFile models.CCLFFile) (uint, error)

func (*Repository) CreateJob

func (r *Repository) CreateJob(ctx context.Context, j models.Job) (uint, error)

func (*Repository) CreateSuppression

func (r *Repository) CreateSuppression(ctx context.Context, suppression optout.OptOutRecord) error

func (*Repository) CreateSuppressionFile

func (r *Repository) CreateSuppressionFile(ctx context.Context, suppressionFile optout.OptOutFile) (uint, error)

func (*Repository) GetACOByCMSID

func (r *Repository) GetACOByCMSID(ctx context.Context, cmsID string) (*models.ACO, error)

func (*Repository) GetACOByClientID

func (r *Repository) GetACOByClientID(ctx context.Context, clientID string) (*models.ACO, error)

func (*Repository) GetACOByUUID

func (r *Repository) GetACOByUUID(ctx context.Context, uuid uuid.UUID) (*models.ACO, error)

func (*Repository) GetCCLFBeneficiaries

func (r *Repository) GetCCLFBeneficiaries(ctx context.Context, cclfFileID uint, ignoredMBIs []string) ([]*models.CCLFBeneficiary, error)

func (*Repository) GetCCLFBeneficiaryMBIs

func (r *Repository) GetCCLFBeneficiaryMBIs(ctx context.Context, cclfFileID uint) ([]string, error)

func (*Repository) GetCCLFFileByID

func (r *Repository) GetCCLFFileByID(ctx context.Context, ID uint) (*models.CCLFFile, error)

func (*Repository) GetCCLFFileExistsByName

func (r *Repository) GetCCLFFileExistsByName(ctx context.Context, name string) (bool, error)

func (*Repository) GetJobByID

func (r *Repository) GetJobByID(ctx context.Context, jobID uint) (*models.Job, error)

func (*Repository) GetJobKey

func (r *Repository) GetJobKey(ctx context.Context, jobID uint, fileName string) (*models.JobKey, error)

func (*Repository) GetJobKeys

func (r *Repository) GetJobKeys(ctx context.Context, jobID uint) ([]*models.JobKey, error)

func (*Repository) GetJobs

func (r *Repository) GetJobs(ctx context.Context, acoID uuid.UUID, statuses ...models.JobStatus) ([]*models.Job, error)

func (*Repository) GetJobsByUpdateTimeAndStatus

func (r *Repository) GetJobsByUpdateTimeAndStatus(ctx context.Context, lowerBound, upperBound time.Time, statuses ...models.JobStatus) ([]*models.Job, error)

func (*Repository) GetLatestCCLFFile

func (r *Repository) GetLatestCCLFFile(ctx context.Context, cmsID string, cclfNum int, importStatus string, lowerBound time.Time, upperBound time.Time, fileType models.CCLFFileType) (*models.CCLFFile, error)

func (*Repository) GetSuppressedMBIs

func (r *Repository) GetSuppressedMBIs(ctx context.Context, lookbackDays int, upperBound time.Time) ([]string, error)

func (*Repository) UpdateACO

func (r *Repository) UpdateACO(ctx context.Context, acoUUID uuid.UUID, fieldsAndValues map[string]interface{}) error

func (*Repository) UpdateCCLFFileImportStatus

func (r *Repository) UpdateCCLFFileImportStatus(ctx context.Context, fileID uint, importStatus string) error

func (*Repository) UpdateJob

func (r *Repository) UpdateJob(ctx context.Context, j models.Job) error

func (*Repository) UpdateSuppressionFileImportStatus

func (r *Repository) UpdateSuppressionFileImportStatus(ctx context.Context, fileID uint, importStatus string) error