Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetupTestGrid (0.05 sec)

  1. internal/grid/benchmark_test.go

    	errFatal := func(err error) {
    		b.Helper()
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    	rpc := NewSingleHandler[*testRequest, *testResponse](handlerTest2, newTestRequest, newTestResponse)
    	grid, err := SetupTestGrid(n)
    	errFatal(err)
    	b.Cleanup(grid.Cleanup)
    	// Create n managers.
    	for _, remote := range grid.Managers {
    		// Register a single handler which echos the payload.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  2. internal/grid/debug.go

    	Managers    []*Manager
    	Mux         []*mux.Router
    	Hosts       []string
    	cleanupOnce sync.Once
    	cancel      context.CancelFunc
    }
    
    // SetupTestGrid creates a new grid for testing purposes.
    // Select the number of hosts to create.
    // Call (TestGrid).Cleanup() when done.
    func SetupTestGrid(n int) (*TestGrid, error) {
    	hosts, listeners, err := getHosts(n)
    	if err != nil {
    		return nil, err
    	}
    	dialer := &net.Dialer{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  3. internal/grid/grid_test.go

    )
    
    func TestSingleRoundtrip(t *testing.T) {
    	defer testlogger.T.SetLogTB(t)()
    	errFatal := func(err error) {
    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    	grid, err := SetupTestGrid(2)
    	errFatal(err)
    	remoteHost := grid.Hosts[1]
    	local := grid.Managers[0]
    
    	// 1: Echo
    	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.1K bytes
    - Viewed (0)
Back to top