integration

Documentation

Index

• Variables
• func CompareSliceOfTraces(t *testing.T, expected []*model.Trace, actual []*model.Trace)
• func CompareTraces(t *testing.T, expected *model.Trace, actual *model.Trace)
• func SkipUnlessEnv(t *testing.T, storage ...string)
• type QueryFixtures
  • func LoadAndParseQueryTestCases(t *testing.T, queriesFile string) []*QueryFixtures
• type RemoteMemoryStorage
  • func StartNewRemoteMemoryStorage(t *testing.T) *RemoteMemoryStorage
  • func (s *RemoteMemoryStorage) Close(t *testing.T)
• type StorageIntegration
  • func (s *StorageIntegration) RunAll(t *testing.T)
  • func (s *StorageIntegration) RunSpanStoreTests(t *testing.T)

Variables

var CassandraSkippedTests = []string{
	"Tags_+_Operation_name_+_Duration_range",
	"Tags_+_Duration_range",
	"Tags_+_Operation_name_+_max_Duration",
	"Tags_+_max_Duration",
	"Operation_name_+_Duration_range",
	"Duration_range",
	"max_Duration",
	"Multiple_Traces",
}

Functions

func CompareSliceOfTraces

func CompareSliceOfTraces(t *testing.T, expected []*model.Trace, actual []*model.Trace)

CompareSliceOfTraces compares two trace slices

func CompareTraces

func CompareTraces(t *testing.T, expected *model.Trace, actual *model.Trace)

CompareTraces compares two traces

func SkipUnlessEnv

func SkipUnlessEnv(t *testing.T, storage ...string)

Types

type QueryFixtures

type QueryFixtures struct {
	Caption          string
	Query            *spanstore.TraceQueryParameters
	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

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

LoadAndParseQueryTestCases loads and parses query test cases

type RemoteMemoryStorage

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

func StartNewRemoteMemoryStorage

func StartNewRemoteMemoryStorage(t *testing.T) *RemoteMemoryStorage

func (*RemoteMemoryStorage) Close

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

type StorageIntegration

type StorageIntegration struct {
	SpanWriter        spanstore.Writer
	SpanReader        spanstore.Reader
	ArchiveSpanReader spanstore.Reader
	ArchiveSpanWriter spanstore.Writer
	DependencyWriter  dependencystore.Writer
	DependencyReader  dependencystore.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 (*StorageIntegration) RunAll

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

RunAll runs all integration tests

func (*StorageIntegration) RunSpanStoreTests

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

RunTestSpanstore runs only span related integration tests