Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for GetMultiple (0.12 sec)

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