integration

type QueryFixtures ¶

type QueryFixtures struct {
	Caption          string
	Query            *tracestore.TraceQueryParams
	ExpectedFixtures []string
}

QueryFixtures and TraceFixtures are under ./fixtures/queries.json and ./fixtures/traces/*.json respectively. Each query fixture includes: - Caption: describes the query we are testing - Query: the query we are testing - ExpectedFixture: the trace fixture that we want back from these queries. Queries are not necessarily numbered, but since each query requires a service name, the service name is formatted "query##-service".

func LoadAndParseQueryTestCases(t *testing.T, queriesFile string) []*QueryFixtures

type RemoteMemoryStorage ¶ added in v1.57.0

type RemoteMemoryStorage struct {
	// contains filtered or unexported fields
}

func StartNewRemoteMemoryStorage(t *testing.T) *RemoteMemoryStorage

func (s *RemoteMemoryStorage) Close(t *testing.T)

type StorageIntegration ¶

type StorageIntegration struct {
	TraceWriter       tracestore.Writer
	TraceReader       tracestore.Reader
	ArchiveSpanReader spanstore.Reader
	ArchiveSpanWriter spanstore.Writer
	DependencyWriter  dependencystore.Writer
	DependencyReader  depstore.Reader
	SamplingStore     samplingstore.Store
	Fixtures          []*QueryFixtures

	// TODO: remove this after all storage backends return spanKind from GetOperations
	GetOperationsMissingSpanKind bool

	GetDependenciesReturnsSource bool

	// Skip Archive Test if not supported by the storage backend
	SkipArchiveTest bool

	// List of tests which has to be skipped, it can be regex too.
	SkipList []string

	// CleanUp() should ensure that the storage backend is clean before another test.
	// called either before or after each test, and should be idempotent
	CleanUp func(t *testing.T)
}

StorageIntegration holds components for storage integration test. The intended usage is as follows: - a specific storage implementation declares its own test functions - in those functions it instantiates and populates this struct - it then calls RunAll.

Some implementations may declare multiple tests, with different settings, and RunAll() under different conditions.

func (s *StorageIntegration) RunAll(t *testing.T)

func (s *StorageIntegration) RunSpanStoreTests(t *testing.T)