- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for lake (0.04 sec)
-
pilot/test/xds/fake.go
objects = append(objects, o) } return objects, nil } // DisableAuthorizationForSecret makes the authorization check always pass. Should be used only for tests. func DisableAuthorizationForSecret(fake *fake.Clientset) { fake.Fake.PrependReactor("create", "subjectaccessreviews", func(action k8stesting.Action) (bool, runtime.Object, error) { return true, &authorizationv1.SubjectAccessReview{ Status: authorizationv1.SubjectAccessReviewStatus{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/fake.go
return false } func (f FakeEnvironment) EnvironmentName() string { if len(f.Name) == 0 { return "fake" } return f.Name } func (f FakeEnvironment) AllClusters() cluster.Clusters { res := cluster.Clusters{} allClusters := make(cluster.Map) for i := 0; i < f.NumClusters; i++ { topo := cluster.NewTopology(cluster.Config{ Name: fmt.Sprintf("cluster-%d", i),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 1.8K bytes - Viewed (0) -
chainable_api.go
// db.Where(User{Name: "non_existing"}).Assign(User{Email: "fake@fake.org"}).FirstOrInit(&user) // // user -> User{Name: "non_existing", Email: "fake@fake.org"} // // // assign email regardless of if record is found // db.Where(User{Name: "jinzhu"}).Assign(User{Email: "fake@fake.org"}).FirstOrInit(&user) // // user -> User{Name: "jinzhu", Age: 20, Email: "fake@fake.org"} //
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 09:47:34 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control_test.go
pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{} pvcIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) pvcLister := corelisters.NewPersistentVolumeClaimLister(pvcIndexer) control := NewStatefulPodControl(fakeClient, nil, pvcLister, recorder) pvcs := getPersistentVolumeClaims(set, pod) volumes := make([]v1.Volume, 0, len(pod.Spec.Volumes))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/printers/internalversion/printers_test.go
ObjectMeta: metav1.ObjectMeta{Name: "pod-template-2"}, Spec: api.PodSpec{ Containers: []api.Container{ { Name: "fake-container1", Image: "fake-image1", }, { Name: "fake-container2", Image: "fake-image2", }, }, }, }, }, options: printers.GenerateOptions{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/components/KtOriginalPsiProvider.kt
* for [this]. Otherwise, returns `null`. */ @KaAnalysisApiInternals public fun KtDeclaration.getOriginalDeclaration(): KtDeclaration? = withValidityAssertion { analysisSession.originalPsiProvider.getOriginalDeclaration(this) } /**
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
assert.Equal(t, ztunnelServer.deletedPods.Load(), 1) assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1) assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1) // make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) client.RunAndWait(ctx.Done()) payload, _ := json.Marshal(valid) // serialize our fake plugin event addEvent, err := processAddEvent(payload) assert.Equal(t, err, nil) // Push it thru the handler pluginServer.ReconcileCNIAddEvent(ctx, addEvent) waitForMockCalls()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } // We fake a local and remote server. remoteHost := remote.HostName() // 1: Echo serverSent := make(chan struct{}) serverCanceled := make(chan struct{}) register := func(manager *Manager) { errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
// Prevent List from succeeding c.Kube().(*fake.Clientset).Fake.PrependReactor("*", "*", func(action k8stesting.Action) (bool, runtime.Object, error) { return true, nil, fmt.Errorf("nope, out of luck") }) c.RunAndWait(test.NewStop(t)) deployments := kclient.New[*appsv1.Deployment](c) deployments.Start(test.NewStop(t)) mt.Assert("controller_sync_errors_total", map[string]string{"cluster": "fake"}, monitortest.AtLeast(1)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0)