go fmt

conn.go

@@ -107,8 +107,8 @@ func (wa websocketAddr) String() string {
 }
 
 type rateLimiter struct {
-	C <-chan struct{}
+	C       <-chan struct{}
-	ticker *time.Ticker
+	ticker  *time.Ticker
 	stopped chan struct{}
 }
 
@@ -135,8 +135,8 @@ func newRateLimiter(delay time.Duration, burst int) *rateLimiter {
 		}
 	}()
 	return &rateLimiter{
-		C: ch,
+		C:       ch,
-		ticker: ticker,
+		ticker:  ticker,
 		stopped: stopped,
 	}
 }
@@ -147,7 +147,7 @@ func (rl *rateLimiter) Stop() {
 }
 
 type connOptions struct {
-	Logger Logger
+	Logger         Logger
 	RateLimitDelay time.Duration
 	RateLimitBurst int
 }

upstream.go

@@ -164,7 +164,7 @@ func connectToUpstream(network *network) (*upstreamConn, error) {
 	}
 
 	options := connOptions{
-		Logger: logger,
+		Logger:         logger,
 		RateLimitDelay: upstreamMessageDelay,
 		RateLimitBurst: upstreamMessageBurst,
 	}