- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for incomingBytes (0.11 sec)
-
internal/grid/connection.go
} // Record per connection stats. c.outgoingBytes = func(n int64) { if o.outgoingBytes != nil { o.outgoingBytes(n) } c.outBytes.Add(n) } c.incomingBytes = func(n int64) { if o.incomingBytes != nil { o.incomingBytes(n) } c.inBytes.Add(n) } if !strings.HasPrefix(o.remote, "https://") && !strings.HasPrefix(o.remote, "wss://") { c.baseFlags |= FlagCRCxxh3 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
internal/grid/manager.go
dial: o.Dialer, handlers: &m.handlers, auth: o.AddAuth, blockConnect: o.BlockConnect, tlsConfig: o.TLSConfig, publisher: o.TraceTo, incomingBytes: o.Incoming, outgoingBytes: o.Outgoing, }) } if !found { return nil, fmt.Errorf("grid: local host (%s) not found in cluster setup", o.Local) } return m, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0)