diff --git a/common/event/interface.go b/common/event/interface.go index c01b462..eb73dfa 100644 --- a/common/event/interface.go +++ b/common/event/interface.go @@ -74,7 +74,7 @@ type EventOnProxyConnectionOver struct { } func (e EventOnProxyConnectionOver) String() string { - return fmt.Sprintf("Proxy connection closed (↑ %d, ↓ %d)", e.InboundTraffic, e.OutboundTraffic) + return fmt.Sprintf("Proxy connection closed") } type EventOnProxyStats struct { diff --git a/proxy/lib/snowflake.go b/proxy/lib/snowflake.go index a0c0ce0..0c85754 100644 --- a/proxy/lib/snowflake.go +++ b/proxy/lib/snowflake.go @@ -661,6 +661,7 @@ func (sf *SnowflakeProxy) Start() error { if !sf.DisableStatsLogger { sf.bytesLogger = newBytesSyncLogger() sf.periodicProxyStats = newPeriodicProxyStats(sf.SummaryInterval, sf.EventDispatcher, sf.bytesLogger) + sf.EventDispatcher.AddSnowflakeEventListener(sf.periodicProxyStats) } broker, err = newSignalingServer(sf.BrokerURL, sf.KeepLocalAddresses)