Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for gridConn (0.04 sec)

  1. cmd/storage-rest-client.go

    		DstVolume: dstVolume,
    		FI:        fi,
    		Opts:      opts,
    	}
    	var resp *RenameDataResp
    	if fi.Data == nil {
    		resp, err = storageRenameDataRPC.Call(ctx, client.gridConn, &params)
    	} else {
    		resp, err = storageRenameDataInlineRPC.Call(ctx, client.gridConn, &RenameDataInlineHandlerParams{params})
    	}
    	if err != nil {
    		return res, toStorageErr(err)
    	}
    
    	defer storageRenameDataRPC.PutResponse(resp)
    	return *resp, nil
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    func (client *peerRESTClient) doTrace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) {
    	gridConn := client.gridConn()
    	if gridConn == nil {
    		return
    	}
    
    	payload, err := json.Marshal(traceOpts)
    	if err != nil {
    		bugLogIf(ctx, err)
    		return
    	}
    
    	st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload)
    	if err != nil {
    		return
    	}
    	st.Results(func(b []byte) error {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    		}
    		peers[i].SetPools(node.Pools)
    	}
    
    	return peers
    }
    
    // Returns a peer S3 client.
    func newPeerS3Client(node Node) peerS3Client {
    	var gridConn atomic.Pointer[grid.Connection]
    
    	return &remotePeerS3Client{
    		node: node,
    		gridConn: func() *grid.Connection {
    			// Lazy initialization of grid connection.
    			// When we create this peer client, the grid connection is likely not yet initialized.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
Back to top