integration

Documentation

Index

• func CopyFileToSharedDir(s *e2e.Scenario, src, dst string) error
• func GetExtraArgs() []string
• func NewJaegerGRPCClient(endpoint string) (*jaeger_grpc.Reporter, error)
• func NewTempoAllInOne() *e2e.HTTPService
• func NewTempoDistributor() *e2e.HTTPService
• func NewTempoIngester(replica int) *e2e.HTTPService
• func NewTempoMetricsGenerator() *e2e.HTTPService
• func NewTempoQuerier() *e2e.HTTPService
• func NewTempoQueryFrontend() *e2e.HTTPService
• func NewTempoScalableSingleBinary(replica int) *e2e.HTTPService
• func SearchAndAssertTrace(t *testing.T, client *tempoUtil.Client, info *tempoUtil.TraceInfo)
• func SearchAndAssertTraceBackend(t *testing.T, client *tempoUtil.Client, info *tempoUtil.TraceInfo, start int64, ...)
• func TempoBackoff() backoff.Config
• func WriteFileToSharedDir(s *e2e.Scenario, dst string, content []byte) error

Functions

func CopyFileToSharedDir

func CopyFileToSharedDir(s *e2e.Scenario, src, dst string) error

func GetExtraArgs

func GetExtraArgs() []string

GetExtraArgs returns the extra args to pass to the Docker command used to run Tempo.

func NewJaegerGRPCClient

func NewJaegerGRPCClient(endpoint string) (*jaeger_grpc.Reporter, error)

func NewTempoAllInOne

func NewTempoAllInOne() *e2e.HTTPService

func NewTempoDistributor

func NewTempoDistributor() *e2e.HTTPService

func NewTempoIngester

func NewTempoIngester(replica int) *e2e.HTTPService

func NewTempoMetricsGenerator

func NewTempoMetricsGenerator() *e2e.HTTPService

func NewTempoQuerier

func NewTempoQuerier() *e2e.HTTPService

func NewTempoQueryFrontend

func NewTempoQueryFrontend() *e2e.HTTPService

func NewTempoScalableSingleBinary

func NewTempoScalableSingleBinary(replica int) *e2e.HTTPService

func SearchAndAssertTrace

func SearchAndAssertTrace(t *testing.T, client *tempoUtil.Client, info *tempoUtil.TraceInfo)

func SearchAndAssertTraceBackend

func SearchAndAssertTraceBackend(t *testing.T, client *tempoUtil.Client, info *tempoUtil.TraceInfo, start int64, end int64)

by passing a time range and using a query_ingesters_until/backend_after of 0 we can force the queriers to look in the backend blocks

func TempoBackoff

func TempoBackoff() backoff.Config

func WriteFileToSharedDir

func WriteFileToSharedDir(s *e2e.Scenario, dst string, content []byte) error