- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PutResponse (0.23 sec)
-
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) -
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) -
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)