- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 968 for Patches (0.2 sec)
-
pkg/config/mesh/kubemesh/watcher.go
}) go c.Run(stop) // Ensure the ConfigMap is initially loaded if present. if !client.WaitForCacheSync("configmap watcher", stop, c.HasSynced) { log.Error("failed to wait for cache sync") } return w } func AddUserMeshConfig(client kube.Client, watcher mesh.Watcher, namespace, key, userMeshConfig string, stop <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 20:54:46 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
func NewFixedWatcher(mesh *meshconfig.MeshConfig) Watcher { iw := internalWatcher{} iw.MeshConfig.Store(mesh) return &iw } // NewFileWatcher creates a new Watcher for changes to the given mesh config file. Returns an error // if the given file does not exist or failed during parsing. func NewFileWatcher(fileWatcher filewatcher.FileWatcher, filename string, multiWatch bool) (Watcher, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authorization/cel/matcher.go
Rita Zhang <******@****.***> 1709268932 -0800
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 22:41:27 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/keycertbundle/watcher.go
id := w.watcherID w.watchers[id] = ch w.watcherID++ return id, ch } // RemoveWatcher removes the given watcher. func (w *Watcher) RemoveWatcher(id int32) { w.mutex.Lock() defer w.mutex.Unlock() ch := w.watchers[id] if ch != nil { close(ch) } delete(w.watchers, id) } // SetAndNotify sets the key cert and root cert and notify the watchers.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 05 14:00:18 UTC 2023 - 2.6K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
const maxStaleRetries = 10 const msInterval = 10 retries := 0 var ambientPod *corev1.Pod var err error // The plugin already consulted the k8s API - but on this end handler caches may be stale, so retry a few times if we get no pod. // if err is returned, we couldn't find the pod // if nil is returned, we found it but ambient is not enabled
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/selection_predicate.go
if matched && s.Field != nil { matched = (matched && s.Field.Matches(f)) } return matched } // MatchesSingleNamespace will return (namespace, true) if and only if s.Field matches on the object's // namespace. func (s *SelectionPredicate) MatchesSingleNamespace() (string, bool) { if len(s.Continue) > 0 || s.Field == nil { return "", false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 5.6K bytes - Viewed (0) -
tests/fuzz/regression_test.go
bytes, err := os.ReadFile(path) if err != nil { return err } matched := pattern.FindAllString(string(bytes), -1) for _, m := range matched { // Add the match, with trailing ( and previous `func ` stripped matches = append(matches, m[5:len(m)-1]) } return nil }) if err != nil { return nil, err } return matches, nil } func TestFuzzers(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 10 16:43:09 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/persistent_volume_claims.go
return true } if op == admission.Update { return true } return false } // Matches returns true if the evaluator matches the specified quota with the provided input item func (p *pvcEvaluator) Matches(resourceQuota *corev1.ResourceQuota, item runtime.Object) (bool, error) { return generic.Matches(resourceQuota, item, p.MatchingResources, generic.MatchesNoScopeFunc) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 23:36:24 UTC 2022 - 9.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/internal/match.go
) // TODO: consider if (some of the) matching algorithm needs to be public after // getting some feel about what is generic and what is specific. // NewInheritanceMatcher returns a matcher that matches based on the inheritance // chain. // // The matcher uses canonicalization and the parent relationship to find a // match. The resulting match will always be either Und or a language with the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go
}{ { name: "add a new node with matched pod affinity topologyKey", pod: st.MakePod().Name("p").PodAffinityIn("service", "zone", []string{"securityscan", "value2"}, st.PodAffinityWithRequiredReq).Obj(), newNode: st.MakeNode().Name("node-a").Label("zone", "zone1").Obj(), expectedHint: framework.Queue, }, { name: "add a new node with matched pod anti-affinity topologyKey",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 9.7K bytes - Viewed (0)