- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for newCounter (0.41 sec)
-
cmd/routers.go
func configureServerHandler(endpointServerPools EndpointServerPools) (http.Handler, error) { // Initialize router. `SkipClean(true)` stops minio/mux from // normalizing URL path minio/minio#3256 router := mux.NewRouter().SkipClean(true).UseEncodedPath() // Initialize distributed NS lock. if globalIsDistErasure { registerDistErasureRouters(router, endpointServerPools) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Mar 08 19:08:18 UTC 2024 - 3.6K bytes - Viewed (0) -
internal/grid/debug.go
AuthRequest: func(r *http.Request) error { return nil }, AddAuth: func(aud string) string { return aud }, BlockConnect: ready, }) if err != nil { return nil, err } m := mux.NewRouter() m.Handle(RoutePath, manager.Handler()) res.Managers = append(res.Managers, manager) res.Servers = append(res.Servers, startHTTPServer(listeners[i], m)) res.Listeners = append(res.Listeners, listeners[i])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/volume/nfs/nfs.go
func (plugin *nfsPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode { return []v1.PersistentVolumeAccessMode{ v1.ReadWriteOnce, v1.ReadOnlyMany, v1.ReadWriteMany, } } func (plugin *nfsPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, _ volume.VolumeOptions) (volume.Mounter, error) { return plugin.newMounterInternal(spec, pod, plugin.host.GetMounter(plugin.GetPluginName())) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/volume/secret/secret.go
func (plugin *secretPlugin) SupportsMountOption() bool { return false } func (plugin *secretPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { return false, nil } func (plugin *secretPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) { return &secretVolumeMounter{ secretVolume: &secretVolume{ spec.Name(), pod.UID, plugin,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/ctrlz/ctrlz.go
_ = augmentLayout(baseLayout, "templates/modules/last-refresh.html") mainLayout := augmentLayout(template.Must(baseLayout.Clone()), "templates/layouts/main.html") router := mux.NewRouter() for _, t := range allTopics { registerTopic(router, mainLayout, t) } if o.EnablePprof && o.Address == "localhost" { router.HandleFunc("/debug/pprof/cmdline", pprof.Cmdline)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 21:22:53 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo.go
return false } func (plugin *gitRepoPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { return false, nil } func (plugin *gitRepoPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) { if err := validateVolume(spec.Volume.GitRepo); err != nil { return nil, err } return &gitRepoVolumeMounter{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 8.2K bytes - Viewed (0) -
src/go/types/instantiate_test.go
{"func (r T[P]) m(T[P], T[string], T[int])", "func (T[int]).m(T[int], T[string], T[int])"}, } for _, test := range tests { src := prefix + test.decl pkg := mustTypecheck(src, nil, nil) typ := NewPointer(pkg.Scope().Lookup("X").Type()) obj, _, _ := LookupFieldOrMethod(typ, false, pkg, "m") m, _ := obj.(*Func) if m == nil { t.Fatalf(`LookupFieldOrMethod(%s, "m") = %v, want func m`, typ, obj) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 18:48:38 UTC 2024 - 5.9K bytes - Viewed (0) -
src/go/types/example_test.go
if err != nil { log.Fatal(err) } // Print the method sets of Celsius and *Celsius. celsius := pkg.Scope().Lookup("Celsius").Type() for _, t := range []types.Type{celsius, types.NewPointer(celsius)} { fmt.Printf("Method set of %s:\n", t) mset := types.NewMethodSet(t) for i := 0; i < mset.Len(); i++ { fmt.Println(mset.At(i)) } fmt.Println() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8.9K bytes - Viewed (0) -
pilot/pkg/model/test/mockopenidserver.go
TLSKeyFile: tlsKey, } return server, server.Start() } // Start starts the mock server. func (ms *MockOpenIDDiscoveryServer) Start() error { var handler http.Handler router := mux.NewRouter() router.HandleFunc("/.well-known/openid-configuration", ms.openIDCfg).Methods("GET") router.HandleFunc("/oauth2/v3/certs", ms.jwtPubKey).Methods("GET") handler = router if ms.timeout != 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 9.4K bytes - Viewed (0)