- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 119 for NewTestContext (0.23 sec)
-
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
reconciler := NewReconciler( reconcilerLoopPeriod, maxWaitForUnmountDuration, syncLoopPeriod, false, false, dsw, asw, ad, nsu, nodeLister, fakeRecorder) // Act _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() go reconciler.Run(ctx) // Assert waitForNewAttacherCallCount(t, 0 /* expectedCallCount */, fakePlugin)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller_test.go
) // TODO flesh this out to cover things like not being able to find the csr in the cache, not // auto-approving, etc. func TestCertificateController(t *testing.T) { _, ctx := ktesting.NewTestContext(t) csr := &certificates.CertificateSigningRequest{ ObjectMeta: metav1.ObjectMeta{ Name: "test-csr", }, } client := fake.NewSimpleClientset(csr)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 03:26:08 UTC 2023 - 2.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodename/node_name_test.go
}, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(test.node) _, ctx := ktesting.NewTestContext(t) p, err := New(ctx, nil, nil) if err != nil { t.Fatalf("creating plugin: %v", err) } gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/test/framework/runtime.go
return i.context } // newRootContext creates and returns a new testContext with no parent. func (i *runtime) newRootContext(test *testImpl, goTest *testing.T, labels label.Set) *testContext { return newTestContext(test, goTest, i.context, nil, labels) } // Close implements io.Closer func (i *runtime) Close() error { return i.context.globalScope.done(i.context.settings.NoCleanup)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 26 17:50:56 UTC 2022 - 1.9K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
informerFactory := informers.NewSharedInformerFactory(client, 0) eventBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{Interface: client.EventsV1()}) _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() s, err := New( ctx, client, informerFactory, nil, profile.NewRecorderFactory(eventBroadcaster),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/controller/job/indexed_job_utils_test.go
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/features" "k8s.io/utils/ptr" ) const noIndex = "-" func TestCalculateSucceededIndexes(t *testing.T) { logger, _ := ktesting.NewTestContext(t) cases := map[string]struct { prevSucceeded string pods []indexPhase completions int32 wantStatusIntervals orderedIntervals wantIntervals orderedIntervals }{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/scheduler/framework/autoscaler_contract/framework_contract_test.go
} func TestFrameworkContract(t *testing.T) { var f framework.Framework var c frameworkContract = f assert.Nil(t, c) } func TestNewFramework(t *testing.T) { _, ctx := ktesting.NewTestContext(t) var f interface{} if f, _ = runtime.NewFramework(ctx, nil, nil); f != nil { _, ok := f.(framework.Framework) assert.True(t, ok) } } func TestNewCycleState(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 23 02:17:34 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
Namespace: namespace, Labels: map[string]string{discovery.LabelServiceName: name}, }, } epsFunc(eps) return eps } func TestCleanupLeftovers(t *testing.T) { _, ctx := ktesting.NewTestContext(t) ipt := iptablestest.NewFake() ipvs := ipvstest.NewFake() ipset := ipsettest.NewFake(testIPSetVersion) fp := NewFakeProxier(ctx, ipt, ipvs, ipset, nil, nil, v1.IPv4Protocol) svcIP := "10.20.30.41"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultbinder/default_binder_test.go
}, }, { name: "binding error", injectErr: errors.New("binding error"), }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() var gotBinding *v1.Binding client := fake.NewSimpleClientset(testPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 23 02:17:34 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
} } type jobInitialStatus struct { active int succeed int failed int startTime *time.Time } func TestControllerSyncJob(t *testing.T) { _, ctx := ktesting.NewTestContext(t) jobConditionComplete := batch.JobComplete jobConditionFailed := batch.JobFailed jobConditionSuspended := batch.JobSuspended referenceTime := time.Now() testCases := map[string]struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)