Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for newCounter (0.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top