fetchers

Documentation

Index

• type MetricsFetcher
  • func NewMetricsFetcher(scraper *scrapers.Scraper, routesFetcher RoutesFetch, ...) *MetricsFetcher
  • func (f MetricsFetcher) Metric(route *models.Route, metricPathDefault, schemeDefault string, ...) (map[string]*dto.MetricFamily, error)
  • func (f MetricsFetcher) Metrics(consulQuery string, metricPathDefault, schemeDefault string, ...) (map[string]*dto.MetricFamily, error)
• type RoutesFetch
• type RoutesFetcher
  • func NewRoutesFetcher(consulConfig config.ConsulConfig) (*RoutesFetcher, error)
  • func (f *RoutesFetcher) Routes(search models.ServiceSearch) (models.Routes, 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, schemeDefault string, headers http.Header) (map[string]*dto.MetricFamily, error)

func (MetricsFetcher) Metrics

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

type RoutesFetch

type RoutesFetch interface {
	Routes(search models.ServiceSearch) (models.Routes, error)
}

type RoutesFetcher

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

func NewRoutesFetcher

func NewRoutesFetcher(consulConfig config.ConsulConfig) (*RoutesFetcher, error)

func (*RoutesFetcher) Routes

func (f *RoutesFetcher) Routes(search models.ServiceSearch) (models.Routes, error)