Home
last modified time | relevance | path

Searched refs:watchEvent (Results 1 – 25 of 102) sorted by relevance

12345

/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/manager/state/
H A Dwatch.go25 _, ok := watchEvent.(EventCommit)
64 typedEvent, ok := watchEvent.(EventCreateTask)
88 typedEvent, ok := watchEvent.(EventUpdateTask)
112 typedEvent, ok := watchEvent.(EventDeleteTask)
145 typedEvent, ok := watchEvent.(EventCreateService)
169 typedEvent, ok := watchEvent.(EventUpdateService)
193 typedEvent, ok := watchEvent.(EventDeleteService)
226 typedEvent, ok := watchEvent.(EventCreateNetwork)
312 typedEvent, ok := watchEvent.(EventCreateNode)
336 typedEvent, ok := watchEvent.(EventUpdateNode)
[all …]
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/apps/
H A Drc.go156 if watchEvent.Type != watch.Added {
159 actualWatchEvents = append(actualWatchEvents, watchEvent)
172 rcBytes, err := json.Marshal(watchEvent.Object)
205 if watchEvent.Type != watch.Modified {
208 actualWatchEvents = append(actualWatchEvents, watchEvent)
233 if watchEvent.Type != watch.Modified {
246 rcBytes, err := json.Marshal(watchEvent.Object)
287 if watchEvent.Type != watch.Modified {
301 rcBytes, err := json.Marshal(watchEvent.Object)
338 if watchEvent.Type != watch.Modified {
[all …]
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiextensions-apiserver/test/integration/
H A Dbasic_test.go133 case watchEvent := <-noxuWatch.ResultChan():
134 if e, a := watch.Added, watchEvent.Type; e != a {
144 t.Errorf("missing uuid: %#v", watchEvent.Object)
243 case watchEvent := <-noxuWatch.ResultChan():
249 if watchEvent.Type != watch.Modified {
285 case watchEvent := <-noxuWatch.ResultChan():
291 if watchEvent.Type != watch.Deleted {
422 case watchEvent := <-noxuWatch.ResultChan():
423 if e, a := watch.Added, watchEvent.Type; e != a {
491 case watchEvent := <-noxuWatch.ResultChan():
[all …]
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apiextensions-apiserver/test/integration/
H A Dbasic_test.go133 case watchEvent := <-noxuWatch.ResultChan():
134 if e, a := watch.Added, watchEvent.Type; e != a {
144 t.Errorf("missing uuid: %#v", watchEvent.Object)
243 case watchEvent := <-noxuWatch.ResultChan():
249 if watchEvent.Type != watch.Modified {
285 case watchEvent := <-noxuWatch.ResultChan():
291 if watchEvent.Type != watch.Deleted {
422 case watchEvent := <-noxuWatch.ResultChan():
423 if e, a := watch.Added, watchEvent.Type; e != a {
491 case watchEvent := <-noxuWatch.ResultChan():
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/apiextensions-apiserver/test/integration/
H A Dbasic_test.go130 case watchEvent := <-noxuWatch.ResultChan():
131 if e, a := watch.Added, watchEvent.Type; e != a {
141 t.Errorf("missing uuid: %#v", watchEvent.Object)
240 case watchEvent := <-noxuWatch.ResultChan():
246 if watchEvent.Type != watch.Modified {
282 case watchEvent := <-noxuWatch.ResultChan():
288 if watchEvent.Type != watch.Deleted {
419 case watchEvent := <-noxuWatch.ResultChan():
420 if e, a := watch.Added, watchEvent.Type; e != a {
488 case watchEvent := <-noxuWatch.ResultChan():
[all …]
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/java/nio/file/WatchService/
H A DUpdateInterference.java96 for (WatchEvent<?> watchEvent : pollEvents) { in main()
97 System.out.println(watchEvent.count() + " " + in main()
98 watchEvent.kind() + " " + in main()
99 watchEvent.context()); in main()
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/java/nio/file/WatchService/
H A DUpdateInterference.java96 for (WatchEvent<?> watchEvent : pollEvents) { in main()
97 System.out.println(watchEvent.count() + " " + in main()
98 watchEvent.kind() + " " + in main()
99 watchEvent.context()); in main()
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) { in main()
104 System.out.println(watchEvent.count() + " " + in main()
105 watchEvent.kind() + " " + in main()
106 watchEvent.context()); in main()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) { in main()
104 System.out.println(watchEvent.count() + " " + in main()
105 watchEvent.kind() + " " + in main()
106 watchEvent.context()); in main()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) { in main()
104 System.out.println(watchEvent.count() + " " + in main()
105 watchEvent.kind() + " " + in main()
106 watchEvent.context()); in main()
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) { in main()
104 System.out.println(watchEvent.count() + " " + in main()
105 watchEvent.kind() + " " + in main()
106 watchEvent.context()); in main()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) { in main()
104 System.out.println(watchEvent.count() + " " + in main()
105 watchEvent.kind() + " " + in main()
106 watchEvent.context()); in main()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) {
104 System.out.println(watchEvent.count() + " " +
105 watchEvent.kind() + " " +
106 watchEvent.context());
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) { in main()
104 System.out.println(watchEvent.count() + " " + in main()
105 watchEvent.kind() + " " + in main()
106 watchEvent.context()); in main()
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/nio/file/WatchService/
H A DUpdateInterference.java103 for (WatchEvent<?> watchEvent : pollEvents) { in main()
104 System.out.println(watchEvent.count() + " " + in main()
105 watchEvent.kind() + " " + in main()
106 watchEvent.context()); in main()
/dports/sysutils/sensu-go/sensu-go-5.11.1/backend/schedulerd/
H A Dcheck_watcher.go110 case watchEvent, ok := <-watchChan:
112 c.handleWatchEvent(watchEvent)
127 func (c *CheckWatcher) handleWatchEvent(watchEvent store.WatchEventCheckConfig) {
128 check := watchEvent.CheckConfig
134 switch watchEvent.Action {
/dports/textproc/fcitx5/fcitx5-5.0.11/src/modules/imselector/
H A Dimselector.cpp60 eventHandlers_.emplace_back(instance_->watchEvent(
80 eventHandlers_.emplace_back(instance_->watchEvent(
108 eventHandlers_.emplace_back(instance_->watchEvent(
110 eventHandlers_.emplace_back(instance_->watchEvent(
113 instance_->watchEvent(EventType::InputContextSwitchInputMethod,
115 eventHandlers_.emplace_back(instance_->watchEvent(
/dports/textproc/fcitx5-lua/fcitx5-lua-5.0.5/src/addonloader/
H A Dluaaddonstate.cpp74 {"watchEvent", &LuaAddonState::watchEvent}, in LuaAddonState()
118 commitHandler_ = instance_->watchEvent( in LuaAddonState()
132 std::unique_ptr<HandlerTableEntry<EventHandler>> LuaAddonState::watchEvent( in watchEvent() function in fcitx::LuaAddonState
136 return instance_->watchEvent( in watchEvent()
176 handler = watchEvent<InputContextEvent>( in watchEventImpl()
180 handler = watchEvent<KeyEvent>( in watchEventImpl()
196 handler = watchEvent<CommitStringEvent>( in watchEventImpl()
206 handler = watchEvent<InputMethodNotificationEvent>( in watchEventImpl()
215 handler = watchEvent<InputContextSwitchInputMethodEvent>( in watchEventImpl()
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/kubectl/pkg/cmd/wait/
H A Dwait.go314 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, Wait{errOut: o.ErrOut}.IsDeleted)
318 return watchEvent.Object, true, nil
322 if watchEvent != nil {
323 return watchEvent.Object, false, errWaitTimeoutWithName
409 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, w.isConditionMet)
413 return watchEvent.Object, true, nil
417 if watchEvent != nil {
418 return watchEvent.Object, false, errWaitTimeoutWithName
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/kubectl/pkg/cmd/wait/
H A Dwait.go305 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, Wait{errOut: o.ErrOut}.IsDeleted)
309 return watchEvent.Object, true, nil
313 if watchEvent != nil {
314 return watchEvent.Object, false, errWaitTimeoutWithName
400 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, w.isConditionMet)
404 return watchEvent.Object, true, nil
408 if watchEvent != nil {
409 return watchEvent.Object, false, errWaitTimeoutWithName
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/kubectl/pkg/cmd/wait/
H A Dwait.go317 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, Wait{errOut: o.ErrOut}.IsDeleted)
321 return watchEvent.Object, true, nil
325 if watchEvent != nil {
326 return watchEvent.Object, false, errWaitTimeoutWithName
412 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, w.isConditionMet)
416 return watchEvent.Object, true, nil
420 if watchEvent != nil {
421 return watchEvent.Object, false, errWaitTimeoutWithName
/dports/textproc/fcitx5/fcitx5-5.0.11/src/ui/classic/
H A Dclassicui.cpp185 eventHandlers_.emplace_back(instance_->watchEvent( in resume()
193 eventHandlers_.emplace_back(instance_->watchEvent( in resume()
202 eventHandlers_.emplace_back(instance_->watchEvent( in resume()
210 eventHandlers_.emplace_back(instance_->watchEvent( in resume()
221 eventHandlers_.emplace_back(instance_->watchEvent( in resume()
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/
H A Dwatch.go15 func (e EventCommit) Matches(watchEvent events.Event) bool {
16 _, ok := watchEvent.(EventCommit)
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/manager/state/
H A Dwatch.go15 func (e EventCommit) Matches(watchEvent events.Event) bool {
16 _, ok := watchEvent.(EventCommit)
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/
H A Dwatch.go15 func (e EventCommit) Matches(watchEvent events.Event) bool {
16 _, ok := watchEvent.(EventCommit)

12345