- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Switch0 (0.14 sec)
-
pilot/pkg/config/kube/gateway/conversion.go
if match.Uri == nil { return -1 } switch match.Uri.MatchType.(type) { case *istio.StringMatch_Exact: return 3 case *istio.StringMatch_Prefix: return 2 case *istio.StringMatch_Regex: return 1 } // should not happen return -1 } func getURILength(match *istio.HTTPMatchRequest) int { if match.Uri == nil { return 0 } switch match.Uri.MatchType.(type) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging.go
const telemetryAccessLogHandled = 14 func telemetryAccessLog(push *PushContext, fp *meshconfig.MeshConfig_ExtensionProvider) *accesslog.AccessLog { var al *accesslog.AccessLog switch prov := fp.Provider.(type) { case *meshconfig.MeshConfig_ExtensionProvider_EnvoyFileAccessLog: // For built-in provider, fallback to MeshConfig for formatting options when LogFormat unset.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 23K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// Refer https://docs.docker.com/storage/bind-mounts/#configure-bind-propagation. return runtimeapi.MountPropagation_PROPAGATION_PRIVATE, nil } switch { case mountMode == nil: // PRIVATE is the default return runtimeapi.MountPropagation_PROPAGATION_PRIVATE, nil case *mountMode == v1.MountPropagationHostToContainer:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_internal.h
~CEvent() override { Destroy(); } Event::Status PollForStatus() override { SE_EventStatus event_status = stream_executor_->get_event_status(device_, event_handle_); switch (event_status) { case SE_EVENT_ERROR: return Event::Status::kError; case SE_EVENT_PENDING: return Event::Status::kPending; case SE_EVENT_COMPLETE:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 8K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} // if Content-Length is unknown/missing, throw away size := r.ContentLength rAuthType := getRequestAuthType(r) // For auth type streaming signature, we need to gather a different content length. switch rAuthType { // Check signature types that must have content length case authTypeStreamingSigned, authTypeStreamingSignedTrailer, authTypeStreamingUnsignedTrailer: if sizeStr, ok := r.Header[xhttp.AmzDecodedContentLength]; ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0) -
cmd/object-handlers.go
writeResponse(w, serr.HTTPStatusCode(), encodedErrorResponse, mimeXML) } else { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) } return } // Set encryption response headers switch kind, _ := crypto.IsEncrypted(objInfo.UserDefined); kind { case crypto.S3: w.Header().Set(xhttp.AmzServerSideEncryption, xhttp.AmzEncryptionAES) case crypto.S3KMS:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
cmd/bucket-handlers.go
v := strings.ToLower(vs) switch v { case "true", "false": objectLockEnabled = v == "true" default: writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL) return } } forceCreate := false if vs := r.Header.Get(xhttp.MinIOForceCreate); len(vs) > 0 { v := strings.ToLower(vs) switch v { case "true", "false": forceCreate = v == "true"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
ResourceNames: req.Delta.Subscribed.UnsortedList(), } } var res model.Resources var deletedRes model.DeletedResources var logdata model.XdsLogDetails var usedDelta bool var err error switch g := gen.(type) { case model.XdsDeltaResourceGenerator: res, deletedRes, logdata, usedDelta, err = g.GenerateDeltas(con.proxy, req, w) if features.EnableUnsafeDeltaTest {
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/config/kube/crdclient/client.go
return nil, fmt.Errorf("failed marhsalling original resource: %v", err) } newJSON, err := json.Marshal(modRes) if err != nil { return nil, fmt.Errorf("failed marhsalling modified resource: %v", err) } switch patchType { case types.JSONPatchType: ops, err := jsonpatch.CreatePatch(oldJSON, newJSON) if err != nil { return nil, err } return json.Marshal(ops) case types.MergePatchType:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
} // Verify listener access log. verify(t, tc.encoding, l.AccessLog[0], tc.wantFormat) for _, fc := range l.FilterChains { for _, filter := range fc.Filters { switch filter.Name { case wellknown.TCPProxy: tcpConfig := &tcp.TcpProxy{} if err := filter.GetTypedConfig().UnmarshalTo(tcpConfig); err != nil { t.Fatal(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0)