- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 988 for watcher (3.31 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
if err != nil { t.Fatalf("Unexpected error: %v", err) } podCreated := objCreated.(*example.Pod) watcher, err := registry.WatchPredicate(testContext, matchPodName("foo"), podCreated.ResourceVersion, nil) if err != nil { t.Fatalf("Unexpected error: %v", err) } defer watcher.Stop()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
// PluginHandler is the plugin registration handler interface passed to the // pluginwatcher module in kubelet var PluginHandler = &RegistrationHandler{} // ValidatePlugin is called by kubelet's plugin watcher upon detection // of a new registration socket opened by CSI Driver registrar side car. func (h *RegistrationHandler) ValidatePlugin(pluginName string, endpoint string, versions []string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
podCache kubecontainer.Cache // os is a facade for various syscalls that need to be mocked during testing. os kubecontainer.OSInterface // Watcher of out of memory events. oomWatcher oomwatcher.Watcher // Monitor resource usage resourceAnalyzer serverstats.ResourceAnalyzer // Whether or not we should have the QOS cgroup hierarchy for resource management cgroupsPerQOS bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
if !apiequality.Semantic.DeepDerivative(rsSpec, testRSSpec) { t.Errorf("Expected %#v, but got %#v", testRSSpec, rsSpec) } close(received) return nil } // Start only the ReplicaSet watcher and the workqueue, send a watch event, // and make sure it hits the sync method. go wait.UntilWithContext(tCtx, manager.worker, 10*time.Millisecond) testRSSpec.Name = "foo" fakeWatch.Add(&testRSSpec) select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/test/framework/resource/matcher.go
"regexp" "strconv" "strings" ) // testFilter is a regex matcher on a test. It is split by / following go subtest format type testFilter []*regexp.Regexp type Matcher struct { filters []testFilter } // NewMatcher reimplements the logic of Go's -test.run. The code is mostly directly copied from Go's source. func NewMatcher(regexs []string) (*Matcher, error) { filters := []testFilter{} for _, regex := range regexs {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 12 23:30:37 UTC 2021 - 3.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matcher.go
// GetServiceMatches returns the subset of echo.Services that match this Matcher. func (m Matcher) GetServiceMatches(services echo.Services) echo.Services { out := make(echo.Services, 0) for _, s := range services { if len(s) > 0 && m(s[0]) { out = append(out, s) } } return out } // First finds the first Instance that matches the Matcher. func (m Matcher) First(i echo.Instances) (echo.Instance, error) { for _, i := range i {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 20:45:12 UTC 2023 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/namespace/matcher.go
} // Matcher decides if a request is exempted by the NamespaceSelector of a // webhook configuration. type Matcher struct { NamespaceLister corelisters.NamespaceLister Client clientset.Interface } func (m *Matcher) GetNamespace(name string) (*v1.Namespace, error) { return m.NamespaceLister.Get(name) } // Validate checks if the Matcher has a NamespaceLister and Client.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 15 00:53:08 UTC 2023 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/matchconditions/matcher.go
return v.Expression } func (v *MatchCondition) ReturnTypes() []*cel.Type { return []*cel.Type{cel.BoolType} } var _ Matcher = &matcher{} // matcher evaluates compiled cel expressions and determines if they match the given request or not type matcher struct { filter celplugin.Filter failPolicy v1.FailurePolicyType matcherType string matcherKind string objectName string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 14:46:11 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/object/matcher.go
return false } return selector.Matches(labels.Set(accessor.GetLabels())) } // MatchObjectSelector decideds whether the request matches the ObjectSelector // of the webhook. Only when they match, the webhook is called. func (m *Matcher) MatchObjectSelector(p ObjectSelectorProvider, attr admission.Attributes) (bool, *apierrors.StatusError) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 26 00:41:14 UTC 2022 - 1.8K 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)