Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 98 for iter (0.4 sec)

  1. internal/s3select/simdj/record.go

    	if elem == nil {
    		return nil, nil
    	}
    	return iterToValue(elem.Iter)
    }
    
    func iterToValue(iter simdjson.Iter) (*sql.Value, error) {
    	switch iter.Type() {
    	case simdjson.TypeString:
    		v, err := iter.String()
    		if err != nil {
    			return nil, err
    		}
    		return sql.FromString(v), nil
    	case simdjson.TypeFloat:
    		v, err := iter.Float()
    		if err != nil {
    			return nil, err
    		}
    		return sql.FromFloat(v), nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  2. internal/s3select/sql/record.go

    		}
    		return v, nil
    	case simdjson.TypeObject:
    		obj, err := iter.Object(nil)
    		if err != nil {
    			return nil, err
    		}
    		return *obj, err
    	case simdjson.TypeArray:
    		arr, err := iter.Array(nil)
    		if err != nil {
    			return nil, err
    		}
    		iter := arr.Iter()
    		var dst []interface{}
    		var next simdjson.Iter
    		for {
    			typ, err := iter.AdvanceIter(&next)
    			if err != nil {
    				return nil, err
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.4K bytes
    - Viewed (0)
  3. internal/s3select/sql/jsonpath.go

    			return Missing{}, false, nil
    		case simdjson.Object:
    			elem := kvs.FindKey(key, nil)
    			if elem == nil {
    				// Key not found - return nil result
    				return Missing{}, false, nil
    			}
    			val, err := IterToValue(elem.Iter)
    			if err != nil {
    				return nil, false, err
    			}
    			return jsonpathEval(p[1:], val)
    		default:
    			return nil, false, errKeyLookup
    		}
    
    	case p[0].Index != nil:
    		idx := *p[0].Index
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  4. internal/s3select/simdj/reader_amd64_test.go

    			if err != nil {
    				t.Fatal(err)
    			}
    			i := pj.Iter()
    			cpy := i
    			b, err := cpy.MarshalJSON()
    			if err != nil {
    				t.Fatal(err)
    			}
    			if false {
    				t.Log(string(b))
    			}
    			// _ = os.WriteFile(filepath.Join("testdata", tt.name+".json"), b, os.ModePerm)
    
    		parser:
    			for {
    				var next simdjson.Iter
    				typ, err := i.AdvanceIter(&next)
    				if err != nil {
    					t.Fatal(err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  5. internal/s3select/simdj/reader.go

    			r.err = &in.Error
    			return
    		}
    		if in.Value == nil {
    			if in.Error == io.EOF {
    				return
    			}
    			continue
    		}
    		i := in.Value.Iter()
    	readloop:
    		for {
    			var next simdjson.Iter
    			typ, err := i.AdvanceIter(&next)
    			if err != nil {
    				r.err = &err
    				return
    			}
    			switch typ {
    			case simdjson.TypeNone:
    				break readloop
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  6. cmd/tier-handlers.go

    )
    
    var (
    	// error returned when remote tier already exists
    	errTierAlreadyExists = AdminError{
    		Code:       "XMinioAdminTierAlreadyExists",
    		Message:    "Specified remote tier already exists",
    		StatusCode: http.StatusConflict,
    	}
    	// error returned when remote tier is not found
    	errTierNotFound = AdminError{
    		Code:       "XMinioAdminTierNotFound",
    		Message:    "Specified remote tier was not found",
    		StatusCode: http.StatusNotFound,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  7. cmd/tier-journal.go

    	VersionID string `msg:"vid"`
    	TierName  string `msg:"tier"`
    }
    
    const (
    	tierJournalVersion = 1
    	tierJournalHdrLen  = 2 // 2 bytes
    )
    
    var errUnsupportedJournalVersion = errors.New("unsupported pending deletes journal version")
    
    func newTierDiskJournal() *tierDiskJournal {
    	return &tierDiskJournal{}
    }
    
    // NewTierJournal initializes tier deletion journal
    func NewTierJournal() *TierJournal {
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  8. cmd/tier-last-day-stats.go

    		merged.Bins[i] = cl.Bins[i].add(cm.Bins[i])
    	}
    
    	return merged
    }
    
    // DailyAllTierStats is used to aggregate last day tier stats across MinIO servers
    type DailyAllTierStats map[string]lastDayTierStats
    
    func (l DailyAllTierStats) merge(m DailyAllTierStats) {
    	for tier, st := range m {
    		l[tier] = l[tier].merge(st)
    	}
    }
    
    func (l DailyAllTierStats) addToTierInfo(tierInfos []madmin.TierInfo) []madmin.TierInfo {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  9. cmd/tier_gen_test.go

    Krishnan Parthasarathi <******@****.***> 1618853442 -0700
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.3K bytes
    - Viewed (0)
  10. cmd/data-usage_test.go

    		{name: "dir1/dira/dirasub/sublevel3/dccccfile", size: 10},
    	}
    	createUsageTestFiles(t, base, bucket, files)
    
    	getSize := func(item scannerItem) (sizeS sizeSummary, err error) {
    		if item.Typ&os.ModeDir == 0 {
    			var s os.FileInfo
    			s, err = os.Stat(item.Path)
    			if err != nil {
    				return
    			}
    			sizeS.totalSize = s.Size()
    			sizeS.versions++
    			return sizeS, nil
    		}
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
Back to top