integration

Documentation

Index

• func EachPyroscopeTest(t *testing.T, f func(p *PyroscopeTest, t *testing.T))
• func GetFreePorts(len int) (ports []int, err error)
• type PyroscopeTest
  • func (p *PyroscopeTest) Configure(t *testing.T, v2 bool) *PyroscopeTest
  • func (p *PyroscopeTest) Ingest(t *testing.T, req *http.Request, expectStatus int)
  • func (p *PyroscopeTest) Metrics(t testing.TB, keep func(string) bool) string
  • func (p *PyroscopeTest) NewRequestBuilder(t *testing.T) *RequestBuilder
  • func (p *PyroscopeTest) TempAppName() string
  • func (p *PyroscopeTest) URL() string
• type RequestBuilder
  • func (b *RequestBuilder) IngestJFRRequestBody(jfr []byte, labels []byte) *http.Request
  • func (b *RequestBuilder) IngestJFRRequestFiles(jfrPath, labelsPath string) *http.Request
  • func (b *RequestBuilder) IngestPPROFRequest(profilePath, prevProfilePath, sampleTypeConfigPath string) *http.Request
  • func (b *RequestBuilder) OtelPushClient() profilesv1.ProfilesServiceClient
  • func (b *RequestBuilder) Push(request *connect.Request[pushv1.PushRequest], expectStatus int, ...)
  • func (b *RequestBuilder) PushClient() pushv1connect.PusherServiceClient
  • func (b *RequestBuilder) PushPPROFRequestFromBytes(rawProfile []byte, name string) *connect.Request[pushv1.PushRequest]
  • func (b *RequestBuilder) PushPPROFRequestFromFile(file string, metric string) *connect.Request[pushv1.PushRequest]
  • func (b *RequestBuilder) QueryClient() querierv1connect.QuerierServiceClient
  • func (b *RequestBuilder) Render(metric string) *flamebearer.FlamebearerProfile
  • func (b *RequestBuilder) SelectMergeProfile(metric string, query map[string]string) *connect.Response[profilev1.Profile]
  • func (b *RequestBuilder) Spy(spy string) *RequestBuilder

Functions

func EachPyroscopeTest

func EachPyroscopeTest(t *testing.T, f func(p *PyroscopeTest, t *testing.T))

func GetFreePorts

func GetFreePorts(len int) (ports []int, err error)

GetFreePorts returns a number of free local port for the tests to listen on. This will make sure the returned ports do not overlap, by stopping to listen once all ports are allocated

Note: This function should only be used in integration tests. Use in-memory network connections in unittests.

Types

type PyroscopeTest

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

func (*PyroscopeTest) Configure

func (p *PyroscopeTest) Configure(t *testing.T, v2 bool) *PyroscopeTest

func (*PyroscopeTest) Ingest

func (p *PyroscopeTest) Ingest(t *testing.T, req *http.Request, expectStatus int)

func (*PyroscopeTest) Metrics

func (p *PyroscopeTest) Metrics(t testing.TB, keep func(string) bool) string

func (*PyroscopeTest) NewRequestBuilder

func (p *PyroscopeTest) NewRequestBuilder(t *testing.T) *RequestBuilder

func (*PyroscopeTest) TempAppName

func (p *PyroscopeTest) TempAppName() string

func (*PyroscopeTest) URL

func (p *PyroscopeTest) URL() string

type RequestBuilder

type RequestBuilder struct {
	AppName string
	// contains filtered or unexported fields
}

func (*RequestBuilder) IngestJFRRequestBody

func (b *RequestBuilder) IngestJFRRequestBody(jfr []byte, labels []byte) *http.Request

func (*RequestBuilder) IngestJFRRequestFiles

func (b *RequestBuilder) IngestJFRRequestFiles(jfrPath, labelsPath string) *http.Request

func (*RequestBuilder) IngestPPROFRequest

func (b *RequestBuilder) IngestPPROFRequest(profilePath, prevProfilePath, sampleTypeConfigPath string) *http.Request

func (*RequestBuilder) OtelPushClient

func (b *RequestBuilder) OtelPushClient() profilesv1.ProfilesServiceClient

func (*RequestBuilder) Push

func (b *RequestBuilder) Push(request *connect.Request[pushv1.PushRequest], expectStatus int, expectedError string)

func (*RequestBuilder) PushClient

func (b *RequestBuilder) PushClient() pushv1connect.PusherServiceClient

func (*RequestBuilder) PushPPROFRequestFromBytes

func (b *RequestBuilder) PushPPROFRequestFromBytes(rawProfile []byte, name string) *connect.Request[pushv1.PushRequest]

func (*RequestBuilder) PushPPROFRequestFromFile

func (b *RequestBuilder) PushPPROFRequestFromFile(file string, metric string) *connect.Request[pushv1.PushRequest]

func (*RequestBuilder) QueryClient

func (b *RequestBuilder) QueryClient() querierv1connect.QuerierServiceClient

func (*RequestBuilder) Render

func (b *RequestBuilder) Render(metric string) *flamebearer.FlamebearerProfile

func (*RequestBuilder) SelectMergeProfile

func (b *RequestBuilder) SelectMergeProfile(metric string, query map[string]string) *connect.Response[profilev1.Profile]

func (*RequestBuilder) Spy

func (b *RequestBuilder) Spy(spy string) *RequestBuilder