db

Documentation

Index

• type DB
  • func NewDB(d *sql.DB) *DB
  • func (db *DB) CreateJob(job *types.Job) error
  • func (db *DB) GetJobs() ([]*types.Job, error)
  • func (db *DB) GetPendingJobs() ([]*types.Job, error)
  • func (db *DB) Ping() error
  • func (db *DB) UpdateJob(job *types.Job) error

Types

type DB

type DB struct {
	DB *sqlx.DB
}

func NewDB

func NewDB(d *sql.DB) *DB

func (*DB) CreateJob

func (db *DB) CreateJob(job *types.Job) error

CreateJob is a tiny method to make sure the db is alive

func (*DB) GetJobs

func (db *DB) GetJobs() ([]*types.Job, error)

func (*DB) GetPendingJobs

func (db *DB) GetPendingJobs() ([]*types.Job, error)

GetPendingJobs gets jobs where try > -1 and try < 4 and sent is false

func (*DB) Ping

func (db *DB) Ping() error

Ping is a tiny method to make sure the db is alive

func (*DB) UpdateJob

func (db *DB) UpdateJob(job *types.Job) error