Function TestSQLiteTaskQueueTaskSuite

common/persistence/tests/sqlite_test.go:234–256

(t *testing.T)

}

func TestSQLiteTaskQueueTaskSuite(t *testing.T) {
	t.Parallel()
	cfg := NewSQLiteMemoryConfig()
	logger := log.NewNoopLogger()
	factory := sql.NewFactory(
		*cfg,
		resolver.NewNoopResolver(),
		testSQLiteClusterName,
		logger,
		metrics.NoopMetricsHandler,
		serialization.NewSerializer(),
	)
	taskQueueStore, err := factory.NewTaskStore()
	if err != nil {
		t.Fatalf("unable to create SQLite DB: %v", err)
	}
	defer func() {
		factory.Close()
	}()

	s := NewTaskQueueTaskSuite(t, taskQueueStore, logger)
	suite.Run(t, s)
}

func TestSQLiteTaskQueueFairTaskSuite(t *testing.T) {
	t.Parallel()