loadlimiter

type LoadLimiter ¶

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

LoadLimiter is a limiter to control loading concurrency and it throttles the loading instead of rejecting. The motivation of this limiter is the fact that loading requires multiple syscalls which can create a new OS threads and might result in hitting the internal thread count limit of Go runtime.

func NewLoadLimiter(reg prometheus.Registerer, name string, limit int) *LoadLimiter

func (l *LoadLimiter) Acquire(ctx context.Context) error

func (l *LoadLimiter) Release()