1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package resultstore
22
23 import (
24 context "context"
25 reflect "reflect"
26 sync "sync"
27
28 _ "google.golang.org/genproto/googleapis/api/annotations"
29 grpc "google.golang.org/grpc"
30 codes "google.golang.org/grpc/codes"
31 status "google.golang.org/grpc/status"
32 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
33 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
34 )
35
36 const (
37
38 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
39
40 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
41 )
42
43
44 type GetFileRequest struct {
45 state protoimpl.MessageState
46 sizeCache protoimpl.SizeCache
47 unknownFields protoimpl.UnknownFields
48
49
50 Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
51
52
53
54
55
56 ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
57
58
59
60
61
62
63
64 ReadLimit int64 `protobuf:"varint,3,opt,name=read_limit,json=readLimit,proto3" json:"read_limit,omitempty"`
65
66
67
68 ArchiveEntry string `protobuf:"bytes,4,opt,name=archive_entry,json=archiveEntry,proto3" json:"archive_entry,omitempty"`
69 }
70
71 func (x *GetFileRequest) Reset() {
72 *x = GetFileRequest{}
73 if protoimpl.UnsafeEnabled {
74 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[0]
75 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
76 ms.StoreMessageInfo(mi)
77 }
78 }
79
80 func (x *GetFileRequest) String() string {
81 return protoimpl.X.MessageStringOf(x)
82 }
83
84 func (*GetFileRequest) ProtoMessage() {}
85
86 func (x *GetFileRequest) ProtoReflect() protoreflect.Message {
87 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[0]
88 if protoimpl.UnsafeEnabled && x != nil {
89 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
90 if ms.LoadMessageInfo() == nil {
91 ms.StoreMessageInfo(mi)
92 }
93 return ms
94 }
95 return mi.MessageOf(x)
96 }
97
98
99 func (*GetFileRequest) Descriptor() ([]byte, []int) {
100 return file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescGZIP(), []int{0}
101 }
102
103 func (x *GetFileRequest) GetUri() string {
104 if x != nil {
105 return x.Uri
106 }
107 return ""
108 }
109
110 func (x *GetFileRequest) GetReadOffset() int64 {
111 if x != nil {
112 return x.ReadOffset
113 }
114 return 0
115 }
116
117 func (x *GetFileRequest) GetReadLimit() int64 {
118 if x != nil {
119 return x.ReadLimit
120 }
121 return 0
122 }
123
124 func (x *GetFileRequest) GetArchiveEntry() string {
125 if x != nil {
126 return x.ArchiveEntry
127 }
128 return ""
129 }
130
131
132 type GetFileResponse struct {
133 state protoimpl.MessageState
134 sizeCache protoimpl.SizeCache
135 unknownFields protoimpl.UnknownFields
136
137
138 Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
139 }
140
141 func (x *GetFileResponse) Reset() {
142 *x = GetFileResponse{}
143 if protoimpl.UnsafeEnabled {
144 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[1]
145 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
146 ms.StoreMessageInfo(mi)
147 }
148 }
149
150 func (x *GetFileResponse) String() string {
151 return protoimpl.X.MessageStringOf(x)
152 }
153
154 func (*GetFileResponse) ProtoMessage() {}
155
156 func (x *GetFileResponse) ProtoReflect() protoreflect.Message {
157 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[1]
158 if protoimpl.UnsafeEnabled && x != nil {
159 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
160 if ms.LoadMessageInfo() == nil {
161 ms.StoreMessageInfo(mi)
162 }
163 return ms
164 }
165 return mi.MessageOf(x)
166 }
167
168
169 func (*GetFileResponse) Descriptor() ([]byte, []int) {
170 return file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescGZIP(), []int{1}
171 }
172
173 func (x *GetFileResponse) GetData() []byte {
174 if x != nil {
175 return x.Data
176 }
177 return nil
178 }
179
180
181 type GetFileTailRequest struct {
182 state protoimpl.MessageState
183 sizeCache protoimpl.SizeCache
184 unknownFields protoimpl.UnknownFields
185
186
187 Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
188
189
190
191
192
193 ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
194
195
196
197
198
199 ReadLimit int64 `protobuf:"varint,3,opt,name=read_limit,json=readLimit,proto3" json:"read_limit,omitempty"`
200
201
202
203 ArchiveEntry string `protobuf:"bytes,4,opt,name=archive_entry,json=archiveEntry,proto3" json:"archive_entry,omitempty"`
204 }
205
206 func (x *GetFileTailRequest) Reset() {
207 *x = GetFileTailRequest{}
208 if protoimpl.UnsafeEnabled {
209 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[2]
210 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
211 ms.StoreMessageInfo(mi)
212 }
213 }
214
215 func (x *GetFileTailRequest) String() string {
216 return protoimpl.X.MessageStringOf(x)
217 }
218
219 func (*GetFileTailRequest) ProtoMessage() {}
220
221 func (x *GetFileTailRequest) ProtoReflect() protoreflect.Message {
222 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[2]
223 if protoimpl.UnsafeEnabled && x != nil {
224 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
225 if ms.LoadMessageInfo() == nil {
226 ms.StoreMessageInfo(mi)
227 }
228 return ms
229 }
230 return mi.MessageOf(x)
231 }
232
233
234 func (*GetFileTailRequest) Descriptor() ([]byte, []int) {
235 return file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescGZIP(), []int{2}
236 }
237
238 func (x *GetFileTailRequest) GetUri() string {
239 if x != nil {
240 return x.Uri
241 }
242 return ""
243 }
244
245 func (x *GetFileTailRequest) GetReadOffset() int64 {
246 if x != nil {
247 return x.ReadOffset
248 }
249 return 0
250 }
251
252 func (x *GetFileTailRequest) GetReadLimit() int64 {
253 if x != nil {
254 return x.ReadLimit
255 }
256 return 0
257 }
258
259 func (x *GetFileTailRequest) GetArchiveEntry() string {
260 if x != nil {
261 return x.ArchiveEntry
262 }
263 return ""
264 }
265
266
267 type GetFileTailResponse struct {
268 state protoimpl.MessageState
269 sizeCache protoimpl.SizeCache
270 unknownFields protoimpl.UnknownFields
271
272
273 Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
274 }
275
276 func (x *GetFileTailResponse) Reset() {
277 *x = GetFileTailResponse{}
278 if protoimpl.UnsafeEnabled {
279 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[3]
280 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
281 ms.StoreMessageInfo(mi)
282 }
283 }
284
285 func (x *GetFileTailResponse) String() string {
286 return protoimpl.X.MessageStringOf(x)
287 }
288
289 func (*GetFileTailResponse) ProtoMessage() {}
290
291 func (x *GetFileTailResponse) ProtoReflect() protoreflect.Message {
292 mi := &file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[3]
293 if protoimpl.UnsafeEnabled && x != nil {
294 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
295 if ms.LoadMessageInfo() == nil {
296 ms.StoreMessageInfo(mi)
297 }
298 return ms
299 }
300 return mi.MessageOf(x)
301 }
302
303
304 func (*GetFileTailResponse) Descriptor() ([]byte, []int) {
305 return file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescGZIP(), []int{3}
306 }
307
308 func (x *GetFileTailResponse) GetData() []byte {
309 if x != nil {
310 return x.Data
311 }
312 return nil
313 }
314
315 var File_google_devtools_resultstore_v2_resultstore_file_download_proto protoreflect.FileDescriptor
316
317 var file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDesc = []byte{
318 0x0a, 0x3e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c,
319 0x73, 0x2f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x32,
320 0x2f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x5f, 0x66, 0x69, 0x6c,
321 0x65, 0x5f, 0x64, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, 0x61, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
322 0x12, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c,
323 0x73, 0x2e, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x32,
324 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e,
325 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17,
326 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e,
327 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x87, 0x01, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x46,
328 0x69, 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x75, 0x72,
329 0x69, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, 0x72, 0x69, 0x12, 0x1f, 0x0a, 0x0b,
330 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28,
331 0x03, 0x52, 0x0a, 0x72, 0x65, 0x61, 0x64, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x1d, 0x0a,
332 0x0a, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28,
333 0x03, 0x52, 0x09, 0x72, 0x65, 0x61, 0x64, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x23, 0x0a, 0x0d,
334 0x61, 0x72, 0x63, 0x68, 0x69, 0x76, 0x65, 0x5f, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x18, 0x04, 0x20,
335 0x01, 0x28, 0x09, 0x52, 0x0c, 0x61, 0x72, 0x63, 0x68, 0x69, 0x76, 0x65, 0x45, 0x6e, 0x74, 0x72,
336 0x79, 0x22, 0x25, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70,
337 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
338 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x8b, 0x01, 0x0a, 0x12, 0x47, 0x65, 0x74,
339 0x46, 0x69, 0x6c, 0x65, 0x54, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
340 0x10, 0x0a, 0x03, 0x75, 0x72, 0x69, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, 0x72,
341 0x69, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74,
342 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x72, 0x65, 0x61, 0x64, 0x4f, 0x66, 0x66, 0x73,
343 0x65, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74,
344 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x72, 0x65, 0x61, 0x64, 0x4c, 0x69, 0x6d, 0x69,
345 0x74, 0x12, 0x23, 0x0a, 0x0d, 0x61, 0x72, 0x63, 0x68, 0x69, 0x76, 0x65, 0x5f, 0x65, 0x6e, 0x74,
346 0x72, 0x79, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x61, 0x72, 0x63, 0x68, 0x69, 0x76,
347 0x65, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x22, 0x29, 0x0a, 0x13, 0x47, 0x65, 0x74, 0x46, 0x69, 0x6c,
348 0x65, 0x54, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a,
349 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74,
350 0x61, 0x32, 0x8a, 0x03, 0x0a, 0x17, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x53, 0x74, 0x6f, 0x72,
351 0x65, 0x46, 0x69, 0x6c, 0x65, 0x44, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x86, 0x01,
352 0x0a, 0x07, 0x47, 0x65, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x12, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
353 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x75,
354 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x46, 0x69,
355 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
356 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x75,
357 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x46, 0x69,
358 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x18, 0x82, 0xd3, 0xe4, 0x93,
359 0x02, 0x12, 0x12, 0x10, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x75, 0x72, 0x69, 0x3d, 0x66, 0x69, 0x6c,
360 0x65, 0x2f, 0x2a, 0x7d, 0x30, 0x01, 0x12, 0x95, 0x01, 0x0a, 0x0b, 0x47, 0x65, 0x74, 0x46, 0x69,
361 0x6c, 0x65, 0x54, 0x61, 0x69, 0x6c, 0x12, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
362 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73,
363 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x54,
364 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x33, 0x2e, 0x67, 0x6f, 0x6f,
365 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x72, 0x65, 0x73,
366 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x46,
367 0x69, 0x6c, 0x65, 0x54, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
368 0x1d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x17, 0x12, 0x15, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x75, 0x72,
369 0x69, 0x3d, 0x66, 0x69, 0x6c, 0x65, 0x2f, 0x74, 0x61, 0x69, 0x6c, 0x2f, 0x2a, 0x7d, 0x1a, 0x4e,
370 0xca, 0x41, 0x1a, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x67,
371 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e,
372 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
373 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f,
374 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x8f,
375 0x01, 0x0a, 0x22, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65,
376 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f,
377 0x72, 0x65, 0x2e, 0x76, 0x32, 0x42, 0x1c, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x53, 0x74, 0x6f,
378 0x72, 0x65, 0x46, 0x69, 0x6c, 0x65, 0x44, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, 0x61, 0x64, 0x50, 0x72,
379 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x49, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f,
380 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74,
381 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x64, 0x65, 0x76,
382 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72,
383 0x65, 0x2f, 0x76, 0x32, 0x3b, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x74, 0x6f, 0x72, 0x65,
384 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
385 }
386
387 var (
388 file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescOnce sync.Once
389 file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescData = file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDesc
390 )
391
392 func file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescGZIP() []byte {
393 file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescOnce.Do(func() {
394 file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescData)
395 })
396 return file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDescData
397 }
398
399 var file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
400 var file_google_devtools_resultstore_v2_resultstore_file_download_proto_goTypes = []interface{}{
401 (*GetFileRequest)(nil),
402 (*GetFileResponse)(nil),
403 (*GetFileTailRequest)(nil),
404 (*GetFileTailResponse)(nil),
405 }
406 var file_google_devtools_resultstore_v2_resultstore_file_download_proto_depIdxs = []int32{
407 0,
408 2,
409 1,
410 3,
411 2,
412 0,
413 0,
414 0,
415 0,
416 }
417
418 func init() { file_google_devtools_resultstore_v2_resultstore_file_download_proto_init() }
419 func file_google_devtools_resultstore_v2_resultstore_file_download_proto_init() {
420 if File_google_devtools_resultstore_v2_resultstore_file_download_proto != nil {
421 return
422 }
423 if !protoimpl.UnsafeEnabled {
424 file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
425 switch v := v.(*GetFileRequest); i {
426 case 0:
427 return &v.state
428 case 1:
429 return &v.sizeCache
430 case 2:
431 return &v.unknownFields
432 default:
433 return nil
434 }
435 }
436 file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
437 switch v := v.(*GetFileResponse); i {
438 case 0:
439 return &v.state
440 case 1:
441 return &v.sizeCache
442 case 2:
443 return &v.unknownFields
444 default:
445 return nil
446 }
447 }
448 file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
449 switch v := v.(*GetFileTailRequest); i {
450 case 0:
451 return &v.state
452 case 1:
453 return &v.sizeCache
454 case 2:
455 return &v.unknownFields
456 default:
457 return nil
458 }
459 }
460 file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
461 switch v := v.(*GetFileTailResponse); i {
462 case 0:
463 return &v.state
464 case 1:
465 return &v.sizeCache
466 case 2:
467 return &v.unknownFields
468 default:
469 return nil
470 }
471 }
472 }
473 type x struct{}
474 out := protoimpl.TypeBuilder{
475 File: protoimpl.DescBuilder{
476 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
477 RawDescriptor: file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDesc,
478 NumEnums: 0,
479 NumMessages: 4,
480 NumExtensions: 0,
481 NumServices: 1,
482 },
483 GoTypes: file_google_devtools_resultstore_v2_resultstore_file_download_proto_goTypes,
484 DependencyIndexes: file_google_devtools_resultstore_v2_resultstore_file_download_proto_depIdxs,
485 MessageInfos: file_google_devtools_resultstore_v2_resultstore_file_download_proto_msgTypes,
486 }.Build()
487 File_google_devtools_resultstore_v2_resultstore_file_download_proto = out.File
488 file_google_devtools_resultstore_v2_resultstore_file_download_proto_rawDesc = nil
489 file_google_devtools_resultstore_v2_resultstore_file_download_proto_goTypes = nil
490 file_google_devtools_resultstore_v2_resultstore_file_download_proto_depIdxs = nil
491 }
492
493
494 var _ context.Context
495 var _ grpc.ClientConnInterface
496
497
498
499 const _ = grpc.SupportPackageIsVersion6
500
501
502
503
504 type ResultStoreFileDownloadClient interface {
505
506
507
508
509
510
511 GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (ResultStoreFileDownload_GetFileClient, error)
512
513
514
515
516
517 GetFileTail(ctx context.Context, in *GetFileTailRequest, opts ...grpc.CallOption) (*GetFileTailResponse, error)
518 }
519
520 type resultStoreFileDownloadClient struct {
521 cc grpc.ClientConnInterface
522 }
523
524 func NewResultStoreFileDownloadClient(cc grpc.ClientConnInterface) ResultStoreFileDownloadClient {
525 return &resultStoreFileDownloadClient{cc}
526 }
527
528 func (c *resultStoreFileDownloadClient) GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (ResultStoreFileDownload_GetFileClient, error) {
529 stream, err := c.cc.NewStream(ctx, &_ResultStoreFileDownload_serviceDesc.Streams[0], "/google.devtools.resultstore.v2.ResultStoreFileDownload/GetFile", opts...)
530 if err != nil {
531 return nil, err
532 }
533 x := &resultStoreFileDownloadGetFileClient{stream}
534 if err := x.ClientStream.SendMsg(in); err != nil {
535 return nil, err
536 }
537 if err := x.ClientStream.CloseSend(); err != nil {
538 return nil, err
539 }
540 return x, nil
541 }
542
543 type ResultStoreFileDownload_GetFileClient interface {
544 Recv() (*GetFileResponse, error)
545 grpc.ClientStream
546 }
547
548 type resultStoreFileDownloadGetFileClient struct {
549 grpc.ClientStream
550 }
551
552 func (x *resultStoreFileDownloadGetFileClient) Recv() (*GetFileResponse, error) {
553 m := new(GetFileResponse)
554 if err := x.ClientStream.RecvMsg(m); err != nil {
555 return nil, err
556 }
557 return m, nil
558 }
559
560 func (c *resultStoreFileDownloadClient) GetFileTail(ctx context.Context, in *GetFileTailRequest, opts ...grpc.CallOption) (*GetFileTailResponse, error) {
561 out := new(GetFileTailResponse)
562 err := c.cc.Invoke(ctx, "/google.devtools.resultstore.v2.ResultStoreFileDownload/GetFileTail", in, out, opts...)
563 if err != nil {
564 return nil, err
565 }
566 return out, nil
567 }
568
569
570 type ResultStoreFileDownloadServer interface {
571
572
573
574
575
576
577 GetFile(*GetFileRequest, ResultStoreFileDownload_GetFileServer) error
578
579
580
581
582
583 GetFileTail(context.Context, *GetFileTailRequest) (*GetFileTailResponse, error)
584 }
585
586
587 type UnimplementedResultStoreFileDownloadServer struct {
588 }
589
590 func (*UnimplementedResultStoreFileDownloadServer) GetFile(*GetFileRequest, ResultStoreFileDownload_GetFileServer) error {
591 return status.Errorf(codes.Unimplemented, "method GetFile not implemented")
592 }
593 func (*UnimplementedResultStoreFileDownloadServer) GetFileTail(context.Context, *GetFileTailRequest) (*GetFileTailResponse, error) {
594 return nil, status.Errorf(codes.Unimplemented, "method GetFileTail not implemented")
595 }
596
597 func RegisterResultStoreFileDownloadServer(s *grpc.Server, srv ResultStoreFileDownloadServer) {
598 s.RegisterService(&_ResultStoreFileDownload_serviceDesc, srv)
599 }
600
601 func _ResultStoreFileDownload_GetFile_Handler(srv interface{}, stream grpc.ServerStream) error {
602 m := new(GetFileRequest)
603 if err := stream.RecvMsg(m); err != nil {
604 return err
605 }
606 return srv.(ResultStoreFileDownloadServer).GetFile(m, &resultStoreFileDownloadGetFileServer{stream})
607 }
608
609 type ResultStoreFileDownload_GetFileServer interface {
610 Send(*GetFileResponse) error
611 grpc.ServerStream
612 }
613
614 type resultStoreFileDownloadGetFileServer struct {
615 grpc.ServerStream
616 }
617
618 func (x *resultStoreFileDownloadGetFileServer) Send(m *GetFileResponse) error {
619 return x.ServerStream.SendMsg(m)
620 }
621
622 func _ResultStoreFileDownload_GetFileTail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
623 in := new(GetFileTailRequest)
624 if err := dec(in); err != nil {
625 return nil, err
626 }
627 if interceptor == nil {
628 return srv.(ResultStoreFileDownloadServer).GetFileTail(ctx, in)
629 }
630 info := &grpc.UnaryServerInfo{
631 Server: srv,
632 FullMethod: "/google.devtools.resultstore.v2.ResultStoreFileDownload/GetFileTail",
633 }
634 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
635 return srv.(ResultStoreFileDownloadServer).GetFileTail(ctx, req.(*GetFileTailRequest))
636 }
637 return interceptor(ctx, in, info, handler)
638 }
639
640 var _ResultStoreFileDownload_serviceDesc = grpc.ServiceDesc{
641 ServiceName: "google.devtools.resultstore.v2.ResultStoreFileDownload",
642 HandlerType: (*ResultStoreFileDownloadServer)(nil),
643 Methods: []grpc.MethodDesc{
644 {
645 MethodName: "GetFileTail",
646 Handler: _ResultStoreFileDownload_GetFileTail_Handler,
647 },
648 },
649 Streams: []grpc.StreamDesc{
650 {
651 StreamName: "GetFile",
652 Handler: _ResultStoreFileDownload_GetFile_Handler,
653 ServerStreams: true,
654 },
655 },
656 Metadata: "google/devtools/resultstore/v2/resultstore_file_download.proto",
657 }
658
View as plain text