- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for GetMultiple (0.12 sec)
-
internal/store/batch_test.go
if !key.Compress { t.Fatal("expected key.Compress=true; but got false") } if key.ItemCount != int(limit) { t.Fatalf("expected key.ItemCount=%d; but got %v", limit, key.ItemCount) } items, err := store.GetMultiple(key) if err != nil { t.Fatalf("unable to read key %v; %v", key.String(), err) } if len(items) != int(limit) { t.Fatalf("expected len(items)=%d; but got %v", limit, len(items)) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0) -
internal/store/queuestore_test.go
if !key.Compress { t.Fatal("expected the item to be compressed") } if key.ItemCount != 10 { t.Fatalf("expected itemcount=10 but found %v", key.ItemCount) } resultItems, err := store.GetMultiple(key) if err != nil { t.Fatalf("unable to get multiple items; %v", err) } if !reflect.DeepEqual(resultItems, items) { t.Fatalf("expected item list: %v; but got %v", items, resultItems) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.7K bytes - Viewed (0) -
internal/store/queuestore.go
return item, os.ErrNotExist } if err = json.Unmarshal(eventData, &item); err != nil { return item, err } return item, nil } // GetMultiple will read the multi payload file and fetch the items func (store *QueueStore[I]) GetMultiple(key Key) (items []I, err error) { store.RLock() defer func(store *QueueStore[I]) { store.RUnlock() if err != nil && !os.IsNotExist(err) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.6K bytes - Viewed (0) -
internal/store/store.go
Name() string SendFromStore(key Key) error } // Store - Used to persist items. type Store[I any] interface { Put(item I) (Key, error) PutMultiple(item []I) (Key, error) Get(key Key) (I, error) GetMultiple(key Key) ([]I, error) GetRaw(key Key) ([]byte, error) PutRaw(b []byte) (Key, error) Len() int List() []Key Del(key Key) error Open() error Delete() error }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0)