File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
util/src/test/java/io/kubernetes/client/informer/cache Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -36,15 +36,20 @@ public void testControllerProcessDeltas() {
36
36
AtomicInteger receivingDeltasCount = new AtomicInteger (0 );
37
37
V1Pod foo1 = new V1Pod ().metadata (new V1ObjectMeta ().name ("foo1" ).namespace ("default" ));
38
38
V1Pod foo2 = new V1Pod ().metadata (new V1ObjectMeta ().name ("foo2" ).namespace ("default" ));
39
- V1Pod foo3 = new V1Pod ().metadata (new V1ObjectMeta ().name ("foo3" ).namespace ("default" ));
39
+ V1Pod foo3 =
40
+ new V1Pod ()
41
+ .metadata (new V1ObjectMeta ().name ("foo3" ).namespace ("default" ).resourceVersion ("rva" ));
42
+ V1Pod foo3Updated =
43
+ new V1Pod ()
44
+ .metadata (new V1ObjectMeta ().name ("foo3" ).namespace ("default" ).resourceVersion ("rvb" ));
40
45
41
46
V1PodList podList =
42
47
new V1PodList ().metadata (new V1ListMeta ()).items (Arrays .asList (foo1 , foo2 , foo3 ));
43
48
DeltaFIFO deltaFIFO = new DeltaFIFO (Caches ::deletionHandlingMetaNamespaceKeyFunc , new Cache ());
44
49
45
50
ListerWatcher <V1Pod , V1PodList > listerWatcher =
46
51
new MockRunOnceListerWatcher <V1Pod , V1PodList >(
47
- podList , new Watch .Response <V1Pod >(EventType .MODIFIED .name (), foo3 ));
52
+ podList , new Watch .Response <V1Pod >(EventType .MODIFIED .name (), foo3Updated ));
48
53
49
54
Controller <V1Pod , V1PodList > controller =
50
55
new Controller <>(
You can’t perform that action at this time.
0 commit comments