- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for tearDownQueueStore (0.12 sec)
-
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) -
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)