database

Documentation

Index

• func PostgresFromEnv() (*sql.DB, error)
• type PostgresRepository
  • func (r *PostgresRepository) ScrapeableProjects(workScore uint32, limit int) ([]*Project, error)
• type Project
• type Scrape
• type User
• type WorkerRepository

Functions

func PostgresFromEnv

func PostgresFromEnv() (*sql.DB, error)

Types

type PostgresRepository

type PostgresRepository struct {
	DB *sql.DB
}

func (*PostgresRepository) ScrapeableProjects

func (r *PostgresRepository) ScrapeableProjects(workScore uint32, limit int) ([]*Project, error)

type Project

type Project struct {
	ID         string
	UserId     string
	ImportPath string
	WorkScore  int32
	Created    time.Time
	Paused     time.Time
}

type Scrape

type Scrape struct {
	ID        string
	Error     string
	WorkScore int32
	Started   time.Time
	Finished  time.Time
}

type User

type User struct {
	ID      string
	Email   string
	Created time.Time
}

type WorkerRepository

type WorkerRepository interface {
	// TODO(adam): docs, but the idea is:
	// - one transaction
	//   - grab N projects from `projects` table (by nonce) without 'started_at is not null and finished_at is null'
	//   - insert new rows into scrapes
	ScrapeableProjects(workScore uint32, limit int) ([]*Project, error)
}