pg_adapter

type ConnectionString interface {
	GetConnectionString() (string, error)
}

type Db struct {
	Connection *sqlx.DB
}

type Queues struct {
	Id              int    `db:"id"`
	Ip              string `db:"ip"`
	ActiveJobsCount int    `db:"active_jobs_count"`

	NotActiveSince pq.NullTime `db:"not_active_since"`
	CreatedAt      time.Time   `db:"created_at"`
	UpdatedAt      time.Time   `db:"updated_at"`
}