Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(436)

Unified Diff: trace/service/traceservice.pb.go

Issue 1413403002: Add a Ping() method to the trace service to make it easier to detect if the service is up and runni… (Closed) Base URL: https://skia.googlesource.com/buildbot@master
Patch Set: tests Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « trace/service/traceservice.proto ('k') | trace/service/traceservice_test.go » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: trace/service/traceservice.pb.go
diff --git a/trace/service/traceservice.pb.go b/trace/service/traceservice.pb.go
index edee2946f3a830ae2a40cde0aaa8c972cd1057e6..4a11693b28fb08ba6ac405efb1d20f4154c41913 100644
--- a/trace/service/traceservice.pb.go
+++ b/trace/service/traceservice.pb.go
@@ -9,7 +9,7 @@ It is generated from these files:
traceservice.proto
It has these top-level messages:
- EmptyResponse
+ Empty
CommitID
Params
MissingParamsRequest
@@ -41,12 +41,12 @@ var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
-type EmptyResponse struct {
+type Empty struct {
}
-func (m *EmptyResponse) Reset() { *m = EmptyResponse{} }
-func (m *EmptyResponse) String() string { return proto.CompactTextString(m) }
-func (*EmptyResponse) ProtoMessage() {}
+func (m *Empty) Reset() { *m = Empty{} }
+func (m *Empty) String() string { return proto.CompactTextString(m) }
+func (*Empty) ProtoMessage() {}
// CommitID identifies one commit, or trybot try.
type CommitID struct {
@@ -265,17 +265,19 @@ type TraceServiceClient interface {
// Returns a list of traceids that don't have Params stored in the datastore.
MissingParams(ctx context.Context, in *MissingParamsRequest, opts ...grpc.CallOption) (*MissingParamsResponse, error)
// Adds Params for a set of traceids.
- AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
+ AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOption) (*Empty, error)
// Adds data for a set of traces for a particular commitid.
- Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
+ Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Empty, error)
// Removes data for a particular commitid.
- Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
+ Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*Empty, error)
// List returns all the CommitIDs that exist in the given time range.
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
// GetValues returns all the trace values stored for the given CommitID.
GetValues(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOption) (*GetValuesResponse, error)
// GetParams returns the Params for all of the given traces.
GetParams(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOption) (*GetParamsResponse, error)
+ // Ping returns the Params for all of the given traces.
+ Ping(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOption) (*Empty, error)
}
type traceServiceClient struct {
@@ -295,8 +297,8 @@ func (c *traceServiceClient) MissingParams(ctx context.Context, in *MissingParam
return out, nil
}
-func (c *traceServiceClient) AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOption) (*EmptyResponse, error) {
- out := new(EmptyResponse)
+func (c *traceServiceClient) AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOption) (*Empty, error) {
+ out := new(Empty)
err := grpc.Invoke(ctx, "/traceservice.TraceService/AddParams", in, out, c.cc, opts...)
if err != nil {
return nil, err
@@ -304,8 +306,8 @@ func (c *traceServiceClient) AddParams(ctx context.Context, in *AddParamsRequest
return out, nil
}
-func (c *traceServiceClient) Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*EmptyResponse, error) {
- out := new(EmptyResponse)
+func (c *traceServiceClient) Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Empty, error) {
+ out := new(Empty)
err := grpc.Invoke(ctx, "/traceservice.TraceService/Add", in, out, c.cc, opts...)
if err != nil {
return nil, err
@@ -313,8 +315,8 @@ func (c *traceServiceClient) Add(ctx context.Context, in *AddRequest, opts ...gr
return out, nil
}
-func (c *traceServiceClient) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*EmptyResponse, error) {
- out := new(EmptyResponse)
+func (c *traceServiceClient) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*Empty, error) {
+ out := new(Empty)
err := grpc.Invoke(ctx, "/traceservice.TraceService/Remove", in, out, c.cc, opts...)
if err != nil {
return nil, err
@@ -349,23 +351,34 @@ func (c *traceServiceClient) GetParams(ctx context.Context, in *GetParamsRequest
return out, nil
}
+func (c *traceServiceClient) Ping(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOption) (*Empty, error) {
+ out := new(Empty)
+ err := grpc.Invoke(ctx, "/traceservice.TraceService/Ping", in, out, c.cc, opts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
// Server API for TraceService service
type TraceServiceServer interface {
// Returns a list of traceids that don't have Params stored in the datastore.
MissingParams(context.Context, *MissingParamsRequest) (*MissingParamsResponse, error)
// Adds Params for a set of traceids.
- AddParams(context.Context, *AddParamsRequest) (*EmptyResponse, error)
+ AddParams(context.Context, *AddParamsRequest) (*Empty, error)
// Adds data for a set of traces for a particular commitid.
- Add(context.Context, *AddRequest) (*EmptyResponse, error)
+ Add(context.Context, *AddRequest) (*Empty, error)
// Removes data for a particular commitid.
- Remove(context.Context, *RemoveRequest) (*EmptyResponse, error)
+ Remove(context.Context, *RemoveRequest) (*Empty, error)
// List returns all the CommitIDs that exist in the given time range.
List(context.Context, *ListRequest) (*ListResponse, error)
// GetValues returns all the trace values stored for the given CommitID.
GetValues(context.Context, *GetValuesRequest) (*GetValuesResponse, error)
// GetParams returns the Params for all of the given traces.
GetParams(context.Context, *GetParamsRequest) (*GetParamsResponse, error)
+ // Ping returns the Params for all of the given traces.
+ Ping(context.Context, *GetParamsRequest) (*Empty, error)
}
func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
@@ -456,6 +469,18 @@ func _TraceService_GetParams_Handler(srv interface{}, ctx context.Context, dec f
return out, nil
}
+func _TraceService_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
+ in := new(GetParamsRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ out, err := srv.(TraceServiceServer).Ping(ctx, in)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
var _TraceService_serviceDesc = grpc.ServiceDesc{
ServiceName: "traceservice.TraceService",
HandlerType: (*TraceServiceServer)(nil),
@@ -488,6 +513,10 @@ var _TraceService_serviceDesc = grpc.ServiceDesc{
MethodName: "GetParams",
Handler: _TraceService_GetParams_Handler,
},
+ {
+ MethodName: "Ping",
+ Handler: _TraceService_Ping_Handler,
+ },
},
Streams: []grpc.StreamDesc{},
}
« no previous file with comments | « trace/service/traceservice.proto ('k') | trace/service/traceservice_test.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698