- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,853 for Patches (0.34 sec)
-
pilot/pkg/xds/debug.go
s.addDebugHandler(mux, internalMux, "/debug/cachez", "Info about the internal XDS caches", s.cachez) s.addDebugHandler(mux, internalMux, "/debug/cachez?sizes=true", "Info about the size of the internal XDS caches", s.cachez) s.addDebugHandler(mux, internalMux, "/debug/cachez?clear=true", "Clear the XDS caches", s.cachez) s.addDebugHandler(mux, internalMux, "/debug/configz", "Debug support for config", s.configz)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
} kl.setNodeStatus(ctx, node) changed := podCIDRChanged || nodeStatusHasChanged(&originalNode.Status, &node.Status) || areRequiredLabelsNotPresent return node, changed } // patchNodeStatus patches node on the API server based on originalNode. // It returns any potential error, or an updatedNode and refreshes the state of kubelet when successful. func (kl *Kubelet) patchNodeStatus(originalNode, node *v1.Node) (*v1.Node, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/registry/core/service/storage/alloc.go
for i, ip := range service.Spec.ClusterIPs { if ip == api.ClusterIPNone { break } // We previously validated that IPs are well-formed and that if an // ipFamilies[] entry exists it matches the IP. fam := familyOf(ip) // If the corresponding family is not specified, add it. if i >= len(service.Spec.IPFamilies) { // Families are checked more later, but this is a better error in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
}, } kubelet.updateRuntimeUp() assert.NoError(t, kubelet.updateNodeStatus(ctx)) actions := kubeClient.Actions() require.Len(t, actions, 2) require.True(t, actions[1].Matches("patch", "nodes")) require.Equal(t, actions[1].GetSubresource(), "status") updatedNode, err := applyNodeStatusPatch(&existingNode, actions[1].(core.PatchActionImpl).GetPatch()) assert.NoError(t, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/listener_patch_test.go
"xffNumTrustedHops": "4" } }`), }, }, // Ensure we can mix v3 patches with v2 internal // Note that alwaysSetRequestIdInResponse is only present in v3 protos. It will be silently ignored // as we are working in v2 protos internally { ApplyTo: networking.EnvoyFilter_NETWORK_FILTER,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 70.1K bytes - Viewed (0) -
cmd/kubeadm/app/preflight/checks.go
} // Checks if k8sVersion greater or equal than the first unsupported versions by current version of kubeadm, // that is major.minor+1 (all patch and pre-releases versions included) // NB. in semver patches number is a numeric, while pre-release is a string where numeric identifiers always have lower precedence than non-numeric identifiers.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:20:55 UTC 2024 - 39.5K bytes - Viewed (0) -
pilot/pkg/networking/core/listener.go
// filter chain match, into a single filter chain and array of destinationcidr matches // The code below checks for TCP over TCP conflicts and merges listeners // Merge the newly built listener with the existing listener, if and only if the filter chains have distinct conditions. // Extract the current filter chain matches, for every new filter chain match being added, check if there is a matching
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/util/Matchers.java
} }; } @Factory public static Matcher<Throwable> hasMessage(final Matcher<String> matcher) { return new BaseMatcher<Throwable>() { @Override public boolean matches(Object o) { Throwable t = (Throwable) o; return matcher.matches(t.getMessage()); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
return &c, nil } // WebhookParameters configures parameters for the sidecar injection // webhook. type WebhookParameters struct { // Watcher watches the sidecar injection configuration. Watcher Watcher // Port is the webhook port, e.g. typically 443 for https. // This is mainly used for tests. Webhook runs on the port started by Istiod. Port int Env *model.Environment
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matchers.go
// Any doesn't filter out any echos. var Any Matcher = func(_ echo.Instance) bool { return true } // And is an aggregate Matcher that requires all matches return true. func And(ms ...Matcher) Matcher { return func(i echo.Instance) bool { for _, m := range ms { if m != nil && !m(i) { return false } } return true } } // Or is an aggregate Matcher that requires at least one matches return true.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 5.6K bytes - Viewed (0)