Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newScanner (0.04 sec)

  1. internal/config/config.go

    }
    
    // Config - MinIO server config structure.
    type Config map[string]map[string]KVS
    
    // DelFrom - deletes all keys in the input reader.
    func (c Config) DelFrom(r io.Reader) error {
    	scanner := bufio.NewScanner(r)
    	for scanner.Scan() {
    		// Skip any empty lines, or comment like characters
    		text := scanner.Text()
    		if text == "" || strings.HasPrefix(text, KvComment) {
    			continue
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 37.7K bytes
    - Viewed (0)
  2. internal/s3select/jstream/decoder.go

    // emitDepth from the provider io.Reader.
    // If emitDepth is < 0, values at every depth will be emitted.
    func NewDecoder(r io.Reader, emitDepth int) *Decoder {
    	d := &Decoder{
    		scanner:   newScanner(r),
    		emitDepth: emitDepth,
    		scratch:   &scratch{data: make([]byte, 1024)},
    		metaCh:    make(chan *MetaValue, 128),
    	}
    	if emitDepth < 0 {
    		d.emitDepth = 0
    		d.emitRecursive = true
    	}
    	return d
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  3. cmd/update.go

    			ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    			internalLogIf(ctx, err)
    		}
    		return ""
    	}
    	defer helmInfoFile.Close()
    	scanner := bufio.NewScanner(helmInfoFile)
    	for scanner.Scan() {
    		if strings.Contains(scanner.Text(), "chart=") {
    			helmChartVersion := strings.TrimPrefix(scanner.Text(), "chart=")
    			// remove quotes from the chart version
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  4. cmd/common-main.go

    func minioEnvironFromFile(envConfigFile string) ([]envKV, error) {
    	f, err := Open(envConfigFile)
    	if err != nil {
    		return nil, err
    	}
    	defer f.Close()
    	var ekvs []envKV
    	scanner := bufio.NewScanner(f)
    	for scanner.Scan() {
    		ekv, err := parsEnvEntry(scanner.Text())
    		if err != nil {
    			return nil, err
    		}
    		if ekv.Skip {
    			// Skips empty lines
    			continue
    		}
    		ekvs = append(ekvs, ekv)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  5. cmd/streaming-signature-v4.go

    	}
    
    	// Parse trailers.
    	wantTrailers := make(map[string]struct{}, len(cr.trailers))
    	for k := range cr.trailers {
    		wantTrailers[strings.ToLower(k)] = struct{}{}
    	}
    	input := bufio.NewScanner(bytes.NewReader(valueBuffer.Bytes()))
    	for input.Scan() {
    		line := strings.TrimSpace(input.Text())
    		if line == "" {
    			continue
    		}
    		// Find first separator.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 18.2K bytes
    - Viewed (0)
Back to top