- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for makeArg (0.27 sec)
-
pkg/revisions/tag_watcher_test.go
whs.Create(makeTag("revision", "tag-foo")) track.WaitOrdered("revision,tag-foo") assert.Equal(t, tw.GetMyTags(), sets.New("revision", "tag-foo")) whs.Create(makeTag("revision", "tag-bar")) track.WaitOrdered("revision,tag-bar,tag-foo") assert.Equal(t, tw.GetMyTags(), sets.New("revision", "tag-foo", "tag-bar")) whs.Update(makeTag("not-revision", "tag-bar"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 2.5K bytes - Viewed (0) -
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) -
src/cmd/vendor/golang.org/x/text/language/parse.go
defer func() { if recover() != nil { t = Tag{} err = language.ErrSyntax } }() tt, err := language.Parse(s) if err != nil { return makeTag(tt), err } tt, changed := canonicalize(c, tt) if changed { tt.RemakeString() } return makeTag(tt), err } // Compose creates a Tag from individual parts, which may be of type Tag, Base,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 7.5K 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) -
src/reflect/export_test.go
// license that can be found in the LICENSE file. package reflect import ( "internal/abi" "internal/goarch" "sync" "unsafe" ) // MakeRO returns a copy of v with the read-only flag set. func MakeRO(v Value) Value { v.flag |= flagStickyRO return v } // IsRO reports whether v's read-only flag is set. func IsRO(v Value) bool { return v.flag&flagStickyRO != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 15:10:48 UTC 2024 - 3.8K 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) -
guava/src/com/google/common/collect/Platform.java
return Arrays.copyOfRange(source, from, to, (Class<? extends T[]>) arrayOfType.getClass()); } /** * Configures the given map maker to use weak keys, if possible; does nothing otherwise (i.e., in * GWT). This is sometimes acceptable, when only server-side code could generate enough volume * that reclamation becomes important. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 5.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Platform.java
return Arrays.copyOfRange(source, from, to, (Class<? extends T[]>) arrayOfType.getClass()); } /** * Configures the given map maker to use weak keys, if possible; does nothing otherwise (i.e., in * GWT). This is sometimes acceptable, when only server-side code could generate enough volume * that reclamation becomes important. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 4.9K bytes - Viewed (0)