Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 68 for splitter (0.05 seconds)

  1. internal/config/identity/openid/openid.go

    			return c, errors.New("please specify config_url to enable fetching claims from UserInfo endpoint")
    		}
    
    		if scopeList := getCfgVal(Scopes); scopeList != "" {
    			var scopes []string
    			for scope := range strings.SplitSeq(scopeList, ",") {
    				scope = strings.TrimSpace(scope)
    				if scope == "" {
    					return c, config.Errorf("empty scope value is not allowed '%s', please refer to our documentation", scopeList)
    				}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  2. src/cmd/asm/internal/asm/endtoend_test.go

    	data, err := os.ReadFile(input)
    	if err != nil {
    		t.Error(err)
    		return
    	}
    	lineno := 0
    	seq := 0
    	hexByLine := map[string]string{}
    	lines := strings.SplitAfter(string(data), "\n")
    Diff:
    	for _, line := range lines {
    		lineno++
    
    		// Ignore include of textflag.h.
    		if strings.HasPrefix(line, "#include ") {
    			continue
    		}
    
    		// Ignore GLOBL.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 17:02:17 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  3. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  4. 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 attributes
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  5. src/bytes/bytes.go

    func Split(s, sep []byte) [][]byte { return genSplit(s, sep, 0, -1) }
    
    // SplitAfter slices s into all subslices after each instance of sep and
    // returns a slice of those subslices.
    // If sep is empty, SplitAfter splits after each UTF-8 sequence.
    // It is equivalent to SplitAfterN with a count of -1.
    func SplitAfter(s, sep []byte) [][]byte {
    	return genSplit(s, sep, len(sep), -1)
    }
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Mar 12 17:56:55 GMT 2026
    - 36.3K bytes
    - Click Count (0)
  6. internal/kms/config.go

    		}
    		return true, nil
    	}
    }
    
    func expandEndpoints(s string) ([]string, error) {
    	var endpoints []string
    	for endpoint := range strings.SplitSeq(s, ",") {
    		endpoint = strings.TrimSpace(endpoint)
    		if endpoint == "" {
    			continue
    		}
    		if !ellipses.HasEllipses(endpoint) {
    			endpoints = append(endpoints, endpoint)
    			continue
    		}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15K bytes
    - Click Count (0)
  7. cmd/bucket-replication-utils.go

    	r = ReplicateDecision{
    		targetsMap: make(map[string]replicateTargetDecision),
    	}
    	if len(s) == 0 {
    		return r, err
    	}
    	for p := range strings.SplitSeq(s, ",") {
    		if p == "" {
    			continue
    		}
    		slc := strings.Split(p, "=")
    		if len(slc) != 2 {
    			return r, errInvalidReplicateDecisionFormat
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  8. 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),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  9. internal/config/notify/parse.go

    		}
    		kafkaBrokers := env.Get(brokersEnv, kv.Get(target.KafkaBrokers))
    		if len(kafkaBrokers) == 0 {
    			return nil, config.Errorf("kafka 'brokers' cannot be empty")
    		}
    		for s := range strings.SplitSeq(kafkaBrokers, config.ValueSeparator) {
    			var host *xnet.Host
    			host, err = xnet.ParseHost(s)
    			if err != nil {
    				break
    			}
    			brokers = append(brokers, *host)
    		}
    		if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  10. 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...)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
Back to Top