Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for expectEvents (0.16 sec)

  1. pkg/kubelet/nodestatus/setters_test.go

    				"Diff: %s", cmp.Diff(tc.expectNode, tc.node))
    			// check expected events
    			require.Equal(t, len(tc.expectEvents), len(events))
    			for i := range tc.expectEvents {
    				assert.Equal(t, tc.expectEvents[i], events[i])
    			}
    		})
    	}
    
    }
    
    func TestVersionInfo(t *testing.T) {
    	cases := []struct {
    		desc                string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    		expectEvents(t, events,
    			Event{Type: "service", ID: "*.google.com", Namespace: httpStatic.Namespace},
    			Event{Type: "xds full", ID: "*.google.com"},
    		)
    
    		// add back httpStatic
    		createConfigs([]*config.Config{httpStatic}, store, t)
    		instances = baseInstances
    		expectServiceInstances(t, sd, httpStatic, 0, instances)
    		expectEvents(t, events,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/controller/repairip_test.go

    				_, err := r.ipAddressLister.Get(ip)
    				if err != nil {
    					t.Errorf("Unexpected error trying to get IPAddress %s object: %v", ip, err)
    				}
    			}
    
    			expectAction(t, c.Actions(), test.actions)
    			expectEvents(t, recorder.Events, test.events)
    		})
    	}
    
    }
    
    func TestRepairIPAddress_syncIPAddress(t *testing.T) {
    	tests := []struct {
    		name    string
    		ip      *networkingv1alpha1.IPAddress
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  4. platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReuseIntegrationTest.groovy

                    }
                }
            """
    
            given:
            executer.beforeExecute {
                executer.withStackTraceChecksDisabled()
            }
            expectEvent("started")
            expectEvent("block")
            def client = new DaemonClientFixture(executer.withArgument("--debug").withTasks("block").start())
            waitFor("started")
            daemons.daemon.assertBusy()
            client.kill()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go

    		t.Errorf("time out after waiting %v on ResultChan", wait.ForeverTestTimeout)
    	}
    }
    
    func testCheckResult(t *testing.T, w watch.Interface, expectEvent watch.Event) {
    	testCheckResultFunc(t, w, func(actualEvent watch.Event) {
    		expectNoDiff(t, "incorrect event", expectEvent, actualEvent)
    	})
    }
    
    func testCheckResultFunc(t *testing.T, w watch.Interface, check func(actualEvent watch.Event)) {
    	select {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 22 07:26:55 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go

    					}
    				} else {
    					err := store.Delete(ctx, key, out, nil, storage.ValidateAllObjectFunc, nil)
    					if err != nil {
    						t.Fatalf("Delete failed: %v", err)
    					}
    				}
    				if watchTest.expectEvent {
    					expectObj := out
    					if watchTest.watchType == watch.Deleted {
    						expectObj = prevObj
    						expectObj.ResourceVersion = out.ResourceVersion
    					}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 63.8K bytes
    - Viewed (0)
Back to top