jobs

type Contributor ¶

type Contributor struct {
	C      *github.Contributor
	RepoID int
	Score  int
}

type GitOrg ¶

type GitOrg struct {
	Name string
}

type JobFunc ¶

type JobFunc func(qc *que.Client, logger *log.Logger, job *que.Job, tx *pgx.Tx) error

JobFunc should do a thing. Return either: nil => wrapper will schedule the next cron (if a cron), then commit the tx. ErrImmediateReschedule => wrapper will commit the tx, then try it again immediately. ErrDidNotReschedule => wrapper will rollback the tx, and if a cron, will not reschedule or retry. any other error => wrapper rollback the tx, and allow que to reschedule

type JobFuncWrapper ¶

type JobFuncWrapper struct {
	QC        *que.Client
	Logger    *log.Logger
	F         JobFunc
	Singleton bool
	Duration  time.Duration
}

func (scw *JobFuncWrapper) Run(job *que.Job) error

type Repository ¶

type Repository struct {
	R        *github.Repository
	OrgID    int
	ParentID int
	Score    int
}