control.pb.go 92 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492
  1. // Copyright 2015 gRPC authors.
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. // Code generated by protoc-gen-go. DO NOT EDIT.
  15. // versions:
  16. // protoc-gen-go v1.30.0
  17. // protoc v4.22.0
  18. // source: grpc/testing/control.proto
  19. package grpc_testing
  20. import (
  21. protoreflect "google.golang.org/protobuf/reflect/protoreflect"
  22. protoimpl "google.golang.org/protobuf/runtime/protoimpl"
  23. timestamppb "google.golang.org/protobuf/types/known/timestamppb"
  24. reflect "reflect"
  25. sync "sync"
  26. )
  27. const (
  28. // Verify that this generated code is sufficiently up-to-date.
  29. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
  30. // Verify that runtime/protoimpl is sufficiently up-to-date.
  31. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
  32. )
  33. type ClientType int32
  34. const (
  35. // Many languages support a basic distinction between using
  36. // sync or async client, and this allows the specification
  37. ClientType_SYNC_CLIENT ClientType = 0
  38. ClientType_ASYNC_CLIENT ClientType = 1
  39. ClientType_OTHER_CLIENT ClientType = 2 // used for some language-specific variants
  40. ClientType_CALLBACK_CLIENT ClientType = 3
  41. )
  42. // Enum value maps for ClientType.
  43. var (
  44. ClientType_name = map[int32]string{
  45. 0: "SYNC_CLIENT",
  46. 1: "ASYNC_CLIENT",
  47. 2: "OTHER_CLIENT",
  48. 3: "CALLBACK_CLIENT",
  49. }
  50. ClientType_value = map[string]int32{
  51. "SYNC_CLIENT": 0,
  52. "ASYNC_CLIENT": 1,
  53. "OTHER_CLIENT": 2,
  54. "CALLBACK_CLIENT": 3,
  55. }
  56. )
  57. func (x ClientType) Enum() *ClientType {
  58. p := new(ClientType)
  59. *p = x
  60. return p
  61. }
  62. func (x ClientType) String() string {
  63. return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
  64. }
  65. func (ClientType) Descriptor() protoreflect.EnumDescriptor {
  66. return file_grpc_testing_control_proto_enumTypes[0].Descriptor()
  67. }
  68. func (ClientType) Type() protoreflect.EnumType {
  69. return &file_grpc_testing_control_proto_enumTypes[0]
  70. }
  71. func (x ClientType) Number() protoreflect.EnumNumber {
  72. return protoreflect.EnumNumber(x)
  73. }
  74. // Deprecated: Use ClientType.Descriptor instead.
  75. func (ClientType) EnumDescriptor() ([]byte, []int) {
  76. return file_grpc_testing_control_proto_rawDescGZIP(), []int{0}
  77. }
  78. type ServerType int32
  79. const (
  80. ServerType_SYNC_SERVER ServerType = 0
  81. ServerType_ASYNC_SERVER ServerType = 1
  82. ServerType_ASYNC_GENERIC_SERVER ServerType = 2
  83. ServerType_OTHER_SERVER ServerType = 3 // used for some language-specific variants
  84. ServerType_CALLBACK_SERVER ServerType = 4
  85. )
  86. // Enum value maps for ServerType.
  87. var (
  88. ServerType_name = map[int32]string{
  89. 0: "SYNC_SERVER",
  90. 1: "ASYNC_SERVER",
  91. 2: "ASYNC_GENERIC_SERVER",
  92. 3: "OTHER_SERVER",
  93. 4: "CALLBACK_SERVER",
  94. }
  95. ServerType_value = map[string]int32{
  96. "SYNC_SERVER": 0,
  97. "ASYNC_SERVER": 1,
  98. "ASYNC_GENERIC_SERVER": 2,
  99. "OTHER_SERVER": 3,
  100. "CALLBACK_SERVER": 4,
  101. }
  102. )
  103. func (x ServerType) Enum() *ServerType {
  104. p := new(ServerType)
  105. *p = x
  106. return p
  107. }
  108. func (x ServerType) String() string {
  109. return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
  110. }
  111. func (ServerType) Descriptor() protoreflect.EnumDescriptor {
  112. return file_grpc_testing_control_proto_enumTypes[1].Descriptor()
  113. }
  114. func (ServerType) Type() protoreflect.EnumType {
  115. return &file_grpc_testing_control_proto_enumTypes[1]
  116. }
  117. func (x ServerType) Number() protoreflect.EnumNumber {
  118. return protoreflect.EnumNumber(x)
  119. }
  120. // Deprecated: Use ServerType.Descriptor instead.
  121. func (ServerType) EnumDescriptor() ([]byte, []int) {
  122. return file_grpc_testing_control_proto_rawDescGZIP(), []int{1}
  123. }
  124. type RpcType int32
  125. const (
  126. RpcType_UNARY RpcType = 0
  127. RpcType_STREAMING RpcType = 1
  128. RpcType_STREAMING_FROM_CLIENT RpcType = 2
  129. RpcType_STREAMING_FROM_SERVER RpcType = 3
  130. RpcType_STREAMING_BOTH_WAYS RpcType = 4
  131. )
  132. // Enum value maps for RpcType.
  133. var (
  134. RpcType_name = map[int32]string{
  135. 0: "UNARY",
  136. 1: "STREAMING",
  137. 2: "STREAMING_FROM_CLIENT",
  138. 3: "STREAMING_FROM_SERVER",
  139. 4: "STREAMING_BOTH_WAYS",
  140. }
  141. RpcType_value = map[string]int32{
  142. "UNARY": 0,
  143. "STREAMING": 1,
  144. "STREAMING_FROM_CLIENT": 2,
  145. "STREAMING_FROM_SERVER": 3,
  146. "STREAMING_BOTH_WAYS": 4,
  147. }
  148. )
  149. func (x RpcType) Enum() *RpcType {
  150. p := new(RpcType)
  151. *p = x
  152. return p
  153. }
  154. func (x RpcType) String() string {
  155. return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
  156. }
  157. func (RpcType) Descriptor() protoreflect.EnumDescriptor {
  158. return file_grpc_testing_control_proto_enumTypes[2].Descriptor()
  159. }
  160. func (RpcType) Type() protoreflect.EnumType {
  161. return &file_grpc_testing_control_proto_enumTypes[2]
  162. }
  163. func (x RpcType) Number() protoreflect.EnumNumber {
  164. return protoreflect.EnumNumber(x)
  165. }
  166. // Deprecated: Use RpcType.Descriptor instead.
  167. func (RpcType) EnumDescriptor() ([]byte, []int) {
  168. return file_grpc_testing_control_proto_rawDescGZIP(), []int{2}
  169. }
  170. // Parameters of poisson process distribution, which is a good representation
  171. // of activity coming in from independent identical stationary sources.
  172. type PoissonParams struct {
  173. state protoimpl.MessageState
  174. sizeCache protoimpl.SizeCache
  175. unknownFields protoimpl.UnknownFields
  176. // The rate of arrivals (a.k.a. lambda parameter of the exp distribution).
  177. OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"`
  178. }
  179. func (x *PoissonParams) Reset() {
  180. *x = PoissonParams{}
  181. if protoimpl.UnsafeEnabled {
  182. mi := &file_grpc_testing_control_proto_msgTypes[0]
  183. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  184. ms.StoreMessageInfo(mi)
  185. }
  186. }
  187. func (x *PoissonParams) String() string {
  188. return protoimpl.X.MessageStringOf(x)
  189. }
  190. func (*PoissonParams) ProtoMessage() {}
  191. func (x *PoissonParams) ProtoReflect() protoreflect.Message {
  192. mi := &file_grpc_testing_control_proto_msgTypes[0]
  193. if protoimpl.UnsafeEnabled && x != nil {
  194. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  195. if ms.LoadMessageInfo() == nil {
  196. ms.StoreMessageInfo(mi)
  197. }
  198. return ms
  199. }
  200. return mi.MessageOf(x)
  201. }
  202. // Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.
  203. func (*PoissonParams) Descriptor() ([]byte, []int) {
  204. return file_grpc_testing_control_proto_rawDescGZIP(), []int{0}
  205. }
  206. func (x *PoissonParams) GetOfferedLoad() float64 {
  207. if x != nil {
  208. return x.OfferedLoad
  209. }
  210. return 0
  211. }
  212. // Once an RPC finishes, immediately start a new one.
  213. // No configuration parameters needed.
  214. type ClosedLoopParams struct {
  215. state protoimpl.MessageState
  216. sizeCache protoimpl.SizeCache
  217. unknownFields protoimpl.UnknownFields
  218. }
  219. func (x *ClosedLoopParams) Reset() {
  220. *x = ClosedLoopParams{}
  221. if protoimpl.UnsafeEnabled {
  222. mi := &file_grpc_testing_control_proto_msgTypes[1]
  223. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  224. ms.StoreMessageInfo(mi)
  225. }
  226. }
  227. func (x *ClosedLoopParams) String() string {
  228. return protoimpl.X.MessageStringOf(x)
  229. }
  230. func (*ClosedLoopParams) ProtoMessage() {}
  231. func (x *ClosedLoopParams) ProtoReflect() protoreflect.Message {
  232. mi := &file_grpc_testing_control_proto_msgTypes[1]
  233. if protoimpl.UnsafeEnabled && x != nil {
  234. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  235. if ms.LoadMessageInfo() == nil {
  236. ms.StoreMessageInfo(mi)
  237. }
  238. return ms
  239. }
  240. return mi.MessageOf(x)
  241. }
  242. // Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.
  243. func (*ClosedLoopParams) Descriptor() ([]byte, []int) {
  244. return file_grpc_testing_control_proto_rawDescGZIP(), []int{1}
  245. }
  246. type LoadParams struct {
  247. state protoimpl.MessageState
  248. sizeCache protoimpl.SizeCache
  249. unknownFields protoimpl.UnknownFields
  250. // Types that are assignable to Load:
  251. //
  252. // *LoadParams_ClosedLoop
  253. // *LoadParams_Poisson
  254. Load isLoadParams_Load `protobuf_oneof:"load"`
  255. }
  256. func (x *LoadParams) Reset() {
  257. *x = LoadParams{}
  258. if protoimpl.UnsafeEnabled {
  259. mi := &file_grpc_testing_control_proto_msgTypes[2]
  260. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  261. ms.StoreMessageInfo(mi)
  262. }
  263. }
  264. func (x *LoadParams) String() string {
  265. return protoimpl.X.MessageStringOf(x)
  266. }
  267. func (*LoadParams) ProtoMessage() {}
  268. func (x *LoadParams) ProtoReflect() protoreflect.Message {
  269. mi := &file_grpc_testing_control_proto_msgTypes[2]
  270. if protoimpl.UnsafeEnabled && x != nil {
  271. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  272. if ms.LoadMessageInfo() == nil {
  273. ms.StoreMessageInfo(mi)
  274. }
  275. return ms
  276. }
  277. return mi.MessageOf(x)
  278. }
  279. // Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.
  280. func (*LoadParams) Descriptor() ([]byte, []int) {
  281. return file_grpc_testing_control_proto_rawDescGZIP(), []int{2}
  282. }
  283. func (m *LoadParams) GetLoad() isLoadParams_Load {
  284. if m != nil {
  285. return m.Load
  286. }
  287. return nil
  288. }
  289. func (x *LoadParams) GetClosedLoop() *ClosedLoopParams {
  290. if x, ok := x.GetLoad().(*LoadParams_ClosedLoop); ok {
  291. return x.ClosedLoop
  292. }
  293. return nil
  294. }
  295. func (x *LoadParams) GetPoisson() *PoissonParams {
  296. if x, ok := x.GetLoad().(*LoadParams_Poisson); ok {
  297. return x.Poisson
  298. }
  299. return nil
  300. }
  301. type isLoadParams_Load interface {
  302. isLoadParams_Load()
  303. }
  304. type LoadParams_ClosedLoop struct {
  305. ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,proto3,oneof"`
  306. }
  307. type LoadParams_Poisson struct {
  308. Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,proto3,oneof"`
  309. }
  310. func (*LoadParams_ClosedLoop) isLoadParams_Load() {}
  311. func (*LoadParams_Poisson) isLoadParams_Load() {}
  312. // presence of SecurityParams implies use of TLS
  313. type SecurityParams struct {
  314. state protoimpl.MessageState
  315. sizeCache protoimpl.SizeCache
  316. unknownFields protoimpl.UnknownFields
  317. UseTestCa bool `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"`
  318. ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"`
  319. CredType string `protobuf:"bytes,3,opt,name=cred_type,json=credType,proto3" json:"cred_type,omitempty"`
  320. }
  321. func (x *SecurityParams) Reset() {
  322. *x = SecurityParams{}
  323. if protoimpl.UnsafeEnabled {
  324. mi := &file_grpc_testing_control_proto_msgTypes[3]
  325. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  326. ms.StoreMessageInfo(mi)
  327. }
  328. }
  329. func (x *SecurityParams) String() string {
  330. return protoimpl.X.MessageStringOf(x)
  331. }
  332. func (*SecurityParams) ProtoMessage() {}
  333. func (x *SecurityParams) ProtoReflect() protoreflect.Message {
  334. mi := &file_grpc_testing_control_proto_msgTypes[3]
  335. if protoimpl.UnsafeEnabled && x != nil {
  336. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  337. if ms.LoadMessageInfo() == nil {
  338. ms.StoreMessageInfo(mi)
  339. }
  340. return ms
  341. }
  342. return mi.MessageOf(x)
  343. }
  344. // Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.
  345. func (*SecurityParams) Descriptor() ([]byte, []int) {
  346. return file_grpc_testing_control_proto_rawDescGZIP(), []int{3}
  347. }
  348. func (x *SecurityParams) GetUseTestCa() bool {
  349. if x != nil {
  350. return x.UseTestCa
  351. }
  352. return false
  353. }
  354. func (x *SecurityParams) GetServerHostOverride() string {
  355. if x != nil {
  356. return x.ServerHostOverride
  357. }
  358. return ""
  359. }
  360. func (x *SecurityParams) GetCredType() string {
  361. if x != nil {
  362. return x.CredType
  363. }
  364. return ""
  365. }
  366. type ChannelArg struct {
  367. state protoimpl.MessageState
  368. sizeCache protoimpl.SizeCache
  369. unknownFields protoimpl.UnknownFields
  370. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  371. // Types that are assignable to Value:
  372. //
  373. // *ChannelArg_StrValue
  374. // *ChannelArg_IntValue
  375. Value isChannelArg_Value `protobuf_oneof:"value"`
  376. }
  377. func (x *ChannelArg) Reset() {
  378. *x = ChannelArg{}
  379. if protoimpl.UnsafeEnabled {
  380. mi := &file_grpc_testing_control_proto_msgTypes[4]
  381. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  382. ms.StoreMessageInfo(mi)
  383. }
  384. }
  385. func (x *ChannelArg) String() string {
  386. return protoimpl.X.MessageStringOf(x)
  387. }
  388. func (*ChannelArg) ProtoMessage() {}
  389. func (x *ChannelArg) ProtoReflect() protoreflect.Message {
  390. mi := &file_grpc_testing_control_proto_msgTypes[4]
  391. if protoimpl.UnsafeEnabled && x != nil {
  392. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  393. if ms.LoadMessageInfo() == nil {
  394. ms.StoreMessageInfo(mi)
  395. }
  396. return ms
  397. }
  398. return mi.MessageOf(x)
  399. }
  400. // Deprecated: Use ChannelArg.ProtoReflect.Descriptor instead.
  401. func (*ChannelArg) Descriptor() ([]byte, []int) {
  402. return file_grpc_testing_control_proto_rawDescGZIP(), []int{4}
  403. }
  404. func (x *ChannelArg) GetName() string {
  405. if x != nil {
  406. return x.Name
  407. }
  408. return ""
  409. }
  410. func (m *ChannelArg) GetValue() isChannelArg_Value {
  411. if m != nil {
  412. return m.Value
  413. }
  414. return nil
  415. }
  416. func (x *ChannelArg) GetStrValue() string {
  417. if x, ok := x.GetValue().(*ChannelArg_StrValue); ok {
  418. return x.StrValue
  419. }
  420. return ""
  421. }
  422. func (x *ChannelArg) GetIntValue() int32 {
  423. if x, ok := x.GetValue().(*ChannelArg_IntValue); ok {
  424. return x.IntValue
  425. }
  426. return 0
  427. }
  428. type isChannelArg_Value interface {
  429. isChannelArg_Value()
  430. }
  431. type ChannelArg_StrValue struct {
  432. StrValue string `protobuf:"bytes,2,opt,name=str_value,json=strValue,proto3,oneof"`
  433. }
  434. type ChannelArg_IntValue struct {
  435. IntValue int32 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
  436. }
  437. func (*ChannelArg_StrValue) isChannelArg_Value() {}
  438. func (*ChannelArg_IntValue) isChannelArg_Value() {}
  439. type ClientConfig struct {
  440. state protoimpl.MessageState
  441. sizeCache protoimpl.SizeCache
  442. unknownFields protoimpl.UnknownFields
  443. // List of targets to connect to. At least one target needs to be specified.
  444. ServerTargets []string `protobuf:"bytes,1,rep,name=server_targets,json=serverTargets,proto3" json:"server_targets,omitempty"`
  445. ClientType ClientType `protobuf:"varint,2,opt,name=client_type,json=clientType,proto3,enum=grpc.testing.ClientType" json:"client_type,omitempty"`
  446. SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
  447. // How many concurrent RPCs to start for each channel.
  448. // For synchronous client, use a separate thread for each outstanding RPC.
  449. OutstandingRpcsPerChannel int32 `protobuf:"varint,4,opt,name=outstanding_rpcs_per_channel,json=outstandingRpcsPerChannel,proto3" json:"outstanding_rpcs_per_channel,omitempty"`
  450. // Number of independent client channels to create.
  451. // i-th channel will connect to server_target[i % server_targets.size()]
  452. ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"`
  453. // Only for async client. Number of threads to use to start/manage RPCs.
  454. AsyncClientThreads int32 `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads,proto3" json:"async_client_threads,omitempty"`
  455. RpcType RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,proto3,enum=grpc.testing.RpcType" json:"rpc_type,omitempty"`
  456. // The requested load for the entire client (aggregated over all the threads).
  457. LoadParams *LoadParams `protobuf:"bytes,10,opt,name=load_params,json=loadParams,proto3" json:"load_params,omitempty"`
  458. PayloadConfig *PayloadConfig `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
  459. HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams,proto3" json:"histogram_params,omitempty"`
  460. // Specify the cores we should run the client on, if desired
  461. CoreList []int32 `protobuf:"varint,13,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
  462. CoreLimit int32 `protobuf:"varint,14,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
  463. // If we use an OTHER_CLIENT client_type, this string gives more detail
  464. OtherClientApi string `protobuf:"bytes,15,opt,name=other_client_api,json=otherClientApi,proto3" json:"other_client_api,omitempty"`
  465. ChannelArgs []*ChannelArg `protobuf:"bytes,16,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,omitempty"`
  466. // Number of threads that share each completion queue
  467. ThreadsPerCq int32 `protobuf:"varint,17,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
  468. // Number of messages on a stream before it gets finished/restarted
  469. MessagesPerStream int32 `protobuf:"varint,18,opt,name=messages_per_stream,json=messagesPerStream,proto3" json:"messages_per_stream,omitempty"`
  470. // Use coalescing API when possible.
  471. UseCoalesceApi bool `protobuf:"varint,19,opt,name=use_coalesce_api,json=useCoalesceApi,proto3" json:"use_coalesce_api,omitempty"`
  472. // If 0, disabled. Else, specifies the period between gathering latency
  473. // medians in milliseconds.
  474. MedianLatencyCollectionIntervalMillis int32 `protobuf:"varint,20,opt,name=median_latency_collection_interval_millis,json=medianLatencyCollectionIntervalMillis,proto3" json:"median_latency_collection_interval_millis,omitempty"`
  475. // Number of client processes. 0 indicates no restriction.
  476. ClientProcesses int32 `protobuf:"varint,21,opt,name=client_processes,json=clientProcesses,proto3" json:"client_processes,omitempty"`
  477. }
  478. func (x *ClientConfig) Reset() {
  479. *x = ClientConfig{}
  480. if protoimpl.UnsafeEnabled {
  481. mi := &file_grpc_testing_control_proto_msgTypes[5]
  482. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  483. ms.StoreMessageInfo(mi)
  484. }
  485. }
  486. func (x *ClientConfig) String() string {
  487. return protoimpl.X.MessageStringOf(x)
  488. }
  489. func (*ClientConfig) ProtoMessage() {}
  490. func (x *ClientConfig) ProtoReflect() protoreflect.Message {
  491. mi := &file_grpc_testing_control_proto_msgTypes[5]
  492. if protoimpl.UnsafeEnabled && x != nil {
  493. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  494. if ms.LoadMessageInfo() == nil {
  495. ms.StoreMessageInfo(mi)
  496. }
  497. return ms
  498. }
  499. return mi.MessageOf(x)
  500. }
  501. // Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
  502. func (*ClientConfig) Descriptor() ([]byte, []int) {
  503. return file_grpc_testing_control_proto_rawDescGZIP(), []int{5}
  504. }
  505. func (x *ClientConfig) GetServerTargets() []string {
  506. if x != nil {
  507. return x.ServerTargets
  508. }
  509. return nil
  510. }
  511. func (x *ClientConfig) GetClientType() ClientType {
  512. if x != nil {
  513. return x.ClientType
  514. }
  515. return ClientType_SYNC_CLIENT
  516. }
  517. func (x *ClientConfig) GetSecurityParams() *SecurityParams {
  518. if x != nil {
  519. return x.SecurityParams
  520. }
  521. return nil
  522. }
  523. func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32 {
  524. if x != nil {
  525. return x.OutstandingRpcsPerChannel
  526. }
  527. return 0
  528. }
  529. func (x *ClientConfig) GetClientChannels() int32 {
  530. if x != nil {
  531. return x.ClientChannels
  532. }
  533. return 0
  534. }
  535. func (x *ClientConfig) GetAsyncClientThreads() int32 {
  536. if x != nil {
  537. return x.AsyncClientThreads
  538. }
  539. return 0
  540. }
  541. func (x *ClientConfig) GetRpcType() RpcType {
  542. if x != nil {
  543. return x.RpcType
  544. }
  545. return RpcType_UNARY
  546. }
  547. func (x *ClientConfig) GetLoadParams() *LoadParams {
  548. if x != nil {
  549. return x.LoadParams
  550. }
  551. return nil
  552. }
  553. func (x *ClientConfig) GetPayloadConfig() *PayloadConfig {
  554. if x != nil {
  555. return x.PayloadConfig
  556. }
  557. return nil
  558. }
  559. func (x *ClientConfig) GetHistogramParams() *HistogramParams {
  560. if x != nil {
  561. return x.HistogramParams
  562. }
  563. return nil
  564. }
  565. func (x *ClientConfig) GetCoreList() []int32 {
  566. if x != nil {
  567. return x.CoreList
  568. }
  569. return nil
  570. }
  571. func (x *ClientConfig) GetCoreLimit() int32 {
  572. if x != nil {
  573. return x.CoreLimit
  574. }
  575. return 0
  576. }
  577. func (x *ClientConfig) GetOtherClientApi() string {
  578. if x != nil {
  579. return x.OtherClientApi
  580. }
  581. return ""
  582. }
  583. func (x *ClientConfig) GetChannelArgs() []*ChannelArg {
  584. if x != nil {
  585. return x.ChannelArgs
  586. }
  587. return nil
  588. }
  589. func (x *ClientConfig) GetThreadsPerCq() int32 {
  590. if x != nil {
  591. return x.ThreadsPerCq
  592. }
  593. return 0
  594. }
  595. func (x *ClientConfig) GetMessagesPerStream() int32 {
  596. if x != nil {
  597. return x.MessagesPerStream
  598. }
  599. return 0
  600. }
  601. func (x *ClientConfig) GetUseCoalesceApi() bool {
  602. if x != nil {
  603. return x.UseCoalesceApi
  604. }
  605. return false
  606. }
  607. func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32 {
  608. if x != nil {
  609. return x.MedianLatencyCollectionIntervalMillis
  610. }
  611. return 0
  612. }
  613. func (x *ClientConfig) GetClientProcesses() int32 {
  614. if x != nil {
  615. return x.ClientProcesses
  616. }
  617. return 0
  618. }
  619. type ClientStatus struct {
  620. state protoimpl.MessageState
  621. sizeCache protoimpl.SizeCache
  622. unknownFields protoimpl.UnknownFields
  623. Stats *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
  624. }
  625. func (x *ClientStatus) Reset() {
  626. *x = ClientStatus{}
  627. if protoimpl.UnsafeEnabled {
  628. mi := &file_grpc_testing_control_proto_msgTypes[6]
  629. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  630. ms.StoreMessageInfo(mi)
  631. }
  632. }
  633. func (x *ClientStatus) String() string {
  634. return protoimpl.X.MessageStringOf(x)
  635. }
  636. func (*ClientStatus) ProtoMessage() {}
  637. func (x *ClientStatus) ProtoReflect() protoreflect.Message {
  638. mi := &file_grpc_testing_control_proto_msgTypes[6]
  639. if protoimpl.UnsafeEnabled && x != nil {
  640. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  641. if ms.LoadMessageInfo() == nil {
  642. ms.StoreMessageInfo(mi)
  643. }
  644. return ms
  645. }
  646. return mi.MessageOf(x)
  647. }
  648. // Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.
  649. func (*ClientStatus) Descriptor() ([]byte, []int) {
  650. return file_grpc_testing_control_proto_rawDescGZIP(), []int{6}
  651. }
  652. func (x *ClientStatus) GetStats() *ClientStats {
  653. if x != nil {
  654. return x.Stats
  655. }
  656. return nil
  657. }
  658. // Request current stats
  659. type Mark struct {
  660. state protoimpl.MessageState
  661. sizeCache protoimpl.SizeCache
  662. unknownFields protoimpl.UnknownFields
  663. // if true, the stats will be reset after taking their snapshot.
  664. Reset_ bool `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"`
  665. }
  666. func (x *Mark) Reset() {
  667. *x = Mark{}
  668. if protoimpl.UnsafeEnabled {
  669. mi := &file_grpc_testing_control_proto_msgTypes[7]
  670. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  671. ms.StoreMessageInfo(mi)
  672. }
  673. }
  674. func (x *Mark) String() string {
  675. return protoimpl.X.MessageStringOf(x)
  676. }
  677. func (*Mark) ProtoMessage() {}
  678. func (x *Mark) ProtoReflect() protoreflect.Message {
  679. mi := &file_grpc_testing_control_proto_msgTypes[7]
  680. if protoimpl.UnsafeEnabled && x != nil {
  681. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  682. if ms.LoadMessageInfo() == nil {
  683. ms.StoreMessageInfo(mi)
  684. }
  685. return ms
  686. }
  687. return mi.MessageOf(x)
  688. }
  689. // Deprecated: Use Mark.ProtoReflect.Descriptor instead.
  690. func (*Mark) Descriptor() ([]byte, []int) {
  691. return file_grpc_testing_control_proto_rawDescGZIP(), []int{7}
  692. }
  693. func (x *Mark) GetReset_() bool {
  694. if x != nil {
  695. return x.Reset_
  696. }
  697. return false
  698. }
  699. type ClientArgs struct {
  700. state protoimpl.MessageState
  701. sizeCache protoimpl.SizeCache
  702. unknownFields protoimpl.UnknownFields
  703. // Types that are assignable to Argtype:
  704. //
  705. // *ClientArgs_Setup
  706. // *ClientArgs_Mark
  707. Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"`
  708. }
  709. func (x *ClientArgs) Reset() {
  710. *x = ClientArgs{}
  711. if protoimpl.UnsafeEnabled {
  712. mi := &file_grpc_testing_control_proto_msgTypes[8]
  713. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  714. ms.StoreMessageInfo(mi)
  715. }
  716. }
  717. func (x *ClientArgs) String() string {
  718. return protoimpl.X.MessageStringOf(x)
  719. }
  720. func (*ClientArgs) ProtoMessage() {}
  721. func (x *ClientArgs) ProtoReflect() protoreflect.Message {
  722. mi := &file_grpc_testing_control_proto_msgTypes[8]
  723. if protoimpl.UnsafeEnabled && x != nil {
  724. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  725. if ms.LoadMessageInfo() == nil {
  726. ms.StoreMessageInfo(mi)
  727. }
  728. return ms
  729. }
  730. return mi.MessageOf(x)
  731. }
  732. // Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.
  733. func (*ClientArgs) Descriptor() ([]byte, []int) {
  734. return file_grpc_testing_control_proto_rawDescGZIP(), []int{8}
  735. }
  736. func (m *ClientArgs) GetArgtype() isClientArgs_Argtype {
  737. if m != nil {
  738. return m.Argtype
  739. }
  740. return nil
  741. }
  742. func (x *ClientArgs) GetSetup() *ClientConfig {
  743. if x, ok := x.GetArgtype().(*ClientArgs_Setup); ok {
  744. return x.Setup
  745. }
  746. return nil
  747. }
  748. func (x *ClientArgs) GetMark() *Mark {
  749. if x, ok := x.GetArgtype().(*ClientArgs_Mark); ok {
  750. return x.Mark
  751. }
  752. return nil
  753. }
  754. type isClientArgs_Argtype interface {
  755. isClientArgs_Argtype()
  756. }
  757. type ClientArgs_Setup struct {
  758. Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
  759. }
  760. type ClientArgs_Mark struct {
  761. Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
  762. }
  763. func (*ClientArgs_Setup) isClientArgs_Argtype() {}
  764. func (*ClientArgs_Mark) isClientArgs_Argtype() {}
  765. type ServerConfig struct {
  766. state protoimpl.MessageState
  767. sizeCache protoimpl.SizeCache
  768. unknownFields protoimpl.UnknownFields
  769. ServerType ServerType `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
  770. SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
  771. // Port on which to listen. Zero means pick unused port.
  772. Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
  773. // Only for async server. Number of threads used to serve the requests.
  774. AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"`
  775. // Specify the number of cores to limit server to, if desired
  776. CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
  777. // payload config, used in generic server.
  778. // Note this must NOT be used in proto (non-generic) servers. For proto servers,
  779. // 'response sizes' must be configured from the 'response_size' field of the
  780. // 'SimpleRequest' objects in RPC requests.
  781. PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
  782. // Specify the cores we should run the server on, if desired
  783. CoreList []int32 `protobuf:"varint,10,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
  784. // If we use an OTHER_SERVER client_type, this string gives more detail
  785. OtherServerApi string `protobuf:"bytes,11,opt,name=other_server_api,json=otherServerApi,proto3" json:"other_server_api,omitempty"`
  786. // Number of threads that share each completion queue
  787. ThreadsPerCq int32 `protobuf:"varint,12,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
  788. // Buffer pool size (no buffer pool specified if unset)
  789. ResourceQuotaSize int32 `protobuf:"varint,1001,opt,name=resource_quota_size,json=resourceQuotaSize,proto3" json:"resource_quota_size,omitempty"`
  790. ChannelArgs []*ChannelArg `protobuf:"bytes,1002,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,omitempty"`
  791. // Number of server processes. 0 indicates no restriction.
  792. ServerProcesses int32 `protobuf:"varint,21,opt,name=server_processes,json=serverProcesses,proto3" json:"server_processes,omitempty"`
  793. }
  794. func (x *ServerConfig) Reset() {
  795. *x = ServerConfig{}
  796. if protoimpl.UnsafeEnabled {
  797. mi := &file_grpc_testing_control_proto_msgTypes[9]
  798. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  799. ms.StoreMessageInfo(mi)
  800. }
  801. }
  802. func (x *ServerConfig) String() string {
  803. return protoimpl.X.MessageStringOf(x)
  804. }
  805. func (*ServerConfig) ProtoMessage() {}
  806. func (x *ServerConfig) ProtoReflect() protoreflect.Message {
  807. mi := &file_grpc_testing_control_proto_msgTypes[9]
  808. if protoimpl.UnsafeEnabled && x != nil {
  809. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  810. if ms.LoadMessageInfo() == nil {
  811. ms.StoreMessageInfo(mi)
  812. }
  813. return ms
  814. }
  815. return mi.MessageOf(x)
  816. }
  817. // Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.
  818. func (*ServerConfig) Descriptor() ([]byte, []int) {
  819. return file_grpc_testing_control_proto_rawDescGZIP(), []int{9}
  820. }
  821. func (x *ServerConfig) GetServerType() ServerType {
  822. if x != nil {
  823. return x.ServerType
  824. }
  825. return ServerType_SYNC_SERVER
  826. }
  827. func (x *ServerConfig) GetSecurityParams() *SecurityParams {
  828. if x != nil {
  829. return x.SecurityParams
  830. }
  831. return nil
  832. }
  833. func (x *ServerConfig) GetPort() int32 {
  834. if x != nil {
  835. return x.Port
  836. }
  837. return 0
  838. }
  839. func (x *ServerConfig) GetAsyncServerThreads() int32 {
  840. if x != nil {
  841. return x.AsyncServerThreads
  842. }
  843. return 0
  844. }
  845. func (x *ServerConfig) GetCoreLimit() int32 {
  846. if x != nil {
  847. return x.CoreLimit
  848. }
  849. return 0
  850. }
  851. func (x *ServerConfig) GetPayloadConfig() *PayloadConfig {
  852. if x != nil {
  853. return x.PayloadConfig
  854. }
  855. return nil
  856. }
  857. func (x *ServerConfig) GetCoreList() []int32 {
  858. if x != nil {
  859. return x.CoreList
  860. }
  861. return nil
  862. }
  863. func (x *ServerConfig) GetOtherServerApi() string {
  864. if x != nil {
  865. return x.OtherServerApi
  866. }
  867. return ""
  868. }
  869. func (x *ServerConfig) GetThreadsPerCq() int32 {
  870. if x != nil {
  871. return x.ThreadsPerCq
  872. }
  873. return 0
  874. }
  875. func (x *ServerConfig) GetResourceQuotaSize() int32 {
  876. if x != nil {
  877. return x.ResourceQuotaSize
  878. }
  879. return 0
  880. }
  881. func (x *ServerConfig) GetChannelArgs() []*ChannelArg {
  882. if x != nil {
  883. return x.ChannelArgs
  884. }
  885. return nil
  886. }
  887. func (x *ServerConfig) GetServerProcesses() int32 {
  888. if x != nil {
  889. return x.ServerProcesses
  890. }
  891. return 0
  892. }
  893. type ServerArgs struct {
  894. state protoimpl.MessageState
  895. sizeCache protoimpl.SizeCache
  896. unknownFields protoimpl.UnknownFields
  897. // Types that are assignable to Argtype:
  898. //
  899. // *ServerArgs_Setup
  900. // *ServerArgs_Mark
  901. Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"`
  902. }
  903. func (x *ServerArgs) Reset() {
  904. *x = ServerArgs{}
  905. if protoimpl.UnsafeEnabled {
  906. mi := &file_grpc_testing_control_proto_msgTypes[10]
  907. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  908. ms.StoreMessageInfo(mi)
  909. }
  910. }
  911. func (x *ServerArgs) String() string {
  912. return protoimpl.X.MessageStringOf(x)
  913. }
  914. func (*ServerArgs) ProtoMessage() {}
  915. func (x *ServerArgs) ProtoReflect() protoreflect.Message {
  916. mi := &file_grpc_testing_control_proto_msgTypes[10]
  917. if protoimpl.UnsafeEnabled && x != nil {
  918. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  919. if ms.LoadMessageInfo() == nil {
  920. ms.StoreMessageInfo(mi)
  921. }
  922. return ms
  923. }
  924. return mi.MessageOf(x)
  925. }
  926. // Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.
  927. func (*ServerArgs) Descriptor() ([]byte, []int) {
  928. return file_grpc_testing_control_proto_rawDescGZIP(), []int{10}
  929. }
  930. func (m *ServerArgs) GetArgtype() isServerArgs_Argtype {
  931. if m != nil {
  932. return m.Argtype
  933. }
  934. return nil
  935. }
  936. func (x *ServerArgs) GetSetup() *ServerConfig {
  937. if x, ok := x.GetArgtype().(*ServerArgs_Setup); ok {
  938. return x.Setup
  939. }
  940. return nil
  941. }
  942. func (x *ServerArgs) GetMark() *Mark {
  943. if x, ok := x.GetArgtype().(*ServerArgs_Mark); ok {
  944. return x.Mark
  945. }
  946. return nil
  947. }
  948. type isServerArgs_Argtype interface {
  949. isServerArgs_Argtype()
  950. }
  951. type ServerArgs_Setup struct {
  952. Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
  953. }
  954. type ServerArgs_Mark struct {
  955. Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
  956. }
  957. func (*ServerArgs_Setup) isServerArgs_Argtype() {}
  958. func (*ServerArgs_Mark) isServerArgs_Argtype() {}
  959. type ServerStatus struct {
  960. state protoimpl.MessageState
  961. sizeCache protoimpl.SizeCache
  962. unknownFields protoimpl.UnknownFields
  963. Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
  964. // the port bound by the server
  965. Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
  966. // Number of cores available to the server
  967. Cores int32 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"`
  968. }
  969. func (x *ServerStatus) Reset() {
  970. *x = ServerStatus{}
  971. if protoimpl.UnsafeEnabled {
  972. mi := &file_grpc_testing_control_proto_msgTypes[11]
  973. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  974. ms.StoreMessageInfo(mi)
  975. }
  976. }
  977. func (x *ServerStatus) String() string {
  978. return protoimpl.X.MessageStringOf(x)
  979. }
  980. func (*ServerStatus) ProtoMessage() {}
  981. func (x *ServerStatus) ProtoReflect() protoreflect.Message {
  982. mi := &file_grpc_testing_control_proto_msgTypes[11]
  983. if protoimpl.UnsafeEnabled && x != nil {
  984. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  985. if ms.LoadMessageInfo() == nil {
  986. ms.StoreMessageInfo(mi)
  987. }
  988. return ms
  989. }
  990. return mi.MessageOf(x)
  991. }
  992. // Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.
  993. func (*ServerStatus) Descriptor() ([]byte, []int) {
  994. return file_grpc_testing_control_proto_rawDescGZIP(), []int{11}
  995. }
  996. func (x *ServerStatus) GetStats() *ServerStats {
  997. if x != nil {
  998. return x.Stats
  999. }
  1000. return nil
  1001. }
  1002. func (x *ServerStatus) GetPort() int32 {
  1003. if x != nil {
  1004. return x.Port
  1005. }
  1006. return 0
  1007. }
  1008. func (x *ServerStatus) GetCores() int32 {
  1009. if x != nil {
  1010. return x.Cores
  1011. }
  1012. return 0
  1013. }
  1014. type CoreRequest struct {
  1015. state protoimpl.MessageState
  1016. sizeCache protoimpl.SizeCache
  1017. unknownFields protoimpl.UnknownFields
  1018. }
  1019. func (x *CoreRequest) Reset() {
  1020. *x = CoreRequest{}
  1021. if protoimpl.UnsafeEnabled {
  1022. mi := &file_grpc_testing_control_proto_msgTypes[12]
  1023. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1024. ms.StoreMessageInfo(mi)
  1025. }
  1026. }
  1027. func (x *CoreRequest) String() string {
  1028. return protoimpl.X.MessageStringOf(x)
  1029. }
  1030. func (*CoreRequest) ProtoMessage() {}
  1031. func (x *CoreRequest) ProtoReflect() protoreflect.Message {
  1032. mi := &file_grpc_testing_control_proto_msgTypes[12]
  1033. if protoimpl.UnsafeEnabled && x != nil {
  1034. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1035. if ms.LoadMessageInfo() == nil {
  1036. ms.StoreMessageInfo(mi)
  1037. }
  1038. return ms
  1039. }
  1040. return mi.MessageOf(x)
  1041. }
  1042. // Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.
  1043. func (*CoreRequest) Descriptor() ([]byte, []int) {
  1044. return file_grpc_testing_control_proto_rawDescGZIP(), []int{12}
  1045. }
  1046. type CoreResponse struct {
  1047. state protoimpl.MessageState
  1048. sizeCache protoimpl.SizeCache
  1049. unknownFields protoimpl.UnknownFields
  1050. // Number of cores available on the server
  1051. Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
  1052. }
  1053. func (x *CoreResponse) Reset() {
  1054. *x = CoreResponse{}
  1055. if protoimpl.UnsafeEnabled {
  1056. mi := &file_grpc_testing_control_proto_msgTypes[13]
  1057. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1058. ms.StoreMessageInfo(mi)
  1059. }
  1060. }
  1061. func (x *CoreResponse) String() string {
  1062. return protoimpl.X.MessageStringOf(x)
  1063. }
  1064. func (*CoreResponse) ProtoMessage() {}
  1065. func (x *CoreResponse) ProtoReflect() protoreflect.Message {
  1066. mi := &file_grpc_testing_control_proto_msgTypes[13]
  1067. if protoimpl.UnsafeEnabled && x != nil {
  1068. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1069. if ms.LoadMessageInfo() == nil {
  1070. ms.StoreMessageInfo(mi)
  1071. }
  1072. return ms
  1073. }
  1074. return mi.MessageOf(x)
  1075. }
  1076. // Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.
  1077. func (*CoreResponse) Descriptor() ([]byte, []int) {
  1078. return file_grpc_testing_control_proto_rawDescGZIP(), []int{13}
  1079. }
  1080. func (x *CoreResponse) GetCores() int32 {
  1081. if x != nil {
  1082. return x.Cores
  1083. }
  1084. return 0
  1085. }
  1086. type Void struct {
  1087. state protoimpl.MessageState
  1088. sizeCache protoimpl.SizeCache
  1089. unknownFields protoimpl.UnknownFields
  1090. }
  1091. func (x *Void) Reset() {
  1092. *x = Void{}
  1093. if protoimpl.UnsafeEnabled {
  1094. mi := &file_grpc_testing_control_proto_msgTypes[14]
  1095. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1096. ms.StoreMessageInfo(mi)
  1097. }
  1098. }
  1099. func (x *Void) String() string {
  1100. return protoimpl.X.MessageStringOf(x)
  1101. }
  1102. func (*Void) ProtoMessage() {}
  1103. func (x *Void) ProtoReflect() protoreflect.Message {
  1104. mi := &file_grpc_testing_control_proto_msgTypes[14]
  1105. if protoimpl.UnsafeEnabled && x != nil {
  1106. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1107. if ms.LoadMessageInfo() == nil {
  1108. ms.StoreMessageInfo(mi)
  1109. }
  1110. return ms
  1111. }
  1112. return mi.MessageOf(x)
  1113. }
  1114. // Deprecated: Use Void.ProtoReflect.Descriptor instead.
  1115. func (*Void) Descriptor() ([]byte, []int) {
  1116. return file_grpc_testing_control_proto_rawDescGZIP(), []int{14}
  1117. }
  1118. // A single performance scenario: input to qps_json_driver
  1119. type Scenario struct {
  1120. state protoimpl.MessageState
  1121. sizeCache protoimpl.SizeCache
  1122. unknownFields protoimpl.UnknownFields
  1123. // Human readable name for this scenario
  1124. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  1125. // Client configuration
  1126. ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`
  1127. // Number of clients to start for the test
  1128. NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
  1129. // Server configuration
  1130. ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`
  1131. // Number of servers to start for the test
  1132. NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"`
  1133. // Warmup period, in seconds
  1134. WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"`
  1135. // Benchmark time, in seconds
  1136. BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"`
  1137. // Number of workers to spawn locally (usually zero)
  1138. SpawnLocalWorkerCount int32 `protobuf:"varint,8,opt,name=spawn_local_worker_count,json=spawnLocalWorkerCount,proto3" json:"spawn_local_worker_count,omitempty"`
  1139. }
  1140. func (x *Scenario) Reset() {
  1141. *x = Scenario{}
  1142. if protoimpl.UnsafeEnabled {
  1143. mi := &file_grpc_testing_control_proto_msgTypes[15]
  1144. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1145. ms.StoreMessageInfo(mi)
  1146. }
  1147. }
  1148. func (x *Scenario) String() string {
  1149. return protoimpl.X.MessageStringOf(x)
  1150. }
  1151. func (*Scenario) ProtoMessage() {}
  1152. func (x *Scenario) ProtoReflect() protoreflect.Message {
  1153. mi := &file_grpc_testing_control_proto_msgTypes[15]
  1154. if protoimpl.UnsafeEnabled && x != nil {
  1155. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1156. if ms.LoadMessageInfo() == nil {
  1157. ms.StoreMessageInfo(mi)
  1158. }
  1159. return ms
  1160. }
  1161. return mi.MessageOf(x)
  1162. }
  1163. // Deprecated: Use Scenario.ProtoReflect.Descriptor instead.
  1164. func (*Scenario) Descriptor() ([]byte, []int) {
  1165. return file_grpc_testing_control_proto_rawDescGZIP(), []int{15}
  1166. }
  1167. func (x *Scenario) GetName() string {
  1168. if x != nil {
  1169. return x.Name
  1170. }
  1171. return ""
  1172. }
  1173. func (x *Scenario) GetClientConfig() *ClientConfig {
  1174. if x != nil {
  1175. return x.ClientConfig
  1176. }
  1177. return nil
  1178. }
  1179. func (x *Scenario) GetNumClients() int32 {
  1180. if x != nil {
  1181. return x.NumClients
  1182. }
  1183. return 0
  1184. }
  1185. func (x *Scenario) GetServerConfig() *ServerConfig {
  1186. if x != nil {
  1187. return x.ServerConfig
  1188. }
  1189. return nil
  1190. }
  1191. func (x *Scenario) GetNumServers() int32 {
  1192. if x != nil {
  1193. return x.NumServers
  1194. }
  1195. return 0
  1196. }
  1197. func (x *Scenario) GetWarmupSeconds() int32 {
  1198. if x != nil {
  1199. return x.WarmupSeconds
  1200. }
  1201. return 0
  1202. }
  1203. func (x *Scenario) GetBenchmarkSeconds() int32 {
  1204. if x != nil {
  1205. return x.BenchmarkSeconds
  1206. }
  1207. return 0
  1208. }
  1209. func (x *Scenario) GetSpawnLocalWorkerCount() int32 {
  1210. if x != nil {
  1211. return x.SpawnLocalWorkerCount
  1212. }
  1213. return 0
  1214. }
  1215. // A set of scenarios to be run with qps_json_driver
  1216. type Scenarios struct {
  1217. state protoimpl.MessageState
  1218. sizeCache protoimpl.SizeCache
  1219. unknownFields protoimpl.UnknownFields
  1220. Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"`
  1221. }
  1222. func (x *Scenarios) Reset() {
  1223. *x = Scenarios{}
  1224. if protoimpl.UnsafeEnabled {
  1225. mi := &file_grpc_testing_control_proto_msgTypes[16]
  1226. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1227. ms.StoreMessageInfo(mi)
  1228. }
  1229. }
  1230. func (x *Scenarios) String() string {
  1231. return protoimpl.X.MessageStringOf(x)
  1232. }
  1233. func (*Scenarios) ProtoMessage() {}
  1234. func (x *Scenarios) ProtoReflect() protoreflect.Message {
  1235. mi := &file_grpc_testing_control_proto_msgTypes[16]
  1236. if protoimpl.UnsafeEnabled && x != nil {
  1237. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1238. if ms.LoadMessageInfo() == nil {
  1239. ms.StoreMessageInfo(mi)
  1240. }
  1241. return ms
  1242. }
  1243. return mi.MessageOf(x)
  1244. }
  1245. // Deprecated: Use Scenarios.ProtoReflect.Descriptor instead.
  1246. func (*Scenarios) Descriptor() ([]byte, []int) {
  1247. return file_grpc_testing_control_proto_rawDescGZIP(), []int{16}
  1248. }
  1249. func (x *Scenarios) GetScenarios() []*Scenario {
  1250. if x != nil {
  1251. return x.Scenarios
  1252. }
  1253. return nil
  1254. }
  1255. // Basic summary that can be computed from ClientStats and ServerStats
  1256. // once the scenario has finished.
  1257. type ScenarioResultSummary struct {
  1258. state protoimpl.MessageState
  1259. sizeCache protoimpl.SizeCache
  1260. unknownFields protoimpl.UnknownFields
  1261. // Total number of operations per second over all clients. What is counted as 1 'operation' depends on the benchmark scenarios:
  1262. // For unary benchmarks, an operation is processing of a single unary RPC.
  1263. // For streaming benchmarks, an operation is processing of a single ping pong of request and response.
  1264. Qps float64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"`
  1265. // QPS per server core.
  1266. QpsPerServerCore float64 `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"`
  1267. // The total server cpu load based on system time across all server processes, expressed as percentage of a single cpu core.
  1268. // For example, 85 implies 85% of a cpu core, 125 implies 125% of a cpu core. Since we are accumulating the cpu load across all the server
  1269. // processes, the value could > 100 when there are multiple servers or a single server using multiple threads and cores.
  1270. // Same explanation for the total client cpu load below.
  1271. ServerSystemTime float64 `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"`
  1272. // The total server cpu load based on user time across all server processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
  1273. ServerUserTime float64 `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"`
  1274. // The total client cpu load based on system time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
  1275. ClientSystemTime float64 `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"`
  1276. // The total client cpu load based on user time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
  1277. ClientUserTime float64 `protobuf:"fixed64,6,opt,name=client_user_time,json=clientUserTime,proto3" json:"client_user_time,omitempty"`
  1278. // X% latency percentiles (in nanoseconds)
  1279. Latency_50 float64 `protobuf:"fixed64,7,opt,name=latency_50,json=latency50,proto3" json:"latency_50,omitempty"`
  1280. Latency_90 float64 `protobuf:"fixed64,8,opt,name=latency_90,json=latency90,proto3" json:"latency_90,omitempty"`
  1281. Latency_95 float64 `protobuf:"fixed64,9,opt,name=latency_95,json=latency95,proto3" json:"latency_95,omitempty"`
  1282. Latency_99 float64 `protobuf:"fixed64,10,opt,name=latency_99,json=latency99,proto3" json:"latency_99,omitempty"`
  1283. Latency_999 float64 `protobuf:"fixed64,11,opt,name=latency_999,json=latency999,proto3" json:"latency_999,omitempty"`
  1284. // server cpu usage percentage
  1285. ServerCpuUsage float64 `protobuf:"fixed64,12,opt,name=server_cpu_usage,json=serverCpuUsage,proto3" json:"server_cpu_usage,omitempty"`
  1286. // Number of requests that succeeded/failed
  1287. SuccessfulRequestsPerSecond float64 `protobuf:"fixed64,13,opt,name=successful_requests_per_second,json=successfulRequestsPerSecond,proto3" json:"successful_requests_per_second,omitempty"`
  1288. FailedRequestsPerSecond float64 `protobuf:"fixed64,14,opt,name=failed_requests_per_second,json=failedRequestsPerSecond,proto3" json:"failed_requests_per_second,omitempty"`
  1289. // Number of polls called inside completion queue per request
  1290. ClientPollsPerRequest float64 `protobuf:"fixed64,15,opt,name=client_polls_per_request,json=clientPollsPerRequest,proto3" json:"client_polls_per_request,omitempty"`
  1291. ServerPollsPerRequest float64 `protobuf:"fixed64,16,opt,name=server_polls_per_request,json=serverPollsPerRequest,proto3" json:"server_polls_per_request,omitempty"`
  1292. // Queries per CPU-sec over all servers or clients
  1293. ServerQueriesPerCpuSec float64 `protobuf:"fixed64,17,opt,name=server_queries_per_cpu_sec,json=serverQueriesPerCpuSec,proto3" json:"server_queries_per_cpu_sec,omitempty"`
  1294. ClientQueriesPerCpuSec float64 `protobuf:"fixed64,18,opt,name=client_queries_per_cpu_sec,json=clientQueriesPerCpuSec,proto3" json:"client_queries_per_cpu_sec,omitempty"`
  1295. // Start and end time for the test scenario
  1296. StartTime *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
  1297. EndTime *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
  1298. }
  1299. func (x *ScenarioResultSummary) Reset() {
  1300. *x = ScenarioResultSummary{}
  1301. if protoimpl.UnsafeEnabled {
  1302. mi := &file_grpc_testing_control_proto_msgTypes[17]
  1303. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1304. ms.StoreMessageInfo(mi)
  1305. }
  1306. }
  1307. func (x *ScenarioResultSummary) String() string {
  1308. return protoimpl.X.MessageStringOf(x)
  1309. }
  1310. func (*ScenarioResultSummary) ProtoMessage() {}
  1311. func (x *ScenarioResultSummary) ProtoReflect() protoreflect.Message {
  1312. mi := &file_grpc_testing_control_proto_msgTypes[17]
  1313. if protoimpl.UnsafeEnabled && x != nil {
  1314. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1315. if ms.LoadMessageInfo() == nil {
  1316. ms.StoreMessageInfo(mi)
  1317. }
  1318. return ms
  1319. }
  1320. return mi.MessageOf(x)
  1321. }
  1322. // Deprecated: Use ScenarioResultSummary.ProtoReflect.Descriptor instead.
  1323. func (*ScenarioResultSummary) Descriptor() ([]byte, []int) {
  1324. return file_grpc_testing_control_proto_rawDescGZIP(), []int{17}
  1325. }
  1326. func (x *ScenarioResultSummary) GetQps() float64 {
  1327. if x != nil {
  1328. return x.Qps
  1329. }
  1330. return 0
  1331. }
  1332. func (x *ScenarioResultSummary) GetQpsPerServerCore() float64 {
  1333. if x != nil {
  1334. return x.QpsPerServerCore
  1335. }
  1336. return 0
  1337. }
  1338. func (x *ScenarioResultSummary) GetServerSystemTime() float64 {
  1339. if x != nil {
  1340. return x.ServerSystemTime
  1341. }
  1342. return 0
  1343. }
  1344. func (x *ScenarioResultSummary) GetServerUserTime() float64 {
  1345. if x != nil {
  1346. return x.ServerUserTime
  1347. }
  1348. return 0
  1349. }
  1350. func (x *ScenarioResultSummary) GetClientSystemTime() float64 {
  1351. if x != nil {
  1352. return x.ClientSystemTime
  1353. }
  1354. return 0
  1355. }
  1356. func (x *ScenarioResultSummary) GetClientUserTime() float64 {
  1357. if x != nil {
  1358. return x.ClientUserTime
  1359. }
  1360. return 0
  1361. }
  1362. func (x *ScenarioResultSummary) GetLatency_50() float64 {
  1363. if x != nil {
  1364. return x.Latency_50
  1365. }
  1366. return 0
  1367. }
  1368. func (x *ScenarioResultSummary) GetLatency_90() float64 {
  1369. if x != nil {
  1370. return x.Latency_90
  1371. }
  1372. return 0
  1373. }
  1374. func (x *ScenarioResultSummary) GetLatency_95() float64 {
  1375. if x != nil {
  1376. return x.Latency_95
  1377. }
  1378. return 0
  1379. }
  1380. func (x *ScenarioResultSummary) GetLatency_99() float64 {
  1381. if x != nil {
  1382. return x.Latency_99
  1383. }
  1384. return 0
  1385. }
  1386. func (x *ScenarioResultSummary) GetLatency_999() float64 {
  1387. if x != nil {
  1388. return x.Latency_999
  1389. }
  1390. return 0
  1391. }
  1392. func (x *ScenarioResultSummary) GetServerCpuUsage() float64 {
  1393. if x != nil {
  1394. return x.ServerCpuUsage
  1395. }
  1396. return 0
  1397. }
  1398. func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64 {
  1399. if x != nil {
  1400. return x.SuccessfulRequestsPerSecond
  1401. }
  1402. return 0
  1403. }
  1404. func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64 {
  1405. if x != nil {
  1406. return x.FailedRequestsPerSecond
  1407. }
  1408. return 0
  1409. }
  1410. func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64 {
  1411. if x != nil {
  1412. return x.ClientPollsPerRequest
  1413. }
  1414. return 0
  1415. }
  1416. func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64 {
  1417. if x != nil {
  1418. return x.ServerPollsPerRequest
  1419. }
  1420. return 0
  1421. }
  1422. func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64 {
  1423. if x != nil {
  1424. return x.ServerQueriesPerCpuSec
  1425. }
  1426. return 0
  1427. }
  1428. func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64 {
  1429. if x != nil {
  1430. return x.ClientQueriesPerCpuSec
  1431. }
  1432. return 0
  1433. }
  1434. func (x *ScenarioResultSummary) GetStartTime() *timestamppb.Timestamp {
  1435. if x != nil {
  1436. return x.StartTime
  1437. }
  1438. return nil
  1439. }
  1440. func (x *ScenarioResultSummary) GetEndTime() *timestamppb.Timestamp {
  1441. if x != nil {
  1442. return x.EndTime
  1443. }
  1444. return nil
  1445. }
  1446. // Results of a single benchmark scenario.
  1447. type ScenarioResult struct {
  1448. state protoimpl.MessageState
  1449. sizeCache protoimpl.SizeCache
  1450. unknownFields protoimpl.UnknownFields
  1451. // Inputs used to run the scenario.
  1452. Scenario *Scenario `protobuf:"bytes,1,opt,name=scenario,proto3" json:"scenario,omitempty"`
  1453. // Histograms from all clients merged into one histogram.
  1454. Latencies *HistogramData `protobuf:"bytes,2,opt,name=latencies,proto3" json:"latencies,omitempty"`
  1455. // Client stats for each client
  1456. ClientStats []*ClientStats `protobuf:"bytes,3,rep,name=client_stats,json=clientStats,proto3" json:"client_stats,omitempty"`
  1457. // Server stats for each server
  1458. ServerStats []*ServerStats `protobuf:"bytes,4,rep,name=server_stats,json=serverStats,proto3" json:"server_stats,omitempty"`
  1459. // Number of cores available to each server
  1460. ServerCores []int32 `protobuf:"varint,5,rep,packed,name=server_cores,json=serverCores,proto3" json:"server_cores,omitempty"`
  1461. // An after-the-fact computed summary
  1462. Summary *ScenarioResultSummary `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"`
  1463. // Information on success or failure of each worker
  1464. ClientSuccess []bool `protobuf:"varint,7,rep,packed,name=client_success,json=clientSuccess,proto3" json:"client_success,omitempty"`
  1465. ServerSuccess []bool `protobuf:"varint,8,rep,packed,name=server_success,json=serverSuccess,proto3" json:"server_success,omitempty"`
  1466. // Number of failed requests (one row per status code seen)
  1467. RequestResults []*RequestResultCount `protobuf:"bytes,9,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"`
  1468. }
  1469. func (x *ScenarioResult) Reset() {
  1470. *x = ScenarioResult{}
  1471. if protoimpl.UnsafeEnabled {
  1472. mi := &file_grpc_testing_control_proto_msgTypes[18]
  1473. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1474. ms.StoreMessageInfo(mi)
  1475. }
  1476. }
  1477. func (x *ScenarioResult) String() string {
  1478. return protoimpl.X.MessageStringOf(x)
  1479. }
  1480. func (*ScenarioResult) ProtoMessage() {}
  1481. func (x *ScenarioResult) ProtoReflect() protoreflect.Message {
  1482. mi := &file_grpc_testing_control_proto_msgTypes[18]
  1483. if protoimpl.UnsafeEnabled && x != nil {
  1484. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1485. if ms.LoadMessageInfo() == nil {
  1486. ms.StoreMessageInfo(mi)
  1487. }
  1488. return ms
  1489. }
  1490. return mi.MessageOf(x)
  1491. }
  1492. // Deprecated: Use ScenarioResult.ProtoReflect.Descriptor instead.
  1493. func (*ScenarioResult) Descriptor() ([]byte, []int) {
  1494. return file_grpc_testing_control_proto_rawDescGZIP(), []int{18}
  1495. }
  1496. func (x *ScenarioResult) GetScenario() *Scenario {
  1497. if x != nil {
  1498. return x.Scenario
  1499. }
  1500. return nil
  1501. }
  1502. func (x *ScenarioResult) GetLatencies() *HistogramData {
  1503. if x != nil {
  1504. return x.Latencies
  1505. }
  1506. return nil
  1507. }
  1508. func (x *ScenarioResult) GetClientStats() []*ClientStats {
  1509. if x != nil {
  1510. return x.ClientStats
  1511. }
  1512. return nil
  1513. }
  1514. func (x *ScenarioResult) GetServerStats() []*ServerStats {
  1515. if x != nil {
  1516. return x.ServerStats
  1517. }
  1518. return nil
  1519. }
  1520. func (x *ScenarioResult) GetServerCores() []int32 {
  1521. if x != nil {
  1522. return x.ServerCores
  1523. }
  1524. return nil
  1525. }
  1526. func (x *ScenarioResult) GetSummary() *ScenarioResultSummary {
  1527. if x != nil {
  1528. return x.Summary
  1529. }
  1530. return nil
  1531. }
  1532. func (x *ScenarioResult) GetClientSuccess() []bool {
  1533. if x != nil {
  1534. return x.ClientSuccess
  1535. }
  1536. return nil
  1537. }
  1538. func (x *ScenarioResult) GetServerSuccess() []bool {
  1539. if x != nil {
  1540. return x.ServerSuccess
  1541. }
  1542. return nil
  1543. }
  1544. func (x *ScenarioResult) GetRequestResults() []*RequestResultCount {
  1545. if x != nil {
  1546. return x.RequestResults
  1547. }
  1548. return nil
  1549. }
  1550. var File_grpc_testing_control_proto protoreflect.FileDescriptor
  1551. var file_grpc_testing_control_proto_rawDesc = []byte{
  1552. 0x0a, 0x1a, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2f, 0x63,
  1553. 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0c, 0x67, 0x72,
  1554. 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x1a, 0x1b, 0x67, 0x72, 0x70, 0x63,
  1555. 0x2f, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2f, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64,
  1556. 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x18, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x74, 0x65,
  1557. 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74,
  1558. 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
  1559. 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f,
  1560. 0x74, 0x6f, 0x22, 0x32, 0x0a, 0x0d, 0x50, 0x6f, 0x69, 0x73, 0x73, 0x6f, 0x6e, 0x50, 0x61, 0x72,
  1561. 0x61, 0x6d, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x6f, 0x66, 0x66, 0x65, 0x72, 0x65, 0x64, 0x5f, 0x6c,
  1562. 0x6f, 0x61, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x01, 0x52, 0x0b, 0x6f, 0x66, 0x66, 0x65, 0x72,
  1563. 0x65, 0x64, 0x4c, 0x6f, 0x61, 0x64, 0x22, 0x12, 0x0a, 0x10, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x64,
  1564. 0x4c, 0x6f, 0x6f, 0x70, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x22, 0x90, 0x01, 0x0a, 0x0a, 0x4c,
  1565. 0x6f, 0x61, 0x64, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12, 0x41, 0x0a, 0x0b, 0x63, 0x6c, 0x6f,
  1566. 0x73, 0x65, 0x64, 0x5f, 0x6c, 0x6f, 0x6f, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e,
  1567. 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6c,
  1568. 0x6f, 0x73, 0x65, 0x64, 0x4c, 0x6f, 0x6f, 0x70, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x48, 0x00,
  1569. 0x52, 0x0a, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x64, 0x4c, 0x6f, 0x6f, 0x70, 0x12, 0x37, 0x0a, 0x07,
  1570. 0x70, 0x6f, 0x69, 0x73, 0x73, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e,
  1571. 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x50, 0x6f, 0x69,
  1572. 0x73, 0x73, 0x6f, 0x6e, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x48, 0x00, 0x52, 0x07, 0x70, 0x6f,
  1573. 0x69, 0x73, 0x73, 0x6f, 0x6e, 0x42, 0x06, 0x0a, 0x04, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x7f, 0x0a,
  1574. 0x0e, 0x53, 0x65, 0x63, 0x75, 0x72, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12,
  1575. 0x1e, 0x0a, 0x0b, 0x75, 0x73, 0x65, 0x5f, 0x74, 0x65, 0x73, 0x74, 0x5f, 0x63, 0x61, 0x18, 0x01,
  1576. 0x20, 0x01, 0x28, 0x08, 0x52, 0x09, 0x75, 0x73, 0x65, 0x54, 0x65, 0x73, 0x74, 0x43, 0x61, 0x12,
  1577. 0x30, 0x0a, 0x14, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x68, 0x6f, 0x73, 0x74, 0x5f, 0x6f,
  1578. 0x76, 0x65, 0x72, 0x72, 0x69, 0x64, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x12, 0x73,
  1579. 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x6f, 0x73, 0x74, 0x4f, 0x76, 0x65, 0x72, 0x72, 0x69, 0x64,
  1580. 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x72, 0x65, 0x64, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03,
  1581. 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x63, 0x72, 0x65, 0x64, 0x54, 0x79, 0x70, 0x65, 0x22, 0x67,
  1582. 0x0a, 0x0a, 0x43, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x41, 0x72, 0x67, 0x12, 0x12, 0x0a, 0x04,
  1583. 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65,
  1584. 0x12, 0x1d, 0x0a, 0x09, 0x73, 0x74, 0x72, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20,
  1585. 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x08, 0x73, 0x74, 0x72, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12,
  1586. 0x1d, 0x0a, 0x09, 0x69, 0x6e, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01,
  1587. 0x28, 0x05, 0x48, 0x00, 0x52, 0x08, 0x69, 0x6e, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x07,
  1588. 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0xf6, 0x07, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65,
  1589. 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x65, 0x72, 0x76,
  1590. 0x65, 0x72, 0x5f, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09,
  1591. 0x52, 0x0d, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73, 0x12,
  1592. 0x39, 0x0a, 0x0b, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02,
  1593. 0x20, 0x01, 0x28, 0x0e, 0x32, 0x18, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74,
  1594. 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a,
  1595. 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x45, 0x0a, 0x0f, 0x73, 0x65,
  1596. 0x63, 0x75, 0x72, 0x69, 0x74, 0x79, 0x5f, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x18, 0x03, 0x20,
  1597. 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69,
  1598. 0x6e, 0x67, 0x2e, 0x53, 0x65, 0x63, 0x75, 0x72, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d,
  1599. 0x73, 0x52, 0x0e, 0x73, 0x65, 0x63, 0x75, 0x72, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d,
  1600. 0x73, 0x12, 0x3f, 0x0a, 0x1c, 0x6f, 0x75, 0x74, 0x73, 0x74, 0x61, 0x6e, 0x64, 0x69, 0x6e, 0x67,
  1601. 0x5f, 0x72, 0x70, 0x63, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65,
  1602. 0x6c, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x19, 0x6f, 0x75, 0x74, 0x73, 0x74, 0x61, 0x6e,
  1603. 0x64, 0x69, 0x6e, 0x67, 0x52, 0x70, 0x63, 0x73, 0x50, 0x65, 0x72, 0x43, 0x68, 0x61, 0x6e, 0x6e,
  1604. 0x65, 0x6c, 0x12, 0x27, 0x0a, 0x0f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x63, 0x68, 0x61,
  1605. 0x6e, 0x6e, 0x65, 0x6c, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0e, 0x63, 0x6c, 0x69,
  1606. 0x65, 0x6e, 0x74, 0x43, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x61,
  1607. 0x73, 0x79, 0x6e, 0x63, 0x5f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x74, 0x68, 0x72, 0x65,
  1608. 0x61, 0x64, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52, 0x12, 0x61, 0x73, 0x79, 0x6e, 0x63,
  1609. 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x54, 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x12, 0x30, 0x0a,
  1610. 0x08, 0x72, 0x70, 0x63, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0e, 0x32,
  1611. 0x15, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x52,
  1612. 0x70, 0x63, 0x54, 0x79, 0x70, 0x65, 0x52, 0x07, 0x72, 0x70, 0x63, 0x54, 0x79, 0x70, 0x65, 0x12,
  1613. 0x39, 0x0a, 0x0b, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x18, 0x0a,
  1614. 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74,
  1615. 0x69, 0x6e, 0x67, 0x2e, 0x4c, 0x6f, 0x61, 0x64, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x0a,
  1616. 0x6c, 0x6f, 0x61, 0x64, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12, 0x42, 0x0a, 0x0e, 0x70, 0x61,
  1617. 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x0b, 0x20, 0x01,
  1618. 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e,
  1619. 0x67, 0x2e, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52,
  1620. 0x0d, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x48,
  1621. 0x0a, 0x10, 0x68, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61, 0x6d, 0x5f, 0x70, 0x61, 0x72, 0x61,
  1622. 0x6d, 0x73, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e,
  1623. 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61,
  1624. 0x6d, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x0f, 0x68, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72,
  1625. 0x61, 0x6d, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x6f, 0x72, 0x65,
  1626. 0x5f, 0x6c, 0x69, 0x73, 0x74, 0x18, 0x0d, 0x20, 0x03, 0x28, 0x05, 0x52, 0x08, 0x63, 0x6f, 0x72,
  1627. 0x65, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x72, 0x65, 0x5f, 0x6c, 0x69,
  1628. 0x6d, 0x69, 0x74, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x63, 0x6f, 0x72, 0x65, 0x4c,
  1629. 0x69, 0x6d, 0x69, 0x74, 0x12, 0x28, 0x0a, 0x10, 0x6f, 0x74, 0x68, 0x65, 0x72, 0x5f, 0x63, 0x6c,
  1630. 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x61, 0x70, 0x69, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e,
  1631. 0x6f, 0x74, 0x68, 0x65, 0x72, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x41, 0x70, 0x69, 0x12, 0x3b,
  1632. 0x0a, 0x0c, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x5f, 0x61, 0x72, 0x67, 0x73, 0x18, 0x10,
  1633. 0x20, 0x03, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74,
  1634. 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x41, 0x72, 0x67, 0x52, 0x0b,
  1635. 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x41, 0x72, 0x67, 0x73, 0x12, 0x24, 0x0a, 0x0e, 0x74,
  1636. 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x63, 0x71, 0x18, 0x11, 0x20,
  1637. 0x01, 0x28, 0x05, 0x52, 0x0c, 0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x50, 0x65, 0x72, 0x43,
  1638. 0x71, 0x12, 0x2e, 0x0a, 0x13, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x5f, 0x70, 0x65,
  1639. 0x72, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x12, 0x20, 0x01, 0x28, 0x05, 0x52, 0x11,
  1640. 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x50, 0x65, 0x72, 0x53, 0x74, 0x72, 0x65, 0x61,
  1641. 0x6d, 0x12, 0x28, 0x0a, 0x10, 0x75, 0x73, 0x65, 0x5f, 0x63, 0x6f, 0x61, 0x6c, 0x65, 0x73, 0x63,
  1642. 0x65, 0x5f, 0x61, 0x70, 0x69, 0x18, 0x13, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0e, 0x75, 0x73, 0x65,
  1643. 0x43, 0x6f, 0x61, 0x6c, 0x65, 0x73, 0x63, 0x65, 0x41, 0x70, 0x69, 0x12, 0x58, 0x0a, 0x29, 0x6d,
  1644. 0x65, 0x64, 0x69, 0x61, 0x6e, 0x5f, 0x6c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x63, 0x6f,
  1645. 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61,
  1646. 0x6c, 0x5f, 0x6d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x18, 0x14, 0x20, 0x01, 0x28, 0x05, 0x52, 0x25,
  1647. 0x6d, 0x65, 0x64, 0x69, 0x61, 0x6e, 0x4c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x43, 0x6f, 0x6c,
  1648. 0x6c, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x4d,
  1649. 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x12, 0x29, 0x0a, 0x10, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f,
  1650. 0x70, 0x72, 0x6f, 0x63, 0x65, 0x73, 0x73, 0x65, 0x73, 0x18, 0x15, 0x20, 0x01, 0x28, 0x05, 0x52,
  1651. 0x0f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x73, 0x73, 0x65, 0x73,
  1652. 0x22, 0x3f, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73,
  1653. 0x12, 0x2f, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1654. 0x19, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x43,
  1655. 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x73, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74,
  1656. 0x73, 0x22, 0x1c, 0x0a, 0x04, 0x4d, 0x61, 0x72, 0x6b, 0x12, 0x14, 0x0a, 0x05, 0x72, 0x65, 0x73,
  1657. 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x05, 0x72, 0x65, 0x73, 0x65, 0x74, 0x22,
  1658. 0x75, 0x0a, 0x0a, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x41, 0x72, 0x67, 0x73, 0x12, 0x32, 0x0a,
  1659. 0x05, 0x73, 0x65, 0x74, 0x75, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67,
  1660. 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6c, 0x69, 0x65,
  1661. 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x48, 0x00, 0x52, 0x05, 0x73, 0x65, 0x74, 0x75,
  1662. 0x70, 0x12, 0x28, 0x0a, 0x04, 0x6d, 0x61, 0x72, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1663. 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x4d,
  1664. 0x61, 0x72, 0x6b, 0x48, 0x00, 0x52, 0x04, 0x6d, 0x61, 0x72, 0x6b, 0x42, 0x09, 0x0a, 0x07, 0x61,
  1665. 0x72, 0x67, 0x74, 0x79, 0x70, 0x65, 0x22, 0xc0, 0x04, 0x0a, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x65,
  1666. 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x39, 0x0a, 0x0b, 0x73, 0x65, 0x72, 0x76, 0x65,
  1667. 0x72, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x18, 0x2e, 0x67,
  1668. 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x53, 0x65, 0x72, 0x76,
  1669. 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x54, 0x79,
  1670. 0x70, 0x65, 0x12, 0x45, 0x0a, 0x0f, 0x73, 0x65, 0x63, 0x75, 0x72, 0x69, 0x74, 0x79, 0x5f, 0x70,
  1671. 0x61, 0x72, 0x61, 0x6d, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x67, 0x72,
  1672. 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x53, 0x65, 0x63, 0x75, 0x72,
  1673. 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x0e, 0x73, 0x65, 0x63, 0x75, 0x72,
  1674. 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72,
  1675. 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x30, 0x0a,
  1676. 0x14, 0x61, 0x73, 0x79, 0x6e, 0x63, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x74, 0x68,
  1677. 0x72, 0x65, 0x61, 0x64, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52, 0x12, 0x61, 0x73, 0x79,
  1678. 0x6e, 0x63, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x54, 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x12,
  1679. 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x72, 0x65, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x08, 0x20,
  1680. 0x01, 0x28, 0x05, 0x52, 0x09, 0x63, 0x6f, 0x72, 0x65, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x42,
  1681. 0x0a, 0x0e, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67,
  1682. 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65,
  1683. 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x43, 0x6f, 0x6e,
  1684. 0x66, 0x69, 0x67, 0x52, 0x0d, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x43, 0x6f, 0x6e, 0x66,
  1685. 0x69, 0x67, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x6f, 0x72, 0x65, 0x5f, 0x6c, 0x69, 0x73, 0x74, 0x18,
  1686. 0x0a, 0x20, 0x03, 0x28, 0x05, 0x52, 0x08, 0x63, 0x6f, 0x72, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x12,
  1687. 0x28, 0x0a, 0x10, 0x6f, 0x74, 0x68, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f,
  1688. 0x61, 0x70, 0x69, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x6f, 0x74, 0x68, 0x65, 0x72,
  1689. 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x41, 0x70, 0x69, 0x12, 0x24, 0x0a, 0x0e, 0x74, 0x68, 0x72,
  1690. 0x65, 0x61, 0x64, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x63, 0x71, 0x18, 0x0c, 0x20, 0x01, 0x28,
  1691. 0x05, 0x52, 0x0c, 0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x50, 0x65, 0x72, 0x43, 0x71, 0x12,
  1692. 0x2f, 0x0a, 0x13, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x5f, 0x71, 0x75, 0x6f, 0x74,
  1693. 0x61, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0xe9, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52, 0x11, 0x72,
  1694. 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x51, 0x75, 0x6f, 0x74, 0x61, 0x53, 0x69, 0x7a, 0x65,
  1695. 0x12, 0x3c, 0x0a, 0x0c, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x5f, 0x61, 0x72, 0x67, 0x73,
  1696. 0x18, 0xea, 0x07, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74,
  1697. 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x41, 0x72,
  1698. 0x67, 0x52, 0x0b, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x41, 0x72, 0x67, 0x73, 0x12, 0x29,
  1699. 0x0a, 0x10, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x70, 0x72, 0x6f, 0x63, 0x65, 0x73, 0x73,
  1700. 0x65, 0x73, 0x18, 0x15, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
  1701. 0x50, 0x72, 0x6f, 0x63, 0x65, 0x73, 0x73, 0x65, 0x73, 0x22, 0x75, 0x0a, 0x0a, 0x53, 0x65, 0x72,
  1702. 0x76, 0x65, 0x72, 0x41, 0x72, 0x67, 0x73, 0x12, 0x32, 0x0a, 0x05, 0x73, 0x65, 0x74, 0x75, 0x70,
  1703. 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65,
  1704. 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66,
  1705. 0x69, 0x67, 0x48, 0x00, 0x52, 0x05, 0x73, 0x65, 0x74, 0x75, 0x70, 0x12, 0x28, 0x0a, 0x04, 0x6d,
  1706. 0x61, 0x72, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63,
  1707. 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x4d, 0x61, 0x72, 0x6b, 0x48, 0x00, 0x52,
  1708. 0x04, 0x6d, 0x61, 0x72, 0x6b, 0x42, 0x09, 0x0a, 0x07, 0x61, 0x72, 0x67, 0x74, 0x79, 0x70, 0x65,
  1709. 0x22, 0x69, 0x0a, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73,
  1710. 0x12, 0x2f, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1711. 0x19, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x53,
  1712. 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x73, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74,
  1713. 0x73, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52,
  1714. 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x6f, 0x72, 0x65, 0x73, 0x18, 0x03,
  1715. 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x63, 0x6f, 0x72, 0x65, 0x73, 0x22, 0x0d, 0x0a, 0x0b, 0x43,
  1716. 0x6f, 0x72, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x24, 0x0a, 0x0c, 0x43, 0x6f,
  1717. 0x72, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x6f,
  1718. 0x72, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x63, 0x6f, 0x72, 0x65, 0x73,
  1719. 0x22, 0x06, 0x0a, 0x04, 0x56, 0x6f, 0x69, 0x64, 0x22, 0xef, 0x02, 0x0a, 0x08, 0x53, 0x63, 0x65,
  1720. 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20,
  1721. 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x3f, 0x0a, 0x0d, 0x63, 0x6c, 0x69,
  1722. 0x65, 0x6e, 0x74, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
  1723. 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e,
  1724. 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x0c, 0x63, 0x6c,
  1725. 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x1f, 0x0a, 0x0b, 0x6e, 0x75,
  1726. 0x6d, 0x5f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52,
  1727. 0x0a, 0x6e, 0x75, 0x6d, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x3f, 0x0a, 0x0d, 0x73,
  1728. 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x04, 0x20, 0x01,
  1729. 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e,
  1730. 0x67, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x0c,
  1731. 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x1f, 0x0a, 0x0b,
  1732. 0x6e, 0x75, 0x6d, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28,
  1733. 0x05, 0x52, 0x0a, 0x6e, 0x75, 0x6d, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x73, 0x12, 0x25, 0x0a,
  1734. 0x0e, 0x77, 0x61, 0x72, 0x6d, 0x75, 0x70, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18,
  1735. 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0d, 0x77, 0x61, 0x72, 0x6d, 0x75, 0x70, 0x53, 0x65, 0x63,
  1736. 0x6f, 0x6e, 0x64, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x62, 0x65, 0x6e, 0x63, 0x68, 0x6d, 0x61, 0x72,
  1737. 0x6b, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52,
  1738. 0x10, 0x62, 0x65, 0x6e, 0x63, 0x68, 0x6d, 0x61, 0x72, 0x6b, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64,
  1739. 0x73, 0x12, 0x37, 0x0a, 0x18, 0x73, 0x70, 0x61, 0x77, 0x6e, 0x5f, 0x6c, 0x6f, 0x63, 0x61, 0x6c,
  1740. 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x08, 0x20,
  1741. 0x01, 0x28, 0x05, 0x52, 0x15, 0x73, 0x70, 0x61, 0x77, 0x6e, 0x4c, 0x6f, 0x63, 0x61, 0x6c, 0x57,
  1742. 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x41, 0x0a, 0x09, 0x53, 0x63,
  1743. 0x65, 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x73, 0x12, 0x34, 0x0a, 0x09, 0x73, 0x63, 0x65, 0x6e, 0x61,
  1744. 0x72, 0x69, 0x6f, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x70,
  1745. 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x53, 0x63, 0x65, 0x6e, 0x61, 0x72,
  1746. 0x69, 0x6f, 0x52, 0x09, 0x73, 0x63, 0x65, 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x73, 0x22, 0xad, 0x07,
  1747. 0x0a, 0x15, 0x53, 0x63, 0x65, 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74,
  1748. 0x53, 0x75, 0x6d, 0x6d, 0x61, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x71, 0x70, 0x73, 0x18, 0x01,
  1749. 0x20, 0x01, 0x28, 0x01, 0x52, 0x03, 0x71, 0x70, 0x73, 0x12, 0x2d, 0x0a, 0x13, 0x71, 0x70, 0x73,
  1750. 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x72, 0x65,
  1751. 0x18, 0x02, 0x20, 0x01, 0x28, 0x01, 0x52, 0x10, 0x71, 0x70, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65,
  1752. 0x72, 0x76, 0x65, 0x72, 0x43, 0x6f, 0x72, 0x65, 0x12, 0x2c, 0x0a, 0x12, 0x73, 0x65, 0x72, 0x76,
  1753. 0x65, 0x72, 0x5f, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x03,
  1754. 0x20, 0x01, 0x28, 0x01, 0x52, 0x10, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x79, 0x73, 0x74,
  1755. 0x65, 0x6d, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x28, 0x0a, 0x10, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
  1756. 0x5f, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x01,
  1757. 0x52, 0x0e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x55, 0x73, 0x65, 0x72, 0x54, 0x69, 0x6d, 0x65,
  1758. 0x12, 0x2c, 0x0a, 0x12, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x79, 0x73, 0x74, 0x65,
  1759. 0x6d, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x01, 0x52, 0x10, 0x63, 0x6c,
  1760. 0x69, 0x65, 0x6e, 0x74, 0x53, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x28,
  1761. 0x0a, 0x10, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x74, 0x69,
  1762. 0x6d, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x01, 0x52, 0x0e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74,
  1763. 0x55, 0x73, 0x65, 0x72, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x6c, 0x61, 0x74, 0x65,
  1764. 0x6e, 0x63, 0x79, 0x5f, 0x35, 0x30, 0x18, 0x07, 0x20, 0x01, 0x28, 0x01, 0x52, 0x09, 0x6c, 0x61,
  1765. 0x74, 0x65, 0x6e, 0x63, 0x79, 0x35, 0x30, 0x12, 0x1d, 0x0a, 0x0a, 0x6c, 0x61, 0x74, 0x65, 0x6e,
  1766. 0x63, 0x79, 0x5f, 0x39, 0x30, 0x18, 0x08, 0x20, 0x01, 0x28, 0x01, 0x52, 0x09, 0x6c, 0x61, 0x74,
  1767. 0x65, 0x6e, 0x63, 0x79, 0x39, 0x30, 0x12, 0x1d, 0x0a, 0x0a, 0x6c, 0x61, 0x74, 0x65, 0x6e, 0x63,
  1768. 0x79, 0x5f, 0x39, 0x35, 0x18, 0x09, 0x20, 0x01, 0x28, 0x01, 0x52, 0x09, 0x6c, 0x61, 0x74, 0x65,
  1769. 0x6e, 0x63, 0x79, 0x39, 0x35, 0x12, 0x1d, 0x0a, 0x0a, 0x6c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x79,
  1770. 0x5f, 0x39, 0x39, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x01, 0x52, 0x09, 0x6c, 0x61, 0x74, 0x65, 0x6e,
  1771. 0x63, 0x79, 0x39, 0x39, 0x12, 0x1f, 0x0a, 0x0b, 0x6c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x5f,
  1772. 0x39, 0x39, 0x39, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x01, 0x52, 0x0a, 0x6c, 0x61, 0x74, 0x65, 0x6e,
  1773. 0x63, 0x79, 0x39, 0x39, 0x39, 0x12, 0x28, 0x0a, 0x10, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f,
  1774. 0x63, 0x70, 0x75, 0x5f, 0x75, 0x73, 0x61, 0x67, 0x65, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x01, 0x52,
  1775. 0x0e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x43, 0x70, 0x75, 0x55, 0x73, 0x61, 0x67, 0x65, 0x12,
  1776. 0x43, 0x0a, 0x1e, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x66, 0x75, 0x6c, 0x5f, 0x72, 0x65,
  1777. 0x71, 0x75, 0x65, 0x73, 0x74, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e,
  1778. 0x64, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x01, 0x52, 0x1b, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73,
  1779. 0x66, 0x75, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65,
  1780. 0x63, 0x6f, 0x6e, 0x64, 0x12, 0x3b, 0x0a, 0x1a, 0x66, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x5f, 0x72,
  1781. 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x6f,
  1782. 0x6e, 0x64, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x01, 0x52, 0x17, 0x66, 0x61, 0x69, 0x6c, 0x65, 0x64,
  1783. 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x6f, 0x6e,
  1784. 0x64, 0x12, 0x37, 0x0a, 0x18, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x70, 0x6f, 0x6c, 0x6c,
  1785. 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x0f, 0x20,
  1786. 0x01, 0x28, 0x01, 0x52, 0x15, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x50, 0x6f, 0x6c, 0x6c, 0x73,
  1787. 0x50, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x18, 0x73, 0x65,
  1788. 0x72, 0x76, 0x65, 0x72, 0x5f, 0x70, 0x6f, 0x6c, 0x6c, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x72,
  1789. 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x10, 0x20, 0x01, 0x28, 0x01, 0x52, 0x15, 0x73, 0x65,
  1790. 0x72, 0x76, 0x65, 0x72, 0x50, 0x6f, 0x6c, 0x6c, 0x73, 0x50, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75,
  1791. 0x65, 0x73, 0x74, 0x12, 0x3a, 0x0a, 0x1a, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x71, 0x75,
  1792. 0x65, 0x72, 0x69, 0x65, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x63, 0x70, 0x75, 0x5f, 0x73, 0x65,
  1793. 0x63, 0x18, 0x11, 0x20, 0x01, 0x28, 0x01, 0x52, 0x16, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x51,
  1794. 0x75, 0x65, 0x72, 0x69, 0x65, 0x73, 0x50, 0x65, 0x72, 0x43, 0x70, 0x75, 0x53, 0x65, 0x63, 0x12,
  1795. 0x3a, 0x0a, 0x1a, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x71, 0x75, 0x65, 0x72, 0x69, 0x65,
  1796. 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x63, 0x70, 0x75, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x12, 0x20,
  1797. 0x01, 0x28, 0x01, 0x52, 0x16, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x51, 0x75, 0x65, 0x72, 0x69,
  1798. 0x65, 0x73, 0x50, 0x65, 0x72, 0x43, 0x70, 0x75, 0x53, 0x65, 0x63, 0x12, 0x39, 0x0a, 0x0a, 0x73,
  1799. 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x13, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1800. 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
  1801. 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x73, 0x74, 0x61,
  1802. 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x35, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69,
  1803. 0x6d, 0x65, 0x18, 0x14, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1804. 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73,
  1805. 0x74, 0x61, 0x6d, 0x70, 0x52, 0x07, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x22, 0xf6, 0x03,
  1806. 0x0a, 0x0e, 0x53, 0x63, 0x65, 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74,
  1807. 0x12, 0x32, 0x0a, 0x08, 0x73, 0x63, 0x65, 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x18, 0x01, 0x20, 0x01,
  1808. 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e,
  1809. 0x67, 0x2e, 0x53, 0x63, 0x65, 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x52, 0x08, 0x73, 0x63, 0x65, 0x6e,
  1810. 0x61, 0x72, 0x69, 0x6f, 0x12, 0x39, 0x0a, 0x09, 0x6c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x69, 0x65,
  1811. 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74,
  1812. 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61, 0x6d,
  1813. 0x44, 0x61, 0x74, 0x61, 0x52, 0x09, 0x6c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x69, 0x65, 0x73, 0x12,
  1814. 0x3c, 0x0a, 0x0c, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x73, 0x18,
  1815. 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73,
  1816. 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x73,
  1817. 0x52, 0x0b, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x73, 0x12, 0x3c, 0x0a,
  1818. 0x0c, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x73, 0x18, 0x04, 0x20,
  1819. 0x03, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69,
  1820. 0x6e, 0x67, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x73, 0x52, 0x0b,
  1821. 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x73,
  1822. 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28,
  1823. 0x05, 0x52, 0x0b, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x43, 0x6f, 0x72, 0x65, 0x73, 0x12, 0x3d,
  1824. 0x0a, 0x07, 0x73, 0x75, 0x6d, 0x6d, 0x61, 0x72, 0x79, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1825. 0x23, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x2e, 0x53,
  1826. 0x63, 0x65, 0x6e, 0x61, 0x72, 0x69, 0x6f, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x53, 0x75, 0x6d,
  1827. 0x6d, 0x61, 0x72, 0x79, 0x52, 0x07, 0x73, 0x75, 0x6d, 0x6d, 0x61, 0x72, 0x79, 0x12, 0x25, 0x0a,
  1828. 0x0e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18,
  1829. 0x07, 0x20, 0x03, 0x28, 0x08, 0x52, 0x0d, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x75, 0x63,
  1830. 0x63, 0x65, 0x73, 0x73, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x73,
  1831. 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x08, 0x52, 0x0d, 0x73, 0x65,
  1832. 0x72, 0x76, 0x65, 0x72, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x49, 0x0a, 0x0f, 0x72,
  1833. 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x18, 0x09,
  1834. 0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x74, 0x65, 0x73, 0x74,
  1835. 0x69, 0x6e, 0x67, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x52, 0x65, 0x73, 0x75, 0x6c,
  1836. 0x74, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x0e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x52,
  1837. 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x2a, 0x56, 0x0a, 0x0a, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
  1838. 0x54, 0x79, 0x70, 0x65, 0x12, 0x0f, 0x0a, 0x0b, 0x53, 0x59, 0x4e, 0x43, 0x5f, 0x43, 0x4c, 0x49,
  1839. 0x45, 0x4e, 0x54, 0x10, 0x00, 0x12, 0x10, 0x0a, 0x0c, 0x41, 0x53, 0x59, 0x4e, 0x43, 0x5f, 0x43,
  1840. 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x01, 0x12, 0x10, 0x0a, 0x0c, 0x4f, 0x54, 0x48, 0x45, 0x52,
  1841. 0x5f, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x02, 0x12, 0x13, 0x0a, 0x0f, 0x43, 0x41, 0x4c,
  1842. 0x4c, 0x42, 0x41, 0x43, 0x4b, 0x5f, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x03, 0x2a, 0x70,
  1843. 0x0a, 0x0a, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0f, 0x0a, 0x0b,
  1844. 0x53, 0x59, 0x4e, 0x43, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x00, 0x12, 0x10, 0x0a,
  1845. 0x0c, 0x41, 0x53, 0x59, 0x4e, 0x43, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x01, 0x12,
  1846. 0x18, 0x0a, 0x14, 0x41, 0x53, 0x59, 0x4e, 0x43, 0x5f, 0x47, 0x45, 0x4e, 0x45, 0x52, 0x49, 0x43,
  1847. 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x02, 0x12, 0x10, 0x0a, 0x0c, 0x4f, 0x54, 0x48,
  1848. 0x45, 0x52, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x03, 0x12, 0x13, 0x0a, 0x0f, 0x43,
  1849. 0x41, 0x4c, 0x4c, 0x42, 0x41, 0x43, 0x4b, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x04,
  1850. 0x2a, 0x72, 0x0a, 0x07, 0x52, 0x70, 0x63, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x55,
  1851. 0x4e, 0x41, 0x52, 0x59, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d,
  1852. 0x49, 0x4e, 0x47, 0x10, 0x01, 0x12, 0x19, 0x0a, 0x15, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x49,
  1853. 0x4e, 0x47, 0x5f, 0x46, 0x52, 0x4f, 0x4d, 0x5f, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x02,
  1854. 0x12, 0x19, 0x0a, 0x15, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x49, 0x4e, 0x47, 0x5f, 0x46, 0x52,
  1855. 0x4f, 0x4d, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x03, 0x12, 0x17, 0x0a, 0x13, 0x53,
  1856. 0x54, 0x52, 0x45, 0x41, 0x4d, 0x49, 0x4e, 0x47, 0x5f, 0x42, 0x4f, 0x54, 0x48, 0x5f, 0x57, 0x41,
  1857. 0x59, 0x53, 0x10, 0x04, 0x42, 0x21, 0x0a, 0x0f, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e,
  1858. 0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67, 0x42, 0x0c, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c,
  1859. 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  1860. }
  1861. var (
  1862. file_grpc_testing_control_proto_rawDescOnce sync.Once
  1863. file_grpc_testing_control_proto_rawDescData = file_grpc_testing_control_proto_rawDesc
  1864. )
  1865. func file_grpc_testing_control_proto_rawDescGZIP() []byte {
  1866. file_grpc_testing_control_proto_rawDescOnce.Do(func() {
  1867. file_grpc_testing_control_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpc_testing_control_proto_rawDescData)
  1868. })
  1869. return file_grpc_testing_control_proto_rawDescData
  1870. }
  1871. var file_grpc_testing_control_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
  1872. var file_grpc_testing_control_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
  1873. var file_grpc_testing_control_proto_goTypes = []interface{}{
  1874. (ClientType)(0), // 0: grpc.testing.ClientType
  1875. (ServerType)(0), // 1: grpc.testing.ServerType
  1876. (RpcType)(0), // 2: grpc.testing.RpcType
  1877. (*PoissonParams)(nil), // 3: grpc.testing.PoissonParams
  1878. (*ClosedLoopParams)(nil), // 4: grpc.testing.ClosedLoopParams
  1879. (*LoadParams)(nil), // 5: grpc.testing.LoadParams
  1880. (*SecurityParams)(nil), // 6: grpc.testing.SecurityParams
  1881. (*ChannelArg)(nil), // 7: grpc.testing.ChannelArg
  1882. (*ClientConfig)(nil), // 8: grpc.testing.ClientConfig
  1883. (*ClientStatus)(nil), // 9: grpc.testing.ClientStatus
  1884. (*Mark)(nil), // 10: grpc.testing.Mark
  1885. (*ClientArgs)(nil), // 11: grpc.testing.ClientArgs
  1886. (*ServerConfig)(nil), // 12: grpc.testing.ServerConfig
  1887. (*ServerArgs)(nil), // 13: grpc.testing.ServerArgs
  1888. (*ServerStatus)(nil), // 14: grpc.testing.ServerStatus
  1889. (*CoreRequest)(nil), // 15: grpc.testing.CoreRequest
  1890. (*CoreResponse)(nil), // 16: grpc.testing.CoreResponse
  1891. (*Void)(nil), // 17: grpc.testing.Void
  1892. (*Scenario)(nil), // 18: grpc.testing.Scenario
  1893. (*Scenarios)(nil), // 19: grpc.testing.Scenarios
  1894. (*ScenarioResultSummary)(nil), // 20: grpc.testing.ScenarioResultSummary
  1895. (*ScenarioResult)(nil), // 21: grpc.testing.ScenarioResult
  1896. (*PayloadConfig)(nil), // 22: grpc.testing.PayloadConfig
  1897. (*HistogramParams)(nil), // 23: grpc.testing.HistogramParams
  1898. (*ClientStats)(nil), // 24: grpc.testing.ClientStats
  1899. (*ServerStats)(nil), // 25: grpc.testing.ServerStats
  1900. (*timestamppb.Timestamp)(nil), // 26: google.protobuf.Timestamp
  1901. (*HistogramData)(nil), // 27: grpc.testing.HistogramData
  1902. (*RequestResultCount)(nil), // 28: grpc.testing.RequestResultCount
  1903. }
  1904. var file_grpc_testing_control_proto_depIdxs = []int32{
  1905. 4, // 0: grpc.testing.LoadParams.closed_loop:type_name -> grpc.testing.ClosedLoopParams
  1906. 3, // 1: grpc.testing.LoadParams.poisson:type_name -> grpc.testing.PoissonParams
  1907. 0, // 2: grpc.testing.ClientConfig.client_type:type_name -> grpc.testing.ClientType
  1908. 6, // 3: grpc.testing.ClientConfig.security_params:type_name -> grpc.testing.SecurityParams
  1909. 2, // 4: grpc.testing.ClientConfig.rpc_type:type_name -> grpc.testing.RpcType
  1910. 5, // 5: grpc.testing.ClientConfig.load_params:type_name -> grpc.testing.LoadParams
  1911. 22, // 6: grpc.testing.ClientConfig.payload_config:type_name -> grpc.testing.PayloadConfig
  1912. 23, // 7: grpc.testing.ClientConfig.histogram_params:type_name -> grpc.testing.HistogramParams
  1913. 7, // 8: grpc.testing.ClientConfig.channel_args:type_name -> grpc.testing.ChannelArg
  1914. 24, // 9: grpc.testing.ClientStatus.stats:type_name -> grpc.testing.ClientStats
  1915. 8, // 10: grpc.testing.ClientArgs.setup:type_name -> grpc.testing.ClientConfig
  1916. 10, // 11: grpc.testing.ClientArgs.mark:type_name -> grpc.testing.Mark
  1917. 1, // 12: grpc.testing.ServerConfig.server_type:type_name -> grpc.testing.ServerType
  1918. 6, // 13: grpc.testing.ServerConfig.security_params:type_name -> grpc.testing.SecurityParams
  1919. 22, // 14: grpc.testing.ServerConfig.payload_config:type_name -> grpc.testing.PayloadConfig
  1920. 7, // 15: grpc.testing.ServerConfig.channel_args:type_name -> grpc.testing.ChannelArg
  1921. 12, // 16: grpc.testing.ServerArgs.setup:type_name -> grpc.testing.ServerConfig
  1922. 10, // 17: grpc.testing.ServerArgs.mark:type_name -> grpc.testing.Mark
  1923. 25, // 18: grpc.testing.ServerStatus.stats:type_name -> grpc.testing.ServerStats
  1924. 8, // 19: grpc.testing.Scenario.client_config:type_name -> grpc.testing.ClientConfig
  1925. 12, // 20: grpc.testing.Scenario.server_config:type_name -> grpc.testing.ServerConfig
  1926. 18, // 21: grpc.testing.Scenarios.scenarios:type_name -> grpc.testing.Scenario
  1927. 26, // 22: grpc.testing.ScenarioResultSummary.start_time:type_name -> google.protobuf.Timestamp
  1928. 26, // 23: grpc.testing.ScenarioResultSummary.end_time:type_name -> google.protobuf.Timestamp
  1929. 18, // 24: grpc.testing.ScenarioResult.scenario:type_name -> grpc.testing.Scenario
  1930. 27, // 25: grpc.testing.ScenarioResult.latencies:type_name -> grpc.testing.HistogramData
  1931. 24, // 26: grpc.testing.ScenarioResult.client_stats:type_name -> grpc.testing.ClientStats
  1932. 25, // 27: grpc.testing.ScenarioResult.server_stats:type_name -> grpc.testing.ServerStats
  1933. 20, // 28: grpc.testing.ScenarioResult.summary:type_name -> grpc.testing.ScenarioResultSummary
  1934. 28, // 29: grpc.testing.ScenarioResult.request_results:type_name -> grpc.testing.RequestResultCount
  1935. 30, // [30:30] is the sub-list for method output_type
  1936. 30, // [30:30] is the sub-list for method input_type
  1937. 30, // [30:30] is the sub-list for extension type_name
  1938. 30, // [30:30] is the sub-list for extension extendee
  1939. 0, // [0:30] is the sub-list for field type_name
  1940. }
  1941. func init() { file_grpc_testing_control_proto_init() }
  1942. func file_grpc_testing_control_proto_init() {
  1943. if File_grpc_testing_control_proto != nil {
  1944. return
  1945. }
  1946. file_grpc_testing_payloads_proto_init()
  1947. file_grpc_testing_stats_proto_init()
  1948. if !protoimpl.UnsafeEnabled {
  1949. file_grpc_testing_control_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1950. switch v := v.(*PoissonParams); i {
  1951. case 0:
  1952. return &v.state
  1953. case 1:
  1954. return &v.sizeCache
  1955. case 2:
  1956. return &v.unknownFields
  1957. default:
  1958. return nil
  1959. }
  1960. }
  1961. file_grpc_testing_control_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1962. switch v := v.(*ClosedLoopParams); i {
  1963. case 0:
  1964. return &v.state
  1965. case 1:
  1966. return &v.sizeCache
  1967. case 2:
  1968. return &v.unknownFields
  1969. default:
  1970. return nil
  1971. }
  1972. }
  1973. file_grpc_testing_control_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1974. switch v := v.(*LoadParams); i {
  1975. case 0:
  1976. return &v.state
  1977. case 1:
  1978. return &v.sizeCache
  1979. case 2:
  1980. return &v.unknownFields
  1981. default:
  1982. return nil
  1983. }
  1984. }
  1985. file_grpc_testing_control_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1986. switch v := v.(*SecurityParams); i {
  1987. case 0:
  1988. return &v.state
  1989. case 1:
  1990. return &v.sizeCache
  1991. case 2:
  1992. return &v.unknownFields
  1993. default:
  1994. return nil
  1995. }
  1996. }
  1997. file_grpc_testing_control_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1998. switch v := v.(*ChannelArg); i {
  1999. case 0:
  2000. return &v.state
  2001. case 1:
  2002. return &v.sizeCache
  2003. case 2:
  2004. return &v.unknownFields
  2005. default:
  2006. return nil
  2007. }
  2008. }
  2009. file_grpc_testing_control_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  2010. switch v := v.(*ClientConfig); i {
  2011. case 0:
  2012. return &v.state
  2013. case 1:
  2014. return &v.sizeCache
  2015. case 2:
  2016. return &v.unknownFields
  2017. default:
  2018. return nil
  2019. }
  2020. }
  2021. file_grpc_testing_control_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  2022. switch v := v.(*ClientStatus); i {
  2023. case 0:
  2024. return &v.state
  2025. case 1:
  2026. return &v.sizeCache
  2027. case 2:
  2028. return &v.unknownFields
  2029. default:
  2030. return nil
  2031. }
  2032. }
  2033. file_grpc_testing_control_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  2034. switch v := v.(*Mark); i {
  2035. case 0:
  2036. return &v.state
  2037. case 1:
  2038. return &v.sizeCache
  2039. case 2:
  2040. return &v.unknownFields
  2041. default:
  2042. return nil
  2043. }
  2044. }
  2045. file_grpc_testing_control_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  2046. switch v := v.(*ClientArgs); i {
  2047. case 0:
  2048. return &v.state
  2049. case 1:
  2050. return &v.sizeCache
  2051. case 2:
  2052. return &v.unknownFields
  2053. default:
  2054. return nil
  2055. }
  2056. }
  2057. file_grpc_testing_control_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  2058. switch v := v.(*ServerConfig); i {
  2059. case 0:
  2060. return &v.state
  2061. case 1:
  2062. return &v.sizeCache
  2063. case 2:
  2064. return &v.unknownFields
  2065. default:
  2066. return nil
  2067. }
  2068. }
  2069. file_grpc_testing_control_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  2070. switch v := v.(*ServerArgs); i {
  2071. case 0:
  2072. return &v.state
  2073. case 1:
  2074. return &v.sizeCache
  2075. case 2:
  2076. return &v.unknownFields
  2077. default:
  2078. return nil
  2079. }
  2080. }
  2081. file_grpc_testing_control_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  2082. switch v := v.(*ServerStatus); i {
  2083. case 0:
  2084. return &v.state
  2085. case 1:
  2086. return &v.sizeCache
  2087. case 2:
  2088. return &v.unknownFields
  2089. default:
  2090. return nil
  2091. }
  2092. }
  2093. file_grpc_testing_control_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  2094. switch v := v.(*CoreRequest); i {
  2095. case 0:
  2096. return &v.state
  2097. case 1:
  2098. return &v.sizeCache
  2099. case 2:
  2100. return &v.unknownFields
  2101. default:
  2102. return nil
  2103. }
  2104. }
  2105. file_grpc_testing_control_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  2106. switch v := v.(*CoreResponse); i {
  2107. case 0:
  2108. return &v.state
  2109. case 1:
  2110. return &v.sizeCache
  2111. case 2:
  2112. return &v.unknownFields
  2113. default:
  2114. return nil
  2115. }
  2116. }
  2117. file_grpc_testing_control_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  2118. switch v := v.(*Void); i {
  2119. case 0:
  2120. return &v.state
  2121. case 1:
  2122. return &v.sizeCache
  2123. case 2:
  2124. return &v.unknownFields
  2125. default:
  2126. return nil
  2127. }
  2128. }
  2129. file_grpc_testing_control_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
  2130. switch v := v.(*Scenario); i {
  2131. case 0:
  2132. return &v.state
  2133. case 1:
  2134. return &v.sizeCache
  2135. case 2:
  2136. return &v.unknownFields
  2137. default:
  2138. return nil
  2139. }
  2140. }
  2141. file_grpc_testing_control_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
  2142. switch v := v.(*Scenarios); i {
  2143. case 0:
  2144. return &v.state
  2145. case 1:
  2146. return &v.sizeCache
  2147. case 2:
  2148. return &v.unknownFields
  2149. default:
  2150. return nil
  2151. }
  2152. }
  2153. file_grpc_testing_control_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
  2154. switch v := v.(*ScenarioResultSummary); i {
  2155. case 0:
  2156. return &v.state
  2157. case 1:
  2158. return &v.sizeCache
  2159. case 2:
  2160. return &v.unknownFields
  2161. default:
  2162. return nil
  2163. }
  2164. }
  2165. file_grpc_testing_control_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
  2166. switch v := v.(*ScenarioResult); i {
  2167. case 0:
  2168. return &v.state
  2169. case 1:
  2170. return &v.sizeCache
  2171. case 2:
  2172. return &v.unknownFields
  2173. default:
  2174. return nil
  2175. }
  2176. }
  2177. }
  2178. file_grpc_testing_control_proto_msgTypes[2].OneofWrappers = []interface{}{
  2179. (*LoadParams_ClosedLoop)(nil),
  2180. (*LoadParams_Poisson)(nil),
  2181. }
  2182. file_grpc_testing_control_proto_msgTypes[4].OneofWrappers = []interface{}{
  2183. (*ChannelArg_StrValue)(nil),
  2184. (*ChannelArg_IntValue)(nil),
  2185. }
  2186. file_grpc_testing_control_proto_msgTypes[8].OneofWrappers = []interface{}{
  2187. (*ClientArgs_Setup)(nil),
  2188. (*ClientArgs_Mark)(nil),
  2189. }
  2190. file_grpc_testing_control_proto_msgTypes[10].OneofWrappers = []interface{}{
  2191. (*ServerArgs_Setup)(nil),
  2192. (*ServerArgs_Mark)(nil),
  2193. }
  2194. type x struct{}
  2195. out := protoimpl.TypeBuilder{
  2196. File: protoimpl.DescBuilder{
  2197. GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  2198. RawDescriptor: file_grpc_testing_control_proto_rawDesc,
  2199. NumEnums: 3,
  2200. NumMessages: 19,
  2201. NumExtensions: 0,
  2202. NumServices: 0,
  2203. },
  2204. GoTypes: file_grpc_testing_control_proto_goTypes,
  2205. DependencyIndexes: file_grpc_testing_control_proto_depIdxs,
  2206. EnumInfos: file_grpc_testing_control_proto_enumTypes,
  2207. MessageInfos: file_grpc_testing_control_proto_msgTypes,
  2208. }.Build()
  2209. File_grpc_testing_control_proto = out.File
  2210. file_grpc_testing_control_proto_rawDesc = nil
  2211. file_grpc_testing_control_proto_goTypes = nil
  2212. file_grpc_testing_control_proto_depIdxs = nil
  2213. }