- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 2,558 for Patches (0.14 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
} // If user couldn't receive results fast enough, we also block incoming events from watcher. // Because storing events in local will cause more memory usage. // The worst case would be closing the fast watcher. select { case wc.resultChan <- *res: case <-wc.ctx.Done(): return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0)