Function New

gate/gate.go:50–52

New returns an instrumented gate limiting the number of requests being executed concurrently. The gate implementation is based on the github.com/prometheus/prometheus/util/gate package. It can be called several times but not with the same registerer otherwise it will panic when trying to register

(reg prometheus.Registerer, maxConcurrent int)

// It can be called several times but not with the same registerer otherwise it
// will panic when trying to register the same metric multiple times.
func New(reg prometheus.Registerer, maxConcurrent int) Gate {
	return NewInstrumented(reg, maxConcurrent, NewBlocking(maxConcurrent))
}

// NewInstrumented wraps a Gate implementation with one that records max number of inflight
// requests, currently inflight requests, and the duration of calls to the Start method.