kubernetes/test/integration/ttlcontroller/ttlcontroller_test.go

func createClientAndInformers(t *testing.T, server *kubeapiservertesting.TestServer) (*clientset.Clientset, informers.SharedInformerFactory) { … }

func createNodes(t *testing.T, client *clientset.Clientset, startIndex, endIndex int) { … }

func deleteNodes(t *testing.T, client *clientset.Clientset, startIndex, endIndex int) { … }

func waitForNodesWithTTLAnnotation(t *testing.T, nodeLister listers.NodeLister, numNodes, ttlSeconds int) { … }

// Test whether ttlcontroller sets correct ttl annotations.
func TestTTLAnnotations(t *testing.T) { … }