implementations

Documentation

Index

• type SubmissionsRabbitMQQueueManager
  • func GetSubmissionsRabbitMQQueueManagerInstance() *SubmissionsRabbitMQQueueManager
  • func (queueManager *SubmissionsRabbitMQQueueManager) QueueWork(work *entities.SubmissionWork) (err error)
• type SubmissionsRealTimeUpdatesQueueMgr
  • func GetSubmissionsRealTimeUpdatesQueueMgrInstance() *SubmissionsRealTimeUpdatesQueueMgr
  • func (queueMgr *SubmissionsRealTimeUpdatesQueueMgr) ListenForUpdates()
• type SubmissionsRealTimeUpdatesSender
  • func GetSubmissionsRealTimeUpdatesSenderInstance() *SubmissionsRealTimeUpdatesSender
  • func (sender *SubmissionsRealTimeUpdatesSender) CreateChannel(submissionUUID string) *UpdatesChannel
  • func (sender *SubmissionsRealTimeUpdatesSender) DeleteChannel(submissionUUID string)
  • func (sender *SubmissionsRealTimeUpdatesSender) Listen()
  • func (sender *SubmissionsRealTimeUpdatesSender) SendUpdate(update *dtos.SubmissionStatusUpdateDTO)
• type SubmissionsRepositoryImpl
  • func GetSubmissionsRepositoryInstance() *SubmissionsRepositoryImpl
  • func (repository *SubmissionsRepositoryImpl) DoesStudentOwnSubmission(studentUUID string, submissionUUID string) (bool, error)
  • func (repository *SubmissionsRepositoryImpl) GetStudentSubmission(studentUUID string, testBlockUUID string) (submission *entities.Submission, err error)
  • func (repository *SubmissionsRepositoryImpl) GetStudentSubmissionArchiveUUIDFromSubmissionUUID(submissionUUID string) (archiveUUID string, err error)
  • func (repository *SubmissionsRepositoryImpl) GetSubmissionWorkMetadata(submissionUUID string) (submissionWorkMetadata *entities.SubmissionWork, err error)
  • func (repository *SubmissionsRepositoryImpl) GetTeacherOfCourseBySubmissionUUID(submissionUUID string) (teacherUUID string, err error)
  • func (repository *SubmissionsRepositoryImpl) ResetSubmissionStatus(submissionUUID string) (err error)
  • func (repository *SubmissionsRepositoryImpl) SaveSubmission(dto *dtos.CreateSubmissionDTO) (submissionUUID string, err error)
• type UpdatesChannel

Types

type SubmissionsRabbitMQQueueManager

type SubmissionsRabbitMQQueueManager struct {
	SubmissionsQueue *amqp.Queue
}

func GetSubmissionsRabbitMQQueueManagerInstance

func GetSubmissionsRabbitMQQueueManagerInstance() *SubmissionsRabbitMQQueueManager

func (*SubmissionsRabbitMQQueueManager) QueueWork

func (queueManager *SubmissionsRabbitMQQueueManager) QueueWork(work *entities.SubmissionWork) (err error)

Methods implementation

type SubmissionsRealTimeUpdatesQueueMgr

type SubmissionsRealTimeUpdatesQueueMgr struct {
	Queue   *amqp.Queue
	Channel <-chan amqp.Delivery
}

func GetSubmissionsRealTimeUpdatesQueueMgrInstance

func GetSubmissionsRealTimeUpdatesQueueMgrInstance() *SubmissionsRealTimeUpdatesQueueMgr

func (*SubmissionsRealTimeUpdatesQueueMgr) ListenForUpdates

func (queueMgr *SubmissionsRealTimeUpdatesQueueMgr) ListenForUpdates()

ListenForUpdates listens for updates in the submission real time updates queue

type SubmissionsRealTimeUpdatesSender

type SubmissionsRealTimeUpdatesSender struct {
	// New updates are pushed to this channel
	Updates UpdatesChannel

	// All the open connections
	OpenConnections map[string]UpdatesChannel
}

func GetSubmissionsRealTimeUpdatesSenderInstance

func GetSubmissionsRealTimeUpdatesSenderInstance() *SubmissionsRealTimeUpdatesSender

func (*SubmissionsRealTimeUpdatesSender) CreateChannel

func (sender *SubmissionsRealTimeUpdatesSender) CreateChannel(submissionUUID string) *UpdatesChannel

Create a channel for a submission

func (*SubmissionsRealTimeUpdatesSender) DeleteChannel

func (sender *SubmissionsRealTimeUpdatesSender) DeleteChannel(submissionUUID string)

Delete a channel for a submission

func (*SubmissionsRealTimeUpdatesSender) Listen

func (sender *SubmissionsRealTimeUpdatesSender) Listen()

listen listens for new updates and new connections

func (*SubmissionsRealTimeUpdatesSender) SendUpdate

func (sender *SubmissionsRealTimeUpdatesSender) SendUpdate(update *dtos.SubmissionStatusUpdateDTO)

SendUpdate sends an update to the updates channel

type SubmissionsRepositoryImpl

type SubmissionsRepositoryImpl struct {
	Connection *sql.DB
}

func GetSubmissionsRepositoryInstance

func GetSubmissionsRepositoryInstance() *SubmissionsRepositoryImpl

func (*SubmissionsRepositoryImpl) DoesStudentOwnSubmission

func (repository *SubmissionsRepositoryImpl) DoesStudentOwnSubmission(studentUUID string, submissionUUID string) (bool, error)

DoesStudentOwnSubmission returns true if the student owns the submission

func (*SubmissionsRepositoryImpl) GetStudentSubmission

func (repository *SubmissionsRepositoryImpl) GetStudentSubmission(studentUUID string, testBlockUUID string) (submission *entities.Submission, err error)

func (*SubmissionsRepositoryImpl) GetStudentSubmissionArchiveUUIDFromSubmissionUUID

func (repository *SubmissionsRepositoryImpl) GetStudentSubmissionArchiveUUIDFromSubmissionUUID(submissionUUID string) (archiveUUID string, err error)

func (*SubmissionsRepositoryImpl) GetSubmissionWorkMetadata

func (repository *SubmissionsRepositoryImpl) GetSubmissionWorkMetadata(submissionUUID string) (submissionWorkMetadata *entities.SubmissionWork, err error)

func (*SubmissionsRepositoryImpl) GetTeacherOfCourseBySubmissionUUID

func (repository *SubmissionsRepositoryImpl) GetTeacherOfCourseBySubmissionUUID(submissionUUID string) (teacherUUID string, err error)

GetTeacherOfCourseBySubmissionUUID returns the teacher of the course that the submission belongs to

func (*SubmissionsRepositoryImpl) ResetSubmissionStatus

func (repository *SubmissionsRepositoryImpl) ResetSubmissionStatus(submissionUUID string) (err error)

func (*SubmissionsRepositoryImpl) SaveSubmission

func (repository *SubmissionsRepositoryImpl) SaveSubmission(dto *dtos.CreateSubmissionDTO) (submissionUUID string, err error)

type UpdatesChannel

type UpdatesChannel chan *dtos.SubmissionStatusUpdateDTO