Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for parseKey (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top