Index: trace/service/impl.go |
diff --git a/trace/service/impl.go b/trace/service/impl.go |
index 43cba44585ef1d951198138f901851f0d6186790..1d735f1406dc7dc3c5d11fd9abba47c2eaf448c4 100644 |
--- a/trace/service/impl.go |
+++ b/trace/service/impl.go |
@@ -300,7 +300,7 @@ func (ts *TraceServiceImpl) MissingParams(ctx context.Context, in *MissingParams |
return resp, nil |
} |
-func (ts *TraceServiceImpl) AddParams(ctx context.Context, in *AddParamsRequest) (*EmptyResponse, error) { |
+func (ts *TraceServiceImpl) AddParams(ctx context.Context, in *AddParamsRequest) (*Empty, error) { |
// Serialize the Params for each trace as a proto and collect the traceids. |
// We do this outside the add func so there's less work taking place in the |
// Update transaction. |
@@ -329,10 +329,10 @@ func (ts *TraceServiceImpl) AddParams(ctx context.Context, in *AddParamsRequest) |
if err := ts.db.Update(add); err != nil { |
return nil, fmt.Errorf("Failed to add values to tracedb: %s", err) |
} |
- return &EmptyResponse{}, nil |
+ return &Empty{}, nil |
} |
-func (ts *TraceServiceImpl) Add(ctx context.Context, in *AddRequest) (*EmptyResponse, error) { |
+func (ts *TraceServiceImpl) Add(ctx context.Context, in *AddRequest) (*Empty, error) { |
glog.Info("Add() begin.") |
if in == nil { |
return nil, fmt.Errorf("Received nil request.") |
@@ -386,10 +386,10 @@ func (ts *TraceServiceImpl) Add(ctx context.Context, in *AddRequest) (*EmptyResp |
if err := ts.db.Update(add); err != nil { |
return nil, fmt.Errorf("Failed to add values to tracedb: %s", err) |
} |
- return &EmptyResponse{}, nil |
+ return &Empty{}, nil |
} |
-func (ts *TraceServiceImpl) Remove(ctx context.Context, in *RemoveRequest) (*EmptyResponse, error) { |
+func (ts *TraceServiceImpl) Remove(ctx context.Context, in *RemoveRequest) (*Empty, error) { |
if in == nil { |
return nil, fmt.Errorf("Received nil request.") |
} |
@@ -404,7 +404,7 @@ func (ts *TraceServiceImpl) Remove(ctx context.Context, in *RemoveRequest) (*Emp |
if err := ts.db.Update(remove); err != nil { |
return nil, fmt.Errorf("Failed to remove values from tracedb: %s", err) |
} |
- ret := &EmptyResponse{} |
+ ret := &Empty{} |
return ret, nil |
} |
@@ -517,6 +517,10 @@ func (ts *TraceServiceImpl) GetParams(ctx context.Context, getParamsRequest *Get |
return ret, nil |
} |
+func (ts *TraceServiceImpl) Ping(ctx context.Context, empty *Empty) (*Empty, error) { |
+ return &Empty{}, nil |
+} |
+ |
// Close closes the underlying datastore and it not part of the TraceServiceServer interface. |
func (ts *TraceServiceImpl) Close() error { |
return ts.db.Close() |