Lines Matching refs:tsm1
21 v1 := tsm1.NewValue(1, float64(1))
22 v2 := tsm1.NewValue(1, float64(1))
23 v3 := tsm1.NewValue(2, float64(2))
25 points1 := map[string][]tsm1.Value{
30 c := tsm1.NewCache(0)
37 compactor := tsm1.NewCompactor()
69 points []tsm1.Value
71 {"cpu,host=A#!~#value", []tsm1.Value{v1}},
72 {"cpu,host=B#!~#value", []tsm1.Value{v2, v3}},
95 var vals tsm1.Values
98 vals = append(vals, tsm1.NewIntegerValue(ts, 1))
103 vals = append(vals, tsm1.NewIntegerValue(ts, 1))
104 writes := map[string][]tsm1.Value{
109 writes = map[string][]tsm1.Value{
116 compactor := tsm1.NewCompactor()
133 err = tsm1.DecodeIntegerArrayBlock(b, &a)
149 a1 := tsm1.NewValue(1, 1.1)
150 writes := map[string][]tsm1.Value{
155 a2 := tsm1.NewValue(2, 1.2)
156 b1 := tsm1.NewValue(1, 2.1)
157 writes = map[string][]tsm1.Value{
163 a3 := tsm1.NewValue(1, 1.3)
164 c1 := tsm1.NewValue(1, 3.1)
165 writes = map[string][]tsm1.Value{
173 compactor := tsm1.NewCompactor()
197 expGen, expSeq, err := tsm1.DefaultParseFileName(f3)
203 gotGen, gotSeq, err := tsm1.DefaultParseFileName(files[0])
224 points []tsm1.Value
226 {"cpu,host=A#!~#value", []tsm1.Value{a3, a2}},
227 {"cpu,host=B#!~#value", []tsm1.Value{b1}},
228 {"cpu,host=C#!~#value", []tsm1.Value{c1}},
253 a1 := tsm1.NewValue(4, 1.1)
254 a2 := tsm1.NewValue(5, 1.1)
255 a3 := tsm1.NewValue(7, 1.1)
257 writes := map[string][]tsm1.Value{
262 c1 := tsm1.NewValue(3, 1.2)
263 c2 := tsm1.NewValue(8, 1.2)
264 c3 := tsm1.NewValue(9, 1.2)
266 writes = map[string][]tsm1.Value{
273 compactor := tsm1.NewCompactor()
297 points []tsm1.Value
299 {"cpu,host=A#!~#value", []tsm1.Value{c1, a1, a2, a3, c2, c3}},
324 a1 := tsm1.NewValue(4, 1.1)
325 a2 := tsm1.NewValue(5, 1.1)
326 a3 := tsm1.NewValue(7, 1.1)
328 writes := map[string][]tsm1.Value{
333 b1 := tsm1.NewValue(1, 1.2)
334 b2 := tsm1.NewValue(2, 1.2)
335 b3 := tsm1.NewValue(6, 1.2)
337 writes = map[string][]tsm1.Value{
342 c1 := tsm1.NewValue(3, 1.2)
343 c2 := tsm1.NewValue(8, 1.2)
344 c3 := tsm1.NewValue(9, 1.2)
346 writes = map[string][]tsm1.Value{
353 compactor := tsm1.NewCompactor()
377 points []tsm1.Value
379 {"cpu,host=A#!~#value", []tsm1.Value{b1, b2, c1, a1, a2, b3, a3, c2, c3}},
403 a1 := tsm1.NewValue(4, 1.1)
404 a2 := tsm1.NewValue(5, 1.1)
405 a3 := tsm1.NewValue(6, 1.1)
407 writes := map[string][]tsm1.Value{
412 b1 := tsm1.NewValue(1, 1.2)
413 b2 := tsm1.NewValue(2, 1.2)
414 b3 := tsm1.NewValue(3, 1.2)
416 writes = map[string][]tsm1.Value{
421 compactor := tsm1.NewCompactor()
445 points []tsm1.Value
447 {"cpu,host=A#!~#value", []tsm1.Value{b1, b2, b3, a1, a2, a3}},
471 a1 := tsm1.NewValue(1, 1.1)
472 a2 := tsm1.NewValue(2, 1.1)
474 writes := map[string][]tsm1.Value{
479 b1 := tsm1.NewValue(3, 1.2)
480 b2 := tsm1.NewValue(4, 1.2)
482 writes = map[string][]tsm1.Value{
487 c1 := tsm1.NewValue(1, 1.1)
488 c2 := tsm1.NewValue(2, 1.1)
490 writes = map[string][]tsm1.Value{
495 compactor := tsm1.NewCompactor()
519 points []tsm1.Value
521 {"cpu,host=A#!~#value", []tsm1.Value{a1, a2, b1, b2}},
546 a1 := tsm1.NewValue(1, 1.1)
547 a2 := tsm1.NewValue(2, 1.2)
548 writes := map[string][]tsm1.Value{
553 a3 := tsm1.NewValue(3, 1.3)
554 writes = map[string][]tsm1.Value{
559 a4 := tsm1.NewValue(4, 1.4)
560 writes = map[string][]tsm1.Value{
567 compactor := tsm1.NewCompactor()
582 expGen, expSeq, err := tsm1.DefaultParseFileName(f3)
588 gotGen, gotSeq, err := tsm1.DefaultParseFileName(files[0])
609 points []tsm1.Value
611 {"cpu,host=A#!~#value", []tsm1.Value{a1, a2, a3, a4}},
641 a1 := tsm1.NewValue(1, 1.1)
642 a2 := tsm1.NewValue(2, 1.2)
643 writes := map[string][]tsm1.Value{
648 ts := tsm1.NewTombstoner(f1, nil)
655 a3 := tsm1.NewValue(3, 1.3)
656 writes = map[string][]tsm1.Value{
661 a4 := tsm1.NewValue(4, 1.4)
662 writes = map[string][]tsm1.Value{
669 compactor := tsm1.NewCompactor()
684 expGen, expSeq, err := tsm1.DefaultParseFileName(f3)
690 gotGen, gotSeq, err := tsm1.DefaultParseFileName(files[0])
711 points []tsm1.Value
713 {"cpu,host=A#!~#value", []tsm1.Value{a3, a4}},
743 a1 := tsm1.NewValue(1, 1.1)
744 a2 := tsm1.NewValue(2, 1.2)
745 writes := map[string][]tsm1.Value{
750 ts := tsm1.NewTombstoner(f1, nil)
758 a3 := tsm1.NewValue(3, 1.3)
759 writes = map[string][]tsm1.Value{
764 a4 := tsm1.NewValue(4, 1.4)
765 writes = map[string][]tsm1.Value{
772 compactor := tsm1.NewCompactor()
787 expGen, expSeq, err := tsm1.DefaultParseFileName(f3)
793 gotGen, gotSeq, err := tsm1.DefaultParseFileName(files[0])
814 points []tsm1.Value
816 {"cpu,host=A#!~#value", []tsm1.Value{a1, a3, a4}},
847 a1 := tsm1.NewValue(1, 1.1)
848 a2 := tsm1.NewValue(2, 1.2)
849 a3 := tsm1.NewValue(3, 1.3)
850 a4 := tsm1.NewValue(4, 1.4)
852 writes := map[string][]tsm1.Value{
857 ts := tsm1.NewTombstoner(f1, nil)
866 a5 := tsm1.NewValue(5, 1.5)
867 writes = map[string][]tsm1.Value{
872 a6 := tsm1.NewValue(6, 1.6)
873 writes = map[string][]tsm1.Value{
880 compactor := tsm1.NewCompactor()
895 expGen, expSeq, err := tsm1.DefaultParseFileName(f3)
901 gotGen, gotSeq, err := tsm1.DefaultParseFileName(files[0])
922 points []tsm1.Value
924 {"cpu,host=A#!~#value", []tsm1.Value{a1, a3, a5, a6}},
960 values := make([]tsm1.Value, 1000)
964 values = append(values, tsm1.NewValue(int64(i*1000+j), int64(1)))
982 values = append(values, tsm1.NewValue(int64(j), int64(1)))
996 compactor := tsm1.NewCompactor()
1011 expGen, expSeq, err := tsm1.DefaultParseFileName(f2Name)
1017 gotGen, gotSeq, err := tsm1.DefaultParseFileName(files[0])
1036 v1 := tsm1.NewValue(1, 1.1)
1037 writes := map[string][]tsm1.Value{
1043 iter, err := tsm1.NewTSMKeyIterator(1, false, nil, r)
1055 values, err := tsm1.DecodeBlock(block, nil)
1088 v1 := tsm1.NewValue(1, int64(1))
1089 v2 := tsm1.NewValue(1, int64(2))
1091 writes1 := map[string][]tsm1.Value{
1097 writes2 := map[string][]tsm1.Value{
1103 iter, err := tsm1.NewTSMKeyIterator(1, false, nil, r1, r2)
1115 values, err := tsm1.DecodeBlock(block, nil)
1143 v1 := tsm1.NewValue(2, int64(1))
1144 points1 := map[string][]tsm1.Value{
1153 v2 := tsm1.NewValue(1, float64(1))
1154 v3 := tsm1.NewValue(1, float64(1))
1156 points2 := map[string][]tsm1.Value{
1164 iter, err := tsm1.NewTSMKeyIterator(1, false, nil, r1, r2)
1172 value tsm1.Value
1183 values, err := tsm1.DecodeBlock(block, nil)
1212 v1 := tsm1.NewValue(10, int64(1))
1213 v2 := tsm1.NewValue(20, int64(1))
1214 v3 := tsm1.NewValue(30, int64(1))
1215 v4 := tsm1.NewValue(40, int64(1))
1216 v5 := tsm1.NewValue(50, int64(1))
1217 v6 := tsm1.NewValue(60, int64(1))
1219 points1 := map[string][]tsm1.Value{
1245 iter, err := tsm1.NewTSMKeyIterator(1, false, nil, r1)
1253 value tsm1.Value
1266 values, err := tsm1.DecodeBlock(block, nil)
1294 v1 := tsm1.NewValue(1, 1.1)
1295 writes := map[string][]tsm1.Value{
1302 iter, err := tsm1.NewTSMKeyIterator(1, false, intC, r)
1325 v0 := tsm1.NewValue(1, 1.0)
1327 writes := map[string][]tsm1.Value{
1331 c := tsm1.NewCache(0)
1339 iter := tsm1.NewCacheKeyIterator(c, 1, nil)
1347 values, err := tsm1.DecodeBlock(block, nil)
1372 v0 := tsm1.NewValue(1, 1.0)
1373 v1 := tsm1.NewValue(2, 2.0)
1375 writes := map[string][]tsm1.Value{
1379 c := tsm1.NewCache(0)
1387 iter := tsm1.NewCacheKeyIterator(c, 1, nil)
1396 values, err := tsm1.DecodeBlock(block, nil)
1423 v0 := tsm1.NewValue(1, 1.0)
1425 writes := map[string][]tsm1.Value{
1429 c := tsm1.NewCache(0)
1439 iter := tsm1.NewCacheKeyIterator(c, 1, intC)
1459 cp := tsm1.NewDefaultPlanner(
1461 PathsFn: func() []tsm1.FileStat {
1462 return []tsm1.FileStat{
1489 data := []tsm1.FileStat{
1520 cp := tsm1.NewDefaultPlanner(
1522 PathsFn: func() []tsm1.FileStat {
1528 expFiles := []tsm1.FileStat{data[0], data[1], data[2], data[3]}
1543 data := []tsm1.FileStat{
1582 cp := tsm1.NewDefaultPlanner(&fakeFileStore{
1583 PathsFn: func() []tsm1.FileStat {
1588 expFiles := []tsm1.FileStat{data[0], data[1], data[2], data[3],
1620 data := []tsm1.FileStat{
1671 cp := tsm1.NewDefaultPlanner(
1673 PathsFn: func() []tsm1.FileStat {
1679 …expFiles := []tsm1.FileStat{data[4], data[5], data[6], data[7], data[8], data[9], data[10], data[1…
1693 data := []tsm1.FileStat{
1724 cp := tsm1.NewDefaultPlanner(
1726 PathsFn: func() []tsm1.FileStat {
1732 expFiles := []tsm1.FileStat{data[0], data[1], data[2], data[3], data[4]}
1746 data := []tsm1.FileStat{
1777 cp := tsm1.NewDefaultPlanner(
1779 PathsFn: func() []tsm1.FileStat {
1785 expFiles := []tsm1.FileStat{}
1793 data := []tsm1.FileStat{
1820 cp := tsm1.NewDefaultPlanner(
1822 PathsFn: func() []tsm1.FileStat {
1828 expFiles := []tsm1.FileStat{}
1836 data := []tsm1.FileStat{
1852 cp := tsm1.NewDefaultPlanner(
1854 PathsFn: func() []tsm1.FileStat {
1860 expFiles := []tsm1.FileStat{}
1868 data := []tsm1.FileStat{
1896 cp := tsm1.NewDefaultPlanner(
1898 PathsFn: func() []tsm1.FileStat {
1904 expFiles := []tsm1.FileStat{data[0], data[1]}
1918 data := []tsm1.FileStat{
1953 cp := tsm1.NewDefaultPlanner(
1955 PathsFn: func() []tsm1.FileStat {
1961 …expFiles1 := []tsm1.FileStat{data[0], data[1], data[2], data[3], data[4], data[5], data[6], data[7…
1976 data := []tsm1.FileStat{
2043 cp := tsm1.NewDefaultPlanner(
2045 PathsFn: func() []tsm1.FileStat {
2090 data := []tsm1.FileStat{
2105 cp := tsm1.NewDefaultPlanner(
2107 PathsFn: func() []tsm1.FileStat {
2113 expFiles := []tsm1.FileStat{}
2121 data := []tsm1.FileStat{
2152 cp := tsm1.NewDefaultPlanner(
2154 PathsFn: func() []tsm1.FileStat {
2160 expFiles1 := []tsm1.FileStat{data[0], data[1], data[2], data[3], data[4], data[5]}
2178 data := []tsm1.FileStat{
2221 cp := tsm1.NewDefaultPlanner(
2223 PathsFn: func() []tsm1.FileStat {
2229 expFiles1 := []tsm1.FileStat{data[0], data[1], data[2], data[3]}
2230 expFiles2 := []tsm1.FileStat{data[6], data[7], data[8], data[9]}
2259 data := []tsm1.FileStat{
2274 cp := tsm1.NewDefaultPlanner(
2276 PathsFn: func() []tsm1.FileStat {
2282 expFiles := []tsm1.FileStat{}
2290 data := []tsm1.FileStat{
2306 cp := tsm1.NewDefaultPlanner(
2308 PathsFn: func() []tsm1.FileStat {
2314 expFiles := []tsm1.FileStat{data[0], data[1], data[2]}
2331 data := []tsm1.FileStat{
2358 cp := tsm1.NewDefaultPlanner(
2360 PathsFn: func() []tsm1.FileStat {
2382 data := []tsm1.FileStat{
2393 cp := tsm1.NewDefaultPlanner(
2395 PathsFn: func() []tsm1.FileStat {
2410 testSet := []tsm1.FileStat{
2430 PathsFn: func() []tsm1.FileStat {
2436 cp := tsm1.NewDefaultPlanner(fs, time.Nanosecond)
2445 over := []tsm1.FileStat{
2469 PathsFn: func() []tsm1.FileStat {
2502 data := []tsm1.FileStat{
2545 cp := tsm1.NewDefaultPlanner(
2548 PathsFn: func() []tsm1.FileStat {
2563 testSet := []tsm1.FileStat{
2583 PathsFn: func() []tsm1.FileStat {
2589 cp := tsm1.NewDefaultPlanner(
2602 over := []tsm1.FileStat{
2614 PathsFn: func() []tsm1.FileStat {
2629 data := []tsm1.FileStat{
2652 cp := tsm1.NewDefaultPlanner(
2654 PathsFn: func() []tsm1.FileStat {
2660 expFiles := []tsm1.FileStat{data[0], data[1], data[2], data[3]}
2674 cp := tsm1.NewDefaultPlanner(
2676 PathsFn: func() []tsm1.FileStat {
2677 return []tsm1.FileStat{
2710 cp := tsm1.NewDefaultPlanner(
2712 PathsFn: func() []tsm1.FileStat {
2713 return []tsm1.FileStat{
2823 func assertValueEqual(t *testing.T, a, b tsm1.Value) {
2832 func MustTSMWriter(dir string, gen int) (tsm1.TSMWriter, string) {
2842 newName := filepath.Join(filepath.Dir(oldName), tsm1.DefaultFormatFileName(gen, 1)+".tsm")
2853 w, err := tsm1.NewTSMWriter(f)
2861 func MustWriteTSM(dir string, gen int, values map[string][]tsm1.Value) string {
2887 func MustTSMReader(dir string, gen int, values map[string][]tsm1.Value) *tsm1.TSMReader {
2891 func MustOpenTSMReader(name string) *tsm1.TSMReader {
2897 r, err := tsm1.NewTSMReader(f)
2905 PathsFn func() []tsm1.FileStat
2908 readers []*tsm1.TSMReader
2911 func (w *fakeFileStore) Stats() []tsm1.FileStat {
2927 func (w *fakeFileStore) TSMReader(path string) *tsm1.TSMReader {
2942 return tsm1.DefaultParseFileName(path)