Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewMSS (0.07 sec)

  1. cmd/peer-rest-server.go

    	deleteBucketRPC                = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerDeleteBucket, grid.NewMSS, grid.NewNoPayload)
    	deletePolicyRPC                = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerDeletePolicy, grid.NewMSS, grid.NewNoPayload).IgnoreNilConn()
    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/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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. 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{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. 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")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  5. internal/grid/types.go

    		return msgp.NilSize
    	}
    	s := msgp.MapHeaderSize
    	for za0001, za0002 := range *m {
    		s += msgp.StringPrefixSize + len(za0001) + msgp.StringPrefixSize + len(za0002)
    	}
    	return s
    }
    
    // NewMSS returns a new MSS.
    func NewMSS() *MSS {
    	m := MSS(mssPool.Get().(map[string]string))
    	for k := range m {
    		delete(m, k)
    	}
    	return &m
    }
    
    // NewMSSWith returns a new MSS with the given map.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  6. 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()
    		for k, v := range *req {
    			(*resp)[k] = v
    		}
    		return resp, nil
    	}
    	// Return error
    	h2 := NewSingleHandler[*MSS, *MSS](handlerTest2, NewMSS, NewMSS)
    	handler2 := func(req *MSS) (resp *MSS, err *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)
  7. 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)
  8. cmd/storage-rest-client.go

    }
    
    // ListDir - lists a directory.
    func (client *storageRESTClient) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (entries []string, err error) {
    	values := grid.NewMSS()
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTDirPath, dirPath)
    	values.Set(storageRESTCount, strconv.Itoa(count))
    	values.Set(storageRESTOrigVolume, origvolume)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
Back to top