- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for parseKey (0.22 sec)
-
internal/store/store_test.go
expectedKey: Key{ Name: "01894394-d046-4783-ba0d-f1c6885790dc", Extension: ".event", ItemCount: 1, }, }, } for i, testCase := range testCases { key := parseKey(testCase.str) if testCase.expectedKey.Name != key.Name { t.Fatalf("case[%v]: Expected key.Name: %v, got %v", i, testCase.expectedKey.Name, key.Name) } if testCase.expectedKey.Compress != key.Compress {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4K bytes - Viewed (0) -
internal/store/store.go
} return "" }() } func getItemCount(k string) (count int, err error) { count = 1 v := strings.Split(k, ":") if len(v) == 2 { return strconv.Atoi(v[0]) } return } func parseKey(k string) (key Key) { key.Name = k if strings.HasSuffix(k, compressExt) { key.Compress = true key.Name = strings.TrimSuffix(key.Name, compressExt) } if key.ItemCount, _ = getItemCount(k); key.ItemCount > 1 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0) -
internal/store/queuestore.go
} // Sort entries... sort.Slice(entries, func(i, j int) bool { return store.entries[entries[i]] < store.entries[entries[j]] }) for i := range entries { keys = append(keys, parseKey(entries[i])) } return keys } // list will read all entries from disk. // Entries are returned sorted by modtime, oldest first. // Underlying entry list in store is *not* updated.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.6K bytes - Viewed (0)