1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: control.proto 3 4package grpc_testing 5 6import ( 7 fmt "fmt" 8 proto "github.com/golang/protobuf/proto" 9 math "math" 10) 11 12// Reference imports to suppress errors if they are not otherwise used. 13var _ = proto.Marshal 14var _ = fmt.Errorf 15var _ = math.Inf 16 17// This is a compile-time assertion to ensure that this generated file 18// is compatible with the proto package it is being compiled against. 19// A compilation error at this line likely means your copy of the 20// proto package needs to be updated. 21const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 22 23type ClientType int32 24 25const ( 26 ClientType_SYNC_CLIENT ClientType = 0 27 ClientType_ASYNC_CLIENT ClientType = 1 28) 29 30var ClientType_name = map[int32]string{ 31 0: "SYNC_CLIENT", 32 1: "ASYNC_CLIENT", 33} 34 35var ClientType_value = map[string]int32{ 36 "SYNC_CLIENT": 0, 37 "ASYNC_CLIENT": 1, 38} 39 40func (x ClientType) String() string { 41 return proto.EnumName(ClientType_name, int32(x)) 42} 43 44func (ClientType) EnumDescriptor() ([]byte, []int) { 45 return fileDescriptor_0c5120591600887d, []int{0} 46} 47 48type ServerType int32 49 50const ( 51 ServerType_SYNC_SERVER ServerType = 0 52 ServerType_ASYNC_SERVER ServerType = 1 53 ServerType_ASYNC_GENERIC_SERVER ServerType = 2 54) 55 56var ServerType_name = map[int32]string{ 57 0: "SYNC_SERVER", 58 1: "ASYNC_SERVER", 59 2: "ASYNC_GENERIC_SERVER", 60} 61 62var ServerType_value = map[string]int32{ 63 "SYNC_SERVER": 0, 64 "ASYNC_SERVER": 1, 65 "ASYNC_GENERIC_SERVER": 2, 66} 67 68func (x ServerType) String() string { 69 return proto.EnumName(ServerType_name, int32(x)) 70} 71 72func (ServerType) EnumDescriptor() ([]byte, []int) { 73 return fileDescriptor_0c5120591600887d, []int{1} 74} 75 76type RpcType int32 77 78const ( 79 RpcType_UNARY RpcType = 0 80 RpcType_STREAMING RpcType = 1 81) 82 83var RpcType_name = map[int32]string{ 84 0: "UNARY", 85 1: "STREAMING", 86} 87 88var RpcType_value = map[string]int32{ 89 "UNARY": 0, 90 "STREAMING": 1, 91} 92 93func (x RpcType) String() string { 94 return proto.EnumName(RpcType_name, int32(x)) 95} 96 97func (RpcType) EnumDescriptor() ([]byte, []int) { 98 return fileDescriptor_0c5120591600887d, []int{2} 99} 100 101// Parameters of poisson process distribution, which is a good representation 102// of activity coming in from independent identical stationary sources. 103type PoissonParams struct { 104 // The rate of arrivals (a.k.a. lambda parameter of the exp distribution). 105 OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"` 106 XXX_NoUnkeyedLiteral struct{} `json:"-"` 107 XXX_unrecognized []byte `json:"-"` 108 XXX_sizecache int32 `json:"-"` 109} 110 111func (m *PoissonParams) Reset() { *m = PoissonParams{} } 112func (m *PoissonParams) String() string { return proto.CompactTextString(m) } 113func (*PoissonParams) ProtoMessage() {} 114func (*PoissonParams) Descriptor() ([]byte, []int) { 115 return fileDescriptor_0c5120591600887d, []int{0} 116} 117 118func (m *PoissonParams) XXX_Unmarshal(b []byte) error { 119 return xxx_messageInfo_PoissonParams.Unmarshal(m, b) 120} 121func (m *PoissonParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 122 return xxx_messageInfo_PoissonParams.Marshal(b, m, deterministic) 123} 124func (m *PoissonParams) XXX_Merge(src proto.Message) { 125 xxx_messageInfo_PoissonParams.Merge(m, src) 126} 127func (m *PoissonParams) XXX_Size() int { 128 return xxx_messageInfo_PoissonParams.Size(m) 129} 130func (m *PoissonParams) XXX_DiscardUnknown() { 131 xxx_messageInfo_PoissonParams.DiscardUnknown(m) 132} 133 134var xxx_messageInfo_PoissonParams proto.InternalMessageInfo 135 136func (m *PoissonParams) GetOfferedLoad() float64 { 137 if m != nil { 138 return m.OfferedLoad 139 } 140 return 0 141} 142 143type UniformParams struct { 144 InterarrivalLo float64 `protobuf:"fixed64,1,opt,name=interarrival_lo,json=interarrivalLo,proto3" json:"interarrival_lo,omitempty"` 145 InterarrivalHi float64 `protobuf:"fixed64,2,opt,name=interarrival_hi,json=interarrivalHi,proto3" json:"interarrival_hi,omitempty"` 146 XXX_NoUnkeyedLiteral struct{} `json:"-"` 147 XXX_unrecognized []byte `json:"-"` 148 XXX_sizecache int32 `json:"-"` 149} 150 151func (m *UniformParams) Reset() { *m = UniformParams{} } 152func (m *UniformParams) String() string { return proto.CompactTextString(m) } 153func (*UniformParams) ProtoMessage() {} 154func (*UniformParams) Descriptor() ([]byte, []int) { 155 return fileDescriptor_0c5120591600887d, []int{1} 156} 157 158func (m *UniformParams) XXX_Unmarshal(b []byte) error { 159 return xxx_messageInfo_UniformParams.Unmarshal(m, b) 160} 161func (m *UniformParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 162 return xxx_messageInfo_UniformParams.Marshal(b, m, deterministic) 163} 164func (m *UniformParams) XXX_Merge(src proto.Message) { 165 xxx_messageInfo_UniformParams.Merge(m, src) 166} 167func (m *UniformParams) XXX_Size() int { 168 return xxx_messageInfo_UniformParams.Size(m) 169} 170func (m *UniformParams) XXX_DiscardUnknown() { 171 xxx_messageInfo_UniformParams.DiscardUnknown(m) 172} 173 174var xxx_messageInfo_UniformParams proto.InternalMessageInfo 175 176func (m *UniformParams) GetInterarrivalLo() float64 { 177 if m != nil { 178 return m.InterarrivalLo 179 } 180 return 0 181} 182 183func (m *UniformParams) GetInterarrivalHi() float64 { 184 if m != nil { 185 return m.InterarrivalHi 186 } 187 return 0 188} 189 190type DeterministicParams struct { 191 OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"` 192 XXX_NoUnkeyedLiteral struct{} `json:"-"` 193 XXX_unrecognized []byte `json:"-"` 194 XXX_sizecache int32 `json:"-"` 195} 196 197func (m *DeterministicParams) Reset() { *m = DeterministicParams{} } 198func (m *DeterministicParams) String() string { return proto.CompactTextString(m) } 199func (*DeterministicParams) ProtoMessage() {} 200func (*DeterministicParams) Descriptor() ([]byte, []int) { 201 return fileDescriptor_0c5120591600887d, []int{2} 202} 203 204func (m *DeterministicParams) XXX_Unmarshal(b []byte) error { 205 return xxx_messageInfo_DeterministicParams.Unmarshal(m, b) 206} 207func (m *DeterministicParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 208 return xxx_messageInfo_DeterministicParams.Marshal(b, m, deterministic) 209} 210func (m *DeterministicParams) XXX_Merge(src proto.Message) { 211 xxx_messageInfo_DeterministicParams.Merge(m, src) 212} 213func (m *DeterministicParams) XXX_Size() int { 214 return xxx_messageInfo_DeterministicParams.Size(m) 215} 216func (m *DeterministicParams) XXX_DiscardUnknown() { 217 xxx_messageInfo_DeterministicParams.DiscardUnknown(m) 218} 219 220var xxx_messageInfo_DeterministicParams proto.InternalMessageInfo 221 222func (m *DeterministicParams) GetOfferedLoad() float64 { 223 if m != nil { 224 return m.OfferedLoad 225 } 226 return 0 227} 228 229type ParetoParams struct { 230 InterarrivalBase float64 `protobuf:"fixed64,1,opt,name=interarrival_base,json=interarrivalBase,proto3" json:"interarrival_base,omitempty"` 231 Alpha float64 `protobuf:"fixed64,2,opt,name=alpha,proto3" json:"alpha,omitempty"` 232 XXX_NoUnkeyedLiteral struct{} `json:"-"` 233 XXX_unrecognized []byte `json:"-"` 234 XXX_sizecache int32 `json:"-"` 235} 236 237func (m *ParetoParams) Reset() { *m = ParetoParams{} } 238func (m *ParetoParams) String() string { return proto.CompactTextString(m) } 239func (*ParetoParams) ProtoMessage() {} 240func (*ParetoParams) Descriptor() ([]byte, []int) { 241 return fileDescriptor_0c5120591600887d, []int{3} 242} 243 244func (m *ParetoParams) XXX_Unmarshal(b []byte) error { 245 return xxx_messageInfo_ParetoParams.Unmarshal(m, b) 246} 247func (m *ParetoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 248 return xxx_messageInfo_ParetoParams.Marshal(b, m, deterministic) 249} 250func (m *ParetoParams) XXX_Merge(src proto.Message) { 251 xxx_messageInfo_ParetoParams.Merge(m, src) 252} 253func (m *ParetoParams) XXX_Size() int { 254 return xxx_messageInfo_ParetoParams.Size(m) 255} 256func (m *ParetoParams) XXX_DiscardUnknown() { 257 xxx_messageInfo_ParetoParams.DiscardUnknown(m) 258} 259 260var xxx_messageInfo_ParetoParams proto.InternalMessageInfo 261 262func (m *ParetoParams) GetInterarrivalBase() float64 { 263 if m != nil { 264 return m.InterarrivalBase 265 } 266 return 0 267} 268 269func (m *ParetoParams) GetAlpha() float64 { 270 if m != nil { 271 return m.Alpha 272 } 273 return 0 274} 275 276// Once an RPC finishes, immediately start a new one. 277// No configuration parameters needed. 278type ClosedLoopParams struct { 279 XXX_NoUnkeyedLiteral struct{} `json:"-"` 280 XXX_unrecognized []byte `json:"-"` 281 XXX_sizecache int32 `json:"-"` 282} 283 284func (m *ClosedLoopParams) Reset() { *m = ClosedLoopParams{} } 285func (m *ClosedLoopParams) String() string { return proto.CompactTextString(m) } 286func (*ClosedLoopParams) ProtoMessage() {} 287func (*ClosedLoopParams) Descriptor() ([]byte, []int) { 288 return fileDescriptor_0c5120591600887d, []int{4} 289} 290 291func (m *ClosedLoopParams) XXX_Unmarshal(b []byte) error { 292 return xxx_messageInfo_ClosedLoopParams.Unmarshal(m, b) 293} 294func (m *ClosedLoopParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 295 return xxx_messageInfo_ClosedLoopParams.Marshal(b, m, deterministic) 296} 297func (m *ClosedLoopParams) XXX_Merge(src proto.Message) { 298 xxx_messageInfo_ClosedLoopParams.Merge(m, src) 299} 300func (m *ClosedLoopParams) XXX_Size() int { 301 return xxx_messageInfo_ClosedLoopParams.Size(m) 302} 303func (m *ClosedLoopParams) XXX_DiscardUnknown() { 304 xxx_messageInfo_ClosedLoopParams.DiscardUnknown(m) 305} 306 307var xxx_messageInfo_ClosedLoopParams proto.InternalMessageInfo 308 309type LoadParams struct { 310 // Types that are valid to be assigned to Load: 311 // *LoadParams_ClosedLoop 312 // *LoadParams_Poisson 313 // *LoadParams_Uniform 314 // *LoadParams_Determ 315 // *LoadParams_Pareto 316 Load isLoadParams_Load `protobuf_oneof:"load"` 317 XXX_NoUnkeyedLiteral struct{} `json:"-"` 318 XXX_unrecognized []byte `json:"-"` 319 XXX_sizecache int32 `json:"-"` 320} 321 322func (m *LoadParams) Reset() { *m = LoadParams{} } 323func (m *LoadParams) String() string { return proto.CompactTextString(m) } 324func (*LoadParams) ProtoMessage() {} 325func (*LoadParams) Descriptor() ([]byte, []int) { 326 return fileDescriptor_0c5120591600887d, []int{5} 327} 328 329func (m *LoadParams) XXX_Unmarshal(b []byte) error { 330 return xxx_messageInfo_LoadParams.Unmarshal(m, b) 331} 332func (m *LoadParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 333 return xxx_messageInfo_LoadParams.Marshal(b, m, deterministic) 334} 335func (m *LoadParams) XXX_Merge(src proto.Message) { 336 xxx_messageInfo_LoadParams.Merge(m, src) 337} 338func (m *LoadParams) XXX_Size() int { 339 return xxx_messageInfo_LoadParams.Size(m) 340} 341func (m *LoadParams) XXX_DiscardUnknown() { 342 xxx_messageInfo_LoadParams.DiscardUnknown(m) 343} 344 345var xxx_messageInfo_LoadParams proto.InternalMessageInfo 346 347type isLoadParams_Load interface { 348 isLoadParams_Load() 349} 350 351type LoadParams_ClosedLoop struct { 352 ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,proto3,oneof"` 353} 354 355type LoadParams_Poisson struct { 356 Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,proto3,oneof"` 357} 358 359type LoadParams_Uniform struct { 360 Uniform *UniformParams `protobuf:"bytes,3,opt,name=uniform,proto3,oneof"` 361} 362 363type LoadParams_Determ struct { 364 Determ *DeterministicParams `protobuf:"bytes,4,opt,name=determ,proto3,oneof"` 365} 366 367type LoadParams_Pareto struct { 368 Pareto *ParetoParams `protobuf:"bytes,5,opt,name=pareto,proto3,oneof"` 369} 370 371func (*LoadParams_ClosedLoop) isLoadParams_Load() {} 372 373func (*LoadParams_Poisson) isLoadParams_Load() {} 374 375func (*LoadParams_Uniform) isLoadParams_Load() {} 376 377func (*LoadParams_Determ) isLoadParams_Load() {} 378 379func (*LoadParams_Pareto) isLoadParams_Load() {} 380 381func (m *LoadParams) GetLoad() isLoadParams_Load { 382 if m != nil { 383 return m.Load 384 } 385 return nil 386} 387 388func (m *LoadParams) GetClosedLoop() *ClosedLoopParams { 389 if x, ok := m.GetLoad().(*LoadParams_ClosedLoop); ok { 390 return x.ClosedLoop 391 } 392 return nil 393} 394 395func (m *LoadParams) GetPoisson() *PoissonParams { 396 if x, ok := m.GetLoad().(*LoadParams_Poisson); ok { 397 return x.Poisson 398 } 399 return nil 400} 401 402func (m *LoadParams) GetUniform() *UniformParams { 403 if x, ok := m.GetLoad().(*LoadParams_Uniform); ok { 404 return x.Uniform 405 } 406 return nil 407} 408 409func (m *LoadParams) GetDeterm() *DeterministicParams { 410 if x, ok := m.GetLoad().(*LoadParams_Determ); ok { 411 return x.Determ 412 } 413 return nil 414} 415 416func (m *LoadParams) GetPareto() *ParetoParams { 417 if x, ok := m.GetLoad().(*LoadParams_Pareto); ok { 418 return x.Pareto 419 } 420 return nil 421} 422 423// XXX_OneofWrappers is for the internal use of the proto package. 424func (*LoadParams) XXX_OneofWrappers() []interface{} { 425 return []interface{}{ 426 (*LoadParams_ClosedLoop)(nil), 427 (*LoadParams_Poisson)(nil), 428 (*LoadParams_Uniform)(nil), 429 (*LoadParams_Determ)(nil), 430 (*LoadParams_Pareto)(nil), 431 } 432} 433 434// presence of SecurityParams implies use of TLS 435type SecurityParams struct { 436 UseTestCa bool `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"` 437 ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"` 438 XXX_NoUnkeyedLiteral struct{} `json:"-"` 439 XXX_unrecognized []byte `json:"-"` 440 XXX_sizecache int32 `json:"-"` 441} 442 443func (m *SecurityParams) Reset() { *m = SecurityParams{} } 444func (m *SecurityParams) String() string { return proto.CompactTextString(m) } 445func (*SecurityParams) ProtoMessage() {} 446func (*SecurityParams) Descriptor() ([]byte, []int) { 447 return fileDescriptor_0c5120591600887d, []int{6} 448} 449 450func (m *SecurityParams) XXX_Unmarshal(b []byte) error { 451 return xxx_messageInfo_SecurityParams.Unmarshal(m, b) 452} 453func (m *SecurityParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 454 return xxx_messageInfo_SecurityParams.Marshal(b, m, deterministic) 455} 456func (m *SecurityParams) XXX_Merge(src proto.Message) { 457 xxx_messageInfo_SecurityParams.Merge(m, src) 458} 459func (m *SecurityParams) XXX_Size() int { 460 return xxx_messageInfo_SecurityParams.Size(m) 461} 462func (m *SecurityParams) XXX_DiscardUnknown() { 463 xxx_messageInfo_SecurityParams.DiscardUnknown(m) 464} 465 466var xxx_messageInfo_SecurityParams proto.InternalMessageInfo 467 468func (m *SecurityParams) GetUseTestCa() bool { 469 if m != nil { 470 return m.UseTestCa 471 } 472 return false 473} 474 475func (m *SecurityParams) GetServerHostOverride() string { 476 if m != nil { 477 return m.ServerHostOverride 478 } 479 return "" 480} 481 482type ClientConfig struct { 483 // List of targets to connect to. At least one target needs to be specified. 484 ServerTargets []string `protobuf:"bytes,1,rep,name=server_targets,json=serverTargets,proto3" json:"server_targets,omitempty"` 485 ClientType ClientType `protobuf:"varint,2,opt,name=client_type,json=clientType,proto3,enum=grpc.testing.ClientType" json:"client_type,omitempty"` 486 SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"` 487 // How many concurrent RPCs to start for each channel. 488 // For synchronous client, use a separate thread for each outstanding RPC. 489 OutstandingRpcsPerChannel int32 `protobuf:"varint,4,opt,name=outstanding_rpcs_per_channel,json=outstandingRpcsPerChannel,proto3" json:"outstanding_rpcs_per_channel,omitempty"` 490 // Number of independent client channels to create. 491 // i-th channel will connect to server_target[i % server_targets.size()] 492 ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"` 493 // Only for async client. Number of threads to use to start/manage RPCs. 494 AsyncClientThreads int32 `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads,proto3" json:"async_client_threads,omitempty"` 495 RpcType RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,proto3,enum=grpc.testing.RpcType" json:"rpc_type,omitempty"` 496 // The requested load for the entire client (aggregated over all the threads). 497 LoadParams *LoadParams `protobuf:"bytes,10,opt,name=load_params,json=loadParams,proto3" json:"load_params,omitempty"` 498 PayloadConfig *PayloadConfig `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"` 499 HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams,proto3" json:"histogram_params,omitempty"` 500 // Specify the cores we should run the client on, if desired 501 CoreList []int32 `protobuf:"varint,13,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"` 502 CoreLimit int32 `protobuf:"varint,14,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"` 503 XXX_NoUnkeyedLiteral struct{} `json:"-"` 504 XXX_unrecognized []byte `json:"-"` 505 XXX_sizecache int32 `json:"-"` 506} 507 508func (m *ClientConfig) Reset() { *m = ClientConfig{} } 509func (m *ClientConfig) String() string { return proto.CompactTextString(m) } 510func (*ClientConfig) ProtoMessage() {} 511func (*ClientConfig) Descriptor() ([]byte, []int) { 512 return fileDescriptor_0c5120591600887d, []int{7} 513} 514 515func (m *ClientConfig) XXX_Unmarshal(b []byte) error { 516 return xxx_messageInfo_ClientConfig.Unmarshal(m, b) 517} 518func (m *ClientConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 519 return xxx_messageInfo_ClientConfig.Marshal(b, m, deterministic) 520} 521func (m *ClientConfig) XXX_Merge(src proto.Message) { 522 xxx_messageInfo_ClientConfig.Merge(m, src) 523} 524func (m *ClientConfig) XXX_Size() int { 525 return xxx_messageInfo_ClientConfig.Size(m) 526} 527func (m *ClientConfig) XXX_DiscardUnknown() { 528 xxx_messageInfo_ClientConfig.DiscardUnknown(m) 529} 530 531var xxx_messageInfo_ClientConfig proto.InternalMessageInfo 532 533func (m *ClientConfig) GetServerTargets() []string { 534 if m != nil { 535 return m.ServerTargets 536 } 537 return nil 538} 539 540func (m *ClientConfig) GetClientType() ClientType { 541 if m != nil { 542 return m.ClientType 543 } 544 return ClientType_SYNC_CLIENT 545} 546 547func (m *ClientConfig) GetSecurityParams() *SecurityParams { 548 if m != nil { 549 return m.SecurityParams 550 } 551 return nil 552} 553 554func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32 { 555 if m != nil { 556 return m.OutstandingRpcsPerChannel 557 } 558 return 0 559} 560 561func (m *ClientConfig) GetClientChannels() int32 { 562 if m != nil { 563 return m.ClientChannels 564 } 565 return 0 566} 567 568func (m *ClientConfig) GetAsyncClientThreads() int32 { 569 if m != nil { 570 return m.AsyncClientThreads 571 } 572 return 0 573} 574 575func (m *ClientConfig) GetRpcType() RpcType { 576 if m != nil { 577 return m.RpcType 578 } 579 return RpcType_UNARY 580} 581 582func (m *ClientConfig) GetLoadParams() *LoadParams { 583 if m != nil { 584 return m.LoadParams 585 } 586 return nil 587} 588 589func (m *ClientConfig) GetPayloadConfig() *PayloadConfig { 590 if m != nil { 591 return m.PayloadConfig 592 } 593 return nil 594} 595 596func (m *ClientConfig) GetHistogramParams() *HistogramParams { 597 if m != nil { 598 return m.HistogramParams 599 } 600 return nil 601} 602 603func (m *ClientConfig) GetCoreList() []int32 { 604 if m != nil { 605 return m.CoreList 606 } 607 return nil 608} 609 610func (m *ClientConfig) GetCoreLimit() int32 { 611 if m != nil { 612 return m.CoreLimit 613 } 614 return 0 615} 616 617type ClientStatus struct { 618 Stats *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` 619 XXX_NoUnkeyedLiteral struct{} `json:"-"` 620 XXX_unrecognized []byte `json:"-"` 621 XXX_sizecache int32 `json:"-"` 622} 623 624func (m *ClientStatus) Reset() { *m = ClientStatus{} } 625func (m *ClientStatus) String() string { return proto.CompactTextString(m) } 626func (*ClientStatus) ProtoMessage() {} 627func (*ClientStatus) Descriptor() ([]byte, []int) { 628 return fileDescriptor_0c5120591600887d, []int{8} 629} 630 631func (m *ClientStatus) XXX_Unmarshal(b []byte) error { 632 return xxx_messageInfo_ClientStatus.Unmarshal(m, b) 633} 634func (m *ClientStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 635 return xxx_messageInfo_ClientStatus.Marshal(b, m, deterministic) 636} 637func (m *ClientStatus) XXX_Merge(src proto.Message) { 638 xxx_messageInfo_ClientStatus.Merge(m, src) 639} 640func (m *ClientStatus) XXX_Size() int { 641 return xxx_messageInfo_ClientStatus.Size(m) 642} 643func (m *ClientStatus) XXX_DiscardUnknown() { 644 xxx_messageInfo_ClientStatus.DiscardUnknown(m) 645} 646 647var xxx_messageInfo_ClientStatus proto.InternalMessageInfo 648 649func (m *ClientStatus) GetStats() *ClientStats { 650 if m != nil { 651 return m.Stats 652 } 653 return nil 654} 655 656// Request current stats 657type Mark struct { 658 // if true, the stats will be reset after taking their snapshot. 659 Reset_ bool `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"` 660 XXX_NoUnkeyedLiteral struct{} `json:"-"` 661 XXX_unrecognized []byte `json:"-"` 662 XXX_sizecache int32 `json:"-"` 663} 664 665func (m *Mark) Reset() { *m = Mark{} } 666func (m *Mark) String() string { return proto.CompactTextString(m) } 667func (*Mark) ProtoMessage() {} 668func (*Mark) Descriptor() ([]byte, []int) { 669 return fileDescriptor_0c5120591600887d, []int{9} 670} 671 672func (m *Mark) XXX_Unmarshal(b []byte) error { 673 return xxx_messageInfo_Mark.Unmarshal(m, b) 674} 675func (m *Mark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 676 return xxx_messageInfo_Mark.Marshal(b, m, deterministic) 677} 678func (m *Mark) XXX_Merge(src proto.Message) { 679 xxx_messageInfo_Mark.Merge(m, src) 680} 681func (m *Mark) XXX_Size() int { 682 return xxx_messageInfo_Mark.Size(m) 683} 684func (m *Mark) XXX_DiscardUnknown() { 685 xxx_messageInfo_Mark.DiscardUnknown(m) 686} 687 688var xxx_messageInfo_Mark proto.InternalMessageInfo 689 690func (m *Mark) GetReset_() bool { 691 if m != nil { 692 return m.Reset_ 693 } 694 return false 695} 696 697type ClientArgs struct { 698 // Types that are valid to be assigned to Argtype: 699 // *ClientArgs_Setup 700 // *ClientArgs_Mark 701 Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"` 702 XXX_NoUnkeyedLiteral struct{} `json:"-"` 703 XXX_unrecognized []byte `json:"-"` 704 XXX_sizecache int32 `json:"-"` 705} 706 707func (m *ClientArgs) Reset() { *m = ClientArgs{} } 708func (m *ClientArgs) String() string { return proto.CompactTextString(m) } 709func (*ClientArgs) ProtoMessage() {} 710func (*ClientArgs) Descriptor() ([]byte, []int) { 711 return fileDescriptor_0c5120591600887d, []int{10} 712} 713 714func (m *ClientArgs) XXX_Unmarshal(b []byte) error { 715 return xxx_messageInfo_ClientArgs.Unmarshal(m, b) 716} 717func (m *ClientArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 718 return xxx_messageInfo_ClientArgs.Marshal(b, m, deterministic) 719} 720func (m *ClientArgs) XXX_Merge(src proto.Message) { 721 xxx_messageInfo_ClientArgs.Merge(m, src) 722} 723func (m *ClientArgs) XXX_Size() int { 724 return xxx_messageInfo_ClientArgs.Size(m) 725} 726func (m *ClientArgs) XXX_DiscardUnknown() { 727 xxx_messageInfo_ClientArgs.DiscardUnknown(m) 728} 729 730var xxx_messageInfo_ClientArgs proto.InternalMessageInfo 731 732type isClientArgs_Argtype interface { 733 isClientArgs_Argtype() 734} 735 736type ClientArgs_Setup struct { 737 Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"` 738} 739 740type ClientArgs_Mark struct { 741 Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"` 742} 743 744func (*ClientArgs_Setup) isClientArgs_Argtype() {} 745 746func (*ClientArgs_Mark) isClientArgs_Argtype() {} 747 748func (m *ClientArgs) GetArgtype() isClientArgs_Argtype { 749 if m != nil { 750 return m.Argtype 751 } 752 return nil 753} 754 755func (m *ClientArgs) GetSetup() *ClientConfig { 756 if x, ok := m.GetArgtype().(*ClientArgs_Setup); ok { 757 return x.Setup 758 } 759 return nil 760} 761 762func (m *ClientArgs) GetMark() *Mark { 763 if x, ok := m.GetArgtype().(*ClientArgs_Mark); ok { 764 return x.Mark 765 } 766 return nil 767} 768 769// XXX_OneofWrappers is for the internal use of the proto package. 770func (*ClientArgs) XXX_OneofWrappers() []interface{} { 771 return []interface{}{ 772 (*ClientArgs_Setup)(nil), 773 (*ClientArgs_Mark)(nil), 774 } 775} 776 777type ServerConfig struct { 778 ServerType ServerType `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"` 779 SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"` 780 // Port on which to listen. Zero means pick unused port. 781 Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"` 782 // Only for async server. Number of threads used to serve the requests. 783 AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"` 784 // Specify the number of cores to limit server to, if desired 785 CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"` 786 // payload config, used in generic server 787 PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"` 788 // Specify the cores we should run the server on, if desired 789 CoreList []int32 `protobuf:"varint,10,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"` 790 XXX_NoUnkeyedLiteral struct{} `json:"-"` 791 XXX_unrecognized []byte `json:"-"` 792 XXX_sizecache int32 `json:"-"` 793} 794 795func (m *ServerConfig) Reset() { *m = ServerConfig{} } 796func (m *ServerConfig) String() string { return proto.CompactTextString(m) } 797func (*ServerConfig) ProtoMessage() {} 798func (*ServerConfig) Descriptor() ([]byte, []int) { 799 return fileDescriptor_0c5120591600887d, []int{11} 800} 801 802func (m *ServerConfig) XXX_Unmarshal(b []byte) error { 803 return xxx_messageInfo_ServerConfig.Unmarshal(m, b) 804} 805func (m *ServerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 806 return xxx_messageInfo_ServerConfig.Marshal(b, m, deterministic) 807} 808func (m *ServerConfig) XXX_Merge(src proto.Message) { 809 xxx_messageInfo_ServerConfig.Merge(m, src) 810} 811func (m *ServerConfig) XXX_Size() int { 812 return xxx_messageInfo_ServerConfig.Size(m) 813} 814func (m *ServerConfig) XXX_DiscardUnknown() { 815 xxx_messageInfo_ServerConfig.DiscardUnknown(m) 816} 817 818var xxx_messageInfo_ServerConfig proto.InternalMessageInfo 819 820func (m *ServerConfig) GetServerType() ServerType { 821 if m != nil { 822 return m.ServerType 823 } 824 return ServerType_SYNC_SERVER 825} 826 827func (m *ServerConfig) GetSecurityParams() *SecurityParams { 828 if m != nil { 829 return m.SecurityParams 830 } 831 return nil 832} 833 834func (m *ServerConfig) GetPort() int32 { 835 if m != nil { 836 return m.Port 837 } 838 return 0 839} 840 841func (m *ServerConfig) GetAsyncServerThreads() int32 { 842 if m != nil { 843 return m.AsyncServerThreads 844 } 845 return 0 846} 847 848func (m *ServerConfig) GetCoreLimit() int32 { 849 if m != nil { 850 return m.CoreLimit 851 } 852 return 0 853} 854 855func (m *ServerConfig) GetPayloadConfig() *PayloadConfig { 856 if m != nil { 857 return m.PayloadConfig 858 } 859 return nil 860} 861 862func (m *ServerConfig) GetCoreList() []int32 { 863 if m != nil { 864 return m.CoreList 865 } 866 return nil 867} 868 869type ServerArgs struct { 870 // Types that are valid to be assigned to Argtype: 871 // *ServerArgs_Setup 872 // *ServerArgs_Mark 873 Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"` 874 XXX_NoUnkeyedLiteral struct{} `json:"-"` 875 XXX_unrecognized []byte `json:"-"` 876 XXX_sizecache int32 `json:"-"` 877} 878 879func (m *ServerArgs) Reset() { *m = ServerArgs{} } 880func (m *ServerArgs) String() string { return proto.CompactTextString(m) } 881func (*ServerArgs) ProtoMessage() {} 882func (*ServerArgs) Descriptor() ([]byte, []int) { 883 return fileDescriptor_0c5120591600887d, []int{12} 884} 885 886func (m *ServerArgs) XXX_Unmarshal(b []byte) error { 887 return xxx_messageInfo_ServerArgs.Unmarshal(m, b) 888} 889func (m *ServerArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 890 return xxx_messageInfo_ServerArgs.Marshal(b, m, deterministic) 891} 892func (m *ServerArgs) XXX_Merge(src proto.Message) { 893 xxx_messageInfo_ServerArgs.Merge(m, src) 894} 895func (m *ServerArgs) XXX_Size() int { 896 return xxx_messageInfo_ServerArgs.Size(m) 897} 898func (m *ServerArgs) XXX_DiscardUnknown() { 899 xxx_messageInfo_ServerArgs.DiscardUnknown(m) 900} 901 902var xxx_messageInfo_ServerArgs proto.InternalMessageInfo 903 904type isServerArgs_Argtype interface { 905 isServerArgs_Argtype() 906} 907 908type ServerArgs_Setup struct { 909 Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"` 910} 911 912type ServerArgs_Mark struct { 913 Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"` 914} 915 916func (*ServerArgs_Setup) isServerArgs_Argtype() {} 917 918func (*ServerArgs_Mark) isServerArgs_Argtype() {} 919 920func (m *ServerArgs) GetArgtype() isServerArgs_Argtype { 921 if m != nil { 922 return m.Argtype 923 } 924 return nil 925} 926 927func (m *ServerArgs) GetSetup() *ServerConfig { 928 if x, ok := m.GetArgtype().(*ServerArgs_Setup); ok { 929 return x.Setup 930 } 931 return nil 932} 933 934func (m *ServerArgs) GetMark() *Mark { 935 if x, ok := m.GetArgtype().(*ServerArgs_Mark); ok { 936 return x.Mark 937 } 938 return nil 939} 940 941// XXX_OneofWrappers is for the internal use of the proto package. 942func (*ServerArgs) XXX_OneofWrappers() []interface{} { 943 return []interface{}{ 944 (*ServerArgs_Setup)(nil), 945 (*ServerArgs_Mark)(nil), 946 } 947} 948 949type ServerStatus struct { 950 Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` 951 // the port bound by the server 952 Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` 953 // Number of cores available to the server 954 Cores int32 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"` 955 XXX_NoUnkeyedLiteral struct{} `json:"-"` 956 XXX_unrecognized []byte `json:"-"` 957 XXX_sizecache int32 `json:"-"` 958} 959 960func (m *ServerStatus) Reset() { *m = ServerStatus{} } 961func (m *ServerStatus) String() string { return proto.CompactTextString(m) } 962func (*ServerStatus) ProtoMessage() {} 963func (*ServerStatus) Descriptor() ([]byte, []int) { 964 return fileDescriptor_0c5120591600887d, []int{13} 965} 966 967func (m *ServerStatus) XXX_Unmarshal(b []byte) error { 968 return xxx_messageInfo_ServerStatus.Unmarshal(m, b) 969} 970func (m *ServerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 971 return xxx_messageInfo_ServerStatus.Marshal(b, m, deterministic) 972} 973func (m *ServerStatus) XXX_Merge(src proto.Message) { 974 xxx_messageInfo_ServerStatus.Merge(m, src) 975} 976func (m *ServerStatus) XXX_Size() int { 977 return xxx_messageInfo_ServerStatus.Size(m) 978} 979func (m *ServerStatus) XXX_DiscardUnknown() { 980 xxx_messageInfo_ServerStatus.DiscardUnknown(m) 981} 982 983var xxx_messageInfo_ServerStatus proto.InternalMessageInfo 984 985func (m *ServerStatus) GetStats() *ServerStats { 986 if m != nil { 987 return m.Stats 988 } 989 return nil 990} 991 992func (m *ServerStatus) GetPort() int32 { 993 if m != nil { 994 return m.Port 995 } 996 return 0 997} 998 999func (m *ServerStatus) GetCores() int32 { 1000 if m != nil { 1001 return m.Cores 1002 } 1003 return 0 1004} 1005 1006type CoreRequest struct { 1007 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1008 XXX_unrecognized []byte `json:"-"` 1009 XXX_sizecache int32 `json:"-"` 1010} 1011 1012func (m *CoreRequest) Reset() { *m = CoreRequest{} } 1013func (m *CoreRequest) String() string { return proto.CompactTextString(m) } 1014func (*CoreRequest) ProtoMessage() {} 1015func (*CoreRequest) Descriptor() ([]byte, []int) { 1016 return fileDescriptor_0c5120591600887d, []int{14} 1017} 1018 1019func (m *CoreRequest) XXX_Unmarshal(b []byte) error { 1020 return xxx_messageInfo_CoreRequest.Unmarshal(m, b) 1021} 1022func (m *CoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1023 return xxx_messageInfo_CoreRequest.Marshal(b, m, deterministic) 1024} 1025func (m *CoreRequest) XXX_Merge(src proto.Message) { 1026 xxx_messageInfo_CoreRequest.Merge(m, src) 1027} 1028func (m *CoreRequest) XXX_Size() int { 1029 return xxx_messageInfo_CoreRequest.Size(m) 1030} 1031func (m *CoreRequest) XXX_DiscardUnknown() { 1032 xxx_messageInfo_CoreRequest.DiscardUnknown(m) 1033} 1034 1035var xxx_messageInfo_CoreRequest proto.InternalMessageInfo 1036 1037type CoreResponse struct { 1038 // Number of cores available on the server 1039 Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"` 1040 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1041 XXX_unrecognized []byte `json:"-"` 1042 XXX_sizecache int32 `json:"-"` 1043} 1044 1045func (m *CoreResponse) Reset() { *m = CoreResponse{} } 1046func (m *CoreResponse) String() string { return proto.CompactTextString(m) } 1047func (*CoreResponse) ProtoMessage() {} 1048func (*CoreResponse) Descriptor() ([]byte, []int) { 1049 return fileDescriptor_0c5120591600887d, []int{15} 1050} 1051 1052func (m *CoreResponse) XXX_Unmarshal(b []byte) error { 1053 return xxx_messageInfo_CoreResponse.Unmarshal(m, b) 1054} 1055func (m *CoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1056 return xxx_messageInfo_CoreResponse.Marshal(b, m, deterministic) 1057} 1058func (m *CoreResponse) XXX_Merge(src proto.Message) { 1059 xxx_messageInfo_CoreResponse.Merge(m, src) 1060} 1061func (m *CoreResponse) XXX_Size() int { 1062 return xxx_messageInfo_CoreResponse.Size(m) 1063} 1064func (m *CoreResponse) XXX_DiscardUnknown() { 1065 xxx_messageInfo_CoreResponse.DiscardUnknown(m) 1066} 1067 1068var xxx_messageInfo_CoreResponse proto.InternalMessageInfo 1069 1070func (m *CoreResponse) GetCores() int32 { 1071 if m != nil { 1072 return m.Cores 1073 } 1074 return 0 1075} 1076 1077type Void struct { 1078 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1079 XXX_unrecognized []byte `json:"-"` 1080 XXX_sizecache int32 `json:"-"` 1081} 1082 1083func (m *Void) Reset() { *m = Void{} } 1084func (m *Void) String() string { return proto.CompactTextString(m) } 1085func (*Void) ProtoMessage() {} 1086func (*Void) Descriptor() ([]byte, []int) { 1087 return fileDescriptor_0c5120591600887d, []int{16} 1088} 1089 1090func (m *Void) XXX_Unmarshal(b []byte) error { 1091 return xxx_messageInfo_Void.Unmarshal(m, b) 1092} 1093func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1094 return xxx_messageInfo_Void.Marshal(b, m, deterministic) 1095} 1096func (m *Void) XXX_Merge(src proto.Message) { 1097 xxx_messageInfo_Void.Merge(m, src) 1098} 1099func (m *Void) XXX_Size() int { 1100 return xxx_messageInfo_Void.Size(m) 1101} 1102func (m *Void) XXX_DiscardUnknown() { 1103 xxx_messageInfo_Void.DiscardUnknown(m) 1104} 1105 1106var xxx_messageInfo_Void proto.InternalMessageInfo 1107 1108// A single performance scenario: input to qps_json_driver 1109type Scenario struct { 1110 // Human readable name for this scenario 1111 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1112 // Client configuration 1113 ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"` 1114 // Number of clients to start for the test 1115 NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"` 1116 // Server configuration 1117 ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"` 1118 // Number of servers to start for the test 1119 NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"` 1120 // Warmup period, in seconds 1121 WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"` 1122 // Benchmark time, in seconds 1123 BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"` 1124 // Number of workers to spawn locally (usually zero) 1125 SpawnLocalWorkerCount int32 `protobuf:"varint,8,opt,name=spawn_local_worker_count,json=spawnLocalWorkerCount,proto3" json:"spawn_local_worker_count,omitempty"` 1126 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1127 XXX_unrecognized []byte `json:"-"` 1128 XXX_sizecache int32 `json:"-"` 1129} 1130 1131func (m *Scenario) Reset() { *m = Scenario{} } 1132func (m *Scenario) String() string { return proto.CompactTextString(m) } 1133func (*Scenario) ProtoMessage() {} 1134func (*Scenario) Descriptor() ([]byte, []int) { 1135 return fileDescriptor_0c5120591600887d, []int{17} 1136} 1137 1138func (m *Scenario) XXX_Unmarshal(b []byte) error { 1139 return xxx_messageInfo_Scenario.Unmarshal(m, b) 1140} 1141func (m *Scenario) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1142 return xxx_messageInfo_Scenario.Marshal(b, m, deterministic) 1143} 1144func (m *Scenario) XXX_Merge(src proto.Message) { 1145 xxx_messageInfo_Scenario.Merge(m, src) 1146} 1147func (m *Scenario) XXX_Size() int { 1148 return xxx_messageInfo_Scenario.Size(m) 1149} 1150func (m *Scenario) XXX_DiscardUnknown() { 1151 xxx_messageInfo_Scenario.DiscardUnknown(m) 1152} 1153 1154var xxx_messageInfo_Scenario proto.InternalMessageInfo 1155 1156func (m *Scenario) GetName() string { 1157 if m != nil { 1158 return m.Name 1159 } 1160 return "" 1161} 1162 1163func (m *Scenario) GetClientConfig() *ClientConfig { 1164 if m != nil { 1165 return m.ClientConfig 1166 } 1167 return nil 1168} 1169 1170func (m *Scenario) GetNumClients() int32 { 1171 if m != nil { 1172 return m.NumClients 1173 } 1174 return 0 1175} 1176 1177func (m *Scenario) GetServerConfig() *ServerConfig { 1178 if m != nil { 1179 return m.ServerConfig 1180 } 1181 return nil 1182} 1183 1184func (m *Scenario) GetNumServers() int32 { 1185 if m != nil { 1186 return m.NumServers 1187 } 1188 return 0 1189} 1190 1191func (m *Scenario) GetWarmupSeconds() int32 { 1192 if m != nil { 1193 return m.WarmupSeconds 1194 } 1195 return 0 1196} 1197 1198func (m *Scenario) GetBenchmarkSeconds() int32 { 1199 if m != nil { 1200 return m.BenchmarkSeconds 1201 } 1202 return 0 1203} 1204 1205func (m *Scenario) GetSpawnLocalWorkerCount() int32 { 1206 if m != nil { 1207 return m.SpawnLocalWorkerCount 1208 } 1209 return 0 1210} 1211 1212// A set of scenarios to be run with qps_json_driver 1213type Scenarios struct { 1214 Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"` 1215 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1216 XXX_unrecognized []byte `json:"-"` 1217 XXX_sizecache int32 `json:"-"` 1218} 1219 1220func (m *Scenarios) Reset() { *m = Scenarios{} } 1221func (m *Scenarios) String() string { return proto.CompactTextString(m) } 1222func (*Scenarios) ProtoMessage() {} 1223func (*Scenarios) Descriptor() ([]byte, []int) { 1224 return fileDescriptor_0c5120591600887d, []int{18} 1225} 1226 1227func (m *Scenarios) XXX_Unmarshal(b []byte) error { 1228 return xxx_messageInfo_Scenarios.Unmarshal(m, b) 1229} 1230func (m *Scenarios) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1231 return xxx_messageInfo_Scenarios.Marshal(b, m, deterministic) 1232} 1233func (m *Scenarios) XXX_Merge(src proto.Message) { 1234 xxx_messageInfo_Scenarios.Merge(m, src) 1235} 1236func (m *Scenarios) XXX_Size() int { 1237 return xxx_messageInfo_Scenarios.Size(m) 1238} 1239func (m *Scenarios) XXX_DiscardUnknown() { 1240 xxx_messageInfo_Scenarios.DiscardUnknown(m) 1241} 1242 1243var xxx_messageInfo_Scenarios proto.InternalMessageInfo 1244 1245func (m *Scenarios) GetScenarios() []*Scenario { 1246 if m != nil { 1247 return m.Scenarios 1248 } 1249 return nil 1250} 1251 1252func init() { 1253 proto.RegisterEnum("grpc.testing.ClientType", ClientType_name, ClientType_value) 1254 proto.RegisterEnum("grpc.testing.ServerType", ServerType_name, ServerType_value) 1255 proto.RegisterEnum("grpc.testing.RpcType", RpcType_name, RpcType_value) 1256 proto.RegisterType((*PoissonParams)(nil), "grpc.testing.PoissonParams") 1257 proto.RegisterType((*UniformParams)(nil), "grpc.testing.UniformParams") 1258 proto.RegisterType((*DeterministicParams)(nil), "grpc.testing.DeterministicParams") 1259 proto.RegisterType((*ParetoParams)(nil), "grpc.testing.ParetoParams") 1260 proto.RegisterType((*ClosedLoopParams)(nil), "grpc.testing.ClosedLoopParams") 1261 proto.RegisterType((*LoadParams)(nil), "grpc.testing.LoadParams") 1262 proto.RegisterType((*SecurityParams)(nil), "grpc.testing.SecurityParams") 1263 proto.RegisterType((*ClientConfig)(nil), "grpc.testing.ClientConfig") 1264 proto.RegisterType((*ClientStatus)(nil), "grpc.testing.ClientStatus") 1265 proto.RegisterType((*Mark)(nil), "grpc.testing.Mark") 1266 proto.RegisterType((*ClientArgs)(nil), "grpc.testing.ClientArgs") 1267 proto.RegisterType((*ServerConfig)(nil), "grpc.testing.ServerConfig") 1268 proto.RegisterType((*ServerArgs)(nil), "grpc.testing.ServerArgs") 1269 proto.RegisterType((*ServerStatus)(nil), "grpc.testing.ServerStatus") 1270 proto.RegisterType((*CoreRequest)(nil), "grpc.testing.CoreRequest") 1271 proto.RegisterType((*CoreResponse)(nil), "grpc.testing.CoreResponse") 1272 proto.RegisterType((*Void)(nil), "grpc.testing.Void") 1273 proto.RegisterType((*Scenario)(nil), "grpc.testing.Scenario") 1274 proto.RegisterType((*Scenarios)(nil), "grpc.testing.Scenarios") 1275} 1276 1277func init() { proto.RegisterFile("control.proto", fileDescriptor_0c5120591600887d) } 1278 1279var fileDescriptor_0c5120591600887d = []byte{ 1280 // 1179 bytes of a gzipped FileDescriptorProto 1281 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0x6f, 0x6f, 0xdb, 0xb6, 1282 0x13, 0xb6, 0x1d, 0xdb, 0xb1, 0x4e, 0xb6, 0xe3, 0x1f, 0x7f, 0xe9, 0xa0, 0xa6, 0x69, 0x97, 0x6a, 1283 0x1b, 0x16, 0x64, 0x40, 0x5a, 0x78, 0x05, 0xba, 0x62, 0x2f, 0x02, 0xc7, 0x33, 0xea, 0x00, 0x69, 1284 0x96, 0xd1, 0x69, 0x87, 0xbe, 0x12, 0x18, 0x99, 0xb1, 0x85, 0xc8, 0xa2, 0x46, 0x52, 0x09, 0xf2, 1285 0x15, 0xf6, 0x99, 0xf6, 0x39, 0xf6, 0x35, 0xf6, 0x15, 0x06, 0xfe, 0x91, 0x23, 0xb9, 0x06, 0x9a, 1286 0x6d, 0xef, 0xc4, 0xbb, 0xe7, 0xe1, 0x91, 0xf7, 0xdc, 0x1d, 0x05, 0x9d, 0x90, 0x25, 0x92, 0xb3, 1287 0xf8, 0x30, 0xe5, 0x4c, 0x32, 0xd4, 0x9e, 0xf1, 0x34, 0x3c, 0x94, 0x54, 0xc8, 0x28, 0x99, 0xed, 1288 0x74, 0x53, 0x72, 0x17, 0x33, 0x32, 0x15, 0xc6, 0xbb, 0xe3, 0x0a, 0x49, 0xa4, 0x5d, 0xf8, 0x7d, 1289 0xe8, 0x9c, 0xb3, 0x48, 0x08, 0x96, 0x9c, 0x13, 0x4e, 0x16, 0x02, 0x3d, 0x87, 0x36, 0xbb, 0xba, 1290 0xa2, 0x9c, 0x4e, 0x03, 0x45, 0xf2, 0xaa, 0x7b, 0xd5, 0xfd, 0x2a, 0x76, 0xad, 0xed, 0x94, 0x91, 1291 0xa9, 0x4f, 0xa0, 0xf3, 0x3e, 0x89, 0xae, 0x18, 0x5f, 0x58, 0xce, 0xb7, 0xb0, 0x15, 0x25, 0x92, 1292 0x72, 0xc2, 0x79, 0x74, 0x43, 0xe2, 0x20, 0x66, 0x96, 0xd6, 0x2d, 0x9a, 0x4f, 0xd9, 0x27, 0xc0, 1293 0x79, 0xe4, 0xd5, 0x3e, 0x05, 0x8e, 0x23, 0xff, 0x07, 0xf8, 0xff, 0x4f, 0x54, 0x52, 0xbe, 0x88, 1294 0x92, 0x48, 0xc8, 0x28, 0x7c, 0xf8, 0xe1, 0x7e, 0x81, 0xf6, 0x39, 0xe1, 0x54, 0x32, 0x4b, 0xf9, 1295 0x0e, 0xfe, 0x57, 0x0a, 0x79, 0x49, 0x04, 0xb5, 0xbc, 0x5e, 0xd1, 0x71, 0x4c, 0x04, 0x45, 0xdb, 1296 0xd0, 0x20, 0x71, 0x3a, 0x27, 0xf6, 0x54, 0x66, 0xe1, 0x23, 0xe8, 0x0d, 0x63, 0x26, 0x54, 0x00, 1297 0x96, 0x9a, 0x6d, 0xfd, 0x3f, 0x6a, 0x00, 0x2a, 0x9e, 0x8d, 0x32, 0x00, 0x37, 0xd4, 0x90, 0x20, 1298 0x66, 0x2c, 0xd5, 0xfb, 0xbb, 0xfd, 0x67, 0x87, 0x45, 0x1d, 0x0e, 0x57, 0xf7, 0x18, 0x57, 0x30, 1299 0x84, 0x4b, 0x1b, 0x7a, 0x0d, 0x9b, 0xa9, 0x51, 0x42, 0x47, 0x77, 0xfb, 0x4f, 0xca, 0xf4, 0x92, 1300 0x4c, 0xe3, 0x0a, 0xce, 0xd1, 0x8a, 0x98, 0x19, 0x39, 0xbc, 0x8d, 0x75, 0xc4, 0x92, 0x56, 0x8a, 1301 0x68, 0xd1, 0xe8, 0x47, 0x68, 0x4e, 0x75, 0x92, 0xbd, 0xba, 0xe6, 0x3d, 0x2f, 0xf3, 0xd6, 0x08, 1302 0x30, 0xae, 0x60, 0x4b, 0x41, 0xaf, 0xa0, 0x99, 0xea, 0x3c, 0x7b, 0x0d, 0x4d, 0xde, 0x59, 0x39, 1303 0x6d, 0x41, 0x03, 0xc5, 0x32, 0xd8, 0xe3, 0x26, 0xd4, 0x95, 0x70, 0xfe, 0x25, 0x74, 0x27, 0x34, 1304 0xcc, 0x78, 0x24, 0xef, 0x6c, 0x06, 0x9f, 0x81, 0x9b, 0x09, 0x1a, 0x28, 0x7e, 0x10, 0x12, 0x9d, 1305 0xc1, 0x16, 0x76, 0x32, 0x41, 0x2f, 0xa8, 0x90, 0x43, 0x82, 0x5e, 0xc2, 0xb6, 0xa0, 0xfc, 0x86, 1306 0xf2, 0x60, 0xce, 0x84, 0x0c, 0xd8, 0x0d, 0xe5, 0x3c, 0x9a, 0x52, 0x9d, 0x2b, 0x07, 0x23, 0xe3, 1307 0x1b, 0x33, 0x21, 0x7f, 0xb6, 0x1e, 0xff, 0xf7, 0x06, 0xb4, 0x87, 0x71, 0x44, 0x13, 0x39, 0x64, 1308 0xc9, 0x55, 0x34, 0x43, 0xdf, 0x40, 0xd7, 0x6e, 0x21, 0x09, 0x9f, 0x51, 0x29, 0xbc, 0xea, 0xde, 1309 0xc6, 0xbe, 0x83, 0x3b, 0xc6, 0x7a, 0x61, 0x8c, 0xe8, 0x8d, 0xd2, 0x52, 0xd1, 0x02, 0x79, 0x97, 1310 0x9a, 0x00, 0xdd, 0xbe, 0xb7, 0xaa, 0xa5, 0x02, 0x5c, 0xdc, 0xa5, 0x54, 0x69, 0x98, 0x7f, 0xa3, 1311 0x11, 0x6c, 0x09, 0x7b, 0xad, 0x20, 0xd5, 0xf7, 0xb2, 0x92, 0xec, 0x96, 0xe9, 0xe5, 0xbb, 0xe3, 1312 0xae, 0x28, 0xe7, 0xe2, 0x08, 0x76, 0x59, 0x26, 0x85, 0x24, 0xc9, 0x34, 0x4a, 0x66, 0x01, 0x4f, 1313 0x43, 0x11, 0xa4, 0x94, 0x07, 0xe1, 0x9c, 0x24, 0x09, 0x8d, 0xb5, 0x5c, 0x0d, 0xfc, 0xb8, 0x80, 1314 0xc1, 0x69, 0x28, 0xce, 0x29, 0x1f, 0x1a, 0x80, 0xea, 0x33, 0x7b, 0x05, 0x4b, 0x11, 0x5a, 0xa5, 1315 0x06, 0xee, 0x1a, 0xb3, 0xc5, 0x09, 0x95, 0x55, 0x22, 0xee, 0x92, 0x30, 0xc8, 0x6f, 0x3c, 0xe7, 1316 0x94, 0x4c, 0x85, 0xb7, 0xa9, 0xd1, 0x48, 0xfb, 0xec, 0x5d, 0x8d, 0x07, 0xbd, 0x84, 0x16, 0x4f, 1317 0x43, 0x93, 0x9a, 0x96, 0x4e, 0xcd, 0xa3, 0xf2, 0xdd, 0x70, 0x1a, 0xea, 0xbc, 0x6c, 0x72, 0xf3, 1318 0xa1, 0xf2, 0xa9, 0x34, 0xcf, 0x13, 0x02, 0x3a, 0x21, 0x2b, 0xf9, 0xbc, 0x6f, 0x25, 0x0c, 0xf1, 1319 0x7d, 0x5b, 0x1d, 0x43, 0x3e, 0xbc, 0x82, 0x50, 0x6b, 0xe8, 0xb9, 0x6b, 0x5b, 0xc3, 0x60, 0x8c, 1320 0xcc, 0xb8, 0x93, 0x16, 0x97, 0x68, 0x0c, 0xbd, 0x79, 0x24, 0x24, 0x9b, 0x71, 0xb2, 0xc8, 0xcf, 1321 0xd0, 0xd6, 0xbb, 0x3c, 0x2d, 0xef, 0x32, 0xce, 0x51, 0xf6, 0x20, 0x5b, 0xf3, 0xb2, 0x01, 0x3d, 1322 0x01, 0x27, 0x64, 0x9c, 0x06, 0x71, 0x24, 0xa4, 0xd7, 0xd9, 0xdb, 0xd8, 0x6f, 0xe0, 0x96, 0x32, 1323 0x9c, 0x46, 0x42, 0xa2, 0xa7, 0x00, 0xd6, 0xb9, 0x88, 0xa4, 0xd7, 0xd5, 0xf9, 0x73, 0x8c, 0x77, 1324 0x11, 0x49, 0xff, 0x28, 0xaf, 0xc5, 0x89, 0x24, 0x32, 0x13, 0xe8, 0x05, 0x34, 0xf4, 0x18, 0xb6, 1325 0xa3, 0xe2, 0xf1, 0xba, 0xf2, 0x52, 0x50, 0x81, 0x0d, 0xce, 0xdf, 0x85, 0xfa, 0x3b, 0xc2, 0xaf, 1326 0xd5, 0x88, 0xe2, 0x54, 0x50, 0x69, 0x3b, 0xc4, 0x2c, 0xfc, 0x0c, 0xc0, 0x70, 0x06, 0x7c, 0x26, 1327 0x50, 0x1f, 0x1a, 0x82, 0xca, 0x2c, 0x9f, 0x43, 0x3b, 0xeb, 0x36, 0x37, 0xd9, 0x19, 0x57, 0xb0, 1328 0x81, 0xa2, 0x7d, 0xa8, 0x2f, 0x08, 0xbf, 0xb6, 0xb3, 0x07, 0x95, 0x29, 0x2a, 0xf2, 0xb8, 0x82, 1329 0x35, 0xe2, 0xd8, 0x81, 0x4d, 0xc2, 0x67, 0xaa, 0x00, 0xfc, 0x3f, 0x6b, 0xd0, 0x9e, 0xe8, 0xe6, 1330 0xb1, 0xc9, 0x7e, 0x03, 0x6e, 0xde, 0x62, 0xaa, 0x40, 0xaa, 0xeb, 0x7a, 0xc7, 0x10, 0x4c, 0xef, 1331 0x88, 0xe5, 0xf7, 0xba, 0xde, 0xa9, 0xfd, 0x8b, 0xde, 0x41, 0x50, 0x4f, 0x19, 0x97, 0xb6, 0x47, 1332 0xf4, 0xf7, 0x7d, 0x95, 0xe7, 0x67, 0x5b, 0x53, 0xe5, 0xf6, 0x54, 0xb6, 0xca, 0xcb, 0x6a, 0xb6, 1333 0x56, 0xd4, 0x5c, 0x53, 0x97, 0xce, 0x3f, 0xae, 0xcb, 0x52, 0x35, 0x41, 0xb9, 0x9a, 0x94, 0x9e, 1334 0xe6, 0x40, 0x0f, 0xd0, 0xb3, 0x28, 0xc0, 0x7f, 0xd4, 0x33, 0xca, 0xe5, 0x7c, 0x50, 0x95, 0xde, 1335 0x43, 0xf3, 0x2a, 0x5d, 0x66, 0xbf, 0x56, 0xc8, 0xfe, 0x36, 0x34, 0xd4, 0xbd, 0xcc, 0x28, 0x6c, 1336 0x60, 0xb3, 0xf0, 0x3b, 0xe0, 0x0e, 0x19, 0xa7, 0x98, 0xfe, 0x96, 0x51, 0x21, 0xfd, 0xaf, 0xa1, 1337 0x6d, 0x96, 0x22, 0x65, 0x89, 0x79, 0x89, 0x0d, 0xa9, 0x5a, 0x24, 0x35, 0xa1, 0xfe, 0x81, 0x45, 1338 0x53, 0xff, 0xaf, 0x1a, 0xb4, 0x26, 0x21, 0x4d, 0x08, 0x8f, 0x98, 0x8a, 0x99, 0x90, 0x85, 0x29, 1339 0x36, 0x07, 0xeb, 0x6f, 0x74, 0x04, 0x9d, 0x7c, 0x00, 0x1a, 0x7d, 0x6a, 0x9f, 0xeb, 0x04, 0xdc, 1340 0x0e, 0x8b, 0x6f, 0xc5, 0x97, 0xe0, 0x26, 0xd9, 0xc2, 0x8e, 0xc5, 0xfc, 0xe8, 0x90, 0x64, 0x0b, 1341 0xc3, 0x51, 0x33, 0xda, 0x3e, 0x1b, 0x79, 0x84, 0xfa, 0xe7, 0xb4, 0xc1, 0x6d, 0x51, 0x6c, 0x15, 1342 0x1b, 0xc1, 0xd8, 0xf2, 0xf9, 0xac, 0x22, 0x18, 0x8e, 0x50, 0xcf, 0xd5, 0x2d, 0xe1, 0x8b, 0x2c, 1343 0x0d, 0x04, 0x0d, 0x59, 0x32, 0x15, 0x5e, 0x53, 0x63, 0x3a, 0xc6, 0x3a, 0x31, 0x46, 0xf5, 0x83, 1344 0x73, 0x49, 0x93, 0x70, 0xae, 0xb4, 0x5c, 0x22, 0x4d, 0x65, 0xf7, 0x96, 0x8e, 0x1c, 0xfc, 0x1a, 1345 0x3c, 0x91, 0x92, 0xdb, 0x24, 0x88, 0x59, 0x48, 0xe2, 0xe0, 0x96, 0xf1, 0x6b, 0x7d, 0x83, 0x2c, 1346 0xc9, 0xab, 0xfc, 0x91, 0xf6, 0x9f, 0x2a, 0xf7, 0xaf, 0xda, 0x3b, 0x54, 0x4e, 0x7f, 0x00, 0x4e, 1347 0x9e, 0x70, 0x81, 0x5e, 0x81, 0x23, 0xf2, 0x85, 0x7e, 0x43, 0xdd, 0xfe, 0x17, 0x2b, 0xf7, 0xb6, 1348 0x6e, 0x7c, 0x0f, 0x3c, 0x78, 0x91, 0xcf, 0x28, 0xdd, 0xee, 0x5b, 0xe0, 0x4e, 0x3e, 0x9e, 0x0d, 1349 0x83, 0xe1, 0xe9, 0xc9, 0xe8, 0xec, 0xa2, 0x57, 0x41, 0x3d, 0x68, 0x0f, 0x8a, 0x96, 0xea, 0xc1, 1350 0x49, 0xde, 0x04, 0x25, 0xc2, 0x64, 0x84, 0x3f, 0x8c, 0x70, 0x91, 0x60, 0x2d, 0x55, 0xe4, 0xc1, 1351 0xb6, 0xb1, 0xbc, 0x1d, 0x9d, 0x8d, 0xf0, 0xc9, 0xd2, 0x53, 0x3b, 0xf8, 0x0a, 0x36, 0xed, 0xbb, 1352 0x84, 0x1c, 0x68, 0xbc, 0x3f, 0x1b, 0xe0, 0x8f, 0xbd, 0x0a, 0xea, 0x80, 0x33, 0xb9, 0xc0, 0xa3, 1353 0xc1, 0xbb, 0x93, 0xb3, 0xb7, 0xbd, 0xea, 0x65, 0x53, 0xff, 0x12, 0x7f, 0xff, 0x77, 0x00, 0x00, 1354 0x00, 0xff, 0xff, 0x75, 0x59, 0xf4, 0x03, 0x4e, 0x0b, 0x00, 0x00, 1355} 1356