- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for capsule (0.19 sec)
-
pilot/pkg/networking/core/cluster.go
ingressPortListSet = getSidecarIngressPortList(proxy) } for _, instance := range instances { // For service instances with the same port, // we still need to capture all the instances on this port, as its required to populate telemetry metadata // The first instance will be used as the "primary" instance; this means if we have an conflicts between // Services the first one wins
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc
// Compute a refined type between two types `lhs` and `rhs`, the result type // is always more refined (i.e. has more static information) than `lhs` // This method will actually merge the information contained in the // types, it is capable of refining: // tensor<!tf_type.variant<tensor<?x8xf32>>> // and: // tensor<!tf_type.variant<tensor<10x?xf32>>> // into: // tensor<!tf_type.variant<tensor<10x8xf32>>> //
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Jun 08 07:28:49 UTC 2024 - 134.1K bytes - Viewed (0) -
pkg/config/analysis/analyzers/analyzers_test.go
requestedInputsByAnalyzer := make(map[string]map[config.GroupVersionKind]struct{}) // For each test case, verify we get the expected messages as output for _, tc := range testGrid { tc := tc // Capture range variable so subtests work correctly t.Run(tc.name, func(t *testing.T) { g := NewWithT(t) // Set up a hook to record which collections are accessed by each analyzer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 07:22:31 UTC 2024 - 42.6K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
func (lb *ListenerBuilder) inboundVirtualListener(chains []*listener.FilterChain) *listener.Listener { actualWildcards, _ := getWildcardsAndLocalHost(lb.node.GetIPMode()) // Build the "virtual" inbound listener. This will capture all inbound redirected traffic and contains: // * Passthrough filter chains, matching all unmatched traffic. There are a few of these to handle all cases
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
cmd/test-utils_test.go
failTestStr := func(testType, failMsg string) string { return fmt.Sprintf("MinIO %s: %s fail for \"%s\": \n<Error> %s", instanceType, testType, testName, failMsg) } // httptest Recorder to capture all the response by the http handler. rec := httptest.NewRecorder() // reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
pkg/features/kube_features.go
TranslateStreamCloseWebsocketRequests featuregate.Feature = "TranslateStreamCloseWebsocketRequests" // owner: @richabanker // alpha: v1.28 // // Proxies client to an apiserver capable of serving the request in the event of version skew. UnknownVersionInteroperabilityProxy featuregate.Feature = "UnknownVersionInteroperabilityProxy" // owner: @rata, @giuseppe // kep: https://kep.k8s.io/127
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0) -
src/os/exec/exec.go
} runtime.SetFinalizer(cmd, func(c *Cmd) { if c.Process != nil && c.ProcessState == nil { debugHint := "" if c.createdByStack == nil { debugHint = " (set GODEBUG=execwait=2 to capture stacks for debugging)" } else { os.Stderr.WriteString("GODEBUG=execwait=2 detected a leaked exec.Cmd created by:\n") os.Stderr.Write(c.createdByStack) os.Stderr.WriteString("\n") debugHint = ""
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
// Note that this test simulates a net-new pod being discovered during HandlePodCleanups that was not // delivered to the pod worker via HandlePodAdditions - there is no *known* scenario that can happen, but // we want to capture it in the metric. The more likely scenario is that a static pod with a predefined // UID is updated, which causes pod config to deliver DELETE -> ADD while the old pod is still shutting
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc
} else { // If `allow_tensorlist_pass_through` is set to true, if legalization fails // we should not leak the diagnostic info outside this pass. Hence we use // a `StatusScopedDiagnosticHandler` here to capture diagnostics generated // within this pass. StatusScopedDiagnosticHandler handler(context); if (failed(applyPartialConversion(module, target, std::move(patterns)))) { auto _ = handler.ConsumeStatus();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 20:00:43 UTC 2024 - 70.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
+ " ms]"; } return null; } @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private void addPendingString(StringBuilder builder) { // Capture current builder length so it can be truncated if this future ends up completing while // the toString is being calculated int truncateLength = builder.length(); builder.append("PENDING");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1)