Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for newConnections (0.09 seconds)

  1. internal/grid/manager.go

    		if host == o.Local {
    			if found {
    				return nil, fmt.Errorf("grid: local host found multiple times")
    			}
    			found = true
    			// No connection to local.
    			continue
    		}
    		m.targets[host] = newConnection(connectionParams{
    			ctx:           ctx,
    			id:            m.ID,
    			local:         o.Local,
    			remote:        host,
    			handlers:      &m.handlers,
    			blockConnect:  o.BlockConnect,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Nov 12 20:41:41 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  2. internal/grid/connection.go

    	publisher     *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]
    	dialer        ConnDialer
    	authFn        AuthFn
    
    	blockConnect chan struct{}
    }
    
    // newConnection will create an unconnected connection to a remote.
    func newConnection(o connectionParams) *Connection {
    	c := &Connection{
    		state:              StateUnconnected,
    		Remote:             o.remote,
    		Local:              o.local,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
Back to Top