scheduler

Documentation

Index

• Variables
• type Scheduler
  • func New(config config.Config, store datastore.Datastore, oauth *oauth.Oauth, ...) *Scheduler
  • func (s *Scheduler) Start()
  • func (s *Scheduler) Stop()

Variables

var ErrorGauge = prometheus.NewGaugeVec(
	prometheus.GaugeOpts{
		Subsystem: "schedule",
		Name:      "error_count",
		Help:      "errors trying to process an user",
	},
	[]string{"id"},
)

ErrorGauge is the error count for prometheus nolint: gochecknoglobals

var TimeGauge = prometheus.NewGaugeVec(
	prometheus.GaugeOpts{
		Subsystem: "schedule",
		Name:      "time_taken_seconds",
		Help:      "Time taken to scan the user",
	},
	[]string{"id"},
)

TimeGauge is the time_taken metric for prometheus nolint: gochecknoglobals

Types

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

Scheduler type

func New

func New(
	config config.Config,
	store datastore.Datastore,
	oauth *oauth.Oauth,
	session sessions.Store,
) *Scheduler

New scheduler

func (*Scheduler) Start

func (s *Scheduler) Start()

Start the scheduler

func (*Scheduler) Stop

func (s *Scheduler) Stop()

Stop the scheduler