Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewSingleHandler (0.85 sec)

  1. cmd/peer-rest-server.go

    	// Request -> Response RPC calls
    	deleteBucketMetadataRPC        = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerDeleteBucketMetadata, grid.NewMSS, grid.NewNoPayload).IgnoreNilConn()
    	deleteBucketRPC                = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerDeleteBucket, grid.NewMSS, grid.NewNoPayload)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
  2. internal/grid/grid_test.go

    	remote := grid.Managers[1]
    
    	// 1: Echo
    	h1 := NewSingleHandler[*MSS, *MSS](handlerTest, NewMSS, NewMSS)
    	// Handles incoming requests, returns a response
    	handler1 := func(req *MSS) (resp *MSS, err *RemoteErr) {
    		resp = h1.NewResponse()
    		maps.Copy((*resp), *req)
    		return resp, nil
    	}
    	// Return error
    	h2 := NewSingleHandler[*MSS, *MSS](handlerTest2, NewMSS, NewMSS)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.1K bytes
    - Viewed (0)
  3. internal/grid/README.md

        }
    
        // Create a typed handler.
        // Due to current generics limitations, a constructor of the empty type must be provided.
        instance := grid.NewSingleHandler[*grid.MSS, *grid.MSS](h, grid.NewMSS, grid.NewMSS)
    
        // Register the handler on the manager
        instance.Register(manager, handler)
    
        // The typed instance is also used for calls
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  4. internal/grid/benchmark_test.go

    		})
    	}
    }
    
    func benchmarkGridRequests(b *testing.B, n int) {
    	defer testlogger.T.SetErrorTB(b)()
    	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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.5K bytes
    - Viewed (0)
Back to top