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(), + }) } } }