Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewSingleHandler (0.06 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. cmd/storage-rest-server.go

    	storageRenamePartRPC       = grid.NewSingleHandler[*RenamePartHandlerParams, grid.NoPayload](grid.HandlerRenamePart, func() *RenamePartHandlerParams { return &RenamePartHandlerParams{} }, grid.NewNoPayload)
    	storageStatVolRPC          = grid.NewSingleHandler[*grid.MSS, *VolInfo](grid.HandlerStatVol, grid.NewMSS, func() *VolInfo { return &VolInfo{} })
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  3. internal/grid/handlers.go

    			if r != rZero {
    				//nolint:staticcheck // SA6002 IT IS A GENERIC VALUE!
    				pool.Put(r)
    			}
    		}
    }
    
    // NewSingleHandler creates a typed handler that can provide Marshal/Unmarshal.
    // Use Register to register a server handler.
    // Use Call to initiate a clientside call.
    func NewSingleHandler[Req, Resp RoundTripper](h HandlerID, newReq func() Req, newResp func() Resp) *SingleHandler[Req, Resp] {
    	s := SingleHandler[Req, Resp]{id: h}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  4. 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)
  5. cmd/lock-rest-server.go

    	lockRPCRUnlock     = newLockHandler(grid.HandlerLockRUnlock)
    )
    
    func newLockHandler(h grid.HandlerID) *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp] {
    	return grid.NewSingleHandler[*dsync.LockArgs, *dsync.LockResp](h, func() *dsync.LockArgs {
    		return &dsync.LockArgs{}
    	}, func() *dsync.LockResp {
    		return &dsync.LockResp{}
    	})
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jan 31 19:54:34 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server.go

    	return scfg
    }
    
    func (s *bootstrapRESTServer) VerifyHandler(params *grid.MSS) (*ServerSystemConfig, *grid.RemoteErr) {
    	return getServerSystemCfg(), nil
    }
    
    var serverVerifyHandler = grid.NewSingleHandler[*grid.MSS, *ServerSystemConfig](grid.HandlerServerVerify, grid.NewMSS, func() *ServerSystemConfig { return &ServerSystemConfig{} })
    
    // registerBootstrapRESTHandlers - register bootstrap rest router.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. 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)
  8. 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