database

Aug 12, 2018

Changes in this version

type Database

+ func (db *Database) CreateArchiveBackport(userID uint, packageCount int) (*models.ArchiveBackport, error)

+ func (db *Database) GetAllArchiveBackports() ([]*models.ArchiveBackport, error)

+ func (db *Database) GetAllArchiveBackportsByUserID(userID uint) ([]*models.ArchiveBackport, error)

+ func (db *Database) GetAllArchiveBackportsPageLimit(page, limit int) ([]*models.ArchiveBackport, error)

+ func (db *Database) GetAllJobsByArchiveBackportID(id uint) ([]*models.Job, error)

+ func (db *Database) GetAllJobsByArchiveBackportIDPageLimit(id uint, page, limit int) ([]*models.Job, error)

+ func (db *Database) GetArchiveBackport(id uint) (*models.ArchiveBackport, error)

Jun 29, 2018

Changes in this version

type Database

+ func (db *Database) GetUserByAuthBackendUserID(id uint) (*models.User, error)

Jun 19, 2018

Changes in this version

type Database

+ func (db *Database) GetAllArchiveUpgradesPageLimit(page, limit int) ([]*models.ArchiveUpgrade, error)

+ func (db *Database) GetAllJobsByArchiveUpgradeIDPageLimit(id uint, page, limit int) ([]*models.Job, error)

+ func (db *Database) GetAllJobsByParentAndStatuses(parentType models.JobParentType, parentID uint, statuses ...models.JobStatus) ([]*models.Job, error)

+ func (db *Database) GetAllJobsPageLimit(page, limit int) ([]*models.Job, error)

+ func (db *Database) GetAllUploadsByUserIDPageLimit(userID uint, page, limit int) ([]*models.Upload, error)

+ func (db *Database) GetAllUploadsPageLimit(page, limit int) ([]*models.Upload, error)

Jun 16, 2018

Changes in this version

type Database

+ func (db *Database) CreateArchiveUpgrade(userID uint, packageCount uint) (*models.ArchiveUpgrade, error)

+ func (db *Database) GetAllArchiveUpgrades() ([]*models.ArchiveUpgrade, error)

+ func (db *Database) GetAllArchiveUpgradesByUserID(userID uint) ([]*models.ArchiveUpgrade, error)

+ func (db *Database) GetAllJobsByArchiveUpgradeID(id uint) ([]*models.Job, error)

+ func (db *Database) GetArchiveUpgrade(id uint) (*models.ArchiveUpgrade, error)

Jun 11, 2018

Changes in this version

type Database

+ func (db *Database) ChangeJobStatus(jobID uint, newStatus models.JobStatus) error

+ func (db *Database) CreateArtifact(jobID uint, filename string) (*models.Artifact, error)

+ func (db *Database) GetAllArtifactsByJobID(jobID uint) ([]*models.Artifact, error)

+ func (db *Database) GetAllArtifactsByJobIDFilename(jobID uint, filename string) ([]*models.Artifact, error)

+ func (db *Database) GetAllJobsByUploadIDStatuses(uploadID uint, statuses ...models.JobStatus) ([]*models.Job, error)

+ func (db *Database) GetArtifact(id uint) (*models.Artifact, error)

Jun 2, 2018

Changes in this version

type Database

+ func (db *Database) CreateAccessToken(userID uint, name, token string) (*models.AccessToken, error)

+ func (db *Database) CreateJobArtifact(jobID uint, filename string) (*models.JobArtifact, error)

+ func (db *Database) CreatePGPKey(userID uint, fingerprint, publicKey string) (*models.PGPKey, error)

+ func (db *Database) CreateUser(id uint, username string) (*models.User, error)

+ func (db *Database) GetAllAccessTokensByToken(token string) ([]*models.AccessToken, error)

+ func (db *Database) GetAllAccessTokensByUserID(userID uint) ([]*models.AccessToken, error)

+ func (db *Database) GetAllJobArtifactsByJobID(jobID uint) ([]*models.JobArtifact, error)

+ func (db *Database) GetAllJobsByUploadID(uploadID uint) ([]*models.Job, error)

+ func (db *Database) GetAllPGPKeys() ([]*models.PGPKey, error)

+ func (db *Database) GetAllPGPKeysByFingerprint(fingerprint string) ([]*models.PGPKey, error)

+ func (db *Database) GetAllPGPKeysByUserID(userID uint) ([]*models.PGPKey, error)

+ func (db *Database) GetAllUploadsByUserID(userID uint) ([]*models.Upload, error)

+ func (db *Database) GetUser(id uint) (*models.User, error)

+ func (db *Database) RemoveAccessToken(id, userID uint) error

+ func (db *Database) RemovePGPKey(id, userID uint) error

May 15, 2018

Changes in this version

type Database

+ func (db *Database) CreateFileUpload(filename, sha256Sum string, uploadedAt time.Time) (*models.FileUpload, error)

+ func (db *Database) GetAllFileUploadsByUploadID(uploadID uint) ([]*models.FileUpload, error)

+ func (db *Database) GetFileUpload(id uint) (*models.FileUpload, error)

+ func (db *Database) GetFileUploadByFileNameSHASumCompleted(filename, sha256Sum string, completed bool) (*models.FileUpload, error)

+ func (db *Database) GetJob(id uint) (*models.Job, error)

+ func (db *Database) GetNextJob() (*models.Job, error)

+ func (db *Database) GetUpload(id uint) (*models.Upload, error)

+ func (db *Database) UpdateFileUpload(fileUpload *models.FileUpload) error

+ func (db *Database) UpdateJob(job *models.Job) error

May 8, 2018

Changes in this version

+ type Database struct

+ func NewDatabase(driver, connectionString string) (*Database, error)

+ func (db *Database) CreateJob(jobType models.JobType, uploadID uint) (*models.Job, error)

+ func (db *Database) CreatePendingFileUpload(filename, sha256Sum string, uploadedAt time.Time) (*models.PendingFileUpload, error)

+ func (db *Database) CreateUpload(source, version, maintainer, changedBy string) (*models.Upload, error)

+ func (db *Database) GetAllJobs() ([]*models.Job, error)

+ func (db *Database) GetAllUploads() ([]*models.Upload, error)

+ func (db *Database) GetPendingFileUpload(filename, sha256Sum string, completed bool) (*models.PendingFileUpload, error)

+ func (db *Database) UpdatePendingFileUpload(fileUpload *models.PendingFileUpload) error