Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  2. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  3. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  4. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.4K bytes
    - Viewed (0)
  5. go.sum

    github.com/lestrrat-go/httpcc v1.0.1 h1:ydWCStUeJLkpYyjLDHihupbn2tYmZ7m22BGkcvZZrIE=
    github.com/lestrrat-go/httpcc v1.0.1/go.mod h1:qiltp3Mt56+55GPVCbTdM9MlqhvzyuL6W/NMDA8vA5E=
    github.com/lestrrat-go/iter v1.0.2 h1:gMXo1q4c2pHmC3dn8LzRhJfP1ceCbgSiT9lUydIzltI=
    github.com/lestrrat-go/iter v1.0.2/go.mod h1:Momfcq3AnRlRjI5b5O8/G5/BvpzrhoFTZcn06fEOPt4=
    github.com/lestrrat-go/jwx v1.2.29 h1:QT0utmUJ4/12rmsVQrJ3u55bycPkKqGYuGT4tyRhxSQ=
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:31:35 GMT 2024
    - 84.2K bytes
    - Viewed (0)
  6. cmd/tier_test.go

    package cmd
    
    import (
    	"testing"
    	"time"
    )
    
    func TestTierMetrics(t *testing.T) {
    	tier := "WARM-1"
    	globalTierMetrics.Observe(tier, 200*time.Millisecond)
    	expSuccess := 10
    	expFailure := 5
    	for i := 0; i < expSuccess; i++ {
    		globalTierMetrics.logSuccess(tier)
    	}
    	for i := 0; i < expFailure; i++ {
    		globalTierMetrics.logFailure(tier)
    	}
    	metrics := globalTierMetrics.Report()
    	var succ, fail float64
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Dec 21 04:13:40 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  7. internal/store/batch_test.go

    	for i := 0; i < int(limit); i++ {
    		wg.Add(1)
    		go func(item int) {
    			defer wg.Done()
    			if err := batch.Add(item, item); err != nil {
    				t.Errorf("failed to add item %v; %v", item, err)
    				return
    			}
    			if _, ok := batch.GetByKey(item); !ok {
    				t.Errorf("failed to get the item by key %v after adding", item)
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	keys, items, err := batch.GetAll()
    	if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  8. internal/store/queuestore_test.go

    	// Get 10 items.
    	if len(itemKeys) == 10 {
    		for _, key := range itemKeys {
    			item, eErr := store.Get(strings.TrimSuffix(key, testItemExt))
    			if eErr != nil {
    				t.Fatal("Failed to Get the item from the queue store ", eErr)
    			}
    			if !reflect.DeepEqual(testItem, item) {
    				t.Fatalf("Failed to read the item: error: expected = %v, got = %v", testItem, item)
    			}
    		}
    	} else {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 04 17:52:24 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  9. cmd/data-usage-cache.go

    	for tier, st := range other.Tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    func (ats *allTierStats) clone() *allTierStats {
    	if ats == nil {
    		return nil
    	}
    	dst := *ats
    	dst.Tiers = make(map[string]tierStats, len(ats.Tiers))
    	for tier, st := range ats.Tiers {
    		dst.Tiers[tier] = st
    	}
    	return &dst
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  10. docs/minio-limits.md

    # MinIO Server Limits Per Tenant
    
    For optimal production setup MinIO recommends Linux kernel version 4.x and later.
    
    ## Erasure Code (Multiple Drives / Servers)
    
    | Item                                                            | Specification |
    |:----------------------------------------------------------------|:--------------|
    | Maximum number of servers per cluster                           | no-limit      |
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.9K bytes
    - Viewed (0)
Back to top