Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PutResponse (0.23 sec)

  1. cmd/lock-rest-client.go

    	r, err := h.Call(ctx, c.connection, args)
    	if err != nil {
    		return false, err
    	}
    	defer h.PutResponse(r)
    	ok = r.Code == dsync.RespOK
    	switch r.Code {
    	case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK:
    	// no error
    	case dsync.RespLockNotInitialized:
    		err = errLockNotInitialized
    	default:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Nov 24 17:07:14 GMT 2023
    - 3.3K bytes
    - Viewed (0)
  2. cmd/bootstrap-peer-server.go

    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    	}
    	// We do not need the response after returning.
    	defer serverVerifyHandler.PutResponse(recvCfg)
    
    	return srcCfg.Diff(recvCfg)
    }
    
    // Stringer provides a canonicalized representation of node.
    func (client *bootstrapRESTClient) String() string {
    	return client.gridConn.String()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  3. internal/grid/README.md

        if err != nil { ... }
    	
        // Read results from the stream
        err = stream.Results(func(resp *Resp) error {
            fmt.Println("Got result", resp)
            // Return the response for reuse
    		instance.PutResponse(resp)
            return nil
        })
    ```
    
    There are handlers for requests with:
     * No input stream: `RegisterNoInput`.
     * No initial payload: `RegisterNoPayload`.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
Back to top