loop

Oct 26, 2020

Changes in this version

type Option

+ func WithHandler(listener net.Listener, fn func(context.Context, net.Conn) error) Option

Oct 23, 2020

Changes in this version

type Option

+ func WithLatch(l *latch.Latch) Option

+ func WithPreflight(fn func(context.Context) error) Option

Oct 21, 2020

Changes in this version

+ type Loop struct

+ func New(options ...Option) *Loop

+ func (s *Loop) Start(ctx context.Context)

+ type Option interface

+ func WithConnectionCounter() (Option, func() uint64)

+ func WithMaxWorkers(count int) Option

+ func WithTCPHandler(listener *net.TCPListener, fn func(context.Context, *net.TCPConn) error) Option

+ func WithWaitGroup(wg *sync.WaitGroup) Option