- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 117 for responses (0.17 sec)
-
internal/grid/muxclient.go
// Space for one message and an error. responseCh := make(chan Response, 1) // Spawn simple disconnect if requests == nil { go m.handleOneWayStream(responseCh, responses) return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil } // Deliver responses and send unblocks back to the server. go m.handleTwowayResponses(responseCh, responses)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/stream.go
import ( "context" "errors" ) // A Stream is a two-way stream. // All responses *must* be read by the caller. // If the call is canceled through the context, // the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/grid/grid_test.go
} // Start processing requests. close(processHandler) // Drain responses got := 0 for resp := range st.responses { // t.Log("got response", resp) errFatal(resp.Err) if resp.Msg[0] != byte(got) { t.Error("expected response", got, "got", resp.Msg[0]) } got++ } if got != 100 { t.Error("expected 100 responses, got", got) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/handlers.go
// when it has been returned on a handler. // This will disable automatic response recycling/pooling. // Typically this is used when the response sharing part of its data structure. func (h *SingleHandler[Req, Resp]) WithSharedResponse() *SingleHandler[Req, Resp] { h.sharedResp = true return h } // NewResponse creates a new response.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
internal/grid/benchmark_test.go
b.Cleanup(grid.Cleanup) const responses = 10 // Create n managers. for _, remote := range grid.Managers { // Register a single handler which echos the payload. errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{ // Send 10x response. Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr { for i := 0; i < responses; i++ { toSend := GetByteBuffer()[:0]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
internal/grid/connection.go
if handler == nil { return nil, ErrUnknownHandler } var requests chan []byte var responses chan Response if handler.InCapacity > 0 { requests = make(chan []byte, handler.InCapacity) } if handler.OutCapacity > 0 { responses = make(chan Response, handler.OutCapacity) } else { responses = make(chan Response, 1) } cl, err := c.newMuxClient(ctx) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/s3select/message.go
payloadLength := messageLength - 4 - 4 - 4 - headerLength - 4 return payloadLength } // continuationMessage - S3 periodically sends this message to keep the TCP connection open. // These messages appear in responses at random. The client must detect the message type and process accordingly. // // Header specification: // Continuation messages contain two headers, as follows:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/config/policy/opa/config.go
if err != nil { return false, err } // Handle large OPA responses when OPA URL is of // form http://localhost:8181/v1/data/httpapi/authz type opaResultAllow struct { Result struct { Allow bool `json:"allow"` } `json:"result"` } // Handle simpler OPA responses when OPA URL is of // form http://localhost:8181/v1/data/httpapi/authz/allow type opaResult struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.2K bytes - Viewed (1) -
cmd/server_test.go
// execute the http request to fetch object. response, err = s.client.Do(request) c.Assert(err, nil) // assert the http response status code. c.Assert(response.StatusCode, http.StatusOK) var buffer bytes.Buffer // extract the body of the response. responseBody, err := io.ReadAll(response.Body) c.Assert(err, nil) // assert the http response body content.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
internal/s3select/errors.go
package s3select import "strings" // SelectError - represents s3 select error specified in // https://docs.aws.amazon.com/AmazonS3/latest/API/RESTObjectSELECTContent.html#RESTObjectSELECTContent-responses-special-errors. type SelectError interface { Cause() error ErrorCode() string ErrorMessage() string HTTPStatusCode() int Error() string } type s3Error struct { code string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 14 16:48:36 GMT 2022 - 4.3K bytes - Viewed (0)