discovery

Jul 18, 2019

Changes in this version

+ var ErrAdvertiseTimeout = errors.NewKind("advertise repositories timeout")

+ var ErrDiscoveryStop = errors.NewKind("discovery failed on stop")

+ var ErrDiscoveryStopped = errors.NewKind("discovery stopped")

+ func GetGHEndpoint(r *github.Repository) (string, error)

+ type AdvertiseGHRepositoriesFn func(context.Context, []*github.Repository) error

+ type GitHub struct

+ func NewGitHub(advertiseRepos AdvertiseGHRepositoriesFn, iter GHRepositoriesIter, ...) *GitHub

+ func (p *GitHub) Start() error

+ func (p *GitHub) Stop() error

+ type GitHubOpts struct

+ AdvertiseTimeout time.Duration

+ BatchSize int

+ MaxJobBuffer int

+ SkipForks bool

+ StopTimeout time.Duration

+ WaitNewRepos bool

+ WaitOnRateLimit bool

Jul 3, 2019

Changes in this version

type GHProviderOpts

+ SkipForks bool

Jun 25, 2019

Changes in this version

+ var ErrEndpointsNotFound = errors.NewKind("endpoinds not found for %s")

+ var ErrNewRepositoriesNotFound = errors.NewKind("couldn't find new repositories")

+ var ErrRateLimitExceeded = errors.NewKind("rate limit requests exceeded")

+ type GHOrgReposIter struct

+ func NewGHOrgReposIter(org string, opts *GHReposIterOpts) *GHOrgReposIter

+ func (p *GHOrgReposIter) Next(ctx context.Context) (*github.Repository, time.Duration, error)

+ type GHProvider struct

+ func NewGHProvider(queue chan<- gitcollector.Job, iter GHRepositoriesIter, opts *GHProviderOpts) *GHProvider

+ func (p *GHProvider) Start() error

+ func (p *GHProvider) Stop() error

+ type GHProviderOpts struct

+ EnqueueTimeout time.Duration

+ MaxJobBuffer int

+ StopTimeout time.Duration

+ WaitNewRepos bool

+ WaitOnRateLimit bool

+ type GHReposIterOpts struct

+ AuthToken string

+ HTTPTimeout time.Duration

+ ResultsPerPage int

+ TimeNewRepos time.Duration

+ type GHRepositoriesIter interface

+ Next func(context.Context) (*github.Repository, time.Duration, error)