Documentation ¶
Index ¶
- type JobRepositoryDb
- func (jrd JobRepositoryDb) DeleteAllJobs() api_error.ApiErr
- func (jrd JobRepositoryDb) DeleteById(id string) api_error.ApiErr
- func (jrd JobRepositoryDb) Dequeue(jobType string) (*domain.Job, api_error.ApiErr)
- func (jrd JobRepositoryDb) FindAll(safReq dto.SortAndFilterRequest) (*[]domain.Job, int, api_error.ApiErr)
- func (jrd JobRepositoryDb) FindById(id string) (*domain.Job, api_error.ApiErr)
- func (jrd JobRepositoryDb) SetHistoryById(id string, message string) api_error.ApiErr
- func (jrd JobRepositoryDb) SetStatusById(id string, newStatus string, message string) api_error.ApiErr
- func (jrd JobRepositoryDb) Store(job domain.Job) api_error.ApiErr
- func (jrd JobRepositoryDb) Update(id string, jobReq dto.CreateUpdateJobRequest) (*domain.Job, api_error.ApiErr)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobRepositoryDb ¶
type JobRepositoryDb struct {
// contains filtered or unexported fields
}
func NewJobRepositoryDb ¶
func NewJobRepositoryDb(c *config.AppConfig) JobRepositoryDb
func (JobRepositoryDb) DeleteAllJobs ¶
func (jrd JobRepositoryDb) DeleteAllJobs() api_error.ApiErr
func (JobRepositoryDb) DeleteById ¶
func (jrd JobRepositoryDb) DeleteById(id string) api_error.ApiErr
func (JobRepositoryDb) FindAll ¶
func (jrd JobRepositoryDb) FindAll(safReq dto.SortAndFilterRequest) (*[]domain.Job, int, api_error.ApiErr)
func (JobRepositoryDb) SetHistoryById ¶
func (jrd JobRepositoryDb) SetHistoryById(id string, message string) api_error.ApiErr
func (JobRepositoryDb) SetStatusById ¶
func (JobRepositoryDb) Update ¶
func (jrd JobRepositoryDb) Update(id string, jobReq dto.CreateUpdateJobRequest) (*domain.Job, api_error.ApiErr)
Click to show internal directories.
Click to hide internal directories.