- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 817 for lake (0.04 sec)
-
cni/pkg/nodeagent/server_test.go
server := &fakeServer{} server.Start(fakeCtx) server.On("DelPodFromMesh", fakeCtx, pod, ).Return(errors.New("fake error")) fakeClientSet := fake.NewSimpleClientset() m := meshDataplane{ kubeClient: fakeClientSet, netServer: server, } // pod is not in fake client, so if this will try to remove annotation, it will fail. err := m.DelPodFromMesh(fakeCtx, pod) assert.Error(t, err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/testing/openapi.go
openapi "k8s.io/kube-openapi/pkg/util/proto" ) // Fake opens and returns a openapi swagger from a file Path. It will // parse only once and then return the same copy everytime. type Fake struct { Path string once sync.Once document *openapi_v2.Document err error } // OpenAPISchema returns the openapi document and a potential error. func (f *Fake) OpenAPISchema() (*openapi_v2.Document, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 14:34:26 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/metrics/metrics_test.go
} fakePluginCount := dswCount["fake-plugin"] if fakePluginCount != 1 { t.Errorf("getVolumeCount failed. Expected <1> fake-plugin volume in DesiredStateOfWorld, got <%d>", fakePluginCount) } aswCount, ok := count["actual_state_of_world"] if !ok { t.Errorf("getVolumeCount failed. Expected <actual_state_of_world>, got nothing") } fakePluginCount = aswCount["fake-plugin"] if fakePluginCount != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher_test.go
"k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" corev1listers "k8s.io/client-go/listers/core/v1" clienttesting "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" "k8s.io/kubernetes/pkg/controller" ) func TestConfigMapCreation(t *testing.T) { ns := metav1.NamespaceDefault fakeRootCA := []byte("fake-root-ca") caConfigMap := defaultCrtConfigMapPtr(fakeRootCA)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:16 UTC 2023 - 7.9K bytes - Viewed (0) -
src/cmd/go/testdata/script/build_cc_cache_issue64423.txt
# this test, we instead simulate it by injecting a fake "clang" # binary that runs the real one as a subprocess. [!cgo] skip [short] skip 'builds and links a fake clang binary' [!cc:clang] skip 'test is specific to clang version parsing' # Save the location of the real clang command for our fake one to use. go run ./which clang cp stdout $WORK/.realclang # Build a fake clang and ensure that it is the one in $PATH. mkdir $WORK/bin
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 07 19:13:29 UTC 2023 - 2.9K bytes - Viewed (0) -
pilot/pkg/networking/core/route/retry/retry_test.go
Retries: &networking.HTTPRetry{ Attempts: 2, RetryOn: "some,fake,conditions", PerTryTimeout: durationpb.New(time.Second * 3), }, }, assertFunc: func(g *WithT, policy *envoyroute.RetryPolicy) { g.Expect(policy).To(Not(BeNil())) g.Expect(policy.RetryOn).To(Equal("some,fake,conditions")) g.Expect(policy.PerTryTimeout).To(Equal(durationpb.New(time.Second * 3)))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 7.7K bytes - Viewed (0) -
operator/pkg/helmreconciler/apply_test.go
var k8sClient client.Client if tt.currentState != "" { k8sClient = fake.NewClientBuilder(). WithRuntimeObjects(loadData(t, tt.currentState). UnstructuredObject()).WithInterceptorFuncs(interceptorFunc).Build() } else { // no current state provided, initialize fake client without runtime object k8sClient = fake.NewClientBuilder().WithInterceptorFuncs(interceptorFunc).Build() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 12 17:12:54 UTC 2023 - 4.9K bytes - Viewed (0) -
tests/test_tutorial/test_dependencies/test_tutorial012_an.py
response = client.get( "/items/", headers={"X-Token": "fake-super-secret-token", "X-Key": "invalid"} ) assert response.status_code == 400, response.text assert response.json() == {"detail": "X-Key header invalid"} def test_get_invalid_second_header_users(): response = client.get( "/users/", headers={"X-Token": "fake-super-secret-token", "X-Key": "invalid"} )
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:40:57 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_status_updater_test.go
"k8s.io/apimachinery/pkg/runtime" "k8s.io/client-go/kubernetes/fake" appslisters "k8s.io/client-go/listers/apps/v1" core "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" ) func TestStatefulSetUpdaterUpdatesSetStatus(t *testing.T) { set := newStatefulSet(3) status := apps.StatefulSetStatus{ObservedGeneration: 1, Replicas: 2} fakeClient := &fake.Clientset{} updater := NewRealStatefulSetStatusUpdater(fakeClient, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 13 15:37:10 UTC 2022 - 5.9K bytes - Viewed (0) -
src/cmd/go/testdata/script/install_modcacherw_issue64282.txt
# the requested package has been downloaded and checked for toolchain # upgrades. ! go install -cake=delicious -modcacherw example.com/printversion@v0.1.0 stderr '^flag provided but not defined: -cake$' # Because the -modcacherw flag was set, we should be able to modify the contents # of a directory within the module cache. cp $WORK/extraneous.txt $GOPATH/pkg/mod/example.com/printversion@v0.1.0/extraneous_file.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 29 17:53:43 UTC 2024 - 1.8K bytes - Viewed (0)