Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for ConnectWS (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/grid/grid.go

    		conn, br, _, err := dialer.Dial(ctx, toDial)
    		if br != nil {
    			ws.PutReader(br)
    		}
    		return conn, err
    	}
    }
    
    // ConnectWS returns a function that dials a websocket connection to the given address.
    // Route and auth are added to the connection.
    func ConnectWS(dial ContextDialer, auth AuthFn, tls *tls.Config) func(ctx context.Context, remote string) (net.Conn, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7K bytes
    - Click Count (0)
  2. internal/grid/connection_test.go

    		})
    	}
    	connReady := make(chan struct{})
    	// We fake a local and remote server.
    	localHost := hosts[0]
    	remoteHost := hosts[1]
    	local, err := NewManager(t.Context(), ManagerOptions{
    		Dialer: ConnectWS(dialer.DialContext,
    			dummyNewToken,
    			nil),
    		Local:        localHost,
    		Hosts:        hosts,
    		AuthFn:       dummyNewToken,
    		AuthToken:    dummyTokenValidate,
    		BlockConnect: connReady,
    	})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 5.9K bytes
    - Click Count (0)
Back to Top