- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 71 for testfunc (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
} }) } } type testLW struct { ListFunc func(options metav1.ListOptions) (runtime.Object, error) WatchFunc func(options metav1.ListOptions) (watch.Interface, error) } func (t *testLW) List(options metav1.ListOptions) (runtime.Object, error) { return t.ListFunc(options) } func (t *testLW) Watch(options metav1.ListOptions) (watch.Interface, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0) -
src/sort/search_test.go
} func TestSearch(t *testing.T) { for _, e := range tests { i := Search(e.n, e.f) if i != e.i { t.Errorf("%s: expected index %d; got %d", e.name, e.i, i) } } } func TestFind(t *testing.T) { str1 := []string{"foo"} str2 := []string{"ab", "ca"} str3 := []string{"mo", "qo", "vo"} str4 := []string{"ab", "ad", "ca", "xy"} // slice with repeating elements
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 07 14:42:13 UTC 2022 - 6.8K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
type PreEnqueuePlugin interface { Plugin // PreEnqueue is called prior to adding Pods to activeQ. PreEnqueue(ctx context.Context, p *v1.Pod) *Status } // LessFunc is the function to sort pod info type LessFunc func(podInfo1, podInfo2 *QueuedPodInfo) bool // QueueSortPlugin is an interface that must be implemented by "QueueSort" plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
src/cmd/cover/cover.go
f.preFunc(n, fname) if pkgconfig.Granularity == "perfunc" { walkBody = false } } if walkBody { ast.Walk(f, n.Body) } if *pkgcfg != "" { flit := false f.postFunc(n, fname, flit, n.Body) } return nil case *ast.FuncLit: // For function literals enclosed in functions, just glom the // code for the literal in with the enclosing function (for now).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 34.5K bytes - Viewed (0) -
src/cmd/internal/cov/readcovdata.go
if err != nil { return r.fatal("reading counter data file %s: %s", cdf, err) } r.vis.BeginCounterDataFile(cdf, cdr, p.Origins[k]) var data decodecounter.FuncPayload for { ok, err := cdr.NextFunc(&data) if err != nil { return r.fatal("reading counter data file %s: %v", cdf, err) } if !ok { break } r.vis.VisitFuncCounterData(data) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 8.4K bytes - Viewed (0) -
src/cmd/go/internal/test/testflag.go
cf.String("blockprofilerate", "", "") cf.Int("count", 0, "") cf.String("cpu", "", "") cf.StringVar(&testCPUProfile, "cpuprofile", "", "") cf.BoolVar(&testFailFast, "failfast", false, "") cf.StringVar(&testFuzz, "fuzz", "", "") cf.Bool("fullpath", false, "") cf.StringVar(&testList, "list", "", "") cf.StringVar(&testMemProfile, "memprofile", "", "") cf.String("memprofilerate", "", "")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 21 19:25:24 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
delete(expected, k) if _, ok := unexpected[k]; ok { t.Errorf("expected %s to be filtered out", k) } } if len(expected) > 0 { t.Errorf("did not include %v", expected) } } func TestRun(t *testing.T) { // source svc/cluster -> dest services -> number of subtests (should == num clusters) framework.NewTest(t).Run(func(t framework.TestContext) { tests := map[string]struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/recycle_test.go
} // Test multiple calls to syncClaim/syncVolume and periodic sync of all // volume/claims. The test follows this pattern: // 0. Load the controller with initial data. // 1. Call controllerTest.testCall() once as in TestSync() // 2. For all volumes/claims changed by previous syncVolume/syncClaim calls, // call appropriate syncVolume/syncClaim (simulating "volume/claim changed" // events). Go to 2. if these calls change anything.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 14.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
// Set up fake informers that return instances of mock Policy definitoins // and mock policy bindings informer = &testInformer{SharedIndexInformer: cache.NewSharedIndexInformer(&cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { return tracker.List(fakeGVR, fakeGVK, "") }, WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { return tracker.Watch(fakeGVR, "")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux.go
ctx, cancelFunc := context.WithTimeout(ctx, timeoutForNodePodCIDR) defer cancelFunc() fieldSelector := fields.OneTermEqualSelector("metadata.name", nodeName).String() lw := &cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (object runtime.Object, e error) { options.FieldSelector = fieldSelector return client.CoreV1().Nodes().List(ctx, options) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K bytes - Viewed (0)