Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for SplitSeq (0.06 sec)

  1. cmd/metacache-marker.go

    		return
    	}
    	start := strings.LastIndex(s, "[")
    	o.Marker = s[:start]
    	end := strings.LastIndex(s, "]")
    	tag := strings.Trim(s[start:end], "[]")
    	tags := strings.SplitSeq(tag, ",")
    	for tag := range tags {
    		kv := strings.Split(tag, ":")
    		if len(kv) < 2 {
    			continue
    		}
    		switch kv[0] {
    		case "minio_cache":
    			if kv[1] != markerTagVersion {
    				continue
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  2. cmd/leak-detect_test.go

    	// get runtime stack buffer.
    	buf := debug.Stack()
    	// runtime stack of go routines will be listed with 2 blank spaces between each of them, so split on "\n\n" .
    	for g := range strings.SplitSeq(string(buf), "\n\n") {
    		// Again split on a new line, the first line of the second half contains the info about the go routine.
    		sl := strings.SplitN(g, "\n", 2)
    		if len(sl) != 2 {
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  3. cmd/signature-v2.go

    // Escape encodedQuery string into unescaped list of query params, returns error
    // if any while unescaping the values.
    func unescapeQueries(encodedQuery string) (unescapedQueries []string, err error) {
    	for query := range strings.SplitSeq(encodedQuery, "&") {
    		var unescapedQuery string
    		unescapedQuery, err = url.QueryUnescape(query)
    		if err != nil {
    			return nil, err
    		}
    		unescapedQueries = append(unescapedQueries, unescapedQuery)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  4. cmd/handler-utils.go

    func trimAwsChunkedContentEncoding(contentEnc string) (trimmedContentEnc string) {
    	if contentEnc == "" {
    		return contentEnc
    	}
    	var newEncs []string
    	for enc := range strings.SplitSeq(contentEnc, ",") {
    		if enc != streamingContentEncoding {
    			newEncs = append(newEncs, enc)
    		}
    	}
    	return strings.Join(newEncs, ",")
    }
    
    func collectInternodeStats(f http.HandlerFunc) http.HandlerFunc {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  5. cmd/object-api-options.go

    }
    
    func parseObjectAttributes(h http.Header) (attributes map[string]struct{}) {
    	attributes = make(map[string]struct{})
    	for _, headerVal := range h.Values(xhttp.AmzObjectAttributes) {
    		for v := range strings.SplitSeq(strings.TrimSpace(headerVal), ",") {
    			if v != "" {
    				attributes[v] = struct{}{}
    			}
    		}
    	}
    
    	return
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Sep 06 17:34:38 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  6. cmd/bucket-replication-utils.go

    	r = ReplicateDecision{
    		targetsMap: make(map[string]replicateTargetDecision),
    	}
    	if len(s) == 0 {
    		return
    	}
    	for p := range strings.SplitSeq(s, ",") {
    		if p == "" {
    			continue
    		}
    		slc := strings.Split(p, "=")
    		if len(slc) != 2 {
    			return r, errInvalidReplicateDecisionFormat
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  7. cmd/common-main.go

    		}
    		globalRootDiskThreshold = size
    	}
    
    	domains := env.Get(config.EnvDomain, "")
    	if len(domains) != 0 {
    		for domainName := range strings.SplitSeq(domains, config.ValueSeparator) {
    			if _, ok := dns2.IsDomainName(domainName); !ok {
    				logger.Fatal(config.ErrInvalidDomainValue(nil).Msgf("Unknown value `%s`", domainName),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    
    	var args dsync.LockArgs
    	var lockers []dsync.NetLocker
    	for path := range strings.SplitSeq(vars["paths"], ",") {
    		if path == "" {
    			continue
    		}
    		args.Resources = append(args.Resources, path)
    	}
    
    	for _, lks := range z.serverPools[0].erasureLockers {
    		lockers = append(lockers, lks...)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  9. cmd/iam-store.go

    		return true
    	})
    	return policies
    }
    
    // converts a mapped policy into a slice of distinct policies
    func (mp MappedPolicy) toSlice() []string {
    	var policies []string
    	for policy := range strings.SplitSeq(mp.Policies, ",") {
    		if strings.TrimSpace(policy) == "" {
    			continue
    		}
    		policies = append(policies, policy)
    	}
    	return policies
    }
    
    func (mp MappedPolicy) policySet() set.StringSet {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    		KeyUsage:              x509.KeyUsageKeyEncipherment | x509.KeyUsageDigitalSignature,
    		ExtKeyUsage:           []x509.ExtKeyUsage{x509.ExtKeyUsageServerAuth},
    		BasicConstraintsValid: true,
    	}
    
    	hosts := strings.SplitSeq(host, ",")
    	for h := range hosts {
    		if ip := net.ParseIP(h); ip != nil {
    			template.IPAddresses = append(template.IPAddresses, ip)
    		} else {
    			template.DNSNames = append(template.DNSNames, h)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top