Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 76 for Sauter (0.61 sec)

  1. cmd/admin-router.go

    type adminAPIHandlers struct{}
    
    // registerAdminRouter - Add handler functions for each service REST API routes.
    func registerAdminRouter(router *mux.Router, enableConfigOps bool) {
    	adminAPI := adminAPIHandlers{}
    	// Admin router
    	adminRouter := router.PathPrefix(adminPathPrefix).Subrouter()
    
    	adminVersions := []string{
    		adminAPIVersionPrefix,
    	}
    
    	for _, adminVersion := range adminVersions {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  2. cmd/api-router.go

    	return handler
    }
    
    // registerAPIRouter - registers S3 compatible APIs.
    func registerAPIRouter(router *mux.Router) {
    	// Initialize API.
    	api := objectAPIHandlers{
    		ObjectAPI: newObjectLayerFn,
    	}
    
    	// API Router
    	apiRouter := router.PathPrefix(SlashSeparator).Subrouter()
    
    	var routers []*mux.Router
    	for _, domainName := range globalDomainNames {
    		if IsKubernetes() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  3. cmd/metacache-entries.go

    		return metaCacheEntriesSorted{o: m}
    	}
    	sort.Slice(m, m.less)
    	return metaCacheEntriesSorted{o: m}
    }
    
    // isSorted returns whether the objects are sorted.
    // This is usually orders of magnitude faster than actually sorting.
    func (m metaCacheEntries) isSorted() bool {
    	return sort.SliceIsSorted(m, m.less)
    }
    
    // shallowClone will create a shallow clone of the array objects,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server.go

    // Note that if the ipset already exist by name, Create will not return an error.
    //
    // We will unconditionally flush our set before use here, so it shouldn't matter.
    func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) {
    	linDeps := ipset.RealNlDeps()
    	probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps)
    	if err != nil {
    		return probeSet, err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  5. internal/grid/manager.go

    		})
    	}
    	if !found {
    		return nil, fmt.Errorf("grid: local host not found")
    	}
    
    	return m, nil
    }
    
    // AddToMux will add the grid manager to the given mux.
    func (m *Manager) AddToMux(router *mux.Router) {
    	router.Handle(RoutePath, m.Handler())
    }
    
    // Handler returns a handler that can be used to serve grid requests.
    // This should be connected on RoutePath to the main server.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  6. internal/kms/single-key.go

    // key ID and key to derive new DEKs and decrypt ciphertext.
    func Parse(s string) (KMS, error) {
    	v := strings.SplitN(s, ":", 2)
    	if len(v) != 2 {
    		return nil, errors.New("kms: invalid master key format")
    	}
    
    	keyID, b64Key := v[0], v[1]
    	key, err := base64.StdEncoding.DecodeString(b64Key)
    	if err != nil {
    		return nil, err
    	}
    	return New(keyID, key)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    //
    // Any updates to this must be serialized via globalLocalDrivesMu (locker)
    var globalLocalSetDrives [][][]StorageAPI
    
    // registerStorageRESTHandlers - register storage rpc router.
    func registerStorageRESTHandlers(router *mux.Router, endpointServerPools EndpointServerPools, gm *grid.Manager) {
    	h := func(f http.HandlerFunc) http.HandlerFunc {
    		return collectInternodeStats(httpTraceHdrs(f))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  8. cmd/tier.go

    		return NewPutObjReader(hr), &ObjectOptions{MaxParity: true}, nil
    	}
    
    	// Note: Local variables with names ek, oek, etc are named inline with
    	// acronyms defined here -
    	// https://github.com/minio/minio/blob/master/docs/security/README.md#acronyms
    
    	// Encrypt json encoded tier configurations
    	metadata := make(map[string]string)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    		}
    		if dataDir != "" {
    			versionID := fi.VersionID
    			if versionID == "" {
    				versionID = nullVersionID
    			}
    
    			// PR #11758 used DataDir, preserve it
    			// for users who might have used master
    			// branch
    			xlMeta.data.remove(versionID, dataDir)
    
    			// We need to attempt delete "dataDir" on the disk
    			// due to a CopyObject() bug where it might have
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  10. cni/pkg/iptables/iptables.go

    	// but with iptables rules - use `--socket-exists` as a proxy for "is this a forwarded packet" vs "is this originating from
    	// a local node socket". If the latter, outside the pod in the host netns, redirect that traffic to a hardcoded/custom proxy
    	// healthcheck port, just like we used to. Otherwise, we can't assume it's local-node privileged traffic, and will capture and process it normally.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
Back to top