if err != nil {
		t.Fatal(err)
	}

	go gc.Run(tCtx, 1)
	// The pseudo-code of GarbageCollector.Sync():
	// GarbageCollector.Sync(client, period, stopCh):
	//    wait.Until() loops with `period` until the `stopCh` is closed :
	//        wait.PollImmediateUntil() loops with 100ms (hardcode) util the `stopCh` is closed:
	//            GetDeletableResources()
	//            gc.resyncMonitors()

nB,IAAIgR,EAAOtV,EAAOuV,UAAYvV,EAAOuV,SAASD,KAC9C,OAAOA,GAAQA,EAAK/U,MAAO,KAAQ+D,EAAKgJ,IAGzCkI,KAAQ,SAAUlR,GACjB,OAAOA,IAASgE,GAGjBmN,MAAS,SAAUnR,GAClB,OAAOA,IAASzE,EAAS6V,iBACrB7V,EAAS8V,UAAY9V,EAAS8V,gBAC7BrR,EAAK1C,MAAQ0C,EAAKsR,OAAStR,EAAKuR,WAItCC,QAAWtG,IAAsB,GACjCnD,SAAYmD,IAAsB,GAElCuG,QAAW,SAAUzR,GAIpB,IAAIgI,EAAWhI,EAAKgI,SAAS5E,cAC7B,MAAsB,UAAb4E,KAA0BhI,EAAKyR,SACxB,WAAbzJ,KAA2BhI,EAAK0R,UAGpCA,SAAY,SAAU1R,GASrB,OALKA,EAAKzB,YAETyB,EAAKzB,WAAWoT,eAGQ,IAAlB3R,EAAK0R,UAIbE,MAAS,SAAU5R...

	m.metricComputationErrorLabels[metricType] = append(m.metricComputationErrorLabels[metricType], err)
}

// waitUntilRecorded waits for the HPA controller to reconcile at least once.
func (m *mockMonitor) waitUntilRecorded(t *testing.T) {
	if err := wait.Poll(20*time.Millisecond, 100*time.Millisecond, func() (done bool, err error) {
		m.RWMutex.RLock()
		defer m.RWMutex.RUnlock()

nB,IAAIgR,EAAOtV,EAAOuV,UAAYvV,EAAOuV,SAASD,KAC9C,OAAOA,GAAQA,EAAK/U,MAAO,KAAQ+D,EAAKgJ,IAGzCkI,KAAQ,SAAUlR,GACjB,OAAOA,IAASgE,GAGjBmN,MAAS,SAAUnR,GAClB,OAAOA,IAASzE,EAAS6V,iBACrB7V,EAAS8V,UAAY9V,EAAS8V,gBAC7BrR,EAAK1C,MAAQ0C,EAAKsR,OAAStR,EAAKuR,WAItCC,QAAWtG,IAAsB,GACjCnD,SAAYmD,IAAsB,GAElCuG,QAAW,SAAUzR,GAIpB,IAAIgI,EAAWhI,EAAKgI,SAAS5E,cAC7B,MAAsB,UAAb4E,KAA0BhI,EAAKyR,SACxB,WAAbzJ,KAA2BhI,EAAK0R,UAGpCA,SAAY,SAAU1R,GASrB,OALKA,EAAKzB,YAETyB,EAAKzB,WAAWoT,eAGQ,IAAlB3R,EAAK0R,UAIbE,MAAS,SAAU5R...

				if ok {
					continue
				}
				client := client
				ng.Go(ctx, func() error {
					return client.CommitBinary(ctx)
				}, idx, *client.host)
			}

			for _, nerr := range ng.Wait() {
				if nerr.Err != nil {
					prs, ok := peerResults[nerr.Host.String()]
					if ok {
						prs.Err = nerr.Err.Error()
						peerResults[nerr.Host.String()] = prs
					} else {

func (db *DB) Stats() DBStats {
	wait := db.waitDuration.Load()

	db.mu.Lock()
	defer db.mu.Unlock()

	stats := DBStats{
		MaxOpenConnections: db.maxOpen,

		Idle:            len(db.freeConn),
		OpenConnections: db.numOpen,
		InUse:           db.numOpen - len(db.freeConn),

		WaitCount:         db.waitCount,
		WaitDuration:      time.Duration(wait),
		MaxIdleClosed:     db.maxIdleClosed,

    }
  }

  /** A reference to a value. */
  interface ValueReference<K, V> {
    /** Returns the value. Does not block or throw exceptions. */
    @CheckForNull
    V get();

    /**
     * Waits for a value that may still be loading. Unlike get(), this method can block (in the case
     * of FutureValueReference).
     *
     * @throws ExecutionException if the loading thread throws an exception

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/util/intstr"
	"k8s.io/apimachinery/pkg/util/sets"
	"k8s.io/apimachinery/pkg/util/uuid"
	"k8s.io/apimachinery/pkg/util/wait"
	"k8s.io/apiserver/pkg/storage/names"
	"k8s.io/client-go/informers"
	"k8s.io/client-go/kubernetes/fake"
	core "k8s.io/client-go/testing"
	"k8s.io/client-go/tools/cache"
	"k8s.io/client-go/tools/record"

          {{- else if $holdProxy }}
            lifecycle:
              postStart:
                exec:
                  command:
                  - pilot-agent
                  - wait
          {{- else if $nativeSidecar }}
            {{- /* preStop is called when the pod starts shutdown. Initialize drain. We will get SIGTERM once applications are torn down. */}}
            lifecycle:

        def cleaningBarrier = blockingHttpServer.expectAndBlock("cleaning")
        def cleaningBuild = executer.withTasks("waitForCleaningBarrier").withArgument("--no-daemon").start()

        then: 'cleaning build starts and waits on its barrier'
        cleaningBarrier.waitForAllPendingCalls()

        when: 'transforming build is started'
        def transformBarrier = blockingHttpServer.expectAndBlock("transform")