- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,083 for watched (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
t.Errorf("Unexpected object watched: %s, expected %s", a, e) } watched++ } // We expect at least N events to be delivered, depending on the implementation. // For now, this number is smallest for Cacher and it equals 10 (size of the out buffer). if watched < 10 { t.Errorf("Unexpected number of events: %v, expected: %v", watched, totalPods) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/filewatcher/filewatcher_test.go
os.Symlink(path.Join(watchDir, "data", "test.conf"), watchFile) fmt.Printf("Watch file location: %s\n", path.Join(watchDir, "test.conf")) return watchDir, watchFile } func TestWatchFile(t *testing.T) { t.Run("file content changed", func(t *testing.T) { g := NewGomegaWithT(t) // Given a file being watched watchFile := newWatchFile(t) _, err := os.Stat(watchFile)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/filewatcher/fakefilewatcher.go
if ok { ch <- err } } // NewFakeWatcher returns a function which creates a new fake watcher for unit // testing. This allows observe callers to inject events and errors per-watched // path. changedFunc() provides a callback notification when a new watch is added // or removed. Production code should use `NewWatcher()`. func NewFakeWatcher(changedFunc func(path string, added bool)) (NewFileWatcherFunc, *FakeWatcher) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 14:06:41 UTC 2023 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/result.go
} return nil, nil } // Watch retrieves changes that occur on the server to the specified resource. // It currently supports watching a single source - if the resource source // (selectors or pure types) can be watched, they will be, otherwise the list // will be visited (equivalent to the Infos() call) and if there is a single // resource present, it will be watched, otherwise an error will be returned.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 23:00:24 UTC 2019 - 7.3K bytes - Viewed (0) -
pkg/xds/server.go
// TypeUrl is copied from the DiscoveryRequest.TypeUrl that initiated watching this resource. // nolint TypeUrl string // ResourceNames tracks the list of resources that are actively watched. // For LDS and CDS, all resources of the TypeUrl type are watched if it is empty. // For endpoints the resource names will have list of clusters and for clusters it is empty. // For Delta Xds, all resources of the TypeUrl that a client has subscribed to.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/networking/core/configgen.go
// that have been deleted and should be removed from a given proxy. This is Delta CDS output. BuildDeltaClusters(proxy *model.Proxy, updates *model.PushRequest, watched *model.WatchedResource) ([]*discovery.Resource, []string, model.XdsLogDetails, bool) // BuildHTTPRoutes returns the list of HTTP routes for the given proxy. This is the RDS output
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.go
) // Watcher is the plugin watcher type Watcher struct { path string fs utilfs.Filesystem fsWatcher *fsnotify.Watcher desiredStateOfWorld cache.DesiredStateOfWorld } // NewWatcher provides a new watcher for socket registration func NewWatcher(sockDir string, desiredStateOfWorld cache.DesiredStateOfWorld) *Watcher { return &Watcher{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 6.1K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
func (f *ConfigGenTest) DeltaClusters( p *model.Proxy, configUpdated sets.Set[model.ConfigKey], watched *model.WatchedResource, ) ([]*cluster.Cluster, []string, bool) { raw, removed, _, delta := f.ConfigGen.BuildDeltaClusters(p, &model.PushRequest{ Push: f.PushContext(), ConfigsUpdated: configUpdated, }, watched) res := make([]*cluster.Cluster, 0, len(raw)) for _, r := range raw { c := &cluster.Cluster{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go
if err != nil { switch err { case io.EOF: // watch closed normally case io.ErrUnexpectedEOF: klog.V(1).Infof("Unexpected EOF during watch stream event decoding: %v", err) default: if net.IsProbableEOF(err) || net.IsTimeout(err) { klog.V(5).Infof("Unable to decode an event from the watch stream: %v", err) } else { select { case <-sw.done:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 06 13:42:59 UTC 2021 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/types.go
// Afterwards, the watch stream will proceed as usual, sending watch events // corresponding to changes (subsequent to the RV) to objects watched. // // When `sendInitialEvents` option is set, we require `resourceVersionMatch` // option to also be set. The semantic of the watch request is as following: // - `resourceVersionMatch` = NotOlderThan
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 09:55:40 UTC 2023 - 4.5K bytes - Viewed (0)