test.pb.go 40 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // source: grpc_testing/test.proto
  3. package grpc_testing
  4. import proto "github.com/golang/protobuf/proto"
  5. import fmt "fmt"
  6. import math "math"
  7. import (
  8. context "golang.org/x/net/context"
  9. grpc "google.golang.org/grpc"
  10. )
  11. // Reference imports to suppress errors if they are not otherwise used.
  12. var _ = proto.Marshal
  13. var _ = fmt.Errorf
  14. var _ = math.Inf
  15. // This is a compile-time assertion to ensure that this generated file
  16. // is compatible with the proto package it is being compiled against.
  17. // A compilation error at this line likely means your copy of the
  18. // proto package needs to be updated.
  19. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  20. // The type of payload that should be returned.
  21. type PayloadType int32
  22. const (
  23. // Compressable text format.
  24. PayloadType_COMPRESSABLE PayloadType = 0
  25. // Uncompressable binary format.
  26. PayloadType_UNCOMPRESSABLE PayloadType = 1
  27. // Randomly chosen from all other formats defined in this enum.
  28. PayloadType_RANDOM PayloadType = 2
  29. )
  30. var PayloadType_name = map[int32]string{
  31. 0: "COMPRESSABLE",
  32. 1: "UNCOMPRESSABLE",
  33. 2: "RANDOM",
  34. }
  35. var PayloadType_value = map[string]int32{
  36. "COMPRESSABLE": 0,
  37. "UNCOMPRESSABLE": 1,
  38. "RANDOM": 2,
  39. }
  40. func (x PayloadType) String() string {
  41. return proto.EnumName(PayloadType_name, int32(x))
  42. }
  43. func (PayloadType) EnumDescriptor() ([]byte, []int) {
  44. return fileDescriptor_test_4001f755b984bb27, []int{0}
  45. }
  46. type Empty struct {
  47. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  48. XXX_unrecognized []byte `json:"-"`
  49. XXX_sizecache int32 `json:"-"`
  50. }
  51. func (m *Empty) Reset() { *m = Empty{} }
  52. func (m *Empty) String() string { return proto.CompactTextString(m) }
  53. func (*Empty) ProtoMessage() {}
  54. func (*Empty) Descriptor() ([]byte, []int) {
  55. return fileDescriptor_test_4001f755b984bb27, []int{0}
  56. }
  57. func (m *Empty) XXX_Unmarshal(b []byte) error {
  58. return xxx_messageInfo_Empty.Unmarshal(m, b)
  59. }
  60. func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  61. return xxx_messageInfo_Empty.Marshal(b, m, deterministic)
  62. }
  63. func (dst *Empty) XXX_Merge(src proto.Message) {
  64. xxx_messageInfo_Empty.Merge(dst, src)
  65. }
  66. func (m *Empty) XXX_Size() int {
  67. return xxx_messageInfo_Empty.Size(m)
  68. }
  69. func (m *Empty) XXX_DiscardUnknown() {
  70. xxx_messageInfo_Empty.DiscardUnknown(m)
  71. }
  72. var xxx_messageInfo_Empty proto.InternalMessageInfo
  73. // A block of data, to simply increase gRPC message size.
  74. type Payload struct {
  75. // The type of data in body.
  76. Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"`
  77. // Primary contents of payload.
  78. Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
  79. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  80. XXX_unrecognized []byte `json:"-"`
  81. XXX_sizecache int32 `json:"-"`
  82. }
  83. func (m *Payload) Reset() { *m = Payload{} }
  84. func (m *Payload) String() string { return proto.CompactTextString(m) }
  85. func (*Payload) ProtoMessage() {}
  86. func (*Payload) Descriptor() ([]byte, []int) {
  87. return fileDescriptor_test_4001f755b984bb27, []int{1}
  88. }
  89. func (m *Payload) XXX_Unmarshal(b []byte) error {
  90. return xxx_messageInfo_Payload.Unmarshal(m, b)
  91. }
  92. func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  93. return xxx_messageInfo_Payload.Marshal(b, m, deterministic)
  94. }
  95. func (dst *Payload) XXX_Merge(src proto.Message) {
  96. xxx_messageInfo_Payload.Merge(dst, src)
  97. }
  98. func (m *Payload) XXX_Size() int {
  99. return xxx_messageInfo_Payload.Size(m)
  100. }
  101. func (m *Payload) XXX_DiscardUnknown() {
  102. xxx_messageInfo_Payload.DiscardUnknown(m)
  103. }
  104. var xxx_messageInfo_Payload proto.InternalMessageInfo
  105. func (m *Payload) GetType() PayloadType {
  106. if m != nil {
  107. return m.Type
  108. }
  109. return PayloadType_COMPRESSABLE
  110. }
  111. func (m *Payload) GetBody() []byte {
  112. if m != nil {
  113. return m.Body
  114. }
  115. return nil
  116. }
  117. // A protobuf representation for grpc status. This is used by test
  118. // clients to specify a status that the server should attempt to return.
  119. type EchoStatus struct {
  120. Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
  121. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
  122. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  123. XXX_unrecognized []byte `json:"-"`
  124. XXX_sizecache int32 `json:"-"`
  125. }
  126. func (m *EchoStatus) Reset() { *m = EchoStatus{} }
  127. func (m *EchoStatus) String() string { return proto.CompactTextString(m) }
  128. func (*EchoStatus) ProtoMessage() {}
  129. func (*EchoStatus) Descriptor() ([]byte, []int) {
  130. return fileDescriptor_test_4001f755b984bb27, []int{2}
  131. }
  132. func (m *EchoStatus) XXX_Unmarshal(b []byte) error {
  133. return xxx_messageInfo_EchoStatus.Unmarshal(m, b)
  134. }
  135. func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  136. return xxx_messageInfo_EchoStatus.Marshal(b, m, deterministic)
  137. }
  138. func (dst *EchoStatus) XXX_Merge(src proto.Message) {
  139. xxx_messageInfo_EchoStatus.Merge(dst, src)
  140. }
  141. func (m *EchoStatus) XXX_Size() int {
  142. return xxx_messageInfo_EchoStatus.Size(m)
  143. }
  144. func (m *EchoStatus) XXX_DiscardUnknown() {
  145. xxx_messageInfo_EchoStatus.DiscardUnknown(m)
  146. }
  147. var xxx_messageInfo_EchoStatus proto.InternalMessageInfo
  148. func (m *EchoStatus) GetCode() int32 {
  149. if m != nil {
  150. return m.Code
  151. }
  152. return 0
  153. }
  154. func (m *EchoStatus) GetMessage() string {
  155. if m != nil {
  156. return m.Message
  157. }
  158. return ""
  159. }
  160. // Unary request.
  161. type SimpleRequest struct {
  162. // Desired payload type in the response from the server.
  163. // If response_type is RANDOM, server randomly chooses one from other formats.
  164. ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
  165. // Desired payload size in the response from the server.
  166. // If response_type is COMPRESSABLE, this denotes the size before compression.
  167. ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`
  168. // Optional input payload sent along with the request.
  169. Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
  170. // Whether SimpleResponse should include username.
  171. FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
  172. // Whether SimpleResponse should include OAuth scope.
  173. FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`
  174. // Whether server should return a given status
  175. ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
  176. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  177. XXX_unrecognized []byte `json:"-"`
  178. XXX_sizecache int32 `json:"-"`
  179. }
  180. func (m *SimpleRequest) Reset() { *m = SimpleRequest{} }
  181. func (m *SimpleRequest) String() string { return proto.CompactTextString(m) }
  182. func (*SimpleRequest) ProtoMessage() {}
  183. func (*SimpleRequest) Descriptor() ([]byte, []int) {
  184. return fileDescriptor_test_4001f755b984bb27, []int{3}
  185. }
  186. func (m *SimpleRequest) XXX_Unmarshal(b []byte) error {
  187. return xxx_messageInfo_SimpleRequest.Unmarshal(m, b)
  188. }
  189. func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  190. return xxx_messageInfo_SimpleRequest.Marshal(b, m, deterministic)
  191. }
  192. func (dst *SimpleRequest) XXX_Merge(src proto.Message) {
  193. xxx_messageInfo_SimpleRequest.Merge(dst, src)
  194. }
  195. func (m *SimpleRequest) XXX_Size() int {
  196. return xxx_messageInfo_SimpleRequest.Size(m)
  197. }
  198. func (m *SimpleRequest) XXX_DiscardUnknown() {
  199. xxx_messageInfo_SimpleRequest.DiscardUnknown(m)
  200. }
  201. var xxx_messageInfo_SimpleRequest proto.InternalMessageInfo
  202. func (m *SimpleRequest) GetResponseType() PayloadType {
  203. if m != nil {
  204. return m.ResponseType
  205. }
  206. return PayloadType_COMPRESSABLE
  207. }
  208. func (m *SimpleRequest) GetResponseSize() int32 {
  209. if m != nil {
  210. return m.ResponseSize
  211. }
  212. return 0
  213. }
  214. func (m *SimpleRequest) GetPayload() *Payload {
  215. if m != nil {
  216. return m.Payload
  217. }
  218. return nil
  219. }
  220. func (m *SimpleRequest) GetFillUsername() bool {
  221. if m != nil {
  222. return m.FillUsername
  223. }
  224. return false
  225. }
  226. func (m *SimpleRequest) GetFillOauthScope() bool {
  227. if m != nil {
  228. return m.FillOauthScope
  229. }
  230. return false
  231. }
  232. func (m *SimpleRequest) GetResponseStatus() *EchoStatus {
  233. if m != nil {
  234. return m.ResponseStatus
  235. }
  236. return nil
  237. }
  238. // Unary response, as configured by the request.
  239. type SimpleResponse struct {
  240. // Payload to increase message size.
  241. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
  242. // The user the request came from, for verifying authentication was
  243. // successful when the client expected it.
  244. Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
  245. // OAuth scope.
  246. OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
  247. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  248. XXX_unrecognized []byte `json:"-"`
  249. XXX_sizecache int32 `json:"-"`
  250. }
  251. func (m *SimpleResponse) Reset() { *m = SimpleResponse{} }
  252. func (m *SimpleResponse) String() string { return proto.CompactTextString(m) }
  253. func (*SimpleResponse) ProtoMessage() {}
  254. func (*SimpleResponse) Descriptor() ([]byte, []int) {
  255. return fileDescriptor_test_4001f755b984bb27, []int{4}
  256. }
  257. func (m *SimpleResponse) XXX_Unmarshal(b []byte) error {
  258. return xxx_messageInfo_SimpleResponse.Unmarshal(m, b)
  259. }
  260. func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  261. return xxx_messageInfo_SimpleResponse.Marshal(b, m, deterministic)
  262. }
  263. func (dst *SimpleResponse) XXX_Merge(src proto.Message) {
  264. xxx_messageInfo_SimpleResponse.Merge(dst, src)
  265. }
  266. func (m *SimpleResponse) XXX_Size() int {
  267. return xxx_messageInfo_SimpleResponse.Size(m)
  268. }
  269. func (m *SimpleResponse) XXX_DiscardUnknown() {
  270. xxx_messageInfo_SimpleResponse.DiscardUnknown(m)
  271. }
  272. var xxx_messageInfo_SimpleResponse proto.InternalMessageInfo
  273. func (m *SimpleResponse) GetPayload() *Payload {
  274. if m != nil {
  275. return m.Payload
  276. }
  277. return nil
  278. }
  279. func (m *SimpleResponse) GetUsername() string {
  280. if m != nil {
  281. return m.Username
  282. }
  283. return ""
  284. }
  285. func (m *SimpleResponse) GetOauthScope() string {
  286. if m != nil {
  287. return m.OauthScope
  288. }
  289. return ""
  290. }
  291. // Client-streaming request.
  292. type StreamingInputCallRequest struct {
  293. // Optional input payload sent along with the request.
  294. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
  295. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  296. XXX_unrecognized []byte `json:"-"`
  297. XXX_sizecache int32 `json:"-"`
  298. }
  299. func (m *StreamingInputCallRequest) Reset() { *m = StreamingInputCallRequest{} }
  300. func (m *StreamingInputCallRequest) String() string { return proto.CompactTextString(m) }
  301. func (*StreamingInputCallRequest) ProtoMessage() {}
  302. func (*StreamingInputCallRequest) Descriptor() ([]byte, []int) {
  303. return fileDescriptor_test_4001f755b984bb27, []int{5}
  304. }
  305. func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error {
  306. return xxx_messageInfo_StreamingInputCallRequest.Unmarshal(m, b)
  307. }
  308. func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  309. return xxx_messageInfo_StreamingInputCallRequest.Marshal(b, m, deterministic)
  310. }
  311. func (dst *StreamingInputCallRequest) XXX_Merge(src proto.Message) {
  312. xxx_messageInfo_StreamingInputCallRequest.Merge(dst, src)
  313. }
  314. func (m *StreamingInputCallRequest) XXX_Size() int {
  315. return xxx_messageInfo_StreamingInputCallRequest.Size(m)
  316. }
  317. func (m *StreamingInputCallRequest) XXX_DiscardUnknown() {
  318. xxx_messageInfo_StreamingInputCallRequest.DiscardUnknown(m)
  319. }
  320. var xxx_messageInfo_StreamingInputCallRequest proto.InternalMessageInfo
  321. func (m *StreamingInputCallRequest) GetPayload() *Payload {
  322. if m != nil {
  323. return m.Payload
  324. }
  325. return nil
  326. }
  327. // Client-streaming response.
  328. type StreamingInputCallResponse struct {
  329. // Aggregated size of payloads received from the client.
  330. AggregatedPayloadSize int32 `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize,proto3" json:"aggregated_payload_size,omitempty"`
  331. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  332. XXX_unrecognized []byte `json:"-"`
  333. XXX_sizecache int32 `json:"-"`
  334. }
  335. func (m *StreamingInputCallResponse) Reset() { *m = StreamingInputCallResponse{} }
  336. func (m *StreamingInputCallResponse) String() string { return proto.CompactTextString(m) }
  337. func (*StreamingInputCallResponse) ProtoMessage() {}
  338. func (*StreamingInputCallResponse) Descriptor() ([]byte, []int) {
  339. return fileDescriptor_test_4001f755b984bb27, []int{6}
  340. }
  341. func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error {
  342. return xxx_messageInfo_StreamingInputCallResponse.Unmarshal(m, b)
  343. }
  344. func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  345. return xxx_messageInfo_StreamingInputCallResponse.Marshal(b, m, deterministic)
  346. }
  347. func (dst *StreamingInputCallResponse) XXX_Merge(src proto.Message) {
  348. xxx_messageInfo_StreamingInputCallResponse.Merge(dst, src)
  349. }
  350. func (m *StreamingInputCallResponse) XXX_Size() int {
  351. return xxx_messageInfo_StreamingInputCallResponse.Size(m)
  352. }
  353. func (m *StreamingInputCallResponse) XXX_DiscardUnknown() {
  354. xxx_messageInfo_StreamingInputCallResponse.DiscardUnknown(m)
  355. }
  356. var xxx_messageInfo_StreamingInputCallResponse proto.InternalMessageInfo
  357. func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32 {
  358. if m != nil {
  359. return m.AggregatedPayloadSize
  360. }
  361. return 0
  362. }
  363. // Configuration for a particular response.
  364. type ResponseParameters struct {
  365. // Desired payload sizes in responses from the server.
  366. // If response_type is COMPRESSABLE, this denotes the size before compression.
  367. Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
  368. // Desired interval between consecutive responses in the response stream in
  369. // microseconds.
  370. IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"`
  371. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  372. XXX_unrecognized []byte `json:"-"`
  373. XXX_sizecache int32 `json:"-"`
  374. }
  375. func (m *ResponseParameters) Reset() { *m = ResponseParameters{} }
  376. func (m *ResponseParameters) String() string { return proto.CompactTextString(m) }
  377. func (*ResponseParameters) ProtoMessage() {}
  378. func (*ResponseParameters) Descriptor() ([]byte, []int) {
  379. return fileDescriptor_test_4001f755b984bb27, []int{7}
  380. }
  381. func (m *ResponseParameters) XXX_Unmarshal(b []byte) error {
  382. return xxx_messageInfo_ResponseParameters.Unmarshal(m, b)
  383. }
  384. func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  385. return xxx_messageInfo_ResponseParameters.Marshal(b, m, deterministic)
  386. }
  387. func (dst *ResponseParameters) XXX_Merge(src proto.Message) {
  388. xxx_messageInfo_ResponseParameters.Merge(dst, src)
  389. }
  390. func (m *ResponseParameters) XXX_Size() int {
  391. return xxx_messageInfo_ResponseParameters.Size(m)
  392. }
  393. func (m *ResponseParameters) XXX_DiscardUnknown() {
  394. xxx_messageInfo_ResponseParameters.DiscardUnknown(m)
  395. }
  396. var xxx_messageInfo_ResponseParameters proto.InternalMessageInfo
  397. func (m *ResponseParameters) GetSize() int32 {
  398. if m != nil {
  399. return m.Size
  400. }
  401. return 0
  402. }
  403. func (m *ResponseParameters) GetIntervalUs() int32 {
  404. if m != nil {
  405. return m.IntervalUs
  406. }
  407. return 0
  408. }
  409. // Server-streaming request.
  410. type StreamingOutputCallRequest struct {
  411. // Desired payload type in the response from the server.
  412. // If response_type is RANDOM, the payload from each response in the stream
  413. // might be of different types. This is to simulate a mixed type of payload
  414. // stream.
  415. ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
  416. // Configuration for each expected response message.
  417. ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
  418. // Optional input payload sent along with the request.
  419. Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
  420. // Whether server should return a given status
  421. ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
  422. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  423. XXX_unrecognized []byte `json:"-"`
  424. XXX_sizecache int32 `json:"-"`
  425. }
  426. func (m *StreamingOutputCallRequest) Reset() { *m = StreamingOutputCallRequest{} }
  427. func (m *StreamingOutputCallRequest) String() string { return proto.CompactTextString(m) }
  428. func (*StreamingOutputCallRequest) ProtoMessage() {}
  429. func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int) {
  430. return fileDescriptor_test_4001f755b984bb27, []int{8}
  431. }
  432. func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error {
  433. return xxx_messageInfo_StreamingOutputCallRequest.Unmarshal(m, b)
  434. }
  435. func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  436. return xxx_messageInfo_StreamingOutputCallRequest.Marshal(b, m, deterministic)
  437. }
  438. func (dst *StreamingOutputCallRequest) XXX_Merge(src proto.Message) {
  439. xxx_messageInfo_StreamingOutputCallRequest.Merge(dst, src)
  440. }
  441. func (m *StreamingOutputCallRequest) XXX_Size() int {
  442. return xxx_messageInfo_StreamingOutputCallRequest.Size(m)
  443. }
  444. func (m *StreamingOutputCallRequest) XXX_DiscardUnknown() {
  445. xxx_messageInfo_StreamingOutputCallRequest.DiscardUnknown(m)
  446. }
  447. var xxx_messageInfo_StreamingOutputCallRequest proto.InternalMessageInfo
  448. func (m *StreamingOutputCallRequest) GetResponseType() PayloadType {
  449. if m != nil {
  450. return m.ResponseType
  451. }
  452. return PayloadType_COMPRESSABLE
  453. }
  454. func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters {
  455. if m != nil {
  456. return m.ResponseParameters
  457. }
  458. return nil
  459. }
  460. func (m *StreamingOutputCallRequest) GetPayload() *Payload {
  461. if m != nil {
  462. return m.Payload
  463. }
  464. return nil
  465. }
  466. func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus {
  467. if m != nil {
  468. return m.ResponseStatus
  469. }
  470. return nil
  471. }
  472. // Server-streaming response, as configured by the request and parameters.
  473. type StreamingOutputCallResponse struct {
  474. // Payload to increase response size.
  475. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
  476. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  477. XXX_unrecognized []byte `json:"-"`
  478. XXX_sizecache int32 `json:"-"`
  479. }
  480. func (m *StreamingOutputCallResponse) Reset() { *m = StreamingOutputCallResponse{} }
  481. func (m *StreamingOutputCallResponse) String() string { return proto.CompactTextString(m) }
  482. func (*StreamingOutputCallResponse) ProtoMessage() {}
  483. func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int) {
  484. return fileDescriptor_test_4001f755b984bb27, []int{9}
  485. }
  486. func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error {
  487. return xxx_messageInfo_StreamingOutputCallResponse.Unmarshal(m, b)
  488. }
  489. func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  490. return xxx_messageInfo_StreamingOutputCallResponse.Marshal(b, m, deterministic)
  491. }
  492. func (dst *StreamingOutputCallResponse) XXX_Merge(src proto.Message) {
  493. xxx_messageInfo_StreamingOutputCallResponse.Merge(dst, src)
  494. }
  495. func (m *StreamingOutputCallResponse) XXX_Size() int {
  496. return xxx_messageInfo_StreamingOutputCallResponse.Size(m)
  497. }
  498. func (m *StreamingOutputCallResponse) XXX_DiscardUnknown() {
  499. xxx_messageInfo_StreamingOutputCallResponse.DiscardUnknown(m)
  500. }
  501. var xxx_messageInfo_StreamingOutputCallResponse proto.InternalMessageInfo
  502. func (m *StreamingOutputCallResponse) GetPayload() *Payload {
  503. if m != nil {
  504. return m.Payload
  505. }
  506. return nil
  507. }
  508. func init() {
  509. proto.RegisterType((*Empty)(nil), "grpc.testing.Empty")
  510. proto.RegisterType((*Payload)(nil), "grpc.testing.Payload")
  511. proto.RegisterType((*EchoStatus)(nil), "grpc.testing.EchoStatus")
  512. proto.RegisterType((*SimpleRequest)(nil), "grpc.testing.SimpleRequest")
  513. proto.RegisterType((*SimpleResponse)(nil), "grpc.testing.SimpleResponse")
  514. proto.RegisterType((*StreamingInputCallRequest)(nil), "grpc.testing.StreamingInputCallRequest")
  515. proto.RegisterType((*StreamingInputCallResponse)(nil), "grpc.testing.StreamingInputCallResponse")
  516. proto.RegisterType((*ResponseParameters)(nil), "grpc.testing.ResponseParameters")
  517. proto.RegisterType((*StreamingOutputCallRequest)(nil), "grpc.testing.StreamingOutputCallRequest")
  518. proto.RegisterType((*StreamingOutputCallResponse)(nil), "grpc.testing.StreamingOutputCallResponse")
  519. proto.RegisterEnum("grpc.testing.PayloadType", PayloadType_name, PayloadType_value)
  520. }
  521. // Reference imports to suppress errors if they are not otherwise used.
  522. var _ context.Context
  523. var _ grpc.ClientConn
  524. // This is a compile-time assertion to ensure that this generated file
  525. // is compatible with the grpc package it is being compiled against.
  526. const _ = grpc.SupportPackageIsVersion4
  527. // TestServiceClient is the client API for TestService service.
  528. //
  529. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  530. type TestServiceClient interface {
  531. // One empty request followed by one empty response.
  532. EmptyCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
  533. // One request followed by one response.
  534. // The server returns the client payload as-is.
  535. UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
  536. // One request followed by a sequence of responses (streamed download).
  537. // The server returns the payload with client desired type and sizes.
  538. StreamingOutputCall(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error)
  539. // A sequence of requests followed by one response (streamed upload).
  540. // The server returns the aggregated size of client payload as the result.
  541. StreamingInputCall(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, error)
  542. // A sequence of requests with each request served by the server immediately.
  543. // As one request could lead to multiple responses, this interface
  544. // demonstrates the idea of full duplexing.
  545. FullDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error)
  546. // A sequence of requests followed by a sequence of responses.
  547. // The server buffers all the client requests and then serves them in order. A
  548. // stream of responses are returned to the client when the server starts with
  549. // first request.
  550. HalfDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error)
  551. }
  552. type testServiceClient struct {
  553. cc *grpc.ClientConn
  554. }
  555. func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient {
  556. return &testServiceClient{cc}
  557. }
  558. func (c *testServiceClient) EmptyCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
  559. out := new(Empty)
  560. err := c.cc.Invoke(ctx, "/grpc.testing.TestService/EmptyCall", in, out, opts...)
  561. if err != nil {
  562. return nil, err
  563. }
  564. return out, nil
  565. }
  566. func (c *testServiceClient) UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) {
  567. out := new(SimpleResponse)
  568. err := c.cc.Invoke(ctx, "/grpc.testing.TestService/UnaryCall", in, out, opts...)
  569. if err != nil {
  570. return nil, err
  571. }
  572. return out, nil
  573. }
  574. func (c *testServiceClient) StreamingOutputCall(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error) {
  575. stream, err := c.cc.NewStream(ctx, &_TestService_serviceDesc.Streams[0], "/grpc.testing.TestService/StreamingOutputCall", opts...)
  576. if err != nil {
  577. return nil, err
  578. }
  579. x := &testServiceStreamingOutputCallClient{stream}
  580. if err := x.ClientStream.SendMsg(in); err != nil {
  581. return nil, err
  582. }
  583. if err := x.ClientStream.CloseSend(); err != nil {
  584. return nil, err
  585. }
  586. return x, nil
  587. }
  588. type TestService_StreamingOutputCallClient interface {
  589. Recv() (*StreamingOutputCallResponse, error)
  590. grpc.ClientStream
  591. }
  592. type testServiceStreamingOutputCallClient struct {
  593. grpc.ClientStream
  594. }
  595. func (x *testServiceStreamingOutputCallClient) Recv() (*StreamingOutputCallResponse, error) {
  596. m := new(StreamingOutputCallResponse)
  597. if err := x.ClientStream.RecvMsg(m); err != nil {
  598. return nil, err
  599. }
  600. return m, nil
  601. }
  602. func (c *testServiceClient) StreamingInputCall(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, error) {
  603. stream, err := c.cc.NewStream(ctx, &_TestService_serviceDesc.Streams[1], "/grpc.testing.TestService/StreamingInputCall", opts...)
  604. if err != nil {
  605. return nil, err
  606. }
  607. x := &testServiceStreamingInputCallClient{stream}
  608. return x, nil
  609. }
  610. type TestService_StreamingInputCallClient interface {
  611. Send(*StreamingInputCallRequest) error
  612. CloseAndRecv() (*StreamingInputCallResponse, error)
  613. grpc.ClientStream
  614. }
  615. type testServiceStreamingInputCallClient struct {
  616. grpc.ClientStream
  617. }
  618. func (x *testServiceStreamingInputCallClient) Send(m *StreamingInputCallRequest) error {
  619. return x.ClientStream.SendMsg(m)
  620. }
  621. func (x *testServiceStreamingInputCallClient) CloseAndRecv() (*StreamingInputCallResponse, error) {
  622. if err := x.ClientStream.CloseSend(); err != nil {
  623. return nil, err
  624. }
  625. m := new(StreamingInputCallResponse)
  626. if err := x.ClientStream.RecvMsg(m); err != nil {
  627. return nil, err
  628. }
  629. return m, nil
  630. }
  631. func (c *testServiceClient) FullDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error) {
  632. stream, err := c.cc.NewStream(ctx, &_TestService_serviceDesc.Streams[2], "/grpc.testing.TestService/FullDuplexCall", opts...)
  633. if err != nil {
  634. return nil, err
  635. }
  636. x := &testServiceFullDuplexCallClient{stream}
  637. return x, nil
  638. }
  639. type TestService_FullDuplexCallClient interface {
  640. Send(*StreamingOutputCallRequest) error
  641. Recv() (*StreamingOutputCallResponse, error)
  642. grpc.ClientStream
  643. }
  644. type testServiceFullDuplexCallClient struct {
  645. grpc.ClientStream
  646. }
  647. func (x *testServiceFullDuplexCallClient) Send(m *StreamingOutputCallRequest) error {
  648. return x.ClientStream.SendMsg(m)
  649. }
  650. func (x *testServiceFullDuplexCallClient) Recv() (*StreamingOutputCallResponse, error) {
  651. m := new(StreamingOutputCallResponse)
  652. if err := x.ClientStream.RecvMsg(m); err != nil {
  653. return nil, err
  654. }
  655. return m, nil
  656. }
  657. func (c *testServiceClient) HalfDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error) {
  658. stream, err := c.cc.NewStream(ctx, &_TestService_serviceDesc.Streams[3], "/grpc.testing.TestService/HalfDuplexCall", opts...)
  659. if err != nil {
  660. return nil, err
  661. }
  662. x := &testServiceHalfDuplexCallClient{stream}
  663. return x, nil
  664. }
  665. type TestService_HalfDuplexCallClient interface {
  666. Send(*StreamingOutputCallRequest) error
  667. Recv() (*StreamingOutputCallResponse, error)
  668. grpc.ClientStream
  669. }
  670. type testServiceHalfDuplexCallClient struct {
  671. grpc.ClientStream
  672. }
  673. func (x *testServiceHalfDuplexCallClient) Send(m *StreamingOutputCallRequest) error {
  674. return x.ClientStream.SendMsg(m)
  675. }
  676. func (x *testServiceHalfDuplexCallClient) Recv() (*StreamingOutputCallResponse, error) {
  677. m := new(StreamingOutputCallResponse)
  678. if err := x.ClientStream.RecvMsg(m); err != nil {
  679. return nil, err
  680. }
  681. return m, nil
  682. }
  683. // TestServiceServer is the server API for TestService service.
  684. type TestServiceServer interface {
  685. // One empty request followed by one empty response.
  686. EmptyCall(context.Context, *Empty) (*Empty, error)
  687. // One request followed by one response.
  688. // The server returns the client payload as-is.
  689. UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
  690. // One request followed by a sequence of responses (streamed download).
  691. // The server returns the payload with client desired type and sizes.
  692. StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error
  693. // A sequence of requests followed by one response (streamed upload).
  694. // The server returns the aggregated size of client payload as the result.
  695. StreamingInputCall(TestService_StreamingInputCallServer) error
  696. // A sequence of requests with each request served by the server immediately.
  697. // As one request could lead to multiple responses, this interface
  698. // demonstrates the idea of full duplexing.
  699. FullDuplexCall(TestService_FullDuplexCallServer) error
  700. // A sequence of requests followed by a sequence of responses.
  701. // The server buffers all the client requests and then serves them in order. A
  702. // stream of responses are returned to the client when the server starts with
  703. // first request.
  704. HalfDuplexCall(TestService_HalfDuplexCallServer) error
  705. }
  706. func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer) {
  707. s.RegisterService(&_TestService_serviceDesc, srv)
  708. }
  709. func _TestService_EmptyCall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  710. in := new(Empty)
  711. if err := dec(in); err != nil {
  712. return nil, err
  713. }
  714. if interceptor == nil {
  715. return srv.(TestServiceServer).EmptyCall(ctx, in)
  716. }
  717. info := &grpc.UnaryServerInfo{
  718. Server: srv,
  719. FullMethod: "/grpc.testing.TestService/EmptyCall",
  720. }
  721. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  722. return srv.(TestServiceServer).EmptyCall(ctx, req.(*Empty))
  723. }
  724. return interceptor(ctx, in, info, handler)
  725. }
  726. func _TestService_UnaryCall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  727. in := new(SimpleRequest)
  728. if err := dec(in); err != nil {
  729. return nil, err
  730. }
  731. if interceptor == nil {
  732. return srv.(TestServiceServer).UnaryCall(ctx, in)
  733. }
  734. info := &grpc.UnaryServerInfo{
  735. Server: srv,
  736. FullMethod: "/grpc.testing.TestService/UnaryCall",
  737. }
  738. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  739. return srv.(TestServiceServer).UnaryCall(ctx, req.(*SimpleRequest))
  740. }
  741. return interceptor(ctx, in, info, handler)
  742. }
  743. func _TestService_StreamingOutputCall_Handler(srv interface{}, stream grpc.ServerStream) error {
  744. m := new(StreamingOutputCallRequest)
  745. if err := stream.RecvMsg(m); err != nil {
  746. return err
  747. }
  748. return srv.(TestServiceServer).StreamingOutputCall(m, &testServiceStreamingOutputCallServer{stream})
  749. }
  750. type TestService_StreamingOutputCallServer interface {
  751. Send(*StreamingOutputCallResponse) error
  752. grpc.ServerStream
  753. }
  754. type testServiceStreamingOutputCallServer struct {
  755. grpc.ServerStream
  756. }
  757. func (x *testServiceStreamingOutputCallServer) Send(m *StreamingOutputCallResponse) error {
  758. return x.ServerStream.SendMsg(m)
  759. }
  760. func _TestService_StreamingInputCall_Handler(srv interface{}, stream grpc.ServerStream) error {
  761. return srv.(TestServiceServer).StreamingInputCall(&testServiceStreamingInputCallServer{stream})
  762. }
  763. type TestService_StreamingInputCallServer interface {
  764. SendAndClose(*StreamingInputCallResponse) error
  765. Recv() (*StreamingInputCallRequest, error)
  766. grpc.ServerStream
  767. }
  768. type testServiceStreamingInputCallServer struct {
  769. grpc.ServerStream
  770. }
  771. func (x *testServiceStreamingInputCallServer) SendAndClose(m *StreamingInputCallResponse) error {
  772. return x.ServerStream.SendMsg(m)
  773. }
  774. func (x *testServiceStreamingInputCallServer) Recv() (*StreamingInputCallRequest, error) {
  775. m := new(StreamingInputCallRequest)
  776. if err := x.ServerStream.RecvMsg(m); err != nil {
  777. return nil, err
  778. }
  779. return m, nil
  780. }
  781. func _TestService_FullDuplexCall_Handler(srv interface{}, stream grpc.ServerStream) error {
  782. return srv.(TestServiceServer).FullDuplexCall(&testServiceFullDuplexCallServer{stream})
  783. }
  784. type TestService_FullDuplexCallServer interface {
  785. Send(*StreamingOutputCallResponse) error
  786. Recv() (*StreamingOutputCallRequest, error)
  787. grpc.ServerStream
  788. }
  789. type testServiceFullDuplexCallServer struct {
  790. grpc.ServerStream
  791. }
  792. func (x *testServiceFullDuplexCallServer) Send(m *StreamingOutputCallResponse) error {
  793. return x.ServerStream.SendMsg(m)
  794. }
  795. func (x *testServiceFullDuplexCallServer) Recv() (*StreamingOutputCallRequest, error) {
  796. m := new(StreamingOutputCallRequest)
  797. if err := x.ServerStream.RecvMsg(m); err != nil {
  798. return nil, err
  799. }
  800. return m, nil
  801. }
  802. func _TestService_HalfDuplexCall_Handler(srv interface{}, stream grpc.ServerStream) error {
  803. return srv.(TestServiceServer).HalfDuplexCall(&testServiceHalfDuplexCallServer{stream})
  804. }
  805. type TestService_HalfDuplexCallServer interface {
  806. Send(*StreamingOutputCallResponse) error
  807. Recv() (*StreamingOutputCallRequest, error)
  808. grpc.ServerStream
  809. }
  810. type testServiceHalfDuplexCallServer struct {
  811. grpc.ServerStream
  812. }
  813. func (x *testServiceHalfDuplexCallServer) Send(m *StreamingOutputCallResponse) error {
  814. return x.ServerStream.SendMsg(m)
  815. }
  816. func (x *testServiceHalfDuplexCallServer) Recv() (*StreamingOutputCallRequest, error) {
  817. m := new(StreamingOutputCallRequest)
  818. if err := x.ServerStream.RecvMsg(m); err != nil {
  819. return nil, err
  820. }
  821. return m, nil
  822. }
  823. var _TestService_serviceDesc = grpc.ServiceDesc{
  824. ServiceName: "grpc.testing.TestService",
  825. HandlerType: (*TestServiceServer)(nil),
  826. Methods: []grpc.MethodDesc{
  827. {
  828. MethodName: "EmptyCall",
  829. Handler: _TestService_EmptyCall_Handler,
  830. },
  831. {
  832. MethodName: "UnaryCall",
  833. Handler: _TestService_UnaryCall_Handler,
  834. },
  835. },
  836. Streams: []grpc.StreamDesc{
  837. {
  838. StreamName: "StreamingOutputCall",
  839. Handler: _TestService_StreamingOutputCall_Handler,
  840. ServerStreams: true,
  841. },
  842. {
  843. StreamName: "StreamingInputCall",
  844. Handler: _TestService_StreamingInputCall_Handler,
  845. ClientStreams: true,
  846. },
  847. {
  848. StreamName: "FullDuplexCall",
  849. Handler: _TestService_FullDuplexCall_Handler,
  850. ServerStreams: true,
  851. ClientStreams: true,
  852. },
  853. {
  854. StreamName: "HalfDuplexCall",
  855. Handler: _TestService_HalfDuplexCall_Handler,
  856. ServerStreams: true,
  857. ClientStreams: true,
  858. },
  859. },
  860. Metadata: "grpc_testing/test.proto",
  861. }
  862. // UnimplementedServiceClient is the client API for UnimplementedService service.
  863. //
  864. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  865. type UnimplementedServiceClient interface {
  866. // A call that no server should implement
  867. UnimplementedCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
  868. }
  869. type unimplementedServiceClient struct {
  870. cc *grpc.ClientConn
  871. }
  872. func NewUnimplementedServiceClient(cc *grpc.ClientConn) UnimplementedServiceClient {
  873. return &unimplementedServiceClient{cc}
  874. }
  875. func (c *unimplementedServiceClient) UnimplementedCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
  876. out := new(Empty)
  877. err := c.cc.Invoke(ctx, "/grpc.testing.UnimplementedService/UnimplementedCall", in, out, opts...)
  878. if err != nil {
  879. return nil, err
  880. }
  881. return out, nil
  882. }
  883. // UnimplementedServiceServer is the server API for UnimplementedService service.
  884. type UnimplementedServiceServer interface {
  885. // A call that no server should implement
  886. UnimplementedCall(context.Context, *Empty) (*Empty, error)
  887. }
  888. func RegisterUnimplementedServiceServer(s *grpc.Server, srv UnimplementedServiceServer) {
  889. s.RegisterService(&_UnimplementedService_serviceDesc, srv)
  890. }
  891. func _UnimplementedService_UnimplementedCall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  892. in := new(Empty)
  893. if err := dec(in); err != nil {
  894. return nil, err
  895. }
  896. if interceptor == nil {
  897. return srv.(UnimplementedServiceServer).UnimplementedCall(ctx, in)
  898. }
  899. info := &grpc.UnaryServerInfo{
  900. Server: srv,
  901. FullMethod: "/grpc.testing.UnimplementedService/UnimplementedCall",
  902. }
  903. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  904. return srv.(UnimplementedServiceServer).UnimplementedCall(ctx, req.(*Empty))
  905. }
  906. return interceptor(ctx, in, info, handler)
  907. }
  908. var _UnimplementedService_serviceDesc = grpc.ServiceDesc{
  909. ServiceName: "grpc.testing.UnimplementedService",
  910. HandlerType: (*UnimplementedServiceServer)(nil),
  911. Methods: []grpc.MethodDesc{
  912. {
  913. MethodName: "UnimplementedCall",
  914. Handler: _UnimplementedService_UnimplementedCall_Handler,
  915. },
  916. },
  917. Streams: []grpc.StreamDesc{},
  918. Metadata: "grpc_testing/test.proto",
  919. }
  920. func init() { proto.RegisterFile("grpc_testing/test.proto", fileDescriptor_test_4001f755b984bb27) }
  921. var fileDescriptor_test_4001f755b984bb27 = []byte{
  922. // 664 bytes of a gzipped FileDescriptorProto
  923. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x55, 0xdd, 0x6e, 0xd3, 0x4c,
  924. 0x10, 0xfd, 0x9c, 0x26, 0x4d, 0x3b, 0x49, 0xfd, 0x85, 0x2d, 0x55, 0xdd, 0x14, 0x89, 0xc8, 0x5c,
  925. 0x60, 0x90, 0x48, 0x51, 0x10, 0x5c, 0x20, 0x01, 0x2a, 0x6d, 0x2a, 0x2a, 0xb5, 0x4d, 0xb1, 0x9b,
  926. 0xeb, 0x68, 0x9b, 0x4c, 0x5d, 0x4b, 0xfe, 0xc3, 0xbb, 0xae, 0x48, 0x2f, 0x78, 0x19, 0x1e, 0x82,
  927. 0x0b, 0x5e, 0x0e, 0xed, 0xda, 0x4e, 0x9c, 0xd4, 0x15, 0x0d, 0x7f, 0x57, 0xf1, 0x9e, 0x39, 0x33,
  928. 0x3b, 0x67, 0xe6, 0xd8, 0x81, 0x4d, 0x3b, 0x0a, 0x87, 0x03, 0x8e, 0x8c, 0x3b, 0xbe, 0xbd, 0x23,
  929. 0x7e, 0xdb, 0x61, 0x14, 0xf0, 0x80, 0xd4, 0x45, 0xa0, 0x9d, 0x06, 0xf4, 0x2a, 0x54, 0xba, 0x5e,
  930. 0xc8, 0xc7, 0xfa, 0x11, 0x54, 0x4f, 0xe9, 0xd8, 0x0d, 0xe8, 0x88, 0x3c, 0x83, 0x32, 0x1f, 0x87,
  931. 0xa8, 0x29, 0x2d, 0xc5, 0x50, 0x3b, 0x5b, 0xed, 0x7c, 0x42, 0x3b, 0x25, 0x9d, 0x8d, 0x43, 0x34,
  932. 0x25, 0x8d, 0x10, 0x28, 0x9f, 0x07, 0xa3, 0xb1, 0x56, 0x6a, 0x29, 0x46, 0xdd, 0x94, 0xcf, 0xfa,
  933. 0x6b, 0x80, 0xee, 0xf0, 0x32, 0xb0, 0x38, 0xe5, 0x31, 0x13, 0x8c, 0x61, 0x30, 0x4a, 0x0a, 0x56,
  934. 0x4c, 0xf9, 0x4c, 0x34, 0xa8, 0x7a, 0xc8, 0x18, 0xb5, 0x51, 0x26, 0xae, 0x9a, 0xd9, 0x51, 0xff,
  935. 0x56, 0x82, 0x35, 0xcb, 0xf1, 0x42, 0x17, 0x4d, 0xfc, 0x14, 0x23, 0xe3, 0xe4, 0x2d, 0xac, 0x45,
  936. 0xc8, 0xc2, 0xc0, 0x67, 0x38, 0xb8, 0x5b, 0x67, 0xf5, 0x8c, 0x2f, 0x4e, 0xe4, 0x51, 0x2e, 0x9f,
  937. 0x39, 0xd7, 0xc9, 0x8d, 0x95, 0x29, 0xc9, 0x72, 0xae, 0x91, 0xec, 0x40, 0x35, 0x4c, 0x2a, 0x68,
  938. 0x4b, 0x2d, 0xc5, 0xa8, 0x75, 0x36, 0x0a, 0xcb, 0x9b, 0x19, 0x4b, 0x54, 0xbd, 0x70, 0x5c, 0x77,
  939. 0x10, 0x33, 0x8c, 0x7c, 0xea, 0xa1, 0x56, 0x6e, 0x29, 0xc6, 0x8a, 0x59, 0x17, 0x60, 0x3f, 0xc5,
  940. 0x88, 0x01, 0x0d, 0x49, 0x0a, 0x68, 0xcc, 0x2f, 0x07, 0x6c, 0x18, 0x84, 0xa8, 0x55, 0x24, 0x4f,
  941. 0x15, 0x78, 0x4f, 0xc0, 0x96, 0x40, 0xc9, 0x2e, 0xfc, 0x3f, 0x6d, 0x52, 0xce, 0x4d, 0xab, 0xca,
  942. 0x3e, 0xb4, 0xd9, 0x3e, 0xa6, 0x73, 0x35, 0xd5, 0x89, 0x00, 0x79, 0xd6, 0xbf, 0x80, 0x9a, 0x0d,
  943. 0x2e, 0xc1, 0xf3, 0xa2, 0x94, 0x3b, 0x89, 0x6a, 0xc2, 0xca, 0x44, 0x4f, 0xb2, 0x97, 0xc9, 0x99,
  944. 0x3c, 0x84, 0x5a, 0x5e, 0xc6, 0x92, 0x0c, 0x43, 0x30, 0x91, 0xa0, 0x1f, 0xc1, 0x96, 0xc5, 0x23,
  945. 0xa4, 0x9e, 0xe3, 0xdb, 0x87, 0x7e, 0x18, 0xf3, 0x3d, 0xea, 0xba, 0xd9, 0x12, 0x17, 0x6d, 0x45,
  946. 0x3f, 0x83, 0x66, 0x51, 0xb5, 0x54, 0xd9, 0x2b, 0xd8, 0xa4, 0xb6, 0x1d, 0xa1, 0x4d, 0x39, 0x8e,
  947. 0x06, 0x69, 0x4e, 0xb2, 0xdd, 0xc4, 0x66, 0x1b, 0xd3, 0x70, 0x5a, 0x5a, 0xac, 0x59, 0x3f, 0x04,
  948. 0x92, 0xd5, 0x38, 0xa5, 0x11, 0xf5, 0x90, 0x63, 0x24, 0x1d, 0x9a, 0x4b, 0x95, 0xcf, 0x42, 0xae,
  949. 0xe3, 0x73, 0x8c, 0xae, 0xa8, 0xd8, 0x71, 0xea, 0x19, 0xc8, 0xa0, 0x3e, 0xd3, 0xbf, 0x96, 0x72,
  950. 0x1d, 0xf6, 0x62, 0x3e, 0x27, 0xf8, 0x77, 0x5d, 0xfb, 0x11, 0xd6, 0x27, 0xf9, 0xe1, 0xa4, 0x55,
  951. 0xad, 0xd4, 0x5a, 0x32, 0x6a, 0x9d, 0xd6, 0x6c, 0x95, 0x9b, 0x92, 0x4c, 0x12, 0xdd, 0x94, 0xb9,
  952. 0xb0, 0xc7, 0xff, 0x80, 0x29, 0x4f, 0x60, 0xbb, 0x70, 0x48, 0xbf, 0xe8, 0xd0, 0xa7, 0xef, 0xa0,
  953. 0x96, 0x9b, 0x19, 0x69, 0x40, 0x7d, 0xaf, 0x77, 0x7c, 0x6a, 0x76, 0x2d, 0x6b, 0xf7, 0xfd, 0x51,
  954. 0xb7, 0xf1, 0x1f, 0x21, 0xa0, 0xf6, 0x4f, 0x66, 0x30, 0x85, 0x00, 0x2c, 0x9b, 0xbb, 0x27, 0xfb,
  955. 0xbd, 0xe3, 0x46, 0xa9, 0xf3, 0xbd, 0x0c, 0xb5, 0x33, 0x64, 0xdc, 0xc2, 0xe8, 0xca, 0x19, 0x22,
  956. 0x79, 0x09, 0xab, 0xf2, 0x13, 0x28, 0xda, 0x22, 0xeb, 0x73, 0xba, 0x44, 0xa0, 0x59, 0x04, 0x92,
  957. 0x03, 0x58, 0xed, 0xfb, 0x34, 0x4a, 0xd2, 0xb6, 0x67, 0x19, 0x33, 0x9f, 0xaf, 0xe6, 0x83, 0xe2,
  958. 0x60, 0x3a, 0x00, 0x17, 0xd6, 0x0b, 0xe6, 0x43, 0x8c, 0xb9, 0xa4, 0x5b, 0x7d, 0xd6, 0x7c, 0x72,
  959. 0x07, 0x66, 0x72, 0xd7, 0x73, 0x85, 0x38, 0x40, 0x6e, 0xbe, 0x54, 0xe4, 0xf1, 0x2d, 0x25, 0xe6,
  960. 0x5f, 0xe2, 0xa6, 0xf1, 0x73, 0x62, 0x72, 0x95, 0x21, 0xae, 0x52, 0x0f, 0x62, 0xd7, 0xdd, 0x8f,
  961. 0x43, 0x17, 0x3f, 0xff, 0x35, 0x4d, 0x86, 0x22, 0x55, 0xa9, 0x1f, 0xa8, 0x7b, 0xf1, 0x0f, 0xae,
  962. 0xea, 0xf4, 0xe1, 0x7e, 0xdf, 0x97, 0x1b, 0xf4, 0xd0, 0xe7, 0x38, 0xca, 0x5c, 0xf4, 0x06, 0xee,
  963. 0xcd, 0xe0, 0x8b, 0xb9, 0xe9, 0x7c, 0x59, 0xfe, 0x39, 0xbf, 0xf8, 0x11, 0x00, 0x00, 0xff, 0xff,
  964. 0x87, 0xd4, 0xf3, 0x98, 0xb7, 0x07, 0x00, 0x00,
  965. }