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

Side by Side 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 unified diff | Download patch
« no previous file with comments | « trace/service/traceservice.proto ('k') | trace/service/traceservice_test.go » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Code generated by protoc-gen-go. 1 // Code generated by protoc-gen-go.
2 // source: traceservice.proto 2 // source: traceservice.proto
3 // DO NOT EDIT! 3 // DO NOT EDIT!
4 4
5 /* 5 /*
6 Package traceservice is a generated protocol buffer package. 6 Package traceservice is a generated protocol buffer package.
7 7
8 It is generated from these files: 8 It is generated from these files:
9 traceservice.proto 9 traceservice.proto
10 10
11 It has these top-level messages: 11 It has these top-level messages:
12 » EmptyResponse 12 » Empty
13 CommitID 13 CommitID
14 Params 14 Params
15 MissingParamsRequest 15 MissingParamsRequest
16 MissingParamsResponse 16 MissingParamsResponse
17 AddParamsRequest 17 AddParamsRequest
18 StoredEntry 18 StoredEntry
19 AddRequest 19 AddRequest
20 RemoveRequest 20 RemoveRequest
21 ListRequest 21 ListRequest
22 ListResponse 22 ListResponse
(...skipping 11 matching lines...) Expand all
34 import ( 34 import (
35 context "golang.org/x/net/context" 35 context "golang.org/x/net/context"
36 grpc "google.golang.org/grpc" 36 grpc "google.golang.org/grpc"
37 ) 37 )
38 38
39 // Reference imports to suppress errors if they are not otherwise used. 39 // Reference imports to suppress errors if they are not otherwise used.
40 var _ = proto.Marshal 40 var _ = proto.Marshal
41 var _ = fmt.Errorf 41 var _ = fmt.Errorf
42 var _ = math.Inf 42 var _ = math.Inf
43 43
44 type EmptyResponse struct { 44 type Empty struct {
45 } 45 }
46 46
47 func (m *EmptyResponse) Reset() { *m = EmptyResponse{} } 47 func (m *Empty) Reset() { *m = Empty{} }
48 func (m *EmptyResponse) String() string { return proto.CompactTextString(m) } 48 func (m *Empty) String() string { return proto.CompactTextString(m) }
49 func (*EmptyResponse) ProtoMessage() {} 49 func (*Empty) ProtoMessage() {}
50 50
51 // CommitID identifies one commit, or trybot try. 51 // CommitID identifies one commit, or trybot try.
52 type CommitID struct { 52 type CommitID struct {
53 // The id of a commit, either a git hash, or a Reitveld patch id. 53 // The id of a commit, either a git hash, or a Reitveld patch id.
54 Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"` 54 Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
55 // The source of the commit, either a git branch name, or a Reitveld iss ue id. 55 // The source of the commit, either a git branch name, or a Reitveld iss ue id.
56 Source string `protobuf:"bytes,2,opt,name=source" json:"source,omitempty "` 56 Source string `protobuf:"bytes,2,opt,name=source" json:"source,omitempty "`
57 // The timestamp of the commit or trybot patch. 57 // The timestamp of the commit or trybot patch.
58 Timestamp int64 `protobuf:"varint,3,opt,name=timestamp" json:"timestamp, omitempty"` 58 Timestamp int64 `protobuf:"varint,3,opt,name=timestamp" json:"timestamp, omitempty"`
59 } 59 }
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after
258 // Reference imports to suppress errors if they are not otherwise used. 258 // Reference imports to suppress errors if they are not otherwise used.
259 var _ context.Context 259 var _ context.Context
260 var _ grpc.ClientConn 260 var _ grpc.ClientConn
261 261
262 // Client API for TraceService service 262 // Client API for TraceService service
263 263
264 type TraceServiceClient interface { 264 type TraceServiceClient interface {
265 // Returns a list of traceids that don't have Params stored in the datas tore. 265 // Returns a list of traceids that don't have Params stored in the datas tore.
266 MissingParams(ctx context.Context, in *MissingParamsRequest, opts ...grp c.CallOption) (*MissingParamsResponse, error) 266 MissingParams(ctx context.Context, in *MissingParamsRequest, opts ...grp c.CallOption) (*MissingParamsResponse, error)
267 // Adds Params for a set of traceids. 267 // Adds Params for a set of traceids.
268 » AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOp tion) (*EmptyResponse, error) 268 » AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOp tion) (*Empty, error)
269 // Adds data for a set of traces for a particular commitid. 269 // Adds data for a set of traces for a particular commitid.
270 » Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Empt yResponse, error) 270 » Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Empt y, error)
271 // Removes data for a particular commitid. 271 // Removes data for a particular commitid.
272 » Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*EmptyResponse, error) 272 » Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*Empty, error)
273 // List returns all the CommitIDs that exist in the given time range. 273 // List returns all the CommitIDs that exist in the given time range.
274 List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*Li stResponse, error) 274 List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*Li stResponse, error)
275 // GetValues returns all the trace values stored for the given CommitID. 275 // GetValues returns all the trace values stored for the given CommitID.
276 GetValues(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOp tion) (*GetValuesResponse, error) 276 GetValues(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOp tion) (*GetValuesResponse, error)
277 // GetParams returns the Params for all of the given traces. 277 // GetParams returns the Params for all of the given traces.
278 GetParams(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOp tion) (*GetParamsResponse, error) 278 GetParams(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOp tion) (*GetParamsResponse, error)
279 // Ping returns the Params for all of the given traces.
280 Ping(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOption) (*Empty, error)
279 } 281 }
280 282
281 type traceServiceClient struct { 283 type traceServiceClient struct {
282 cc *grpc.ClientConn 284 cc *grpc.ClientConn
283 } 285 }
284 286
285 func NewTraceServiceClient(cc *grpc.ClientConn) TraceServiceClient { 287 func NewTraceServiceClient(cc *grpc.ClientConn) TraceServiceClient {
286 return &traceServiceClient{cc} 288 return &traceServiceClient{cc}
287 } 289 }
288 290
289 func (c *traceServiceClient) MissingParams(ctx context.Context, in *MissingParam sRequest, opts ...grpc.CallOption) (*MissingParamsResponse, error) { 291 func (c *traceServiceClient) MissingParams(ctx context.Context, in *MissingParam sRequest, opts ...grpc.CallOption) (*MissingParamsResponse, error) {
290 out := new(MissingParamsResponse) 292 out := new(MissingParamsResponse)
291 err := grpc.Invoke(ctx, "/traceservice.TraceService/MissingParams", in, out, c.cc, opts...) 293 err := grpc.Invoke(ctx, "/traceservice.TraceService/MissingParams", in, out, c.cc, opts...)
292 if err != nil { 294 if err != nil {
293 return nil, err 295 return nil, err
294 } 296 }
295 return out, nil 297 return out, nil
296 } 298 }
297 299
298 func (c *traceServiceClient) AddParams(ctx context.Context, in *AddParamsRequest , opts ...grpc.CallOption) (*EmptyResponse, error) { 300 func (c *traceServiceClient) AddParams(ctx context.Context, in *AddParamsRequest , opts ...grpc.CallOption) (*Empty, error) {
299 » out := new(EmptyResponse) 301 » out := new(Empty)
300 err := grpc.Invoke(ctx, "/traceservice.TraceService/AddParams", in, out, c.cc, opts...) 302 err := grpc.Invoke(ctx, "/traceservice.TraceService/AddParams", in, out, c.cc, opts...)
301 if err != nil { 303 if err != nil {
302 return nil, err 304 return nil, err
303 } 305 }
304 return out, nil 306 return out, nil
305 } 307 }
306 308
307 func (c *traceServiceClient) Add(ctx context.Context, in *AddRequest, opts ...gr pc.CallOption) (*EmptyResponse, error) { 309 func (c *traceServiceClient) Add(ctx context.Context, in *AddRequest, opts ...gr pc.CallOption) (*Empty, error) {
308 » out := new(EmptyResponse) 310 » out := new(Empty)
309 err := grpc.Invoke(ctx, "/traceservice.TraceService/Add", in, out, c.cc, opts...) 311 err := grpc.Invoke(ctx, "/traceservice.TraceService/Add", in, out, c.cc, opts...)
310 if err != nil { 312 if err != nil {
311 return nil, err 313 return nil, err
312 } 314 }
313 return out, nil 315 return out, nil
314 } 316 }
315 317
316 func (c *traceServiceClient) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*EmptyResponse, error) { 318 func (c *traceServiceClient) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*Empty, error) {
317 » out := new(EmptyResponse) 319 » out := new(Empty)
318 err := grpc.Invoke(ctx, "/traceservice.TraceService/Remove", in, out, c. cc, opts...) 320 err := grpc.Invoke(ctx, "/traceservice.TraceService/Remove", in, out, c. cc, opts...)
319 if err != nil { 321 if err != nil {
320 return nil, err 322 return nil, err
321 } 323 }
322 return out, nil 324 return out, nil
323 } 325 }
324 326
325 func (c *traceServiceClient) List(ctx context.Context, in *ListRequest, opts ... grpc.CallOption) (*ListResponse, error) { 327 func (c *traceServiceClient) List(ctx context.Context, in *ListRequest, opts ... grpc.CallOption) (*ListResponse, error) {
326 out := new(ListResponse) 328 out := new(ListResponse)
327 err := grpc.Invoke(ctx, "/traceservice.TraceService/List", in, out, c.cc , opts...) 329 err := grpc.Invoke(ctx, "/traceservice.TraceService/List", in, out, c.cc , opts...)
(...skipping 14 matching lines...) Expand all
342 344
343 func (c *traceServiceClient) GetParams(ctx context.Context, in *GetParamsRequest , opts ...grpc.CallOption) (*GetParamsResponse, error) { 345 func (c *traceServiceClient) GetParams(ctx context.Context, in *GetParamsRequest , opts ...grpc.CallOption) (*GetParamsResponse, error) {
344 out := new(GetParamsResponse) 346 out := new(GetParamsResponse)
345 err := grpc.Invoke(ctx, "/traceservice.TraceService/GetParams", in, out, c.cc, opts...) 347 err := grpc.Invoke(ctx, "/traceservice.TraceService/GetParams", in, out, c.cc, opts...)
346 if err != nil { 348 if err != nil {
347 return nil, err 349 return nil, err
348 } 350 }
349 return out, nil 351 return out, nil
350 } 352 }
351 353
354 func (c *traceServiceClient) Ping(ctx context.Context, in *GetParamsRequest, opt s ...grpc.CallOption) (*Empty, error) {
355 out := new(Empty)
356 err := grpc.Invoke(ctx, "/traceservice.TraceService/Ping", in, out, c.cc , opts...)
357 if err != nil {
358 return nil, err
359 }
360 return out, nil
361 }
362
352 // Server API for TraceService service 363 // Server API for TraceService service
353 364
354 type TraceServiceServer interface { 365 type TraceServiceServer interface {
355 // Returns a list of traceids that don't have Params stored in the datas tore. 366 // Returns a list of traceids that don't have Params stored in the datas tore.
356 MissingParams(context.Context, *MissingParamsRequest) (*MissingParamsRes ponse, error) 367 MissingParams(context.Context, *MissingParamsRequest) (*MissingParamsRes ponse, error)
357 // Adds Params for a set of traceids. 368 // Adds Params for a set of traceids.
358 » AddParams(context.Context, *AddParamsRequest) (*EmptyResponse, error) 369 » AddParams(context.Context, *AddParamsRequest) (*Empty, error)
359 // Adds data for a set of traces for a particular commitid. 370 // Adds data for a set of traces for a particular commitid.
360 » Add(context.Context, *AddRequest) (*EmptyResponse, error) 371 » Add(context.Context, *AddRequest) (*Empty, error)
361 // Removes data for a particular commitid. 372 // Removes data for a particular commitid.
362 » Remove(context.Context, *RemoveRequest) (*EmptyResponse, error) 373 » Remove(context.Context, *RemoveRequest) (*Empty, error)
363 // List returns all the CommitIDs that exist in the given time range. 374 // List returns all the CommitIDs that exist in the given time range.
364 List(context.Context, *ListRequest) (*ListResponse, error) 375 List(context.Context, *ListRequest) (*ListResponse, error)
365 // GetValues returns all the trace values stored for the given CommitID. 376 // GetValues returns all the trace values stored for the given CommitID.
366 GetValues(context.Context, *GetValuesRequest) (*GetValuesResponse, error ) 377 GetValues(context.Context, *GetValuesRequest) (*GetValuesResponse, error )
367 // GetParams returns the Params for all of the given traces. 378 // GetParams returns the Params for all of the given traces.
368 GetParams(context.Context, *GetParamsRequest) (*GetParamsResponse, error ) 379 GetParams(context.Context, *GetParamsRequest) (*GetParamsResponse, error )
380 // Ping returns the Params for all of the given traces.
381 Ping(context.Context, *GetParamsRequest) (*Empty, error)
369 } 382 }
370 383
371 func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) { 384 func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
372 s.RegisterService(&_TraceService_serviceDesc, srv) 385 s.RegisterService(&_TraceService_serviceDesc, srv)
373 } 386 }
374 387
375 func _TraceService_MissingParams_Handler(srv interface{}, ctx context.Context, d ec func(interface{}) error) (interface{}, error) { 388 func _TraceService_MissingParams_Handler(srv interface{}, ctx context.Context, d ec func(interface{}) error) (interface{}, error) {
376 in := new(MissingParamsRequest) 389 in := new(MissingParamsRequest)
377 if err := dec(in); err != nil { 390 if err := dec(in); err != nil {
378 return nil, err 391 return nil, err
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after
449 if err := dec(in); err != nil { 462 if err := dec(in); err != nil {
450 return nil, err 463 return nil, err
451 } 464 }
452 out, err := srv.(TraceServiceServer).GetParams(ctx, in) 465 out, err := srv.(TraceServiceServer).GetParams(ctx, in)
453 if err != nil { 466 if err != nil {
454 return nil, err 467 return nil, err
455 } 468 }
456 return out, nil 469 return out, nil
457 } 470 }
458 471
472 func _TraceService_Ping_Handler(srv interface{}, ctx context.Context, dec func(i nterface{}) error) (interface{}, error) {
473 in := new(GetParamsRequest)
474 if err := dec(in); err != nil {
475 return nil, err
476 }
477 out, err := srv.(TraceServiceServer).Ping(ctx, in)
478 if err != nil {
479 return nil, err
480 }
481 return out, nil
482 }
483
459 var _TraceService_serviceDesc = grpc.ServiceDesc{ 484 var _TraceService_serviceDesc = grpc.ServiceDesc{
460 ServiceName: "traceservice.TraceService", 485 ServiceName: "traceservice.TraceService",
461 HandlerType: (*TraceServiceServer)(nil), 486 HandlerType: (*TraceServiceServer)(nil),
462 Methods: []grpc.MethodDesc{ 487 Methods: []grpc.MethodDesc{
463 { 488 {
464 MethodName: "MissingParams", 489 MethodName: "MissingParams",
465 Handler: _TraceService_MissingParams_Handler, 490 Handler: _TraceService_MissingParams_Handler,
466 }, 491 },
467 { 492 {
468 MethodName: "AddParams", 493 MethodName: "AddParams",
(...skipping 12 matching lines...) Expand all
481 Handler: _TraceService_List_Handler, 506 Handler: _TraceService_List_Handler,
482 }, 507 },
483 { 508 {
484 MethodName: "GetValues", 509 MethodName: "GetValues",
485 Handler: _TraceService_GetValues_Handler, 510 Handler: _TraceService_GetValues_Handler,
486 }, 511 },
487 { 512 {
488 MethodName: "GetParams", 513 MethodName: "GetParams",
489 Handler: _TraceService_GetParams_Handler, 514 Handler: _TraceService_GetParams_Handler,
490 }, 515 },
516 {
517 MethodName: "Ping",
518 Handler: _TraceService_Ping_Handler,
519 },
491 }, 520 },
492 Streams: []grpc.StreamDesc{}, 521 Streams: []grpc.StreamDesc{},
493 } 522 }
OLDNEW
« 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