Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 163 for separated (0.1 seconds)

  1. internal/lru/lru.go

    	// initialize the buckets
    	res.buckets = make([]bucket[K, V], numBuckets)
    	for i := 0; i < numBuckets; i++ {
    		res.buckets[i] = bucket[K, V]{entries: make(map[K]*Entry[K, V])}
    	}
    
    	// enable deleteExpired() running in separate goroutine for cache with non-zero TTL
    	//
    	// Important: done channel is never closed, so deleteExpired() goroutine will never exit,
    	// it's decided to add functionality to close it in the version later than v2.
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  2. docs/debugging/xl-meta/main.go

    	isPart := regexp.MustCompile("[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}/part\\.[0-9]+$")
    
    	app.HideHelpCommand = true
    	app.Flags = []cli.Flag{
    		cli.BoolFlag{
    			Usage:  "print each file as a separate line without formatting",
    			Name:   "ndjson",
    			Hidden: true,
    		},
    		cli.BoolFlag{
    			Usage: "display inline data keys and sizes",
    			Name:  "data",
    		},
    		cli.BoolFlag{
    			Usage: "export inline data",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.4K bytes
    - Click Count (0)
  3. docs/security/README.md

    ##### Figure 1 - Secure Channel construction
    
    ```
    plaintext   := chunk_0          ||       chunk_1          ||       chunk_2          ||       ...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 13.8K bytes
    - Click Count (0)
  4. cmd/storage-rest-client.go

    		Path:   path.Join(storageRESTPrefix, endpoint.Path, storageRESTVersion),
    	}
    
    	restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	if healthCheck {
    		// Use a separate client to avoid recursive calls.
    		healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    		healthClient.NoMetrics = true
    		restClient.HealthCheckFn = func() bool {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  5. cmd/endpoint-ellipses.go

    		for j := uint64(0); j < totalSizes[i]/setSize; j++ {
    			setIndexes[i] = append(setIndexes[i], setSize)
    		}
    	}
    
    	return setIndexes, nil
    }
    
    // Returns all the expanded endpoints, each argument is expanded separately.
    func (s *endpointSet) getEndpoints() (endpoints []string) {
    	if len(s.endpoints) != 0 {
    		return s.endpoints
    	}
    	for _, argPattern := range s.argPatterns {
    		for _, lbls := range argPattern.Expand() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  6. cmd/streaming-signature-v4.go

    	}
    	input := bufio.NewScanner(bytes.NewReader(valueBuffer.Bytes()))
    	for input.Scan() {
    		line := strings.TrimSpace(input.Text())
    		if line == "" {
    			continue
    		}
    		// Find first separator.
    		idx := strings.IndexByte(line, trailerKVSeparator[0])
    		if idx <= 0 || idx >= len(line) {
    			if cr.debug {
    				fmt.Printf("index, ':' not found in %q\n", line)
    			}
    			return errMalformedEncoding
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  7. cmd/peer-rest-client.go

    	}
    
    	serverURL := &url.URL{
    		Scheme: scheme,
    		Host:   peer.String(),
    		Path:   peerRESTPath,
    	}
    
    	restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	// Use a separate client to avoid recursive calls.
    	healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	healthClient.NoMetrics = true
    
    	// Construct a new health function.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  8. LICENSE

          this License, without any additional terms or conditions.
          Notwithstanding the above, nothing herein shall supersede or modify
          the terms of any separate license agreement you may have executed
          with Licensor regarding such Contributions.
    
       6. Trademarks. This License does not grant permission to use the trade
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed May 07 12:40:53 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  9. src/cmd/asm/internal/arch/arch.go

    	}
    	for i, s := range ppc64.Anames {
    		if obj.As(i) >= obj.A_ARCHSPECIFIC {
    			instructions[s] = obj.As(i) + obj.ABasePPC64
    		}
    	}
    	// The opcodes generated by x/arch's ppc64map are listed in
    	// a separate slice, add them too.
    	for i, s := range ppc64.GenAnames {
    		instructions[s] = obj.As(i) + ppc64.AFIRSTGEN
    	}
    	// Annoying aliases.
    	instructions["BR"] = ppc64.ABR
    	instructions["BL"] = ppc64.ABL
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Nov 13 12:17:37 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  10. internal/s3select/csv/reader_contrib_test.go

    			wantColumns:     []string{"header1", "header2", "header3"},
    			wantFields:      "ok1,ok2,ok3\n" + `""""""",b,c` + "\n\"\n",
    			wantErr:         io.EOF,
    		},
    		{
    			// Test when file ends with a half separator
    			file:            "endswithhalfsep.csv",
    			recordDelimiter: "%!",
    			fieldDelimiter:  ",",
    			sendErr:         nil,
    			header:          false,
    			wantColumns:     []string{"_1", "_2", "_3"},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.4K bytes
    - Click Count (0)
Back to Top