netutil

Documentation

Index

• func SharedLimitListener(listener net.Listener, limiter *Limiter) net.Listener
• type Limiter
  • func NewLimiterWithMetrics(n int, maxConnsCount, concurrentConnsCount, waitingConnsCount prometheus.Gauge) *Limiter

Functions

func SharedLimitListener

func SharedLimitListener(listener net.Listener, limiter *Limiter) net.Listener

SharedLimitListener returns a Listener that accepts simultaneous connections from the provided Listener only if a shared availability pool permits it. Based on https://godoc.org/golang.org/x/net/netutil

Types

type Limiter

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

Limiter is used to provide a shared pool of connection slots. Use NewLimiter to create an instance

func NewLimiterWithMetrics

func NewLimiterWithMetrics(n int, maxConnsCount, concurrentConnsCount, waitingConnsCount prometheus.Gauge) *Limiter

NewLimiterWithMetrics creates a Limiter with metrics