database

package

v0.2.2 Latest Latest Go to latest Published: May 8, 2018 License: MIT Imports: 4 Imported by: 0

Details

Package database is responsible for all database logic. It handles connecting to the database and performing queries.

This section is empty.

This section is empty.

This section is empty.

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

Database is an implementation of the app.Datastore interface

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

NewDatabase creates a new database connection

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

CreateJob will create a job

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

CreatePendingFileUpload will create a pending file upload

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

CreateUpload will create an upload

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

GetAllJobs returns all jobs

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

GetAllUploads returns all uploads

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

GetPendingFileUpload will return the first pending file upload that matches

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

UpdatePendingFileUpload will a file upload