fetchers

Documentation

Index

• type MetricsFetcher
  • func NewMetricsFetcher(scraper *scrapers.Scraper, routesFetcher RoutesFetch, ...) *MetricsFetcher
  • func (f MetricsFetcher) Metric(route *models.Route, metricPathDefault string, headers http.Header) (map[string]*dto.MetricFamily, error)
  • func (f MetricsFetcher) Metrics(appIdOrPathOrName, metricPathDefault string, onlyAppMetrics bool, ...) (map[string]*dto.MetricFamily, error)
• type RouterStart
• type RoutesFetch
• type RoutesFetcher
  • func NewRoutesFetcher(mbusClient mbus.Client, c *config.Config, reconnected <-chan mbus.Signal, ...) *RoutesFetcher
  • func (f *RoutesFetcher) Dropped() (int, error)
  • func (f *RoutesFetcher) Pending() (int, error)
  • func (f *RoutesFetcher) RouteHandler(w http.ResponseWriter, req *http.Request)
  • func (f *RoutesFetcher) Routes() models.Routes
  • func (f *RoutesFetcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Types

type MetricsFetcher

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

func NewMetricsFetcher

func NewMetricsFetcher(scraper *scrapers.Scraper, routesFetcher RoutesFetch, externalExporters config.ExternalExporters) *MetricsFetcher

func (MetricsFetcher) Metric

func (f MetricsFetcher) Metric(route *models.Route, metricPathDefault string, headers http.Header) (map[string]*dto.MetricFamily, error)

func (MetricsFetcher) Metrics

func (f MetricsFetcher) Metrics(appIdOrPathOrName, metricPathDefault string, onlyAppMetrics bool, headers http.Header) (map[string]*dto.MetricFamily, error)

type RouterStart

type RouterStart struct {
	Id                               string   `json:"id"`
	Hosts                            []string `json:"hosts"`
	MinimumRegisterIntervalInSeconds int      `json:"minimumRegisterIntervalInSeconds"`
	PruneThresholdInSeconds          int      `json:"pruneThresholdInSeconds"`
}

type RoutesFetch

type RoutesFetch interface {
	Run(signals <-chan os.Signal, ready chan<- struct{}) error
	Routes() models.Routes
}

type RoutesFetcher

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

func NewRoutesFetcher

func NewRoutesFetcher(mbusClient mbus.Client, c *config.Config, reconnected <-chan mbus.Signal, healthCheck *healthchecks.HealthCheck) *RoutesFetcher

func (*RoutesFetcher) Dropped

func (f *RoutesFetcher) Dropped() (int, error)

func (*RoutesFetcher) Pending

func (f *RoutesFetcher) Pending() (int, error)

func (*RoutesFetcher) RouteHandler

func (f *RoutesFetcher) RouteHandler(w http.ResponseWriter, req *http.Request)

func (*RoutesFetcher) Routes

func (f *RoutesFetcher) Routes() models.Routes

func (*RoutesFetcher) Run

func (f *RoutesFetcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error