Skip to content

Commit

Permalink
rename struct
Browse files Browse the repository at this point in the history
Signed-off-by: rim99 <[email protected]>
  • Loading branch information
rim99 committed Nov 21, 2024
1 parent 93825bb commit 7c3ab0c
Show file tree
Hide file tree
Showing 43 changed files with 150 additions and 150 deletions.
8 changes: 4 additions & 4 deletions cmd/anonymizer/app/query/query_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ import (

var (
matchContext = mock.AnythingOfType("*context.valueCtx")
matchTraceGetParameters = mock.AnythingOfType("spanstore.TraceGetParameters")
matchGetTraceParameters = mock.AnythingOfType("spanstore.GetTraceParameters")

mockInvalidTraceID = "xyz"
mockTraceID = model.NewTraceID(0, 123456)
Expand Down Expand Up @@ -109,12 +109,12 @@ func TestQueryTrace(t *testing.T) {
t.Run("No error", func(t *testing.T) {
startTime := time.Date(1970, time.January, 1, 0, 0, 0, 1000, time.UTC)
endTime := time.Date(1970, time.January, 1, 0, 0, 0, 2000, time.UTC)
expectedTraceGetParameters := spanstore.TraceGetParameters{
expectedGetTraceParameters := spanstore.GetTraceParameters{
TraceID: mockTraceID,
StartTime: startTime,
EndTime: endTime,
}
s.spanReader.On("GetTrace", matchContext, expectedTraceGetParameters).Return(
s.spanReader.On("GetTrace", matchContext, expectedGetTraceParameters).Return(
mockTraceGRPC, nil).Once()

spans, err := q.QueryTrace(mockTraceID.String(), startTime, endTime)
Expand All @@ -128,7 +128,7 @@ func TestQueryTrace(t *testing.T) {
})

t.Run("Trace not found", func(t *testing.T) {
s.spanReader.On("GetTrace", matchContext, matchTraceGetParameters).Return(
s.spanReader.On("GetTrace", matchContext, matchGetTraceParameters).Return(
nil, spanstore.ErrTraceNotFound).Once()

spans, err := q.QueryTrace(mockTraceID.String(), time.Time{}, time.Time{})
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ func TestExporter(t *testing.T) {
spanReader, err := storageFactory.CreateSpanReader()
require.NoError(t, err)
requiredTraceID := model.NewTraceID(0, 1) // 00000000000000000000000000000001
requiredTrace, err := spanReader.GetTrace(ctx, spanstore.TraceGetParameters{TraceID: requiredTraceID})
requiredTrace, err := spanReader.GetTrace(ctx, spanstore.GetTraceParameters{TraceID: requiredTraceID})
require.NoError(t, err)
assert.Equal(t, spanID.String(), requiredTrace.Spans[0].SpanID.String())

Expand Down
2 changes: 1 addition & 1 deletion cmd/jaeger/internal/integration/span_reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ func unwrapNotFoundErr(err error) error {
return err
}

func (r *spanReader) GetTrace(ctx context.Context, query spanstore.TraceGetParameters) (*model.Trace, error) {
func (r *spanReader) GetTrace(ctx context.Context, query spanstore.GetTraceParameters) (*model.Trace, error) {
stream, err := r.client.GetTrace(ctx, &api_v2.GetTraceRequest{
TraceID: query.TraceID,
StartTime: query.StartTime,
Expand Down
4 changes: 2 additions & 2 deletions cmd/query/app/apiv3/gateway_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -80,9 +80,9 @@ func parseResponse(t *testing.T, body []byte, obj gogoproto.Message) {
require.NoError(t, gogojsonpb.Unmarshal(bytes.NewBuffer(body), obj))
}

func makeTestTrace() (*model.Trace, spanstore.TraceGetParameters) {
func makeTestTrace() (*model.Trace, spanstore.GetTraceParameters) {
traceID := model.NewTraceID(150, 160)
query := spanstore.TraceGetParameters{TraceID: traceID}
query := spanstore.GetTraceParameters{TraceID: traceID}
return &model.Trace{
Spans: []*model.Span{
{
Expand Down
2 changes: 1 addition & 1 deletion cmd/query/app/apiv3/grpc_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ func (h *Handler) GetTrace(request *api_v3.GetTraceRequest, stream api_v3.QueryS
return fmt.Errorf("malform trace ID: %w", err)
}

query := spanstore.TraceGetParameters{
query := spanstore.GetTraceParameters{
TraceID: traceID,
StartTime: request.GetStartTime(),
EndTime: request.GetEndTime(),
Expand Down
14 changes: 7 additions & 7 deletions cmd/query/app/apiv3/grpc_handler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ import (

var (
matchContext = mock.AnythingOfType("*context.valueCtx")
matchTraceGetParameters = mock.AnythingOfType("spanstore.TraceGetParameters")
matchGetTraceParameters = mock.AnythingOfType("spanstore.GetTraceParameters")
)

func newGrpcServer(t *testing.T, handler *Handler) (*grpc.Server, net.Addr) {
Expand Down Expand Up @@ -82,12 +82,12 @@ func TestGetTrace(t *testing.T) {
traceIdLiteral := "156"
traceId, _ := model.TraceIDFromString(traceIdLiteral)

expectedTraceGetParameters := spanstore.TraceGetParameters{
expectedGetTraceParameters := spanstore.GetTraceParameters{
TraceID: traceId,
StartTime: time.Time{},
EndTime: time.Time{},
}
tsc.reader.On("GetTrace", matchContext, expectedTraceGetParameters).Return(
tsc.reader.On("GetTrace", matchContext, expectedGetTraceParameters).Return(
&model.Trace{
Spans: []*model.Span{
{
Expand Down Expand Up @@ -117,12 +117,12 @@ func TestGetTraceWithTimeWindow(t *testing.T) {

start_ts := time.Unix(1, 2).UTC()
end_ts := time.Unix(3, 4).UTC()
expectedTraceGetParameters := spanstore.TraceGetParameters{
expectedGetTraceParameters := spanstore.GetTraceParameters{
TraceID: traceId,
StartTime: start_ts,
EndTime: end_ts,
}
tsc.reader.On("GetTrace", matchContext, expectedTraceGetParameters).Return(
tsc.reader.On("GetTrace", matchContext, expectedGetTraceParameters).Return(
&model.Trace{
Spans: []*model.Span{
{
Expand All @@ -149,7 +149,7 @@ func TestGetTraceWithTimeWindow(t *testing.T) {

func TestGetTraceStorageError(t *testing.T) {
tsc := newTestServerClient(t)
tsc.reader.On("GetTrace", matchContext, matchTraceGetParameters).Return(
tsc.reader.On("GetTrace", matchContext, matchGetTraceParameters).Return(
nil, errors.New("storage_error")).Once()

getTraceStream, err := tsc.client.GetTrace(context.Background(), &api_v3.GetTraceRequest{
Expand All @@ -163,7 +163,7 @@ func TestGetTraceStorageError(t *testing.T) {

func TestGetTraceTraceIDError(t *testing.T) {
tsc := newTestServerClient(t)
tsc.reader.On("GetTrace", matchContext, matchTraceGetParameters).Return(
tsc.reader.On("GetTrace", matchContext, matchGetTraceParameters).Return(
&model.Trace{
Spans: []*model.Span{},
}, nil).Once()
Expand Down
2 changes: 1 addition & 1 deletion cmd/query/app/apiv3/http_gateway.go
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,7 @@ func (h *HTTPGateway) getTrace(w http.ResponseWriter, r *http.Request) {
if h.tryParamError(w, err, paramTraceID) {
return
}
query := spanstore.TraceGetParameters{
query := spanstore.GetTraceParameters{
TraceID: traceID,
}
http_query := r.URL.Query()
Expand Down
6 changes: 3 additions & 3 deletions cmd/query/app/apiv3/http_gateway_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,7 @@ func TestHTTPGatewayGetTraceErrors(t *testing.T) {
// error from span reader
const simErr = "simulated error"
gw.reader.
On("GetTrace", matchContext, matchTraceGetParameters).
On("GetTrace", matchContext, matchGetTraceParameters).
Return(nil, errors.New(simErr)).Once()

r, err = http.NewRequest(http.MethodGet, "/api/v3/traces/123", nil)
Expand All @@ -135,13 +135,13 @@ func TestHTTPGatewayGetTraceWithTimeWindowErrors(t *testing.T) {
const simErr = "simulated error"
startTime := time.Date(2020, time.January, 1, 12, 0, 0, 0, time.UTC)
endTime := time.Date(2020, time.January, 1, 13, 0, 0, 0, time.UTC)
expectedTraceGetParameters := spanstore.TraceGetParameters{
expectedGetTraceParameters := spanstore.GetTraceParameters{
TraceID: model.TraceID{High: 0, Low: 0x123},
StartTime: startTime,
EndTime: endTime,
}
gw.reader.
On("GetTrace", matchContext, expectedTraceGetParameters).
On("GetTrace", matchContext, expectedGetTraceParameters).
Return(nil, errors.New(simErr)).Once()

q := url.Values{}
Expand Down
4 changes: 2 additions & 2 deletions cmd/query/app/grpc_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ func (g *GRPCHandler) GetTrace(r *api_v2.GetTraceRequest, stream api_v2.QuerySer
if r.TraceID == (model.TraceID{}) {
return errUninitializedTraceID
}
query := spanstore.TraceGetParameters{
query := spanstore.GetTraceParameters{
TraceID: r.TraceID,
StartTime: r.StartTime,
EndTime: r.EndTime,
Expand All @@ -114,7 +114,7 @@ func (g *GRPCHandler) ArchiveTrace(ctx context.Context, r *api_v2.ArchiveTraceRe
if r.TraceID == (model.TraceID{}) {
return nil, errUninitializedTraceID
}
query := spanstore.TraceGetParameters{
query := spanstore.GetTraceParameters{
TraceID: r.TraceID,
}
if r.StartTime != nil {
Expand Down
26 changes: 13 additions & 13 deletions cmd/query/app/grpc_handler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -199,12 +199,12 @@ func TestGetTraceSuccessGRPC(t *testing.T) {
withServerAndClient(t, func(server *grpcServer, client *grpcClient) {
startTime := time.Date(2020, time.January, 1, 13, 0, 0, 0, time.UTC)
endTime := time.Date(2020, time.January, 1, 14, 0, 0, 0, time.UTC)
expectedTraceGetParameters := spanstore.TraceGetParameters{
expectedGetTraceParameters := spanstore.GetTraceParameters{
TraceID: mockTraceID,
StartTime: startTime,
EndTime: endTime,
}
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), expectedTraceGetParameters).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), expectedGetTraceParameters).
Return(mockTrace, nil).Once()

res, err := client.GetTrace(context.Background(), &api_v2.GetTraceRequest{
Expand All @@ -229,7 +229,7 @@ func assertGRPCError(t *testing.T, err error, code codes.Code, msg string) {

func TestGetTraceEmptyTraceIDFailure_GRPC(t *testing.T) {
withServerAndClient(t, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()

res, err := client.GetTrace(context.Background(), &api_v2.GetTraceRequest{
Expand All @@ -246,7 +246,7 @@ func TestGetTraceEmptyTraceIDFailure_GRPC(t *testing.T) {

func TestGetTraceDBFailureGRPC(t *testing.T) {
withServerAndClient(t, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, errStorageGRPC).Once()

res, err := client.GetTrace(context.Background(), &api_v2.GetTraceRequest{
Expand All @@ -262,10 +262,10 @@ func TestGetTraceDBFailureGRPC(t *testing.T) {

func TestGetTraceNotFoundGRPC(t *testing.T) {
withServerAndClient(t, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()

server.archiveSpanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.archiveSpanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()

res, err := client.GetTrace(context.Background(), &api_v2.GetTraceRequest{
Expand All @@ -287,7 +287,7 @@ func TestGetTraceNilRequestOnHandlerGRPC(t *testing.T) {

func TestArchiveTraceSuccessGRPC(t *testing.T) {
withServerAndClient(t, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()
server.archiveSpanWriter.On("WriteSpan", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("*model.Span")).
Return(nil).Times(2)
Expand All @@ -302,9 +302,9 @@ func TestArchiveTraceSuccessGRPC(t *testing.T) {

func TestArchiveTraceNotFoundGRPC(t *testing.T) {
withServerAndClient(t, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()
server.archiveSpanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.archiveSpanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()

_, err := client.ArchiveTrace(context.Background(), &api_v2.ArchiveTraceRequest{
Expand Down Expand Up @@ -333,7 +333,7 @@ func TestArchiveTraceNilRequestOnHandlerGRPC(t *testing.T) {

func TestArchiveTraceFailureGRPC(t *testing.T) {
withServerAndClient(t, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()
server.archiveSpanWriter.On("WriteSpan", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("*model.Span")).
Return(errStorageGRPC).Times(2)
Expand Down Expand Up @@ -964,7 +964,7 @@ func TestSearchTenancyGRPC(t *testing.T) {
Enabled: true,
})
withTenantedServerAndClient(t, tm, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()

// First try without tenancy header
Expand Down Expand Up @@ -1021,7 +1021,7 @@ func TestSearchTenancyGRPCExplicitList(t *testing.T) {
Tenants: []string{"mercury", "venus", "mars"},
})
withTenantedServerAndClient(t, tm, func(server *grpcServer, client *grpcClient) {
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
server.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()

for _, tc := range []struct {
Expand Down Expand Up @@ -1133,7 +1133,7 @@ func TestTenancyContextFlowGRPC(t *testing.T) {
return false
}
return true
}), mock.AnythingOfType("spanstore.TraceGetParameters")).Return(trace, err).Once()
}), mock.AnythingOfType("spanstore.GetTraceParameters")).Return(trace, err).Once()
}

for tenant, expected := range allExpectedResults {
Expand Down
16 changes: 8 additions & 8 deletions cmd/query/app/handler_archive_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import (

func TestGetArchivedTrace_NotFound(t *testing.T) {
mockReader := &spanstoremocks.Reader{}
mockReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
mockReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()
for _, tc := range []struct {
name string
Expand All @@ -37,7 +37,7 @@ func TestGetArchivedTrace_NotFound(t *testing.T) {
} {
t.Run(tc.name, func(t *testing.T) {
withTestServer(t, func(ts *testServer) {
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()
var response structuredResponse
err := getJSON(ts.server.URL+"/api/traces/"+mockTraceID.String(), &response)
Expand All @@ -52,11 +52,11 @@ func TestGetArchivedTrace_NotFound(t *testing.T) {
func TestGetArchivedTraceSuccess(t *testing.T) {
traceID := model.NewTraceID(0, 123456)
mockReader := &spanstoremocks.Reader{}
mockReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
mockReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()
withTestServer(t, func(ts *testServer) {
// make main reader return NotFound
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()
var response structuredTraceResponse
err := getJSON(ts.server.URL+"/api/traces/"+mockTraceID.String(), &response)
Expand All @@ -79,13 +79,13 @@ func TestArchiveTrace_BadTraceID(t *testing.T) {
// Test return of 404 when trace is not found in APIHandler.archive
func TestArchiveTrace_TraceNotFound(t *testing.T) {
mockReader := &spanstoremocks.Reader{}
mockReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
mockReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()
mockWriter := &spanstoremocks.Writer{}
// Not actually going to write the trace, so no need to define mockWriter action
withTestServer(t, func(ts *testServer) {
// make main reader return NotFound
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(nil, spanstore.ErrTraceNotFound).Once()
var response structuredResponse
err := postJSON(ts.server.URL+"/api/archive/"+mockTraceID.String(), []string{}, &response)
Expand All @@ -106,7 +106,7 @@ func TestArchiveTrace_Success(t *testing.T) {
mockWriter.On("WriteSpan", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("*model.Span")).
Return(nil).Times(2)
withTestServer(t, func(ts *testServer) {
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()
var response structuredResponse
err := postJSON(ts.server.URL+"/api/archive/"+mockTraceID.String(), []string{}, &response)
Expand All @@ -119,7 +119,7 @@ func TestArchiveTrace_WriteErrors(t *testing.T) {
mockWriter.On("WriteSpan", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("*model.Span")).
Return(errors.New("cannot save")).Times(2)
withTestServer(t, func(ts *testServer) {
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.TraceGetParameters")).
ts.spanReader.On("GetTrace", mock.AnythingOfType("*context.valueCtx"), mock.AnythingOfType("spanstore.GetTraceParameters")).
Return(mockTrace, nil).Once()
var response structuredResponse
err := postJSON(ts.server.URL+"/api/archive/"+mockTraceID.String(), []string{}, &response)
Expand Down
6 changes: 3 additions & 3 deletions cmd/query/app/http_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -266,7 +266,7 @@ func (aH *APIHandler) tracesByIDs(ctx context.Context, traceIDs []model.TraceID)
var traceErrors []structuredError
retMe := make([]*model.Trace, 0, len(traceIDs))
for _, traceID := range traceIDs {
query := spanstore.TraceGetParameters{
query := spanstore.GetTraceParameters{
TraceID: traceID,
}
if trc, err := aH.queryService.GetTrace(ctx, query); err != nil {
Expand Down Expand Up @@ -432,7 +432,7 @@ func (aH *APIHandler) getTrace(w http.ResponseWriter, r *http.Request) {
if !ok {
return
}
query := spanstore.TraceGetParameters{
query := spanstore.GetTraceParameters{
TraceID: traceID,
}
err := aH.queryParser.parseTraceGetParams(r, &query)
Expand Down Expand Up @@ -468,7 +468,7 @@ func (aH *APIHandler) archiveTrace(w http.ResponseWriter, r *http.Request) {
}

// QueryService.ArchiveTrace can now archive this traceID.
query := spanstore.TraceGetParameters{
query := spanstore.GetTraceParameters{
TraceID: traceID,
}
err := aH.queryService.ArchiveTrace(r.Context(), query)
Expand Down
Loading

0 comments on commit 7c3ab0c

Please sign in to comment.