Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewSingleHandler (0.14 sec)

  1. cmd/peer-rest-server.go

    	localStorageInfoRPC            = grid.NewSingleHandler[*grid.MSS, *grid.JSON[madmin.StorageInfo]](grid.HandlerStorageInfo, grid.NewMSS, madminStorageInfo.NewJSON)
    	makeBucketRPC                  = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerMakeBucket, grid.NewMSS, grid.NewNoPayload)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    	storageReadVersionRPC      = grid.NewSingleHandler[*grid.MSS, *FileInfo](grid.HandlerReadVersion, grid.NewMSS, func() *FileInfo { return &FileInfo{} })
    	storageReadXLRPC           = grid.NewSingleHandler[*grid.MSS, *RawFileInfo](grid.HandlerReadXL, grid.NewMSS, func() *RawFileInfo { return &RawFileInfo{} })
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. 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()
    		for k, v := range *req {
    			(*resp)[k] = v
    		}
    		return resp, nil
    	}
    	// Return error
    	h2 := NewSingleHandler[*MSS, *MSS](handlerTest2, NewMSS, NewMSS)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
Back to top