probe

Documentation

Index

• type Config
  • func GetConfigFromRequest(request *http.Request) (*Config, error)
• type Probe
  • func New(logger log.Logger, httpClient *http.Client, cred azcore.TokenCredential, ...) (*Probe, error)
  • func (p *Probe) ServeHTTP(reg prometheus.Registerer) http.HandlerFunc
• type Request
  • func (r *Request) Collect(ch chan<- prometheus.Metric)
  • func (r *Request) Describe(_ chan<- *prometheus.Desc)
• type Resources

Types

type Config

type Config struct {
	Subscriptions   []string
	ResourceType    string
	Query           string
	MetricNamespace string
	MetricNames     []string
	MetricPrefix    string

	QueryCacheCacheExpiration time.Duration

	azmetrics.QueryResourcesOptions
}

func GetConfigFromRequest

func GetConfigFromRequest(request *http.Request) (*Config, error)

type Probe

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

func New

func New(
	logger log.Logger,
	httpClient *http.Client,
	cred azcore.TokenCredential,
	subscriptions []string,
	queryCache *cache.Cache[Resources],
	metricsClientCache *cache.Cache[azmetrics.Client],
) (*Probe, error)

func (*Probe) ServeHTTP

func (p *Probe) ServeHTTP(reg prometheus.Registerer) http.HandlerFunc

type Request

type Request struct {
	http.Request
	log.Logger
	// contains filtered or unexported fields
}

func (*Request) Collect

func (r *Request) Collect(ch chan<- prometheus.Metric)

func (*Request) Describe

func (r *Request) Describe(_ chan<- *prometheus.Desc)

type Resources

type Resources struct {
	Resources        map[string]map[string][]string
	AdditionalLabels map[string]map[string]string
}