netconnlimit

Documentation

Overview

Package netconnlimit provides network utility functions for limiting simultaneous connections across multiple listeners.

Index

• func NewSharedSemaphore(n int) chan struct{}
• func SharedLimitListener(l net.Listener, sem chan struct{}) net.Listener

Functions

func NewSharedSemaphore

func NewSharedSemaphore(n int) chan struct{}

NewSharedSemaphore creates and returns a new semaphore channel that can be used to limit the number of simultaneous connections across multiple listeners.

func SharedLimitListener

func SharedLimitListener(l net.Listener, sem chan struct{}) net.Listener

SharedLimitListener returns a listener that accepts at most n simultaneous connections across multiple listeners using the provided shared semaphore.