wr := getWatchedResources(tpe, tt, s, proxy)
			b.ResetTimer()
			var c model.Resources
			for n := 0; n < b.N; n++ {
				c, _, _ = s.Discovery.Generators[tpe].Generate(proxy, wr, &model.PushRequest{Full: true, Push: s.PushContext()})
				if len(c) == 0 {
					b.Fatalf("Got no %v's!", tpe)
				}
			}
			logDebug(b, c)
		})
	}
}

func testBenchmark(t *testing.T, tpe string, testCases []ConfigInput) {

				if rec == nil && len(rec) != len(tt.expectedDeltaResources.lastReceived) {
					return false
				}
				for tpe, rsrcs := range tt.expectedDeltaResources.lastReceived {
					if _, ok := rec[tpe]; !ok {
						return false
					}
					if len(rsrcs.Resources) != len(rec[tpe].Resources) {
						return false
					}
				}
				return true
			}, true, retry.Timeout(time.Second), retry.Delay(time.Millisecond))

								expectMTLS := c.ExpectMTLS(from, opts)
								var tpe string
								if expectSuccess {
									tpe = "positive"
									opts.Check = check.And(
										check.OK(),
										check.ReachedTargetClusters(t))
									if expectMTLS {
										opts.Check = check.And(opts.Check,
											check.MTLSForHTTP())
									}
								} else {
									tpe = "negative"
									opts.Check = check.NotOK()
								}

				rec := tt.inAdsc.Received

				if rec == nil && len(rec) != len(tt.expectedADSResources.Received) {
					return false
				}
				for tpe, rsrcs := range tt.expectedADSResources.Received {
					if _, ok := rec[tpe]; !ok {
						return false
					}
					if len(rsrcs.Resources) != len(rec[tpe].Resources) {
						return false
					}
				}
				return true
			}, true, retry.Timeout(time.Second), retry.Delay(time.Millisecond))

				expectMTLS := c.ExpectMTLS(src, opt)

				var tpe string
				if expectSuccess {
					tpe = "positive"
					opt.Check = check.And(
						check.OK(),
						check.ReachedTargetClusters(t))
					if expectMTLS {
						opt.Check = check.And(opt.Check, check.MTLSForHTTP())
					}
				} else {
					tpe = "negative"
					opt.Check = check.NotOK()
				}

package xsbt.boot; public final synchronized class UpdateApp implements UpdateTarget { private final Application id; private final scala.collection.immutable.List classifiers; private final String tpe; public final Application id(); public final scala.collection.immutable.List classifiers(); public final String tpe(); public void UpdateApp(Application, scala.collection.immutable.List, String); } xsbt/boot/ConfigurationParser$$anonfun$processClassifiers$1.class package xsbt.boot; public final synchronized...