Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 234 for Scanner (0.11 sec)

  1. cni/pkg/nodeagent/podcgroupns.go

    func GetCgroups(procCgroupData bytes.Buffer) ([]Cgroup, error) {
    	reader := bytes.NewReader(procCgroupData.Bytes())
    	var cgroups []Cgroup
    	scanner := bufio.NewScanner(reader)
    
    	for scanner.Scan() {
    		token := scanner.Text()
    		substrings := strings.SplitN(token, ":", 3)
    		if len(substrings) < 3 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. schema/field.go

    						}
    
    						if valuer, ok := v.(driver.Valuer); ok {
    							v, _ = valuer.Value()
    						}
    
    						err = fieldValue.Interface().(sql.Scanner).Scan(v)
    					}
    					return
    				}
    			} else if _, ok := fieldValue.Interface().(sql.Scanner); ok {
    				// struct scanner
    				field.Set = func(ctx context.Context, value reflect.Value, v interface{}) (err error) {
    					reflectV := reflect.ValueOf(v)
    					if !reflectV.IsValid() {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 15 03:20:20 UTC 2024
    - 32K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/lex/lex_test.go

    // Copyright 2015 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package lex
    
    import (
    	"strings"
    	"testing"
    	"text/scanner"
    )
    
    type lexTest struct {
    	name   string
    	input  string
    	output string
    }
    
    var lexTests = []lexTest{
    	{
    		"empty",
    		"",
    		"",
    	},
    	{
    		"simple",
    		"1 (a)",
    		"1.(.a.)",
    	},
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  4. docs/bucket/replication/DESIGN.md

    for existing object replication are detected when scanner runs, and will be replicated if existing object replication is enabled and applicable replication rules are satisfied. Because replication depends on the immutability of versions, only pre-existing objects created while versioning was enabled can be replicated. Even if replication rules are disabled and re-enabled later, the objects created during the interim will be synced as the scanner queues them. For saving iops, objects qualifying for...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  5. docs/bucket/lifecycle/DESIGN.md

    ## Implementation
    
    ILM tiering takes place when a object placed in the bucket meets lifecycle transition rules and becomes eligible for tiering. MinIO scanner (which runs at one minute intervals, each time scanning one sixteenth of the namespace), picks up the object for tiering. The data is moved to the remote tier in entirety, leaving only the object metadata on MinIO.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  6. internal/config/config.go

    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
    		}
    		if err := c.DelKVS(text); err != nil {
    			return err
    		}
    	}
    	return scanner.Err()
    }
    
    // ContextKeyString is type(string) for contextKey
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  7. scan.go

    				sch, _ = schema.Parse(db.Statement.Dest, db.cacheStore, db.NamingStrategy)
    			}
    
    			if len(columns) == 1 {
    				// Is Pluck
    				if _, ok := reflect.New(reflectValueType).Interface().(sql.Scanner); (reflectValueType != sch.ModelType && ok) || // is scanner
    					reflectValueType.Kind() != reflect.Struct || // is not struct
    					sch.ModelType.ConvertibleTo(schema.TimeReflectType) { // is time
    					sch = nil
    				}
    			}
    
    			// Not Pluck
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  8. internal/mountinfo/mountinfo_linux.go

    		return nil, err
    	}
    	defer file.Close()
    	return parseMountFrom(file)
    }
    
    func parseMountFrom(file io.Reader) (mountInfos, error) {
    	mounts := mountInfos{}
    	scanner := bufio.NewReader(file)
    	for {
    		line, err := scanner.ReadString('\n')
    		if err == io.EOF {
    			break
    		}
    
    		fields := strings.Fields(line)
    		if len(fields) != expectedNumFieldsPerLine {
    			// ignore incorrect lines.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  9. cmd/scannermetric_string.go

    // Code generated by "stringer -type=scannerMetric -trimprefix=scannerMetric data-scanner-metric.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[scannerMetricReadMetadata-0]
    	_ = x[scannerMetricCheckMissing-1]
    	_ = x[scannerMetricSaveUsage-2]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 05:15:31 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  10. cmd/logging.go

    }
    
    func scannerLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "scanner", err, errKind...)
    }
    
    func scannerLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, "scanner", err, id, errKind...)
    }
    
    func ilmLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "ilm", err, errKind...)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top