Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 94 for iter (0.18 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/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)
  4. 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)
  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.go

    	histogram: prometheus.NewHistogramVec(prometheus.HistogramOpts{
    		Name:    "tier_ttlb_seconds",
    		Help:    "Time taken by requests served by warm tier",
    		Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60},
    	}, []string{"tier"}),
    }
    
    func (t *tierMetrics) Observe(tier string, dur time.Duration) {
    	t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds())
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  7. cmd/tier_gen.go

    Aditya Manthramurthy <******@****.***> 1687222388 -0700
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 20 00:53:08 GMT 2023
    - 4K bytes
    - Viewed (0)
  8. cmd/tier-sweeper.go

    	os.TransitionTier = info.Tier
    	os.TransitionStatus = info.Status
    	os.RemoteObject = info.Name
    	os.TransitionVersionID = info.VersionID
    }
    
    // shouldRemoveRemoteObject determines if a transitioned object should be
    // removed from remote tier. If remote object is to be deleted, returns the
    // corresponding tier deletion journal entry and true. Otherwise returns empty
    // jentry value and false.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  9. cmd/tier-journal_gen_test.go

    Aditya Manthramurthy <******@****.***> 1622755611 -0700
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jun 03 21:26:51 GMT 2021
    - 4.3K bytes
    - Viewed (0)
  10. cmd/admin-router.go

    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/tier/{tier}").HandlerFunc(adminMiddleware(adminAPI.VerifyTierHandler))
    		// Tier stats
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/tier-stats").HandlerFunc(adminMiddleware(adminAPI.TierStatsHandler))
    
    		// Cluster Replication APIs
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
Back to top