Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for setUpQueueStore (0.19 sec)

  1. internal/store/queuestore_test.go

    	// Sample test item.
    	testItem = TestItem{Name: "test-item", Property: "property"}
    	// Ext for test item
    	testItemExt = ".test"
    )
    
    // Initialize the queue store.
    func setUpQueueStore(directory string, limit uint64) (Store[TestItem], error) {
    	queueStore := NewQueueStore[TestItem](queueDir, limit, testItemExt)
    	if oErr := queueStore.Open(); oErr != nil {
    		return nil, oErr
    	}
    	return queueStore, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. internal/store/batch_test.go

    	"testing"
    	"time"
    )
    
    func TestBatchCommit(t *testing.T) {
    	defer func() {
    		if err := tearDownQueueStore(); err != nil {
    			t.Fatalf("Failed to tear down store; %v", err)
    		}
    	}()
    	store, err := setUpQueueStore(queueDir, 100)
    	if err != nil {
    		t.Fatalf("Failed to create a queue store; %v", err)
    	}
    
    	var limit uint32 = 100
    
    	batch := NewBatch[TestItem](BatchConfig[TestItem]{
    		Limit:         limit,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top