- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 695 for WATCH (0.1 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake/clientset_generated.go
cs.AddReactor("*", "*", testing.ObjectReaction(o)) cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { gvr := action.GetResource() ns := action.GetNamespace() watch, err := o.Watch(gvr, ns) if err != nil { return false, nil, err } return true, watch, nil }) return cs } // Clientset implements clientset.Interface. Meant to be embedded into a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
fs.BoolVar(&s.EnableWatchCache, "watch-cache", s.EnableWatchCache, "Enable watch caching in the apiserver") fs.IntVar(&s.DefaultWatchCacheSize, "default-watch-cache-size", s.DefaultWatchCacheSize, "Default watch cache size. If zero, watch cache will be disabled for resources that do not have a default watch size set.") fs.MarkDeprecated("default-watch-cache-size",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/response.go
// that we're effectively serializing the whole watch event, but storing // it in serializations of the Object within the watch event. identifier := watchEncoderIdentifier{ Name: "watch", EmbeddedEncoder: string(e.embeddedEncoder.Identifier()), Encoder: string(e.encoder.Identifier()), EventType: string(eventType), } result, err := json.Marshal(identifier) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 09:07:03 UTC 2023 - 16.5K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
gvr := action.GetResource() ns := action.GetNamespace() watch, err := fc.Tracker().Watch(gvr, ns) if err != nil { return false, nil, err } // Kubernetes Fake watches do not add initial state, but real server does // https://kubernetes.io/docs/reference/using-api/api-concepts/#semantics-for-watch
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 6.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux_test.go
} m.Shutdown() wg.Wait() } func TestBroadcasterWatcherClose(t *testing.T) { m := NewBroadcaster(0, WaitIfChannelFull) w, err := m.Watch() if err != nil { t.Fatalf("Unable start event watcher: '%v' (will not retry!)", err) } w2, err := m.Watch() if err != nil { t.Fatalf("Unable start event watcher: '%v' (will not retry!)", err) } w.Stop() m.Shutdown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:25 UTC 2022 - 8K bytes - Viewed (0) -
api/discovery/apis__admissionregistration.k8s.io__v1alpha1.json
"storageVersionHash": "6OxvlMmQ6is=", "verbs": [ "create", "delete", "deletecollection", "get", "list", "patch", "update", "watch" ] }, { "kind": "ValidatingAdmissionPolicy", "name": "validatingadmissionpolicies/status", "namespaced": false, "singularName": "", "verbs": [ "get",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 20:14:51 UTC 2024 - 1.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// Add grpc context metadata to watch and progress notify requests done by cacher to: // * Prevent starvation of watch opened by cacher, by moving it to separate Watch RPC than watch request that bypass cacher. // * Ensure that progress notification requests are executed on the same Watch RPC as their watch, which is required for it to work.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/artifacts/openapi/swagger-with-shared-parameters.json
}, { "$ref": "#/parameters/watch--CFxmTDM" } ] }, "/api/v1/watch/configmaps": { "get": { "consumes": [ "*/*" ], "description": "watch individual changes to a list of ConfigMap. deprecated: use the 'watch' parameter with a list operation instead.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 2.3M bytes - Viewed (0) -
pkg/volume/flexvolume/probe.go
} prober.eventsMap[eventDirAbs] = op } // Recursively adds to watch all directories inside and including the file specified by the given filename. // If the file is a symlink to a directory, it will watch the symlink but not any of the subdirectories. // // Each file or directory change triggers two events: one from the watch on itself, another from the watch // on its parent directory.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 9K bytes - Viewed (0) -
api/discovery/apis__flowcontrol.apiserver.k8s.io__v1beta3.json
"storageVersionHash": "GJVAJZSZBIw=", "verbs": [ "create", "delete", "deletecollection", "get", "list", "patch", "update", "watch" ] }, { "kind": "FlowSchema", "name": "flowschemas/status", "namespaced": false, "singularName": "", "verbs": [ "get", "patch",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 25 06:24:50 UTC 2023 - 1.3K bytes - Viewed (0)