- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for fakeVM (0.48 sec)
-
pkg/kubelet/stats/cri_stats_provider_test.go
} ctrl := gomock.NewController(t) defer ctrl.Finish() fakeOS := &kubecontainertest.FakeOS{} fakeOS.ReadDirFn = func(path string) ([]os.DirEntry, error) { var dirEntries []os.DirEntry mockDE := kubecontainertest.NewMockDirEntry(ctrl) switch path {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
src/net/http/fs_test.go
{`<combo>?foo`, `<a href="%3Ccombo%3E%3Ffoo"><combo>?foo</a>`}, {`foo:bar`, `<a href="./foo:bar">foo:bar</a>`}, } // We put each test file in its own directory in the fakeFS so we can look at it in isolation. fs := make(fakeFS) for i, test := range tests { testFile := &fakeFileInfo{basename: test.name} fs[fmt.Sprintf("/%d", i)] = &fakeFileInfo{ dir: true, modtime: time.Unix(1000000000, 0).UTC(),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
} func TestSyncPod(t *testing.T) { syncer := newTestManager(&fake.Clientset{}) testPod := getTestPod() syncer.kubeClient = fake.NewSimpleClientset(testPod) syncer.SetPodStatus(testPod, getRandomPodStatus()) verifyActions(t, syncer, []core.Action{getAction(), patchAction()}) } func TestSyncPodChecksMismatchedUID(t *testing.T) { syncer := newTestManager(&fake.Clientset{}) pod := getTestPod() pod.UID = "first"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
"k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/uuid" "k8s.io/apimachinery/pkg/util/wait" discoveryfake "k8s.io/client-go/discovery/fake" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" scalefake "k8s.io/client-go/scale/fake" core "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record" "k8s.io/client-go/util/workqueue"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager_test.go
t.Errorf("Memory Manager Allocate() error (%v), expected error: %v, but got: %v", testCase.description, testCase.expectedAllocateError, err) } mgr.AddContainer(pod, container, "fakeID") _, _, err = mgr.containerMap.GetContainerRef("fakeID") if !reflect.DeepEqual(err, testCase.expectedAddContainerError) { t.Errorf("Memory Manager AddContainer() error (%v), expected error: %v, but got: %v",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
podSyncStatus: &podSyncStatus{ finished: false, fullname: "fake-fullname", }, startedStaticPodsByFullname: map[string]types.UID{ "fake-fullname": "another-pod-uid", }, waitingToStartStaticPodsByFullname: map[string][]types.UID{ "fake-fullname": {podUID}, }, removed: false, }, { desc: "not yet started worker",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
t.Helper() tc := &testContext{} tCtx := ktesting.Init(t) tc.ctx = tCtx tc.client = fake.NewSimpleClientset(objs...) reactor := createReactor(tc.client.Tracker()) tc.client.PrependReactor("*", "*", reactor) // Quick-and-dirty workaround for fake client storing ResourceClassParameters and // ResourceClaimParameters as "resourceclassparameterses" and "resourceclaimparameterses":
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/controller/podautoscaler/replica_calculator_test.go
emapi "k8s.io/metrics/pkg/apis/external_metrics/v1beta1" metricsapi "k8s.io/metrics/pkg/apis/metrics/v1beta1" metricsfake "k8s.io/metrics/pkg/client/clientset/versioned/fake" cmfake "k8s.io/metrics/pkg/client/custom_metrics/fake" emfake "k8s.io/metrics/pkg/client/external_metrics/fake" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" ) type resourceInfo struct { name v1.ResourceName
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 19 03:31:34 UTC 2023 - 68.4K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/tools/record" "k8s.io/client-go/util/workqueue" "k8s.io/klog/v2/ktesting" "k8s.io/utils/pointer" _ "k8s.io/kubernetes/pkg/apis/batch/install" _ "k8s.io/kubernetes/pkg/apis/core/install"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0) -
src/net/http/client_test.go
if err != nil { t.Fatal(err) } got := jar.log.String() want := `Cookies("http://firsthost.fake/") SetCookie("http://firsthost.fake/", [name=val]) Cookies("http://secondhost.fake/secondpath") SetCookie("http://secondhost.fake/secondpath", [namesecondpath=valsecondpath]) Cookies("http://firsthost.fake/nosetcookie") ` if got != want { t.Errorf("Got Jar calls:\n%s\nWant:\n%s", got, want) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0)