1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
#![allow(unknown_lints)]
#![allow(clippy::all)]
#![allow(unused_attributes)]
#![cfg_attr(rustfmt, rustfmt::skip)]
#![allow(box_pointers)]
#![allow(dead_code)]
#![allow(missing_docs)]
#![allow(non_camel_case_types)]
#![allow(non_snake_case)]
#![allow(non_upper_case_globals)]
#![allow(trivial_casts)]
#![allow(unused_imports)]
#![allow(unused_results)]
static file_descriptor_proto_data: &'static [u8] = b"\
\n\x17grpc/testing/test.proto\x12\x0cgrpc.testing\x1a\x18grpc/testing/em\
pty.proto\x1a\x1bgrpc/testing/messages.proto2\xcb\x05\n\x0bTestService\
\x125\n\tEmptyCall\x12\x13.grpc.testing.Empty\x1a\x13.grpc.testing.Empty\
\x12F\n\tUnaryCall\x12\x1b.grpc.testing.SimpleRequest\x1a\x1c.grpc.testi\
ng.SimpleResponse\x12O\n\x12CacheableUnaryCall\x12\x1b.grpc.testing.Simp\
leRequest\x1a\x1c.grpc.testing.SimpleResponse\x12l\n\x13StreamingOutputC\
all\x12(.grpc.testing.StreamingOutputCallRequest\x1a).grpc.testing.Strea\
mingOutputCallResponse0\x01\x12i\n\x12StreamingInputCall\x12'.grpc.testi\
ng.StreamingInputCallRequest\x1a(.grpc.testing.StreamingInputCallRespons\
e(\x01\x12i\n\x0eFullDuplexCall\x12(.grpc.testing.StreamingOutputCallReq\
uest\x1a).grpc.testing.StreamingOutputCallResponse(\x010\x01\x12i\n\x0eH\
alfDuplexCall\x12(.grpc.testing.StreamingOutputCallRequest\x1a).grpc.tes\
ting.StreamingOutputCallResponse(\x010\x01\x12=\n\x11UnimplementedCall\
\x12\x13.grpc.testing.Empty\x1a\x13.grpc.testing.Empty2U\n\x14Unimplemen\
tedService\x12=\n\x11UnimplementedCall\x12\x13.grpc.testing.Empty\x1a\
\x13.grpc.testing.Empty2\x89\x01\n\x10ReconnectService\x12;\n\x05Start\
\x12\x1d.grpc.testing.ReconnectParams\x1a\x13.grpc.testing.Empty\x128\n\
\x04Stop\x12\x13.grpc.testing.Empty\x1a\x1b.grpc.testing.ReconnectInfoJ\
\xd0\x16\n\x06\x12\x04\x12\0N\x01\n\xbd\x05\n\x01\x0c\x12\x03\x12\0\x122\
\xb9\x04\x20Copyright\x202015-2016\x20gRPC\x20authors.\n\n\x20Licensed\
\x20under\x20the\x20Apache\x20License,\x20Version\x202.0\x20(the\x20\"Li\
cense\");\n\x20you\x20may\x20not\x20use\x20this\x20file\x20except\x20in\
\x20compliance\x20with\x20the\x20License.\n\x20You\x20may\x20obtain\x20a\
\x20copy\x20of\x20the\x20License\x20at\n\n\x20\x20\x20\x20\x20http://www\
.apache.org/licenses/LICENSE-2.0\n\n\x20Unless\x20required\x20by\x20appl\
icable\x20law\x20or\x20agreed\x20to\x20in\x20writing,\x20software\n\x20d\
istributed\x20under\x20the\x20License\x20is\x20distributed\x20on\x20an\
\x20\"AS\x20IS\"\x20BASIS,\n\x20WITHOUT\x20WARRANTIES\x20OR\x20CONDITION\
S\x20OF\x20ANY\x20KIND,\x20either\x20express\x20or\x20implied.\n\x20See\
\x20the\x20License\x20for\x20the\x20specific\x20language\x20governing\
\x20permissions\x20and\n\x20limitations\x20under\x20the\x20License.\n2w\
\x20An\x20integration\x20test\x20service\x20that\x20covers\x20all\x20the\
\x20method\x20signature\x20permutations\n\x20of\x20unary/streaming\x20re\
quests/responses.\n\n\t\n\x02\x03\0\x12\x03\x14\x07!\n\t\n\x02\x03\x01\
\x12\x03\x15\x07$\n\x08\n\x01\x02\x12\x03\x17\x08\x14\n\x80\x01\n\x02\
\x06\0\x12\x04\x1b\0A\x01\x1at\x20A\x20simple\x20service\x20to\x20test\
\x20the\x20various\x20types\x20of\x20RPCs\x20and\x20experiment\x20with\n\
\x20performance\x20with\x20various\x20types\x20of\x20payload.\n\n\n\n\
\x03\x06\0\x01\x12\x03\x1b\x08\x13\n@\n\x04\x06\0\x02\0\x12\x03\x1d\x02A\
\x1a3\x20One\x20empty\x20request\x20followed\x20by\x20one\x20empty\x20re\
sponse.\n\n\x0c\n\x05\x06\0\x02\0\x01\x12\x03\x1d\x06\x0f\n\x0c\n\x05\
\x06\0\x02\0\x02\x12\x03\x1d\x10\"\n\x0c\n\x05\x06\0\x02\0\x03\x12\x03\
\x1d-?\n4\n\x04\x06\0\x02\x01\x12\x03\x20\x028\x1a'\x20One\x20request\
\x20followed\x20by\x20one\x20response.\n\n\x0c\n\x05\x06\0\x02\x01\x01\
\x12\x03\x20\x06\x0f\n\x0c\n\x05\x06\0\x02\x01\x02\x12\x03\x20\x10\x1d\n\
\x0c\n\x05\x06\0\x02\x01\x03\x12\x03\x20(6\n\xac\x01\n\x04\x06\0\x02\x02\
\x12\x03%\x02A\x1a\x9e\x01\x20One\x20request\x20followed\x20by\x20one\
\x20response.\x20Response\x20has\x20cache\x20control\n\x20headers\x20set\
\x20such\x20that\x20a\x20caching\x20HTTP\x20proxy\x20(such\x20as\x20GFE)\
\x20can\n\x20satisfy\x20subsequent\x20requests.\n\n\x0c\n\x05\x06\0\x02\
\x02\x01\x12\x03%\x06\x18\n\x0c\n\x05\x06\0\x02\x02\x02\x12\x03%\x19&\n\
\x0c\n\x05\x06\0\x02\x02\x03\x12\x03%1?\n\x99\x01\n\x04\x06\0\x02\x03\
\x12\x04)\x02*3\x1a\x8a\x01\x20One\x20request\x20followed\x20by\x20a\x20\
sequence\x20of\x20responses\x20(streamed\x20download).\n\x20The\x20serve\
r\x20returns\x20the\x20payload\x20with\x20client\x20desired\x20type\x20a\
nd\x20sizes.\n\n\x0c\n\x05\x06\0\x02\x03\x01\x12\x03)\x06\x19\n\x0c\n\
\x05\x06\0\x02\x03\x02\x12\x03)\x1a4\n\x0c\n\x05\x06\0\x02\x03\x06\x12\
\x03*\x0f\x15\n\x0c\n\x05\x06\0\x02\x03\x03\x12\x03*\x161\n\x9c\x01\n\
\x04\x06\0\x02\x04\x12\x04.\x02/+\x1a\x8d\x01\x20A\x20sequence\x20of\x20\
requests\x20followed\x20by\x20one\x20response\x20(streamed\x20upload).\n\
\x20The\x20server\x20returns\x20the\x20aggregated\x20size\x20of\x20clien\
t\x20payload\x20as\x20the\x20result.\n\n\x0c\n\x05\x06\0\x02\x04\x01\x12\
\x03.\x06\x18\n\x0c\n\x05\x06\0\x02\x04\x05\x12\x03.\x19\x1f\n\x0c\n\x05\
\x06\0\x02\x04\x02\x12\x03.\x209\n\x0c\n\x05\x06\0\x02\x04\x03\x12\x03/\
\x0f)\n\xc6\x01\n\x04\x06\0\x02\x05\x12\x044\x0253\x1a\xb7\x01\x20A\x20s\
equence\x20of\x20requests\x20with\x20each\x20request\x20served\x20by\x20\
the\x20server\x20immediately.\n\x20As\x20one\x20request\x20could\x20lead\
\x20to\x20multiple\x20responses,\x20this\x20interface\n\x20demonstrates\
\x20the\x20idea\x20of\x20full\x20duplexing.\n\n\x0c\n\x05\x06\0\x02\x05\
\x01\x12\x034\x06\x14\n\x0c\n\x05\x06\0\x02\x05\x05\x12\x034\x15\x1b\n\
\x0c\n\x05\x06\0\x02\x05\x02\x12\x034\x1c6\n\x0c\n\x05\x06\0\x02\x05\x06\
\x12\x035\x0f\x15\n\x0c\n\x05\x06\0\x02\x05\x03\x12\x035\x161\n\xf5\x01\
\n\x04\x06\0\x02\x06\x12\x04;\x02<3\x1a\xe6\x01\x20A\x20sequence\x20of\
\x20requests\x20followed\x20by\x20a\x20sequence\x20of\x20responses.\n\
\x20The\x20server\x20buffers\x20all\x20the\x20client\x20requests\x20and\
\x20then\x20serves\x20them\x20in\x20order.\x20A\n\x20stream\x20of\x20res\
ponses\x20are\x20returned\x20to\x20the\x20client\x20when\x20the\x20serve\
r\x20starts\x20with\n\x20first\x20request.\n\n\x0c\n\x05\x06\0\x02\x06\
\x01\x12\x03;\x06\x14\n\x0c\n\x05\x06\0\x02\x06\x05\x12\x03;\x15\x1b\n\
\x0c\n\x05\x06\0\x02\x06\x02\x12\x03;\x1c6\n\x0c\n\x05\x06\0\x02\x06\x06\
\x12\x03<\x0f\x15\n\x0c\n\x05\x06\0\x02\x06\x03\x12\x03<\x161\n\x8e\x01\
\n\x04\x06\0\x02\x07\x12\x03@\x02I\x1a\x80\x01\x20The\x20test\x20server\
\x20will\x20not\x20implement\x20this\x20method.\x20It\x20will\x20be\x20u\
sed\n\x20to\x20test\x20the\x20behavior\x20when\x20clients\x20call\x20uni\
mplemented\x20methods.\n\n\x0c\n\x05\x06\0\x02\x07\x01\x12\x03@\x06\x17\
\n\x0c\n\x05\x06\0\x02\x07\x02\x12\x03@\x18*\n\x0c\n\x05\x06\0\x02\x07\
\x03\x12\x03@5G\n]\n\x02\x06\x01\x12\x04E\0H\x01\x1aQ\x20A\x20simple\x20\
service\x20NOT\x20implemented\x20at\x20servers\x20so\x20clients\x20can\
\x20test\x20for\n\x20that\x20case.\n\n\n\n\x03\x06\x01\x01\x12\x03E\x08\
\x1c\n5\n\x04\x06\x01\x02\0\x12\x03G\x02I\x1a(\x20A\x20call\x20that\x20n\
o\x20server\x20should\x20implement\n\n\x0c\n\x05\x06\x01\x02\0\x01\x12\
\x03G\x06\x17\n\x0c\n\x05\x06\x01\x02\0\x02\x12\x03G\x18*\n\x0c\n\x05\
\x06\x01\x02\0\x03\x12\x03G5G\n9\n\x02\x06\x02\x12\x04K\0N\x01\x1a-\x20A\
\x20service\x20used\x20to\x20control\x20reconnect\x20server.\n\n\n\n\x03\
\x06\x02\x01\x12\x03K\x08\x18\n\x0b\n\x04\x06\x02\x02\0\x12\x03L\x02G\n\
\x0c\n\x05\x06\x02\x02\0\x01\x12\x03L\x06\x0b\n\x0c\n\x05\x06\x02\x02\0\
\x02\x12\x03L\x0c(\n\x0c\n\x05\x06\x02\x02\0\x03\x12\x03L3E\n\x0b\n\x04\
\x06\x02\x02\x01\x12\x03M\x02D\n\x0c\n\x05\x06\x02\x02\x01\x01\x12\x03M\
\x06\n\n\x0c\n\x05\x06\x02\x02\x01\x02\x12\x03M\x0b\x1d\n\x0c\n\x05\x06\
\x02\x02\x01\x03\x12\x03M(Bb\x06proto3\
";
static file_descriptor_proto_lazy: ::protobuf::rt::LazyV2<::protobuf::descriptor::FileDescriptorProto> = ::protobuf::rt::LazyV2::INIT;
fn parse_descriptor_proto() -> ::protobuf::descriptor::FileDescriptorProto {
::protobuf::Message::parse_from_bytes(file_descriptor_proto_data).unwrap()
}
pub fn file_descriptor_proto() -> &'static ::protobuf::descriptor::FileDescriptorProto {
file_descriptor_proto_lazy.get(|| {
parse_descriptor_proto()
})
}
pub use super::test_grpc::*;