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 *RoutesFetcher) *MetricsFetcher
  • func (f MetricsFetcher) Metric(route models.Route) (map[string]*dto.MetricFamily, error)
  • func (f MetricsFetcher) Metrics(appIdOrPathOrName string) (map[string]*dto.MetricFamily, error)
• type RoutesFetcher
  • func NewRoutesFetcher(confGorouters []config.GorouterConfig) *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 *RoutesFetcher) *MetricsFetcher

func (MetricsFetcher) Metric

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

func (MetricsFetcher) Metrics

func (f MetricsFetcher) Metrics(appIdOrPathOrName string) (map[string]*dto.MetricFamily, error)

type RoutesFetcher

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

func NewRoutesFetcher

func NewRoutesFetcher(confGorouters []config.GorouterConfig) *RoutesFetcher

func (RoutesFetcher) Routes

func (f RoutesFetcher) Routes() models.Routes

func (RoutesFetcher) Run

func (f RoutesFetcher) Run()