metrics

Documentation

Index

• Variables
• func CollectRequestsMetric(client, method string, err error, start time.Time)
• func CollectSnapshotKeyState(key, name string, val float64)
• type HeaderWatcher
  • func NewHeaderWatcher(name string) *HeaderWatcher
  • func (m *HeaderWatcher) RoundTrip(r *http.Request) (*http.Response, error)

Variables

var (
	RequestsHistogram = promauto.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: "datasource",
			Name:      "snapshot_sdk_requests",
			Help:      "Time taken to process snapshot requests",
			Buckets:   []float64{.005, .01, .025, .05, .075, .1, .15, .2, .25, .5, 1, 2.5, 5, 10, 15, 30},
		},
		[]string{"client", "method", "error"},
	)

	SnapshotKeyStateGauge = promauto.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: "datasource",
			Name:      "snapshot_key_state",
			Help:      "Stores the last received number of remaining requests",
		}, []string{"key", "name"},
	)
)

Functions

func CollectRequestsMetric

func CollectRequestsMetric(client, method string, err error, start time.Time)

func CollectSnapshotKeyState

func CollectSnapshotKeyState(key, name string, val float64)

Types

type HeaderWatcher

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

func NewHeaderWatcher

func NewHeaderWatcher(name string) *HeaderWatcher

func (*HeaderWatcher) RoundTrip

func (m *HeaderWatcher) RoundTrip(r *http.Request) (*http.Response, error)