- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for respAdd (0.28 sec)
-
pilot/pkg/xds/delta.go
// with EDS and SDS. // This can happen with the following sequence // 1. Envoy disconnects and reconnects to Istiod. // 2. Envoy sends EDS request and we respond with it. // 3. Envoy sends CDS request and we respond with clusters. // 4. Envoy detects a change in cluster state and tries to warm those clusters but never sends // an EDS request for them.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
return } if deltaRes == nil && deleted == nil && len(sotwRes) == 0 { // TODO: it suspicious full is never nil - are there case where we should be deleting everything? // Both SotW and Delta did not respond, nothing to compare return } newByName := slices.GroupUnique(sotwRes, (*discovery.Resource).GetName) curByName := slices.GroupUnique(current, (*discovery.Resource).GetName) watched := sets.New(w.ResourceNames...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/model/context.go
// force the response. It is important to respond to those requests for Envoy to finish // warming of those resources(Clusters). // This can happen with the following sequence // 1. Envoy disconnects and reconnects to Istiod. // 2. Envoy sends EDS request and we respond with it. // 3. Envoy sends CDS request and we respond with clusters.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
docs/en/docs/tutorial/security/first-steps.md
If it doesn't see an `Authorization` header, or the value doesn't have a `Bearer ` token, it will respond with a 401 status code error (`UNAUTHORIZED`) directly. You don't even have to check if the token exists to return an error. You can be sure that if your function is executed, it will have a `str` in that token.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon Jun 03 01:48:20 UTC 2024 - 9.1K bytes - Viewed (0) -
cmd/handler-utils.go
return matches[1] } return "unknown" } func methodNotAllowedHandler(api string) func(w http.ResponseWriter, r *http.Request) { return errorResponseHandler } // If none of the http routes match respond with appropriate errors func errorResponseHandler(w http.ResponseWriter, r *http.Request) { if r.Method == http.MethodOptions { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
pkg/kubelet/server/server.go
} func (a *filteringContainer) RegisteredHandlePaths() []string { return a.registeredHandlePaths } // ListenAndServeKubeletServer initializes a server to respond to HTTP network requests on the Kubelet. func ListenAndServeKubeletServer( host HostInterface, resourceAnalyzer stats.ResourceAnalyzer, kubeCfg *kubeletconfiginternal.KubeletConfiguration, tlsOptions *TLSOptions,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
api/openapi-spec/v3/apis__batch__v1_openapi.json
to expiration (generally five to fifteen minutes) or a configuration change on the server, the server will respond with a 410 ResourceExpired error together with a continue token. If the client needs a consistent list, it must restart their list without the continue field. Otherwise, the client may send another list request with the token received with the 410 error, the server will respond with a list starting from the next key, but from the latest snapshot, which is inconsistent from the previous...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 485.4K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
# E1023 04:03:58.150266 4840 reflector.go:205] k8s.io/kubernetes/pkg/client/informers/informers_generated/internalversion/factory.go:129: Failed to list *core.Service: Get https://35....
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
cluster/gce/upgrade.sh
NODE_PROBLEM_DETECTOR_TOKEN=$(dd if=/dev/urandom bs=128 count=1 2>/dev/null | base64 | tr -d "=+/" | dd bs=32 count=1 2>/dev/null) fi } function wait-for-master() { echo "== Waiting for new master to respond to API requests ==" local curl_auth_arg if [[ -n ${KUBE_BEARER_TOKEN:-} ]]; then curl_auth_arg=(-H "Authorization: Bearer ${KUBE_BEARER_TOKEN}") elif [[ -n ${KUBE_PASSWORD:-} ]]; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 25.2K bytes - Viewed (0) -
src/net/http/transport_test.go
test.respond("HTTP/1.1 100 Continue") test.wantBodySent() test.respond("HTTP/1.1 200", "Content-Length: 0") test.wantRequestDone(200) } func TestTransportExpect100Continue200ResponseNoConnClose(t *testing.T) { test := newTransport100ContinueTest(t, 1*time.Hour) // No 100 Continue response, no Connection: close header. test.respond("HTTP/1.1 200", "Content-Length: 0")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0)