c.Helper()
	return c.T.Name()
}

func (c *testContext) Skip(args ...any) {
	c.Helper()
	c.T.Skip(args...)
}

func (c *testContext) SkipNow() {
	c.Helper()
	c.T.SkipNow()
}

func (c *testContext) Skipf(format string, args ...any) {
	c.Helper()
	c.T.Skipf(format, args...)
}

func (c *testContext) Skipped() bool {
	c.Helper()
	return c.T.Skipped()
}

	t      test.Failer
	inputs []any
}

// NewMock creates a helper to build Collections of static inputs for use with testing.
// Example usage:
//
//	mock := krttest.NewMock(t, []any{serviceFoo, podBar, namespaceBaz})
//	pods := krttest.GetMockCollection[Pod](mock) // makes a collection of all Pod types from inputs
func NewMock(t test.Failer, inputs []any) *MockCollection {
	t.Helper()
	mc := &MockCollection{t: t, inputs: inputs}

	"regexp"
	"strings"
	"testing"
)

func TestTBHelper(t *testing.T) {
	if os.Getenv("GO_WANT_HELPER_PROCESS") == "1" {
		testTestHelper(t)

		// Check that calling Helper from inside a top-level test function
		// has no effect.
		t.Helper()
		t.Error("8")
		return
	}

	testenv.MustHaveExec(t)
	t.Parallel()

	exe, err := os.Executable()
	if err != nil {
		t.Fatal(err)
	}

package org.gradle.sample.services;

import org.gradle.sample.api.Person;
import org.gradle.sample.shared.Helper;

public class PersonService {
    boolean checkPerson(Person person) {
        System.out.println(Helper.prettyPrint("Checking"));
        if (person.getFirstname().length() < 2) {
            return false;
        }
        return true;
    }

package org.gradle.sample.services;

import org.gradle.sample.api.Person;
import org.gradle.sample.shared.Helper;

public class PersonService {
    boolean checkPerson(Person person) {
        System.out.println(Helper.prettyPrint("Checking"));
        if (person.getFirstname().length() < 2) {
            return false;
        }
        return true;
    }

package org.gradle.sample.services;

import org.gradle.sample.api.Person;
import org.gradle.sample.shared.Helper;

public class PersonService {
    boolean checkPerson(Person person) {
        System.out.println(Helper.prettyPrint("Checking"));
        if (person.getFirstname().length() < 2) {
            return false;
        }
        return true;
    }

func (a *DeltaAdsTest) DrainResponses() {
	a.t.Helper()
	for {
		select {
		case <-a.context.Done():
			return
		case r := <-a.responses:
			log.Infof("drained response %v", r.TypeUrl)
		}
	}
}

// ExpectResponse waits until a response is received and returns it
func (a *DeltaAdsTest) ExpectResponse() *discovery.DeltaDiscoveryResponse {
	a.t.Helper()
	select {
	case <-time.After(a.timeout):

package service

import (
	"strings"
	"testing"

	v1 "k8s.io/api/core/v1"
	utilnet "k8s.io/utils/net"
)

func TestGetLoadBalancerSourceRanges(t *testing.T) {
	checkError := func(v string) {
		t.Helper()
		annotations := make(map[string]string)
		annotations[v1.AnnotationLoadBalancerSourceRangesKey] = v
		svc := v1.Service{}
		svc.Annotations = annotations
		_, err := GetLoadBalancerSourceRanges(&svc)
		if err == nil {

	for _, container := range pod.Spec.Containers {
		for resourceName := range container.Resources.Requests {
			if helper.IsExtendedResourceName(resourceName) {
				resources.Insert(string(resourceName))
			}
		}
	}
	for _, container := range pod.Spec.InitContainers {
		for resourceName := range container.Resources.Requests {
			if helper.IsExtendedResourceName(resourceName) {
				resources.Insert(string(resourceName))
			}
		}
	}

	return t.c.List(namespace, selector)
}

func (t TestWriter[T]) Create(object T) T {
	t.t.Helper()
	res, err := t.c.Create(object)
	if err != nil {
		t.t.Fatalf("create %v/%v: %v", object.GetNamespace(), object.GetName(), err)
	}
	return res
}

func (t TestWriter[T]) Update(object T) T {
	t.t.Helper()
	res, err := t.c.Update(object)
	if err != nil {