From 5e31b95bb59256c2474ad4054c9b78a5d1fcf4f9 Mon Sep 17 00:00:00 2001 From: 9seconds Date: Wed, 17 Mar 2021 21:24:55 +0300 Subject: [PATCH] Add timestamp to EventConcurrencyLimited --- mtglib/proxy.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/mtglib/proxy.go b/mtglib/proxy.go index 6cec3bc..f3b32bb 100644 --- a/mtglib/proxy.go +++ b/mtglib/proxy.go @@ -74,7 +74,9 @@ func (p *Proxy) Serve(listener net.Listener) error { case errors.Is(err, ants.ErrPoolClosed): return nil case errors.Is(err, ants.ErrPoolOverload): - p.eventStream.Send(p.ctx, EventConcurrencyLimited{}) + p.eventStream.Send(p.ctx, EventConcurrencyLimited{ + CreatedAt: time.Now(), + }) } } }