control.pb.go 53 KB

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