fetchers

Documentation

Index

• type FetcherTransport
  • func NewFetcherTransport(gorouterConf config.GorouterConfig, transport http.RoundTripper) *FetcherTransport
  • func (t FetcherTransport) RoundTrip(req *http.Request) (*http.Response, error)
• 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 RoutesFetch
• type RoutesFetcher
  • func NewRoutesFetcher(confGorouters []config.GorouterConfig, healthCheck *healthchecks.HealthCheck) *RoutesFetcher
  • func (f *RoutesFetcher) Routes() models.Routes
  • func (f *RoutesFetcher) Run()

Types

type FetcherTransport

type FetcherTransport struct {
	GorouterConf  config.GorouterConfig
	WrapTransport http.RoundTripper
}

func NewFetcherTransport

func NewFetcherTransport(gorouterConf config.GorouterConfig, transport http.RoundTripper) *FetcherTransport

func (FetcherTransport) RoundTrip

func (t FetcherTransport) RoundTrip(req *http.Request) (*http.Response, error)

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 RoutesFetch

type RoutesFetch interface {
	Run()
	Routes() models.Routes
}

type RoutesFetcher

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

func NewRoutesFetcher

func NewRoutesFetcher(confGorouters []config.GorouterConfig, healthCheck *healthchecks.HealthCheck) *RoutesFetcher

func (*RoutesFetcher) Routes

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

func (*RoutesFetcher) Run

func (f *RoutesFetcher) Run()