| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 } |
| OLD | NEW |