- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for makeArg (0.11 sec)
-
pkg/kube/kclient/crdwatcher_test.go
// Happened sync vsCalls.Inc() } }() clienttest.MakeCRD(t, c, gvr.VirtualService) c.RunAndWait(stop) assert.EventuallyEqual(t, vsCalls.Load, 1) } func TestCRDWatcher(t *testing.T) { stop := test.NewStop(t) c := kube.NewFakeClient() clienttest.MakeCRD(t, c, gvr.VirtualService) vsCalls := atomic.NewInt32(0) clienttest.MakeCRD(t, c, gvr.GatewayClass) ctl := c.CrdWatcher()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/settings.go
} { for src, dst := range m { if int(src) >= nClusters { return makeErr(src, flag) } if int(dst) >= nClusters { return makeErr(dst, flag) } } } for idx := range s.networkTopology { if int(idx) >= nClusters { return makeErr(idx, "istio.test.kube.networkTopology") } } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/crd.go
"k8s.io/apimachinery/pkg/runtime/schema" metadatafake "k8s.io/client-go/metadata/fake" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test" ) func MakeCRD(t test.Failer, c kube.Client, g schema.GroupVersionResource) { t.Helper() MakeCRDWithAnnotations(t, c, g, nil) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
assert.NoError(t, queue.WaitForClose(c.queue, time.Second*5)) }) } c.stop = stop if cleanupStop { t.Cleanup(func() { close(stop) }) } for _, crd := range opts.CRDs { clienttest.MakeCRD(t, c.client, crd) } opts.Client.RunAndWait(c.stop) var fx *xdsfake.Updater if x, ok := xdsUpdater.(*xdsfake.Updater); ok { fx = x } if !opts.SkipRun { go c.Run(c.stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/settings.go
configs = append(configs, settings.Configs...) } // Convert to menu entries. result := make([]configMenuEntry, len(configs)) lastMatch := -1 for i, cfg := range configs { dst, changed := cfg.config.makeURL(u) if !changed { lastMatch = i } // Use a relative URL to work in presence of stripping/redirects in webui.go. rel := &url.URL{RawQuery: dst.RawQuery, ForceQuery: true} result[i] = configMenuEntry{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 4.2K bytes - Viewed (0)