- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for NewMSS (0.03 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/peer-rest-server.go
reloadSiteReplicationConfigRPC = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerReloadSiteReplicationConfig, grid.NewMSS, grid.NewNoPayload) serverInfoRPC = grid.NewSingleHandler[*grid.MSS, *grid.JSON[madmin.ServerProperties]](grid.HandlerServerInfo, grid.NewMSS, madminServerProperties.NewJSON)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
cmd/peer-rest-client.go
resp, err := getCPUsHandler.Call(ctx, client.gridConn(), grid.NewMSS()) return resp.ValueOrZero(), err } // GetNetInfo - fetch network information for a remote node. func (client *peerRESTClient) GetNetInfo(ctx context.Context) (info madmin.NetInfo, err error) { resp, err := getNetInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS()) return resp.ValueOrZero(), err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
cmd/bootstrap-peer-server.go
return getServerSystemCfg(), nil } var serverVerifyHandler = grid.NewSingleHandler[*grid.MSS, *ServerSystemConfig](grid.HandlerServerVerify, grid.NewMSS, func() *ServerSystemConfig { return &ServerSystemConfig{} }) // registerBootstrapRESTHandlers - register bootstrap rest router. func registerBootstrapRESTHandlers(gm *grid.Manager) { server := &bootstrapRESTServer{}
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 01 22:13:18 GMT 2024 - 8.4K bytes - Click Count (0) -
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 conn := manager.Connection("host")Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/grid/grid_test.go
// 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) handler2 := func(req *MSS) (resp *MSS, err *RemoteErr) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
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{} })
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0)