Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for tearDownQueueStore (0.12 sec)

  1. internal/store/queuestore_test.go

    		return nil, oErr
    	}
    	return queueStore, nil
    }
    
    // Tear down queue store.
    func tearDownQueueStore() error {
    	return os.RemoveAll(queueDir)
    }
    
    // TestQueueStorePut - tests for store.Put
    func TestQueueStorePut(t *testing.T) {
    	defer func() {
    		if err := tearDownQueueStore(); err != nil {
    			t.Fatal("Failed to tear down store ", err)
    		}
    	}()
    	store, err := setUpQueueStore(queueDir, 100)
    Registered: 2024-11-03 19:28
    - Last Modified: 2024-09-06 23:06
    - 8.7K bytes
    - Viewed (0)
  2. internal/store/batch_test.go

    package store
    
    import (
    	"context"
    	"sync"
    	"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)
    	}
    
    Registered: 2024-11-03 19:28
    - Last Modified: 2024-09-06 23:06
    - 5.6K bytes
    - Viewed (0)
Back to top