Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for outgoingBytes (0.1 sec)

  1. internal/grid/connection.go

    		authFn:             o.authFn,
    	}
    	if debugPrint {
    		// Random Mux ID
    		c.NextID = rand.Uint64()
    	}
    
    	// 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)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. internal/grid/manager.go

    			id:            m.ID,
    			local:         o.Local,
    			remote:        host,
    			handlers:      &m.handlers,
    			blockConnect:  o.BlockConnect,
    			publisher:     o.TraceTo,
    			incomingBytes: o.Incoming,
    			outgoingBytes: o.Outgoing,
    			dialer:        o.Dialer,
    			authFn:        o.AuthFn,
    		})
    	}
    	if !found {
    		return nil, fmt.Errorf("grid: local host (%s) not found in cluster setup", o.Local)
    	}
    
    	return m, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top