- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 97 for iter (0.21 sec)
-
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) -
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) -
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) -
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) -
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 3.4K bytes - Viewed (0) -
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) -
cmd/tier-journal_test.go
} var b bytes.Buffer for _, item := range readOldToNewCases { bs, err := item.je.MarshalMsg(nil) if err != nil { t.Fatal(err) } b.Write(bs) } mr := msgp.NewReader(&b) for i, item := range readOldToNewCases { var je jentry err := je.DecodeMsg(mr) if err != nil { t.Fatal(err) } if je != item.exp { t.Errorf("Case %d: Expected: %v Got: %v", i, item.exp, je)
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 3.2K bytes - Viewed (0) -
cmd/tier-mem-journal.go
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Aug 03 21:16:15 GMT 2023 - 1.5K bytes - Viewed (0) -
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) -
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)