- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 372 for Response_ (0.34 sec)
-
api/openapi-spec/v3/api__v1_openapi.json
"type": "string" }, "remainingItemCount": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 1.8M bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
} } // sendDownstream sends discovery response. func sendDownstream(downstream adsStream, response *discovery.DiscoveryResponse) error { tStart := time.Now() defer func() { // This is a hint to help debug slow responses. if time.Since(tStart) > 10*time.Second { proxyLog.Warnf("sendDownstream took %v", time.Since(tStart)) } }() return downstream.Send(response) } func (p *XdsProxy) close() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
} deleteResp := txnResp.Responses[0].GetResponseDeleteRange() if deleteResp.Header == nil { return errors.New("invalid DeleteRange response - nil header") } err = decode(s.codec, s.versioner, origState.data, out, deleteResp.Header.Revision) if err != nil { recordDecodeError(s.groupResourceString, key) return err } return nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
if rec.Code != testCase.expectedRespStatus { t.Errorf("Test %d: %s: Expected the response status to be `%d`, but instead found `%d`", i+1, instanceType, testCase.expectedRespStatus, rec.Code) } // Verify response the V2 signed HTTP request. // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. recV2 := httptest.NewRecorder()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 39.8K bytes - Viewed (0) -
docs/en/docs/advanced/templates.md
By declaring `response_class=HTMLResponse` the docs UI will be able to know that the response will be HTML. !!! note "Technical Details" You could also use `from starlette.templating import Jinja2Templates`. **FastAPI** provides the same `starlette.templating` as `fastapi.templating` just as a convenience for you, the developer. But most of the available responses come directly from Starlette. The same with `Request` and `StaticFiles`.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 18 23:43:13 UTC 2024 - 3.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
package configdump import ( "encoding/json" "fmt" "io" "text/tabwriter" "sigs.k8s.io/yaml" "istio.io/istio/pkg/maps" ) // ConfigWriter is a writer for processing responses from the Ztunnel Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer ztunnelDump *ZtunnelDump FullDump []byte } type rawDump struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 3.9K bytes - Viewed (0) -
api/openapi-spec/v3/apis__apps__v1_openapi.json
"type": "string" }, "remainingItemCount": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 810.7K bytes - Viewed (0) -
cmd/storage-rest-server.go
err := req.DecodeMsg(mr) if err != nil { rw.CloseWithError(err) return } mw := msgp.NewWriter(rw) responses := make(chan ReadMultipleResp, len(req.Files)) var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() for resp := range responses { err := resp.EncodeMsg(mw) if err != nil { rw.CloseWithError(err) return } mw.Flush() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
} } type failingRoundTripper struct{} func (failingRoundTripper) RoundTrip(*http.Request) (*http.Response, error) { return nil, errors.New("some error") } type staticResponseRoundTripper struct{ res *http.Response } func (rt staticResponseRoundTripper) RoundTrip(*http.Request) (*http.Response, error) { return rt.res, nil } func TestReverseProxyErrorHandler(t *testing.T) { tests := []struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
src/net/http/transport.go
// OnProxyConnectResponse is called when the Transport gets an HTTP response from // a proxy for a CONNECT request. It's called before the check for a 200 OK response. // If it returns an error, the request fails with that error. OnProxyConnectResponse func(ctx context.Context, proxyURL *url.URL, connectReq *Request, connectRes *Response) error // DialContext specifies the dial function for creating unencrypted TCP connections.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0)