Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for gridConn (0.23 sec)

  1. cmd/peer-rest-client.go

    	conn := client.gridConn()
    	if conn == nil {
    		return nil
    	}
    	_, err := loadTransitionTierConfigRPC.Call(ctx, conn, grid.NewMSSWith(map[string]string{}))
    	return err
    }
    
    func (client *peerRESTClient) doTrace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) {
    	gridConn := client.gridConn()
    	if gridConn == nil {
    		return
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  2. 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 0, toStorageErr(err)
    	}
    
    	defer storageRenameDataRPC.PutResponse(resp)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 26K 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.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  4. cmd/bootstrap-peer-server.go

    type bootstrapRESTClient struct {
    	gridConn *grid.Connection
    }
    
    // Verify function verifies the server config.
    func (client *bootstrapRESTClient) Verify(ctx context.Context, srcCfg *ServerSystemConfig) (err error) {
    	if newObjectLayerFn() != nil {
    		return nil
    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  5. cmd/metacache-walk.go

    	// Ensure remote has the same disk ID.
    	opts.DiskID = *client.diskID.Load()
    	b, err := opts.MarshalMsg(grid.GetByteBuffer()[:0])
    	if err != nil {
    		return toStorageErr(err)
    	}
    
    	st, err := client.gridConn.NewStream(ctx, grid.HandlerWalkDir, b)
    	if err != nil {
    		return toStorageErr(err)
    	}
    	return toStorageErr(st.Results(func(in []byte) error {
    		_, err := wr.Write(in)
    		return err
    	}))
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
Back to top