/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/manager/state/ |
H A D | watch.go | 25 _, 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 D | rc.go | 156 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 D | basic_test.go | 133 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 D | basic_test.go | 133 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 D | basic_test.go | 130 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 D | UpdateInterference.java | 96 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 D | UpdateInterference.java | 96 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 D | UpdateInterference.java | 103 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 D | UpdateInterference.java | 103 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 D | UpdateInterference.java | 103 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 D | UpdateInterference.java | 103 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 D | UpdateInterference.java | 103 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 D | UpdateInterference.java | 103 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 D | UpdateInterference.java | 103 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 D | UpdateInterference.java | 103 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 D | check_watcher.go | 110 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 D | imselector.cpp | 60 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 D | luaaddonstate.cpp | 74 {"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 D | wait.go | 314 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 D | wait.go | 305 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 D | wait.go | 317 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 D | classicui.cpp | 185 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 D | watch.go | 15 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 D | watch.go | 15 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 D | watch.go | 15 func (e EventCommit) Matches(watchEvent events.Event) bool { 16 _, ok := watchEvent.(EventCommit)
|