implementations

Documentation

Index

• type SubmissionsPgRepository
  • func GetSubmissionsPgRepository() *SubmissionsPgRepository
  • func (repo *SubmissionsPgRepository) UpdateSubmissionStatus(dto *dtos.SubmissionStatusUpdateDTO) error
• type SubmissionsRealTimeUpdatesRabbitmqMgr
  • func GetSubmissionsRealTimeUpdatesQueueMgrInstance() *SubmissionsRealTimeUpdatesRabbitmqMgr
  • func (queueMgr *SubmissionsRealTimeUpdatesRabbitmqMgr) SendUpdate(updateDTO *dtos.SubmissionStatusUpdateDTO) error

Types

type SubmissionsPgRepository

type SubmissionsPgRepository struct {
	Connection *sql.DB
}

func GetSubmissionsPgRepository

func GetSubmissionsPgRepository() *SubmissionsPgRepository

GetSubmissionsPgRepository returns a singleton of SubmissionsPgRepository

func (*SubmissionsPgRepository) UpdateSubmissionStatus

func (repo *SubmissionsPgRepository) UpdateSubmissionStatus(dto *dtos.SubmissionStatusUpdateDTO) error

UpdateSubmissionStatus updates the status of a submission

type SubmissionsRealTimeUpdatesRabbitmqMgr

type SubmissionsRealTimeUpdatesRabbitmqMgr struct{}

func GetSubmissionsRealTimeUpdatesQueueMgrInstance

func GetSubmissionsRealTimeUpdatesQueueMgrInstance() *SubmissionsRealTimeUpdatesRabbitmqMgr

GetSubmissionsRealTimeUpdatesQueueMgrInstance returns the singleton instance of the submissionsRealTimeUpdatesQueueMgr

func (*SubmissionsRealTimeUpdatesRabbitmqMgr) SendUpdate

func (queueMgr *SubmissionsRealTimeUpdatesRabbitmqMgr) SendUpdate(updateDTO *dtos.SubmissionStatusUpdateDTO) error

SendUpdate enqueues a submission status update