Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetupTestGrid (0.06 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. cmd/storage-rest_test.go

    		}
    	}
    }
    
    func newStorageRESTHTTPServerClient(t testing.TB) *storageRESTClient {
    	// Grid with 2 hosts
    	tg, err := grid.SetupTestGrid(2)
    	if err != nil {
    		t.Fatalf("SetupTestGrid: %v", err)
    	}
    	t.Cleanup(tg.Cleanup)
    	prevHost, prevPort := globalMinioHost, globalMinioPort
    	defer func() {
    		globalMinioHost, globalMinioPort = prevHost, prevPort
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
Back to top