- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,083 for watched (0.3 sec)
-
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/vfs/impl/WatchingVirtualFileSystem.java
import org.gradle.internal.watch.vfs.BuildLifecycleAwareVirtualFileSystem; import org.gradle.internal.watch.vfs.BuildStartedFileSystemWatchingBuildOperationType; import org.gradle.internal.watch.vfs.FileChangeListeners; import org.gradle.internal.watch.vfs.FileSystemWatchingStatistics; import org.gradle.internal.watch.vfs.VfsLogging; import org.gradle.internal.watch.vfs.WatchLogging;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 02 16:22:15 UTC 2024 - 25.2K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
if patched := cp.patch(nil, defaultCluster.build()); patched != nil { resources = append(resources, patched) if features.EnableCDSCaching { cb.cache.Add(&clusterKey, cb.req, patched) } } for _, ss := range subsetClusters { if patched := cp.patch(nil, ss); patched != nil { resources = append(resources, patched) if features.EnableCDSCaching {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/credentials/kube/secrets.go
expDelta *= 5 } log.Debugf("cached authorization for user %s: %v", user, response) s.authorizationCache[key] = authorizationResponse{ expiration: time.Now().Add(expDelta), authorized: response, } } func (s *CredentialsController) Authorize(serviceAccount, namespace string) error { user := sa.MakeUsername(namespace, serviceAccount) if cached, f := s.cachedAuthorization(user); f { return cached
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 10K bytes - Viewed (0) -
api/openapi-spec/v3/apis__resource.k8s.io__v1alpha2_openapi.json
"`sendInitialEvents=true` may be set together with `watch=true`. In that case, the watch stream will begin with synthetic events to produce the current state of objects in the collection. Once all such events have been sent, a synthetic \"Bookmark\" event will be sent. The bookmark will report the ResourceVersion (RV) corresponding to the set of objects, and be marked with `\"k8s.io/initial-events-end\": \"true\"` annotation. Afterwards, the watch stream will proceed as usual, sending watch events...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 12:18:45 UTC 2024 - 656.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
var prevResIps []*cniv1.IPConfig if conf.PrevResult != nil { prevResult := conf.PrevResult.(*cniv1.Result) prevResIps = prevResult.IPs } // Only send event if this pod "would be" an ambient-watched pod - otherwise skip if podIsAmbient { cniClient := newCNIClient(conf.CNIEventAddress, constants.CNIAddEventPath) if err = PushCNIEvent(cniClient, args, prevResIps, podName, podNamespace); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 10.7K bytes - Viewed (0) -
api/openapi-spec/v3/apis__rbac.authorization.k8s.io__v1_openapi.json
"in": "query", "name": "watch", "schema": { "type": "boolean", "uniqueItems": true } } ] }, "/apis/rbac.authorization.k8s.io/v1/watch/clusterrolebindings": { "get": { "description": "watch individual changes to a list of ClusterRoleBinding. deprecated: use the 'watch' parameter with a list operation instead.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 352.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
t.Errorf("Expected %v got %v", wantTag, labels.Instance(pod[0].Labels)) } } // This pod exists, but should not be in the cache because it is in a // namespace not watched by the controller. assert.Equal(t, c.pods.getPodsByIP("128.0.0.4"), nil) // This pod should not be in the cache because it never existed. assert.Equal(t, c.pods.getPodsByIP("128.0.0.128"), nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/model/context.go
type Environment struct { // Discovery interface for listing services and instances. ServiceDiscovery // Config interface for listing routing rules ConfigStore // Watcher is the watcher for the mesh config (to be merged into the config store) mesh.Watcher // NetworksWatcher (loaded from a config map) provides information about the // set of networks inside a mesh and how to route to endpoints in each
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
api/openapi-spec/v3/apis__networking.k8s.io__v1_openapi.json
(e.g. \"*.foo.com\"). The wildcard character '*' must appear by itself as the first DNS label and matches only a single label. You cannot have a wildcard label by itself (e.g. Host == \"*\"). Requests will be matched against the Host field in the following way: 1. If host is precise, the request matches this rule if the http host header is equal to Host. 2. If host is a wildcard, then the request matches this rule if the http host header is to equal to the suffix (removing the first label) of the wildcard...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 324.8K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
Labels map[string]string `json:"labels"` Metadata *model.NodeMetadata `json:"metadata,omitempty"` Locality *core.Locality `json:"locality,omitempty"` Watches map[string][]string `json:"watches,omitempty"` } // AdsClients is collection of AdsClient connected to this Istiod. type AdsClients struct { Total int `json:"totalClients"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0)