- Timestamp:
- Aug 20, 2020, 7:13:56 AM (5 years ago)
- Location:
- trunk
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/conn.go
r398 r402 108 108 109 109 type rateLimiter struct { 110 C <-chan struct{}111 ticker *time.Ticker110 C <-chan struct{} 111 ticker *time.Ticker 112 112 stopped chan struct{} 113 113 } … … 136 136 }() 137 137 return &rateLimiter{ 138 C: ch,139 ticker: ticker,138 C: ch, 139 ticker: ticker, 140 140 stopped: stopped, 141 141 } … … 148 148 149 149 type connOptions struct { 150 Logger Logger150 Logger Logger 151 151 RateLimitDelay time.Duration 152 152 RateLimitBurst int -
trunk/upstream.go
r399 r402 165 165 166 166 options := connOptions{ 167 Logger: logger,167 Logger: logger, 168 168 RateLimitDelay: upstreamMessageDelay, 169 169 RateLimitBurst: upstreamMessageBurst,
Note:
See TracChangeset
for help on using the changeset viewer.