metrics

Jun 25, 2019

Changes in this version

+ func PrepareDB(uri string, table string, orgs []string) (*sql.DB, error)

+ type Collector struct

+ func NewCollector(opts *CollectorOpts) *Collector

+ func (c *Collector) Discover(job gitcollector.Job)

+ func (c *Collector) Fail(job gitcollector.Job)

+ func (c *Collector) Start()

+ func (c *Collector) Stop(immediate bool)

+ func (c *Collector) Success(job gitcollector.Job)

+ type CollectorByOrg struct

+ func NewCollectorByOrg(orgsMetrics map[string]*Collector) *CollectorByOrg

+ func (c *CollectorByOrg) Discover(job gitcollector.Job)

+ func (c *CollectorByOrg) Fail(job gitcollector.Job)

+ func (c *CollectorByOrg) Start()

+ func (c *CollectorByOrg) Stop(immediate bool)

+ func (c *CollectorByOrg) Success(job gitcollector.Job)

+ type CollectorOpts struct

+ BatchSize int

+ Log log.Logger

+ Send SendFn

+ SyncTime time.Duration

+ type SendFn func(context.Context, *Collector, *library.Job) error

+ func SendToDB(db *sql.DB, table, org string) SendFn