Versions in this module Expand all Collapse all v0 v0.1.0 Jan 4, 2020 Changes in this version + var Kv *cache.Cache + func NewDevCollector(gs []*GitHubCollector) prometheus.Collector + func NewGitHubClient(ctx context.Context) (*github.Client, error) + func RecordMetrics(gs []*GitHubCollector) + type Dispatcher struct + func NewDispatcher(worker Worker) *Dispatcher + func (d *Dispatcher) Add(job *Job) + func (d *Dispatcher) Start(ctx context.Context) + func (d *Dispatcher) Stop() + func (d *Dispatcher) Wait() + type GitHubCollector struct + func NewGitHubCollector(org string) *GitHubCollector + func (g *GitHubCollector) GetIssuesByRepo(repoName string) ([]*github.Issue, error) + func (g *GitHubCollector) GetOrg() (*github.Organization, error) + func (g *GitHubCollector) GetPullRequestsByRepo(repoName string) ([]*github.PullRequest, error) + func (g *GitHubCollector) GetReposByOrg() ([]*github.Repository, error) + type Job struct + func NewJob(client *github.Client, orgName string) *Job + func (j *Job) Execute(ctx context.Context) error + type Worker interface + Work func(ctx context.Context, job *Job) + func NewWorker() Worker