1// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: google/firestore/v1beta1/firestore.proto
3
4package firestore
5
6import (
7	context "context"
8	fmt "fmt"
9	math "math"
10
11	proto "github.com/golang/protobuf/proto"
12	empty "github.com/golang/protobuf/ptypes/empty"
13	timestamp "github.com/golang/protobuf/ptypes/timestamp"
14	_ "google.golang.org/genproto/googleapis/api/annotations"
15	status "google.golang.org/genproto/googleapis/rpc/status"
16	grpc "google.golang.org/grpc"
17)
18
19// Reference imports to suppress errors if they are not otherwise used.
20var _ = proto.Marshal
21var _ = fmt.Errorf
22var _ = math.Inf
23
24// This is a compile-time assertion to ensure that this generated file
25// is compatible with the proto package it is being compiled against.
26// A compilation error at this line likely means your copy of the
27// proto package needs to be updated.
28const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
29
30// The type of change.
31type TargetChange_TargetChangeType int32
32
33const (
34	// No change has occurred. Used only to send an updated `resume_token`.
35	TargetChange_NO_CHANGE TargetChange_TargetChangeType = 0
36	// The targets have been added.
37	TargetChange_ADD TargetChange_TargetChangeType = 1
38	// The targets have been removed.
39	TargetChange_REMOVE TargetChange_TargetChangeType = 2
40	// The targets reflect all changes committed before the targets were added
41	// to the stream.
42	//
43	// This will be sent after or with a `read_time` that is greater than or
44	// equal to the time at which the targets were added.
45	//
46	// Listeners can wait for this change if read-after-write semantics
47	// are desired.
48	TargetChange_CURRENT TargetChange_TargetChangeType = 3
49	// The targets have been reset, and a new initial state for the targets
50	// will be returned in subsequent changes.
51	//
52	// After the initial state is complete, `CURRENT` will be returned even
53	// if the target was previously indicated to be `CURRENT`.
54	TargetChange_RESET TargetChange_TargetChangeType = 4
55)
56
57var TargetChange_TargetChangeType_name = map[int32]string{
58	0: "NO_CHANGE",
59	1: "ADD",
60	2: "REMOVE",
61	3: "CURRENT",
62	4: "RESET",
63}
64
65var TargetChange_TargetChangeType_value = map[string]int32{
66	"NO_CHANGE": 0,
67	"ADD":       1,
68	"REMOVE":    2,
69	"CURRENT":   3,
70	"RESET":     4,
71}
72
73func (x TargetChange_TargetChangeType) String() string {
74	return proto.EnumName(TargetChange_TargetChangeType_name, int32(x))
75}
76
77func (TargetChange_TargetChangeType) EnumDescriptor() ([]byte, []int) {
78	return fileDescriptor_9bc8b30a28454f4b, []int{20, 0}
79}
80
81// The request for [Firestore.GetDocument][google.firestore.v1beta1.Firestore.GetDocument].
82type GetDocumentRequest struct {
83	// The resource name of the Document to get. In the format:
84	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
85	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
86	// The fields to return. If not set, returns all fields.
87	//
88	// If the document has a field that is not present in this mask, that field
89	// will not be returned in the response.
90	Mask *DocumentMask `protobuf:"bytes,2,opt,name=mask,proto3" json:"mask,omitempty"`
91	// The consistency mode for this transaction.
92	// If not set, defaults to strong consistency.
93	//
94	// Types that are valid to be assigned to ConsistencySelector:
95	//	*GetDocumentRequest_Transaction
96	//	*GetDocumentRequest_ReadTime
97	ConsistencySelector  isGetDocumentRequest_ConsistencySelector `protobuf_oneof:"consistency_selector"`
98	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
99	XXX_unrecognized     []byte                                   `json:"-"`
100	XXX_sizecache        int32                                    `json:"-"`
101}
102
103func (m *GetDocumentRequest) Reset()         { *m = GetDocumentRequest{} }
104func (m *GetDocumentRequest) String() string { return proto.CompactTextString(m) }
105func (*GetDocumentRequest) ProtoMessage()    {}
106func (*GetDocumentRequest) Descriptor() ([]byte, []int) {
107	return fileDescriptor_9bc8b30a28454f4b, []int{0}
108}
109
110func (m *GetDocumentRequest) XXX_Unmarshal(b []byte) error {
111	return xxx_messageInfo_GetDocumentRequest.Unmarshal(m, b)
112}
113func (m *GetDocumentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
114	return xxx_messageInfo_GetDocumentRequest.Marshal(b, m, deterministic)
115}
116func (m *GetDocumentRequest) XXX_Merge(src proto.Message) {
117	xxx_messageInfo_GetDocumentRequest.Merge(m, src)
118}
119func (m *GetDocumentRequest) XXX_Size() int {
120	return xxx_messageInfo_GetDocumentRequest.Size(m)
121}
122func (m *GetDocumentRequest) XXX_DiscardUnknown() {
123	xxx_messageInfo_GetDocumentRequest.DiscardUnknown(m)
124}
125
126var xxx_messageInfo_GetDocumentRequest proto.InternalMessageInfo
127
128func (m *GetDocumentRequest) GetName() string {
129	if m != nil {
130		return m.Name
131	}
132	return ""
133}
134
135func (m *GetDocumentRequest) GetMask() *DocumentMask {
136	if m != nil {
137		return m.Mask
138	}
139	return nil
140}
141
142type isGetDocumentRequest_ConsistencySelector interface {
143	isGetDocumentRequest_ConsistencySelector()
144}
145
146type GetDocumentRequest_Transaction struct {
147	Transaction []byte `protobuf:"bytes,3,opt,name=transaction,proto3,oneof"`
148}
149
150type GetDocumentRequest_ReadTime struct {
151	ReadTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=read_time,json=readTime,proto3,oneof"`
152}
153
154func (*GetDocumentRequest_Transaction) isGetDocumentRequest_ConsistencySelector() {}
155
156func (*GetDocumentRequest_ReadTime) isGetDocumentRequest_ConsistencySelector() {}
157
158func (m *GetDocumentRequest) GetConsistencySelector() isGetDocumentRequest_ConsistencySelector {
159	if m != nil {
160		return m.ConsistencySelector
161	}
162	return nil
163}
164
165func (m *GetDocumentRequest) GetTransaction() []byte {
166	if x, ok := m.GetConsistencySelector().(*GetDocumentRequest_Transaction); ok {
167		return x.Transaction
168	}
169	return nil
170}
171
172func (m *GetDocumentRequest) GetReadTime() *timestamp.Timestamp {
173	if x, ok := m.GetConsistencySelector().(*GetDocumentRequest_ReadTime); ok {
174		return x.ReadTime
175	}
176	return nil
177}
178
179// XXX_OneofWrappers is for the internal use of the proto package.
180func (*GetDocumentRequest) XXX_OneofWrappers() []interface{} {
181	return []interface{}{
182		(*GetDocumentRequest_Transaction)(nil),
183		(*GetDocumentRequest_ReadTime)(nil),
184	}
185}
186
187// The request for [Firestore.ListDocuments][google.firestore.v1beta1.Firestore.ListDocuments].
188type ListDocumentsRequest struct {
189	// The parent resource name. In the format:
190	// `projects/{project_id}/databases/{database_id}/documents` or
191	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
192	// For example:
193	// `projects/my-project/databases/my-database/documents` or
194	// `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
195	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
196	// The collection ID, relative to `parent`, to list. For example: `chatrooms`
197	// or `messages`.
198	CollectionId string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
199	// The maximum number of documents to return.
200	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
201	// The `next_page_token` value returned from a previous List request, if any.
202	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
203	// The order to sort results by. For example: `priority desc, name`.
204	OrderBy string `protobuf:"bytes,6,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
205	// The fields to return. If not set, returns all fields.
206	//
207	// If a document has a field that is not present in this mask, that field
208	// will not be returned in the response.
209	Mask *DocumentMask `protobuf:"bytes,7,opt,name=mask,proto3" json:"mask,omitempty"`
210	// The consistency mode for this transaction.
211	// If not set, defaults to strong consistency.
212	//
213	// Types that are valid to be assigned to ConsistencySelector:
214	//	*ListDocumentsRequest_Transaction
215	//	*ListDocumentsRequest_ReadTime
216	ConsistencySelector isListDocumentsRequest_ConsistencySelector `protobuf_oneof:"consistency_selector"`
217	// If the list should show missing documents. A missing document is a
218	// document that does not exist but has sub-documents. These documents will
219	// be returned with a key but will not have fields, [Document.create_time][google.firestore.v1beta1.Document.create_time],
220	// or [Document.update_time][google.firestore.v1beta1.Document.update_time] set.
221	//
222	// Requests with `show_missing` may not specify `where` or
223	// `order_by`.
224	ShowMissing          bool     `protobuf:"varint,12,opt,name=show_missing,json=showMissing,proto3" json:"show_missing,omitempty"`
225	XXX_NoUnkeyedLiteral struct{} `json:"-"`
226	XXX_unrecognized     []byte   `json:"-"`
227	XXX_sizecache        int32    `json:"-"`
228}
229
230func (m *ListDocumentsRequest) Reset()         { *m = ListDocumentsRequest{} }
231func (m *ListDocumentsRequest) String() string { return proto.CompactTextString(m) }
232func (*ListDocumentsRequest) ProtoMessage()    {}
233func (*ListDocumentsRequest) Descriptor() ([]byte, []int) {
234	return fileDescriptor_9bc8b30a28454f4b, []int{1}
235}
236
237func (m *ListDocumentsRequest) XXX_Unmarshal(b []byte) error {
238	return xxx_messageInfo_ListDocumentsRequest.Unmarshal(m, b)
239}
240func (m *ListDocumentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
241	return xxx_messageInfo_ListDocumentsRequest.Marshal(b, m, deterministic)
242}
243func (m *ListDocumentsRequest) XXX_Merge(src proto.Message) {
244	xxx_messageInfo_ListDocumentsRequest.Merge(m, src)
245}
246func (m *ListDocumentsRequest) XXX_Size() int {
247	return xxx_messageInfo_ListDocumentsRequest.Size(m)
248}
249func (m *ListDocumentsRequest) XXX_DiscardUnknown() {
250	xxx_messageInfo_ListDocumentsRequest.DiscardUnknown(m)
251}
252
253var xxx_messageInfo_ListDocumentsRequest proto.InternalMessageInfo
254
255func (m *ListDocumentsRequest) GetParent() string {
256	if m != nil {
257		return m.Parent
258	}
259	return ""
260}
261
262func (m *ListDocumentsRequest) GetCollectionId() string {
263	if m != nil {
264		return m.CollectionId
265	}
266	return ""
267}
268
269func (m *ListDocumentsRequest) GetPageSize() int32 {
270	if m != nil {
271		return m.PageSize
272	}
273	return 0
274}
275
276func (m *ListDocumentsRequest) GetPageToken() string {
277	if m != nil {
278		return m.PageToken
279	}
280	return ""
281}
282
283func (m *ListDocumentsRequest) GetOrderBy() string {
284	if m != nil {
285		return m.OrderBy
286	}
287	return ""
288}
289
290func (m *ListDocumentsRequest) GetMask() *DocumentMask {
291	if m != nil {
292		return m.Mask
293	}
294	return nil
295}
296
297type isListDocumentsRequest_ConsistencySelector interface {
298	isListDocumentsRequest_ConsistencySelector()
299}
300
301type ListDocumentsRequest_Transaction struct {
302	Transaction []byte `protobuf:"bytes,8,opt,name=transaction,proto3,oneof"`
303}
304
305type ListDocumentsRequest_ReadTime struct {
306	ReadTime *timestamp.Timestamp `protobuf:"bytes,10,opt,name=read_time,json=readTime,proto3,oneof"`
307}
308
309func (*ListDocumentsRequest_Transaction) isListDocumentsRequest_ConsistencySelector() {}
310
311func (*ListDocumentsRequest_ReadTime) isListDocumentsRequest_ConsistencySelector() {}
312
313func (m *ListDocumentsRequest) GetConsistencySelector() isListDocumentsRequest_ConsistencySelector {
314	if m != nil {
315		return m.ConsistencySelector
316	}
317	return nil
318}
319
320func (m *ListDocumentsRequest) GetTransaction() []byte {
321	if x, ok := m.GetConsistencySelector().(*ListDocumentsRequest_Transaction); ok {
322		return x.Transaction
323	}
324	return nil
325}
326
327func (m *ListDocumentsRequest) GetReadTime() *timestamp.Timestamp {
328	if x, ok := m.GetConsistencySelector().(*ListDocumentsRequest_ReadTime); ok {
329		return x.ReadTime
330	}
331	return nil
332}
333
334func (m *ListDocumentsRequest) GetShowMissing() bool {
335	if m != nil {
336		return m.ShowMissing
337	}
338	return false
339}
340
341// XXX_OneofWrappers is for the internal use of the proto package.
342func (*ListDocumentsRequest) XXX_OneofWrappers() []interface{} {
343	return []interface{}{
344		(*ListDocumentsRequest_Transaction)(nil),
345		(*ListDocumentsRequest_ReadTime)(nil),
346	}
347}
348
349// The response for [Firestore.ListDocuments][google.firestore.v1beta1.Firestore.ListDocuments].
350type ListDocumentsResponse struct {
351	// The Documents found.
352	Documents []*Document `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
353	// The next page token.
354	NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
355	XXX_NoUnkeyedLiteral struct{} `json:"-"`
356	XXX_unrecognized     []byte   `json:"-"`
357	XXX_sizecache        int32    `json:"-"`
358}
359
360func (m *ListDocumentsResponse) Reset()         { *m = ListDocumentsResponse{} }
361func (m *ListDocumentsResponse) String() string { return proto.CompactTextString(m) }
362func (*ListDocumentsResponse) ProtoMessage()    {}
363func (*ListDocumentsResponse) Descriptor() ([]byte, []int) {
364	return fileDescriptor_9bc8b30a28454f4b, []int{2}
365}
366
367func (m *ListDocumentsResponse) XXX_Unmarshal(b []byte) error {
368	return xxx_messageInfo_ListDocumentsResponse.Unmarshal(m, b)
369}
370func (m *ListDocumentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
371	return xxx_messageInfo_ListDocumentsResponse.Marshal(b, m, deterministic)
372}
373func (m *ListDocumentsResponse) XXX_Merge(src proto.Message) {
374	xxx_messageInfo_ListDocumentsResponse.Merge(m, src)
375}
376func (m *ListDocumentsResponse) XXX_Size() int {
377	return xxx_messageInfo_ListDocumentsResponse.Size(m)
378}
379func (m *ListDocumentsResponse) XXX_DiscardUnknown() {
380	xxx_messageInfo_ListDocumentsResponse.DiscardUnknown(m)
381}
382
383var xxx_messageInfo_ListDocumentsResponse proto.InternalMessageInfo
384
385func (m *ListDocumentsResponse) GetDocuments() []*Document {
386	if m != nil {
387		return m.Documents
388	}
389	return nil
390}
391
392func (m *ListDocumentsResponse) GetNextPageToken() string {
393	if m != nil {
394		return m.NextPageToken
395	}
396	return ""
397}
398
399// The request for [Firestore.CreateDocument][google.firestore.v1beta1.Firestore.CreateDocument].
400type CreateDocumentRequest struct {
401	// The parent resource. For example:
402	// `projects/{project_id}/databases/{database_id}/documents` or
403	// `projects/{project_id}/databases/{database_id}/documents/chatrooms/{chatroom_id}`
404	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
405	// The collection ID, relative to `parent`, to list. For example: `chatrooms`.
406	CollectionId string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
407	// The client-assigned document ID to use for this document.
408	//
409	// Optional. If not specified, an ID will be assigned by the service.
410	DocumentId string `protobuf:"bytes,3,opt,name=document_id,json=documentId,proto3" json:"document_id,omitempty"`
411	// The document to create. `name` must not be set.
412	Document *Document `protobuf:"bytes,4,opt,name=document,proto3" json:"document,omitempty"`
413	// The fields to return. If not set, returns all fields.
414	//
415	// If the document has a field that is not present in this mask, that field
416	// will not be returned in the response.
417	Mask                 *DocumentMask `protobuf:"bytes,5,opt,name=mask,proto3" json:"mask,omitempty"`
418	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
419	XXX_unrecognized     []byte        `json:"-"`
420	XXX_sizecache        int32         `json:"-"`
421}
422
423func (m *CreateDocumentRequest) Reset()         { *m = CreateDocumentRequest{} }
424func (m *CreateDocumentRequest) String() string { return proto.CompactTextString(m) }
425func (*CreateDocumentRequest) ProtoMessage()    {}
426func (*CreateDocumentRequest) Descriptor() ([]byte, []int) {
427	return fileDescriptor_9bc8b30a28454f4b, []int{3}
428}
429
430func (m *CreateDocumentRequest) XXX_Unmarshal(b []byte) error {
431	return xxx_messageInfo_CreateDocumentRequest.Unmarshal(m, b)
432}
433func (m *CreateDocumentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
434	return xxx_messageInfo_CreateDocumentRequest.Marshal(b, m, deterministic)
435}
436func (m *CreateDocumentRequest) XXX_Merge(src proto.Message) {
437	xxx_messageInfo_CreateDocumentRequest.Merge(m, src)
438}
439func (m *CreateDocumentRequest) XXX_Size() int {
440	return xxx_messageInfo_CreateDocumentRequest.Size(m)
441}
442func (m *CreateDocumentRequest) XXX_DiscardUnknown() {
443	xxx_messageInfo_CreateDocumentRequest.DiscardUnknown(m)
444}
445
446var xxx_messageInfo_CreateDocumentRequest proto.InternalMessageInfo
447
448func (m *CreateDocumentRequest) GetParent() string {
449	if m != nil {
450		return m.Parent
451	}
452	return ""
453}
454
455func (m *CreateDocumentRequest) GetCollectionId() string {
456	if m != nil {
457		return m.CollectionId
458	}
459	return ""
460}
461
462func (m *CreateDocumentRequest) GetDocumentId() string {
463	if m != nil {
464		return m.DocumentId
465	}
466	return ""
467}
468
469func (m *CreateDocumentRequest) GetDocument() *Document {
470	if m != nil {
471		return m.Document
472	}
473	return nil
474}
475
476func (m *CreateDocumentRequest) GetMask() *DocumentMask {
477	if m != nil {
478		return m.Mask
479	}
480	return nil
481}
482
483// The request for [Firestore.UpdateDocument][google.firestore.v1beta1.Firestore.UpdateDocument].
484type UpdateDocumentRequest struct {
485	// The updated document.
486	// Creates the document if it does not already exist.
487	Document *Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
488	// The fields to update.
489	// None of the field paths in the mask may contain a reserved name.
490	//
491	// If the document exists on the server and has fields not referenced in the
492	// mask, they are left unchanged.
493	// Fields referenced in the mask, but not present in the input document, are
494	// deleted from the document on the server.
495	UpdateMask *DocumentMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
496	// The fields to return. If not set, returns all fields.
497	//
498	// If the document has a field that is not present in this mask, that field
499	// will not be returned in the response.
500	Mask *DocumentMask `protobuf:"bytes,3,opt,name=mask,proto3" json:"mask,omitempty"`
501	// An optional precondition on the document.
502	// The request will fail if this is set and not met by the target document.
503	CurrentDocument      *Precondition `protobuf:"bytes,4,opt,name=current_document,json=currentDocument,proto3" json:"current_document,omitempty"`
504	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
505	XXX_unrecognized     []byte        `json:"-"`
506	XXX_sizecache        int32         `json:"-"`
507}
508
509func (m *UpdateDocumentRequest) Reset()         { *m = UpdateDocumentRequest{} }
510func (m *UpdateDocumentRequest) String() string { return proto.CompactTextString(m) }
511func (*UpdateDocumentRequest) ProtoMessage()    {}
512func (*UpdateDocumentRequest) Descriptor() ([]byte, []int) {
513	return fileDescriptor_9bc8b30a28454f4b, []int{4}
514}
515
516func (m *UpdateDocumentRequest) XXX_Unmarshal(b []byte) error {
517	return xxx_messageInfo_UpdateDocumentRequest.Unmarshal(m, b)
518}
519func (m *UpdateDocumentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
520	return xxx_messageInfo_UpdateDocumentRequest.Marshal(b, m, deterministic)
521}
522func (m *UpdateDocumentRequest) XXX_Merge(src proto.Message) {
523	xxx_messageInfo_UpdateDocumentRequest.Merge(m, src)
524}
525func (m *UpdateDocumentRequest) XXX_Size() int {
526	return xxx_messageInfo_UpdateDocumentRequest.Size(m)
527}
528func (m *UpdateDocumentRequest) XXX_DiscardUnknown() {
529	xxx_messageInfo_UpdateDocumentRequest.DiscardUnknown(m)
530}
531
532var xxx_messageInfo_UpdateDocumentRequest proto.InternalMessageInfo
533
534func (m *UpdateDocumentRequest) GetDocument() *Document {
535	if m != nil {
536		return m.Document
537	}
538	return nil
539}
540
541func (m *UpdateDocumentRequest) GetUpdateMask() *DocumentMask {
542	if m != nil {
543		return m.UpdateMask
544	}
545	return nil
546}
547
548func (m *UpdateDocumentRequest) GetMask() *DocumentMask {
549	if m != nil {
550		return m.Mask
551	}
552	return nil
553}
554
555func (m *UpdateDocumentRequest) GetCurrentDocument() *Precondition {
556	if m != nil {
557		return m.CurrentDocument
558	}
559	return nil
560}
561
562// The request for [Firestore.DeleteDocument][google.firestore.v1beta1.Firestore.DeleteDocument].
563type DeleteDocumentRequest struct {
564	// The resource name of the Document to delete. In the format:
565	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
566	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
567	// An optional precondition on the document.
568	// The request will fail if this is set and not met by the target document.
569	CurrentDocument      *Precondition `protobuf:"bytes,2,opt,name=current_document,json=currentDocument,proto3" json:"current_document,omitempty"`
570	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
571	XXX_unrecognized     []byte        `json:"-"`
572	XXX_sizecache        int32         `json:"-"`
573}
574
575func (m *DeleteDocumentRequest) Reset()         { *m = DeleteDocumentRequest{} }
576func (m *DeleteDocumentRequest) String() string { return proto.CompactTextString(m) }
577func (*DeleteDocumentRequest) ProtoMessage()    {}
578func (*DeleteDocumentRequest) Descriptor() ([]byte, []int) {
579	return fileDescriptor_9bc8b30a28454f4b, []int{5}
580}
581
582func (m *DeleteDocumentRequest) XXX_Unmarshal(b []byte) error {
583	return xxx_messageInfo_DeleteDocumentRequest.Unmarshal(m, b)
584}
585func (m *DeleteDocumentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
586	return xxx_messageInfo_DeleteDocumentRequest.Marshal(b, m, deterministic)
587}
588func (m *DeleteDocumentRequest) XXX_Merge(src proto.Message) {
589	xxx_messageInfo_DeleteDocumentRequest.Merge(m, src)
590}
591func (m *DeleteDocumentRequest) XXX_Size() int {
592	return xxx_messageInfo_DeleteDocumentRequest.Size(m)
593}
594func (m *DeleteDocumentRequest) XXX_DiscardUnknown() {
595	xxx_messageInfo_DeleteDocumentRequest.DiscardUnknown(m)
596}
597
598var xxx_messageInfo_DeleteDocumentRequest proto.InternalMessageInfo
599
600func (m *DeleteDocumentRequest) GetName() string {
601	if m != nil {
602		return m.Name
603	}
604	return ""
605}
606
607func (m *DeleteDocumentRequest) GetCurrentDocument() *Precondition {
608	if m != nil {
609		return m.CurrentDocument
610	}
611	return nil
612}
613
614// The request for [Firestore.BatchGetDocuments][google.firestore.v1beta1.Firestore.BatchGetDocuments].
615type BatchGetDocumentsRequest struct {
616	// The database name. In the format:
617	// `projects/{project_id}/databases/{database_id}`.
618	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
619	// The names of the documents to retrieve. In the format:
620	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
621	// The request will fail if any of the document is not a child resource of the
622	// given `database`. Duplicate names will be elided.
623	Documents []string `protobuf:"bytes,2,rep,name=documents,proto3" json:"documents,omitempty"`
624	// The fields to return. If not set, returns all fields.
625	//
626	// If a document has a field that is not present in this mask, that field will
627	// not be returned in the response.
628	Mask *DocumentMask `protobuf:"bytes,3,opt,name=mask,proto3" json:"mask,omitempty"`
629	// The consistency mode for this transaction.
630	// If not set, defaults to strong consistency.
631	//
632	// Types that are valid to be assigned to ConsistencySelector:
633	//	*BatchGetDocumentsRequest_Transaction
634	//	*BatchGetDocumentsRequest_NewTransaction
635	//	*BatchGetDocumentsRequest_ReadTime
636	ConsistencySelector  isBatchGetDocumentsRequest_ConsistencySelector `protobuf_oneof:"consistency_selector"`
637	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
638	XXX_unrecognized     []byte                                         `json:"-"`
639	XXX_sizecache        int32                                          `json:"-"`
640}
641
642func (m *BatchGetDocumentsRequest) Reset()         { *m = BatchGetDocumentsRequest{} }
643func (m *BatchGetDocumentsRequest) String() string { return proto.CompactTextString(m) }
644func (*BatchGetDocumentsRequest) ProtoMessage()    {}
645func (*BatchGetDocumentsRequest) Descriptor() ([]byte, []int) {
646	return fileDescriptor_9bc8b30a28454f4b, []int{6}
647}
648
649func (m *BatchGetDocumentsRequest) XXX_Unmarshal(b []byte) error {
650	return xxx_messageInfo_BatchGetDocumentsRequest.Unmarshal(m, b)
651}
652func (m *BatchGetDocumentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
653	return xxx_messageInfo_BatchGetDocumentsRequest.Marshal(b, m, deterministic)
654}
655func (m *BatchGetDocumentsRequest) XXX_Merge(src proto.Message) {
656	xxx_messageInfo_BatchGetDocumentsRequest.Merge(m, src)
657}
658func (m *BatchGetDocumentsRequest) XXX_Size() int {
659	return xxx_messageInfo_BatchGetDocumentsRequest.Size(m)
660}
661func (m *BatchGetDocumentsRequest) XXX_DiscardUnknown() {
662	xxx_messageInfo_BatchGetDocumentsRequest.DiscardUnknown(m)
663}
664
665var xxx_messageInfo_BatchGetDocumentsRequest proto.InternalMessageInfo
666
667func (m *BatchGetDocumentsRequest) GetDatabase() string {
668	if m != nil {
669		return m.Database
670	}
671	return ""
672}
673
674func (m *BatchGetDocumentsRequest) GetDocuments() []string {
675	if m != nil {
676		return m.Documents
677	}
678	return nil
679}
680
681func (m *BatchGetDocumentsRequest) GetMask() *DocumentMask {
682	if m != nil {
683		return m.Mask
684	}
685	return nil
686}
687
688type isBatchGetDocumentsRequest_ConsistencySelector interface {
689	isBatchGetDocumentsRequest_ConsistencySelector()
690}
691
692type BatchGetDocumentsRequest_Transaction struct {
693	Transaction []byte `protobuf:"bytes,4,opt,name=transaction,proto3,oneof"`
694}
695
696type BatchGetDocumentsRequest_NewTransaction struct {
697	NewTransaction *TransactionOptions `protobuf:"bytes,5,opt,name=new_transaction,json=newTransaction,proto3,oneof"`
698}
699
700type BatchGetDocumentsRequest_ReadTime struct {
701	ReadTime *timestamp.Timestamp `protobuf:"bytes,7,opt,name=read_time,json=readTime,proto3,oneof"`
702}
703
704func (*BatchGetDocumentsRequest_Transaction) isBatchGetDocumentsRequest_ConsistencySelector() {}
705
706func (*BatchGetDocumentsRequest_NewTransaction) isBatchGetDocumentsRequest_ConsistencySelector() {}
707
708func (*BatchGetDocumentsRequest_ReadTime) isBatchGetDocumentsRequest_ConsistencySelector() {}
709
710func (m *BatchGetDocumentsRequest) GetConsistencySelector() isBatchGetDocumentsRequest_ConsistencySelector {
711	if m != nil {
712		return m.ConsistencySelector
713	}
714	return nil
715}
716
717func (m *BatchGetDocumentsRequest) GetTransaction() []byte {
718	if x, ok := m.GetConsistencySelector().(*BatchGetDocumentsRequest_Transaction); ok {
719		return x.Transaction
720	}
721	return nil
722}
723
724func (m *BatchGetDocumentsRequest) GetNewTransaction() *TransactionOptions {
725	if x, ok := m.GetConsistencySelector().(*BatchGetDocumentsRequest_NewTransaction); ok {
726		return x.NewTransaction
727	}
728	return nil
729}
730
731func (m *BatchGetDocumentsRequest) GetReadTime() *timestamp.Timestamp {
732	if x, ok := m.GetConsistencySelector().(*BatchGetDocumentsRequest_ReadTime); ok {
733		return x.ReadTime
734	}
735	return nil
736}
737
738// XXX_OneofWrappers is for the internal use of the proto package.
739func (*BatchGetDocumentsRequest) XXX_OneofWrappers() []interface{} {
740	return []interface{}{
741		(*BatchGetDocumentsRequest_Transaction)(nil),
742		(*BatchGetDocumentsRequest_NewTransaction)(nil),
743		(*BatchGetDocumentsRequest_ReadTime)(nil),
744	}
745}
746
747// The streamed response for [Firestore.BatchGetDocuments][google.firestore.v1beta1.Firestore.BatchGetDocuments].
748type BatchGetDocumentsResponse struct {
749	// A single result.
750	// This can be empty if the server is just returning a transaction.
751	//
752	// Types that are valid to be assigned to Result:
753	//	*BatchGetDocumentsResponse_Found
754	//	*BatchGetDocumentsResponse_Missing
755	Result isBatchGetDocumentsResponse_Result `protobuf_oneof:"result"`
756	// The transaction that was started as part of this request.
757	// Will only be set in the first response, and only if
758	// [BatchGetDocumentsRequest.new_transaction][google.firestore.v1beta1.BatchGetDocumentsRequest.new_transaction] was set in the request.
759	Transaction []byte `protobuf:"bytes,3,opt,name=transaction,proto3" json:"transaction,omitempty"`
760	// The time at which the document was read.
761	// This may be monotically increasing, in this case the previous documents in
762	// the result stream are guaranteed not to have changed between their
763	// read_time and this one.
764	ReadTime             *timestamp.Timestamp `protobuf:"bytes,4,opt,name=read_time,json=readTime,proto3" json:"read_time,omitempty"`
765	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
766	XXX_unrecognized     []byte               `json:"-"`
767	XXX_sizecache        int32                `json:"-"`
768}
769
770func (m *BatchGetDocumentsResponse) Reset()         { *m = BatchGetDocumentsResponse{} }
771func (m *BatchGetDocumentsResponse) String() string { return proto.CompactTextString(m) }
772func (*BatchGetDocumentsResponse) ProtoMessage()    {}
773func (*BatchGetDocumentsResponse) Descriptor() ([]byte, []int) {
774	return fileDescriptor_9bc8b30a28454f4b, []int{7}
775}
776
777func (m *BatchGetDocumentsResponse) XXX_Unmarshal(b []byte) error {
778	return xxx_messageInfo_BatchGetDocumentsResponse.Unmarshal(m, b)
779}
780func (m *BatchGetDocumentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
781	return xxx_messageInfo_BatchGetDocumentsResponse.Marshal(b, m, deterministic)
782}
783func (m *BatchGetDocumentsResponse) XXX_Merge(src proto.Message) {
784	xxx_messageInfo_BatchGetDocumentsResponse.Merge(m, src)
785}
786func (m *BatchGetDocumentsResponse) XXX_Size() int {
787	return xxx_messageInfo_BatchGetDocumentsResponse.Size(m)
788}
789func (m *BatchGetDocumentsResponse) XXX_DiscardUnknown() {
790	xxx_messageInfo_BatchGetDocumentsResponse.DiscardUnknown(m)
791}
792
793var xxx_messageInfo_BatchGetDocumentsResponse proto.InternalMessageInfo
794
795type isBatchGetDocumentsResponse_Result interface {
796	isBatchGetDocumentsResponse_Result()
797}
798
799type BatchGetDocumentsResponse_Found struct {
800	Found *Document `protobuf:"bytes,1,opt,name=found,proto3,oneof"`
801}
802
803type BatchGetDocumentsResponse_Missing struct {
804	Missing string `protobuf:"bytes,2,opt,name=missing,proto3,oneof"`
805}
806
807func (*BatchGetDocumentsResponse_Found) isBatchGetDocumentsResponse_Result() {}
808
809func (*BatchGetDocumentsResponse_Missing) isBatchGetDocumentsResponse_Result() {}
810
811func (m *BatchGetDocumentsResponse) GetResult() isBatchGetDocumentsResponse_Result {
812	if m != nil {
813		return m.Result
814	}
815	return nil
816}
817
818func (m *BatchGetDocumentsResponse) GetFound() *Document {
819	if x, ok := m.GetResult().(*BatchGetDocumentsResponse_Found); ok {
820		return x.Found
821	}
822	return nil
823}
824
825func (m *BatchGetDocumentsResponse) GetMissing() string {
826	if x, ok := m.GetResult().(*BatchGetDocumentsResponse_Missing); ok {
827		return x.Missing
828	}
829	return ""
830}
831
832func (m *BatchGetDocumentsResponse) GetTransaction() []byte {
833	if m != nil {
834		return m.Transaction
835	}
836	return nil
837}
838
839func (m *BatchGetDocumentsResponse) GetReadTime() *timestamp.Timestamp {
840	if m != nil {
841		return m.ReadTime
842	}
843	return nil
844}
845
846// XXX_OneofWrappers is for the internal use of the proto package.
847func (*BatchGetDocumentsResponse) XXX_OneofWrappers() []interface{} {
848	return []interface{}{
849		(*BatchGetDocumentsResponse_Found)(nil),
850		(*BatchGetDocumentsResponse_Missing)(nil),
851	}
852}
853
854// The request for [Firestore.BeginTransaction][google.firestore.v1beta1.Firestore.BeginTransaction].
855type BeginTransactionRequest struct {
856	// The database name. In the format:
857	// `projects/{project_id}/databases/{database_id}`.
858	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
859	// The options for the transaction.
860	// Defaults to a read-write transaction.
861	Options              *TransactionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
862	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
863	XXX_unrecognized     []byte              `json:"-"`
864	XXX_sizecache        int32               `json:"-"`
865}
866
867func (m *BeginTransactionRequest) Reset()         { *m = BeginTransactionRequest{} }
868func (m *BeginTransactionRequest) String() string { return proto.CompactTextString(m) }
869func (*BeginTransactionRequest) ProtoMessage()    {}
870func (*BeginTransactionRequest) Descriptor() ([]byte, []int) {
871	return fileDescriptor_9bc8b30a28454f4b, []int{8}
872}
873
874func (m *BeginTransactionRequest) XXX_Unmarshal(b []byte) error {
875	return xxx_messageInfo_BeginTransactionRequest.Unmarshal(m, b)
876}
877func (m *BeginTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
878	return xxx_messageInfo_BeginTransactionRequest.Marshal(b, m, deterministic)
879}
880func (m *BeginTransactionRequest) XXX_Merge(src proto.Message) {
881	xxx_messageInfo_BeginTransactionRequest.Merge(m, src)
882}
883func (m *BeginTransactionRequest) XXX_Size() int {
884	return xxx_messageInfo_BeginTransactionRequest.Size(m)
885}
886func (m *BeginTransactionRequest) XXX_DiscardUnknown() {
887	xxx_messageInfo_BeginTransactionRequest.DiscardUnknown(m)
888}
889
890var xxx_messageInfo_BeginTransactionRequest proto.InternalMessageInfo
891
892func (m *BeginTransactionRequest) GetDatabase() string {
893	if m != nil {
894		return m.Database
895	}
896	return ""
897}
898
899func (m *BeginTransactionRequest) GetOptions() *TransactionOptions {
900	if m != nil {
901		return m.Options
902	}
903	return nil
904}
905
906// The response for [Firestore.BeginTransaction][google.firestore.v1beta1.Firestore.BeginTransaction].
907type BeginTransactionResponse struct {
908	// The transaction that was started.
909	Transaction          []byte   `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
910	XXX_NoUnkeyedLiteral struct{} `json:"-"`
911	XXX_unrecognized     []byte   `json:"-"`
912	XXX_sizecache        int32    `json:"-"`
913}
914
915func (m *BeginTransactionResponse) Reset()         { *m = BeginTransactionResponse{} }
916func (m *BeginTransactionResponse) String() string { return proto.CompactTextString(m) }
917func (*BeginTransactionResponse) ProtoMessage()    {}
918func (*BeginTransactionResponse) Descriptor() ([]byte, []int) {
919	return fileDescriptor_9bc8b30a28454f4b, []int{9}
920}
921
922func (m *BeginTransactionResponse) XXX_Unmarshal(b []byte) error {
923	return xxx_messageInfo_BeginTransactionResponse.Unmarshal(m, b)
924}
925func (m *BeginTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
926	return xxx_messageInfo_BeginTransactionResponse.Marshal(b, m, deterministic)
927}
928func (m *BeginTransactionResponse) XXX_Merge(src proto.Message) {
929	xxx_messageInfo_BeginTransactionResponse.Merge(m, src)
930}
931func (m *BeginTransactionResponse) XXX_Size() int {
932	return xxx_messageInfo_BeginTransactionResponse.Size(m)
933}
934func (m *BeginTransactionResponse) XXX_DiscardUnknown() {
935	xxx_messageInfo_BeginTransactionResponse.DiscardUnknown(m)
936}
937
938var xxx_messageInfo_BeginTransactionResponse proto.InternalMessageInfo
939
940func (m *BeginTransactionResponse) GetTransaction() []byte {
941	if m != nil {
942		return m.Transaction
943	}
944	return nil
945}
946
947// The request for [Firestore.Commit][google.firestore.v1beta1.Firestore.Commit].
948type CommitRequest struct {
949	// The database name. In the format:
950	// `projects/{project_id}/databases/{database_id}`.
951	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
952	// The writes to apply.
953	//
954	// Always executed atomically and in order.
955	Writes []*Write `protobuf:"bytes,2,rep,name=writes,proto3" json:"writes,omitempty"`
956	// If set, applies all writes in this transaction, and commits it.
957	Transaction          []byte   `protobuf:"bytes,3,opt,name=transaction,proto3" json:"transaction,omitempty"`
958	XXX_NoUnkeyedLiteral struct{} `json:"-"`
959	XXX_unrecognized     []byte   `json:"-"`
960	XXX_sizecache        int32    `json:"-"`
961}
962
963func (m *CommitRequest) Reset()         { *m = CommitRequest{} }
964func (m *CommitRequest) String() string { return proto.CompactTextString(m) }
965func (*CommitRequest) ProtoMessage()    {}
966func (*CommitRequest) Descriptor() ([]byte, []int) {
967	return fileDescriptor_9bc8b30a28454f4b, []int{10}
968}
969
970func (m *CommitRequest) XXX_Unmarshal(b []byte) error {
971	return xxx_messageInfo_CommitRequest.Unmarshal(m, b)
972}
973func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
974	return xxx_messageInfo_CommitRequest.Marshal(b, m, deterministic)
975}
976func (m *CommitRequest) XXX_Merge(src proto.Message) {
977	xxx_messageInfo_CommitRequest.Merge(m, src)
978}
979func (m *CommitRequest) XXX_Size() int {
980	return xxx_messageInfo_CommitRequest.Size(m)
981}
982func (m *CommitRequest) XXX_DiscardUnknown() {
983	xxx_messageInfo_CommitRequest.DiscardUnknown(m)
984}
985
986var xxx_messageInfo_CommitRequest proto.InternalMessageInfo
987
988func (m *CommitRequest) GetDatabase() string {
989	if m != nil {
990		return m.Database
991	}
992	return ""
993}
994
995func (m *CommitRequest) GetWrites() []*Write {
996	if m != nil {
997		return m.Writes
998	}
999	return nil
1000}
1001
1002func (m *CommitRequest) GetTransaction() []byte {
1003	if m != nil {
1004		return m.Transaction
1005	}
1006	return nil
1007}
1008
1009// The response for [Firestore.Commit][google.firestore.v1beta1.Firestore.Commit].
1010type CommitResponse struct {
1011	// The result of applying the writes.
1012	//
1013	// This i-th write result corresponds to the i-th write in the
1014	// request.
1015	WriteResults []*WriteResult `protobuf:"bytes,1,rep,name=write_results,json=writeResults,proto3" json:"write_results,omitempty"`
1016	// The time at which the commit occurred.
1017	CommitTime           *timestamp.Timestamp `protobuf:"bytes,2,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
1018	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
1019	XXX_unrecognized     []byte               `json:"-"`
1020	XXX_sizecache        int32                `json:"-"`
1021}
1022
1023func (m *CommitResponse) Reset()         { *m = CommitResponse{} }
1024func (m *CommitResponse) String() string { return proto.CompactTextString(m) }
1025func (*CommitResponse) ProtoMessage()    {}
1026func (*CommitResponse) Descriptor() ([]byte, []int) {
1027	return fileDescriptor_9bc8b30a28454f4b, []int{11}
1028}
1029
1030func (m *CommitResponse) XXX_Unmarshal(b []byte) error {
1031	return xxx_messageInfo_CommitResponse.Unmarshal(m, b)
1032}
1033func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1034	return xxx_messageInfo_CommitResponse.Marshal(b, m, deterministic)
1035}
1036func (m *CommitResponse) XXX_Merge(src proto.Message) {
1037	xxx_messageInfo_CommitResponse.Merge(m, src)
1038}
1039func (m *CommitResponse) XXX_Size() int {
1040	return xxx_messageInfo_CommitResponse.Size(m)
1041}
1042func (m *CommitResponse) XXX_DiscardUnknown() {
1043	xxx_messageInfo_CommitResponse.DiscardUnknown(m)
1044}
1045
1046var xxx_messageInfo_CommitResponse proto.InternalMessageInfo
1047
1048func (m *CommitResponse) GetWriteResults() []*WriteResult {
1049	if m != nil {
1050		return m.WriteResults
1051	}
1052	return nil
1053}
1054
1055func (m *CommitResponse) GetCommitTime() *timestamp.Timestamp {
1056	if m != nil {
1057		return m.CommitTime
1058	}
1059	return nil
1060}
1061
1062// The request for [Firestore.Rollback][google.firestore.v1beta1.Firestore.Rollback].
1063type RollbackRequest struct {
1064	// The database name. In the format:
1065	// `projects/{project_id}/databases/{database_id}`.
1066	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
1067	// The transaction to roll back.
1068	Transaction          []byte   `protobuf:"bytes,2,opt,name=transaction,proto3" json:"transaction,omitempty"`
1069	XXX_NoUnkeyedLiteral struct{} `json:"-"`
1070	XXX_unrecognized     []byte   `json:"-"`
1071	XXX_sizecache        int32    `json:"-"`
1072}
1073
1074func (m *RollbackRequest) Reset()         { *m = RollbackRequest{} }
1075func (m *RollbackRequest) String() string { return proto.CompactTextString(m) }
1076func (*RollbackRequest) ProtoMessage()    {}
1077func (*RollbackRequest) Descriptor() ([]byte, []int) {
1078	return fileDescriptor_9bc8b30a28454f4b, []int{12}
1079}
1080
1081func (m *RollbackRequest) XXX_Unmarshal(b []byte) error {
1082	return xxx_messageInfo_RollbackRequest.Unmarshal(m, b)
1083}
1084func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1085	return xxx_messageInfo_RollbackRequest.Marshal(b, m, deterministic)
1086}
1087func (m *RollbackRequest) XXX_Merge(src proto.Message) {
1088	xxx_messageInfo_RollbackRequest.Merge(m, src)
1089}
1090func (m *RollbackRequest) XXX_Size() int {
1091	return xxx_messageInfo_RollbackRequest.Size(m)
1092}
1093func (m *RollbackRequest) XXX_DiscardUnknown() {
1094	xxx_messageInfo_RollbackRequest.DiscardUnknown(m)
1095}
1096
1097var xxx_messageInfo_RollbackRequest proto.InternalMessageInfo
1098
1099func (m *RollbackRequest) GetDatabase() string {
1100	if m != nil {
1101		return m.Database
1102	}
1103	return ""
1104}
1105
1106func (m *RollbackRequest) GetTransaction() []byte {
1107	if m != nil {
1108		return m.Transaction
1109	}
1110	return nil
1111}
1112
1113// The request for [Firestore.RunQuery][google.firestore.v1beta1.Firestore.RunQuery].
1114type RunQueryRequest struct {
1115	// The parent resource name. In the format:
1116	// `projects/{project_id}/databases/{database_id}/documents` or
1117	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
1118	// For example:
1119	// `projects/my-project/databases/my-database/documents` or
1120	// `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
1121	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
1122	// The query to run.
1123	//
1124	// Types that are valid to be assigned to QueryType:
1125	//	*RunQueryRequest_StructuredQuery
1126	QueryType isRunQueryRequest_QueryType `protobuf_oneof:"query_type"`
1127	// The consistency mode for this transaction.
1128	// If not set, defaults to strong consistency.
1129	//
1130	// Types that are valid to be assigned to ConsistencySelector:
1131	//	*RunQueryRequest_Transaction
1132	//	*RunQueryRequest_NewTransaction
1133	//	*RunQueryRequest_ReadTime
1134	ConsistencySelector  isRunQueryRequest_ConsistencySelector `protobuf_oneof:"consistency_selector"`
1135	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
1136	XXX_unrecognized     []byte                                `json:"-"`
1137	XXX_sizecache        int32                                 `json:"-"`
1138}
1139
1140func (m *RunQueryRequest) Reset()         { *m = RunQueryRequest{} }
1141func (m *RunQueryRequest) String() string { return proto.CompactTextString(m) }
1142func (*RunQueryRequest) ProtoMessage()    {}
1143func (*RunQueryRequest) Descriptor() ([]byte, []int) {
1144	return fileDescriptor_9bc8b30a28454f4b, []int{13}
1145}
1146
1147func (m *RunQueryRequest) XXX_Unmarshal(b []byte) error {
1148	return xxx_messageInfo_RunQueryRequest.Unmarshal(m, b)
1149}
1150func (m *RunQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1151	return xxx_messageInfo_RunQueryRequest.Marshal(b, m, deterministic)
1152}
1153func (m *RunQueryRequest) XXX_Merge(src proto.Message) {
1154	xxx_messageInfo_RunQueryRequest.Merge(m, src)
1155}
1156func (m *RunQueryRequest) XXX_Size() int {
1157	return xxx_messageInfo_RunQueryRequest.Size(m)
1158}
1159func (m *RunQueryRequest) XXX_DiscardUnknown() {
1160	xxx_messageInfo_RunQueryRequest.DiscardUnknown(m)
1161}
1162
1163var xxx_messageInfo_RunQueryRequest proto.InternalMessageInfo
1164
1165func (m *RunQueryRequest) GetParent() string {
1166	if m != nil {
1167		return m.Parent
1168	}
1169	return ""
1170}
1171
1172type isRunQueryRequest_QueryType interface {
1173	isRunQueryRequest_QueryType()
1174}
1175
1176type RunQueryRequest_StructuredQuery struct {
1177	StructuredQuery *StructuredQuery `protobuf:"bytes,2,opt,name=structured_query,json=structuredQuery,proto3,oneof"`
1178}
1179
1180func (*RunQueryRequest_StructuredQuery) isRunQueryRequest_QueryType() {}
1181
1182func (m *RunQueryRequest) GetQueryType() isRunQueryRequest_QueryType {
1183	if m != nil {
1184		return m.QueryType
1185	}
1186	return nil
1187}
1188
1189func (m *RunQueryRequest) GetStructuredQuery() *StructuredQuery {
1190	if x, ok := m.GetQueryType().(*RunQueryRequest_StructuredQuery); ok {
1191		return x.StructuredQuery
1192	}
1193	return nil
1194}
1195
1196type isRunQueryRequest_ConsistencySelector interface {
1197	isRunQueryRequest_ConsistencySelector()
1198}
1199
1200type RunQueryRequest_Transaction struct {
1201	Transaction []byte `protobuf:"bytes,5,opt,name=transaction,proto3,oneof"`
1202}
1203
1204type RunQueryRequest_NewTransaction struct {
1205	NewTransaction *TransactionOptions `protobuf:"bytes,6,opt,name=new_transaction,json=newTransaction,proto3,oneof"`
1206}
1207
1208type RunQueryRequest_ReadTime struct {
1209	ReadTime *timestamp.Timestamp `protobuf:"bytes,7,opt,name=read_time,json=readTime,proto3,oneof"`
1210}
1211
1212func (*RunQueryRequest_Transaction) isRunQueryRequest_ConsistencySelector() {}
1213
1214func (*RunQueryRequest_NewTransaction) isRunQueryRequest_ConsistencySelector() {}
1215
1216func (*RunQueryRequest_ReadTime) isRunQueryRequest_ConsistencySelector() {}
1217
1218func (m *RunQueryRequest) GetConsistencySelector() isRunQueryRequest_ConsistencySelector {
1219	if m != nil {
1220		return m.ConsistencySelector
1221	}
1222	return nil
1223}
1224
1225func (m *RunQueryRequest) GetTransaction() []byte {
1226	if x, ok := m.GetConsistencySelector().(*RunQueryRequest_Transaction); ok {
1227		return x.Transaction
1228	}
1229	return nil
1230}
1231
1232func (m *RunQueryRequest) GetNewTransaction() *TransactionOptions {
1233	if x, ok := m.GetConsistencySelector().(*RunQueryRequest_NewTransaction); ok {
1234		return x.NewTransaction
1235	}
1236	return nil
1237}
1238
1239func (m *RunQueryRequest) GetReadTime() *timestamp.Timestamp {
1240	if x, ok := m.GetConsistencySelector().(*RunQueryRequest_ReadTime); ok {
1241		return x.ReadTime
1242	}
1243	return nil
1244}
1245
1246// XXX_OneofWrappers is for the internal use of the proto package.
1247func (*RunQueryRequest) XXX_OneofWrappers() []interface{} {
1248	return []interface{}{
1249		(*RunQueryRequest_StructuredQuery)(nil),
1250		(*RunQueryRequest_Transaction)(nil),
1251		(*RunQueryRequest_NewTransaction)(nil),
1252		(*RunQueryRequest_ReadTime)(nil),
1253	}
1254}
1255
1256// The response for [Firestore.RunQuery][google.firestore.v1beta1.Firestore.RunQuery].
1257type RunQueryResponse struct {
1258	// The transaction that was started as part of this request.
1259	// Can only be set in the first response, and only if
1260	// [RunQueryRequest.new_transaction][google.firestore.v1beta1.RunQueryRequest.new_transaction] was set in the request.
1261	// If set, no other fields will be set in this response.
1262	Transaction []byte `protobuf:"bytes,2,opt,name=transaction,proto3" json:"transaction,omitempty"`
1263	// A query result.
1264	// Not set when reporting partial progress.
1265	Document *Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
1266	// The time at which the document was read. This may be monotonically
1267	// increasing; in this case, the previous documents in the result stream are
1268	// guaranteed not to have changed between their `read_time` and this one.
1269	//
1270	// If the query returns no results, a response with `read_time` and no
1271	// `document` will be sent, and this represents the time at which the query
1272	// was run.
1273	ReadTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=read_time,json=readTime,proto3" json:"read_time,omitempty"`
1274	// The number of results that have been skipped due to an offset between
1275	// the last response and the current response.
1276	SkippedResults       int32    `protobuf:"varint,4,opt,name=skipped_results,json=skippedResults,proto3" json:"skipped_results,omitempty"`
1277	XXX_NoUnkeyedLiteral struct{} `json:"-"`
1278	XXX_unrecognized     []byte   `json:"-"`
1279	XXX_sizecache        int32    `json:"-"`
1280}
1281
1282func (m *RunQueryResponse) Reset()         { *m = RunQueryResponse{} }
1283func (m *RunQueryResponse) String() string { return proto.CompactTextString(m) }
1284func (*RunQueryResponse) ProtoMessage()    {}
1285func (*RunQueryResponse) Descriptor() ([]byte, []int) {
1286	return fileDescriptor_9bc8b30a28454f4b, []int{14}
1287}
1288
1289func (m *RunQueryResponse) XXX_Unmarshal(b []byte) error {
1290	return xxx_messageInfo_RunQueryResponse.Unmarshal(m, b)
1291}
1292func (m *RunQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1293	return xxx_messageInfo_RunQueryResponse.Marshal(b, m, deterministic)
1294}
1295func (m *RunQueryResponse) XXX_Merge(src proto.Message) {
1296	xxx_messageInfo_RunQueryResponse.Merge(m, src)
1297}
1298func (m *RunQueryResponse) XXX_Size() int {
1299	return xxx_messageInfo_RunQueryResponse.Size(m)
1300}
1301func (m *RunQueryResponse) XXX_DiscardUnknown() {
1302	xxx_messageInfo_RunQueryResponse.DiscardUnknown(m)
1303}
1304
1305var xxx_messageInfo_RunQueryResponse proto.InternalMessageInfo
1306
1307func (m *RunQueryResponse) GetTransaction() []byte {
1308	if m != nil {
1309		return m.Transaction
1310	}
1311	return nil
1312}
1313
1314func (m *RunQueryResponse) GetDocument() *Document {
1315	if m != nil {
1316		return m.Document
1317	}
1318	return nil
1319}
1320
1321func (m *RunQueryResponse) GetReadTime() *timestamp.Timestamp {
1322	if m != nil {
1323		return m.ReadTime
1324	}
1325	return nil
1326}
1327
1328func (m *RunQueryResponse) GetSkippedResults() int32 {
1329	if m != nil {
1330		return m.SkippedResults
1331	}
1332	return 0
1333}
1334
1335// The request for [Firestore.Write][google.firestore.v1beta1.Firestore.Write].
1336//
1337// The first request creates a stream, or resumes an existing one from a token.
1338//
1339// When creating a new stream, the server replies with a response containing
1340// only an ID and a token, to use in the next request.
1341//
1342// When resuming a stream, the server first streams any responses later than the
1343// given token, then a response containing only an up-to-date token, to use in
1344// the next request.
1345type WriteRequest struct {
1346	// The database name. In the format:
1347	// `projects/{project_id}/databases/{database_id}`.
1348	// This is only required in the first message.
1349	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
1350	// The ID of the write stream to resume.
1351	// This may only be set in the first message. When left empty, a new write
1352	// stream will be created.
1353	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
1354	// The writes to apply.
1355	//
1356	// Always executed atomically and in order.
1357	// This must be empty on the first request.
1358	// This may be empty on the last request.
1359	// This must not be empty on all other requests.
1360	Writes []*Write `protobuf:"bytes,3,rep,name=writes,proto3" json:"writes,omitempty"`
1361	// A stream token that was previously sent by the server.
1362	//
1363	// The client should set this field to the token from the most recent
1364	// [WriteResponse][google.firestore.v1beta1.WriteResponse] it has received. This acknowledges that the client has
1365	// received responses up to this token. After sending this token, earlier
1366	// tokens may not be used anymore.
1367	//
1368	// The server may close the stream if there are too many unacknowledged
1369	// responses.
1370	//
1371	// Leave this field unset when creating a new stream. To resume a stream at
1372	// a specific point, set this field and the `stream_id` field.
1373	//
1374	// Leave this field unset when creating a new stream.
1375	StreamToken []byte `protobuf:"bytes,4,opt,name=stream_token,json=streamToken,proto3" json:"stream_token,omitempty"`
1376	// Labels associated with this write request.
1377	Labels               map[string]string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
1378	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
1379	XXX_unrecognized     []byte            `json:"-"`
1380	XXX_sizecache        int32             `json:"-"`
1381}
1382
1383func (m *WriteRequest) Reset()         { *m = WriteRequest{} }
1384func (m *WriteRequest) String() string { return proto.CompactTextString(m) }
1385func (*WriteRequest) ProtoMessage()    {}
1386func (*WriteRequest) Descriptor() ([]byte, []int) {
1387	return fileDescriptor_9bc8b30a28454f4b, []int{15}
1388}
1389
1390func (m *WriteRequest) XXX_Unmarshal(b []byte) error {
1391	return xxx_messageInfo_WriteRequest.Unmarshal(m, b)
1392}
1393func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1394	return xxx_messageInfo_WriteRequest.Marshal(b, m, deterministic)
1395}
1396func (m *WriteRequest) XXX_Merge(src proto.Message) {
1397	xxx_messageInfo_WriteRequest.Merge(m, src)
1398}
1399func (m *WriteRequest) XXX_Size() int {
1400	return xxx_messageInfo_WriteRequest.Size(m)
1401}
1402func (m *WriteRequest) XXX_DiscardUnknown() {
1403	xxx_messageInfo_WriteRequest.DiscardUnknown(m)
1404}
1405
1406var xxx_messageInfo_WriteRequest proto.InternalMessageInfo
1407
1408func (m *WriteRequest) GetDatabase() string {
1409	if m != nil {
1410		return m.Database
1411	}
1412	return ""
1413}
1414
1415func (m *WriteRequest) GetStreamId() string {
1416	if m != nil {
1417		return m.StreamId
1418	}
1419	return ""
1420}
1421
1422func (m *WriteRequest) GetWrites() []*Write {
1423	if m != nil {
1424		return m.Writes
1425	}
1426	return nil
1427}
1428
1429func (m *WriteRequest) GetStreamToken() []byte {
1430	if m != nil {
1431		return m.StreamToken
1432	}
1433	return nil
1434}
1435
1436func (m *WriteRequest) GetLabels() map[string]string {
1437	if m != nil {
1438		return m.Labels
1439	}
1440	return nil
1441}
1442
1443// The response for [Firestore.Write][google.firestore.v1beta1.Firestore.Write].
1444type WriteResponse struct {
1445	// The ID of the stream.
1446	// Only set on the first message, when a new stream was created.
1447	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
1448	// A token that represents the position of this response in the stream.
1449	// This can be used by a client to resume the stream at this point.
1450	//
1451	// This field is always set.
1452	StreamToken []byte `protobuf:"bytes,2,opt,name=stream_token,json=streamToken,proto3" json:"stream_token,omitempty"`
1453	// The result of applying the writes.
1454	//
1455	// This i-th write result corresponds to the i-th write in the
1456	// request.
1457	WriteResults []*WriteResult `protobuf:"bytes,3,rep,name=write_results,json=writeResults,proto3" json:"write_results,omitempty"`
1458	// The time at which the commit occurred.
1459	CommitTime           *timestamp.Timestamp `protobuf:"bytes,4,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
1460	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
1461	XXX_unrecognized     []byte               `json:"-"`
1462	XXX_sizecache        int32                `json:"-"`
1463}
1464
1465func (m *WriteResponse) Reset()         { *m = WriteResponse{} }
1466func (m *WriteResponse) String() string { return proto.CompactTextString(m) }
1467func (*WriteResponse) ProtoMessage()    {}
1468func (*WriteResponse) Descriptor() ([]byte, []int) {
1469	return fileDescriptor_9bc8b30a28454f4b, []int{16}
1470}
1471
1472func (m *WriteResponse) XXX_Unmarshal(b []byte) error {
1473	return xxx_messageInfo_WriteResponse.Unmarshal(m, b)
1474}
1475func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1476	return xxx_messageInfo_WriteResponse.Marshal(b, m, deterministic)
1477}
1478func (m *WriteResponse) XXX_Merge(src proto.Message) {
1479	xxx_messageInfo_WriteResponse.Merge(m, src)
1480}
1481func (m *WriteResponse) XXX_Size() int {
1482	return xxx_messageInfo_WriteResponse.Size(m)
1483}
1484func (m *WriteResponse) XXX_DiscardUnknown() {
1485	xxx_messageInfo_WriteResponse.DiscardUnknown(m)
1486}
1487
1488var xxx_messageInfo_WriteResponse proto.InternalMessageInfo
1489
1490func (m *WriteResponse) GetStreamId() string {
1491	if m != nil {
1492		return m.StreamId
1493	}
1494	return ""
1495}
1496
1497func (m *WriteResponse) GetStreamToken() []byte {
1498	if m != nil {
1499		return m.StreamToken
1500	}
1501	return nil
1502}
1503
1504func (m *WriteResponse) GetWriteResults() []*WriteResult {
1505	if m != nil {
1506		return m.WriteResults
1507	}
1508	return nil
1509}
1510
1511func (m *WriteResponse) GetCommitTime() *timestamp.Timestamp {
1512	if m != nil {
1513		return m.CommitTime
1514	}
1515	return nil
1516}
1517
1518// A request for [Firestore.Listen][google.firestore.v1beta1.Firestore.Listen]
1519type ListenRequest struct {
1520	// The database name. In the format:
1521	// `projects/{project_id}/databases/{database_id}`.
1522	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
1523	// The supported target changes.
1524	//
1525	// Types that are valid to be assigned to TargetChange:
1526	//	*ListenRequest_AddTarget
1527	//	*ListenRequest_RemoveTarget
1528	TargetChange isListenRequest_TargetChange `protobuf_oneof:"target_change"`
1529	// Labels associated with this target change.
1530	Labels               map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
1531	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
1532	XXX_unrecognized     []byte            `json:"-"`
1533	XXX_sizecache        int32             `json:"-"`
1534}
1535
1536func (m *ListenRequest) Reset()         { *m = ListenRequest{} }
1537func (m *ListenRequest) String() string { return proto.CompactTextString(m) }
1538func (*ListenRequest) ProtoMessage()    {}
1539func (*ListenRequest) Descriptor() ([]byte, []int) {
1540	return fileDescriptor_9bc8b30a28454f4b, []int{17}
1541}
1542
1543func (m *ListenRequest) XXX_Unmarshal(b []byte) error {
1544	return xxx_messageInfo_ListenRequest.Unmarshal(m, b)
1545}
1546func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1547	return xxx_messageInfo_ListenRequest.Marshal(b, m, deterministic)
1548}
1549func (m *ListenRequest) XXX_Merge(src proto.Message) {
1550	xxx_messageInfo_ListenRequest.Merge(m, src)
1551}
1552func (m *ListenRequest) XXX_Size() int {
1553	return xxx_messageInfo_ListenRequest.Size(m)
1554}
1555func (m *ListenRequest) XXX_DiscardUnknown() {
1556	xxx_messageInfo_ListenRequest.DiscardUnknown(m)
1557}
1558
1559var xxx_messageInfo_ListenRequest proto.InternalMessageInfo
1560
1561func (m *ListenRequest) GetDatabase() string {
1562	if m != nil {
1563		return m.Database
1564	}
1565	return ""
1566}
1567
1568type isListenRequest_TargetChange interface {
1569	isListenRequest_TargetChange()
1570}
1571
1572type ListenRequest_AddTarget struct {
1573	AddTarget *Target `protobuf:"bytes,2,opt,name=add_target,json=addTarget,proto3,oneof"`
1574}
1575
1576type ListenRequest_RemoveTarget struct {
1577	RemoveTarget int32 `protobuf:"varint,3,opt,name=remove_target,json=removeTarget,proto3,oneof"`
1578}
1579
1580func (*ListenRequest_AddTarget) isListenRequest_TargetChange() {}
1581
1582func (*ListenRequest_RemoveTarget) isListenRequest_TargetChange() {}
1583
1584func (m *ListenRequest) GetTargetChange() isListenRequest_TargetChange {
1585	if m != nil {
1586		return m.TargetChange
1587	}
1588	return nil
1589}
1590
1591func (m *ListenRequest) GetAddTarget() *Target {
1592	if x, ok := m.GetTargetChange().(*ListenRequest_AddTarget); ok {
1593		return x.AddTarget
1594	}
1595	return nil
1596}
1597
1598func (m *ListenRequest) GetRemoveTarget() int32 {
1599	if x, ok := m.GetTargetChange().(*ListenRequest_RemoveTarget); ok {
1600		return x.RemoveTarget
1601	}
1602	return 0
1603}
1604
1605func (m *ListenRequest) GetLabels() map[string]string {
1606	if m != nil {
1607		return m.Labels
1608	}
1609	return nil
1610}
1611
1612// XXX_OneofWrappers is for the internal use of the proto package.
1613func (*ListenRequest) XXX_OneofWrappers() []interface{} {
1614	return []interface{}{
1615		(*ListenRequest_AddTarget)(nil),
1616		(*ListenRequest_RemoveTarget)(nil),
1617	}
1618}
1619
1620// The response for [Firestore.Listen][google.firestore.v1beta1.Firestore.Listen].
1621type ListenResponse struct {
1622	// The supported responses.
1623	//
1624	// Types that are valid to be assigned to ResponseType:
1625	//	*ListenResponse_TargetChange
1626	//	*ListenResponse_DocumentChange
1627	//	*ListenResponse_DocumentDelete
1628	//	*ListenResponse_DocumentRemove
1629	//	*ListenResponse_Filter
1630	ResponseType         isListenResponse_ResponseType `protobuf_oneof:"response_type"`
1631	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
1632	XXX_unrecognized     []byte                        `json:"-"`
1633	XXX_sizecache        int32                         `json:"-"`
1634}
1635
1636func (m *ListenResponse) Reset()         { *m = ListenResponse{} }
1637func (m *ListenResponse) String() string { return proto.CompactTextString(m) }
1638func (*ListenResponse) ProtoMessage()    {}
1639func (*ListenResponse) Descriptor() ([]byte, []int) {
1640	return fileDescriptor_9bc8b30a28454f4b, []int{18}
1641}
1642
1643func (m *ListenResponse) XXX_Unmarshal(b []byte) error {
1644	return xxx_messageInfo_ListenResponse.Unmarshal(m, b)
1645}
1646func (m *ListenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1647	return xxx_messageInfo_ListenResponse.Marshal(b, m, deterministic)
1648}
1649func (m *ListenResponse) XXX_Merge(src proto.Message) {
1650	xxx_messageInfo_ListenResponse.Merge(m, src)
1651}
1652func (m *ListenResponse) XXX_Size() int {
1653	return xxx_messageInfo_ListenResponse.Size(m)
1654}
1655func (m *ListenResponse) XXX_DiscardUnknown() {
1656	xxx_messageInfo_ListenResponse.DiscardUnknown(m)
1657}
1658
1659var xxx_messageInfo_ListenResponse proto.InternalMessageInfo
1660
1661type isListenResponse_ResponseType interface {
1662	isListenResponse_ResponseType()
1663}
1664
1665type ListenResponse_TargetChange struct {
1666	TargetChange *TargetChange `protobuf:"bytes,2,opt,name=target_change,json=targetChange,proto3,oneof"`
1667}
1668
1669type ListenResponse_DocumentChange struct {
1670	DocumentChange *DocumentChange `protobuf:"bytes,3,opt,name=document_change,json=documentChange,proto3,oneof"`
1671}
1672
1673type ListenResponse_DocumentDelete struct {
1674	DocumentDelete *DocumentDelete `protobuf:"bytes,4,opt,name=document_delete,json=documentDelete,proto3,oneof"`
1675}
1676
1677type ListenResponse_DocumentRemove struct {
1678	DocumentRemove *DocumentRemove `protobuf:"bytes,6,opt,name=document_remove,json=documentRemove,proto3,oneof"`
1679}
1680
1681type ListenResponse_Filter struct {
1682	Filter *ExistenceFilter `protobuf:"bytes,5,opt,name=filter,proto3,oneof"`
1683}
1684
1685func (*ListenResponse_TargetChange) isListenResponse_ResponseType() {}
1686
1687func (*ListenResponse_DocumentChange) isListenResponse_ResponseType() {}
1688
1689func (*ListenResponse_DocumentDelete) isListenResponse_ResponseType() {}
1690
1691func (*ListenResponse_DocumentRemove) isListenResponse_ResponseType() {}
1692
1693func (*ListenResponse_Filter) isListenResponse_ResponseType() {}
1694
1695func (m *ListenResponse) GetResponseType() isListenResponse_ResponseType {
1696	if m != nil {
1697		return m.ResponseType
1698	}
1699	return nil
1700}
1701
1702func (m *ListenResponse) GetTargetChange() *TargetChange {
1703	if x, ok := m.GetResponseType().(*ListenResponse_TargetChange); ok {
1704		return x.TargetChange
1705	}
1706	return nil
1707}
1708
1709func (m *ListenResponse) GetDocumentChange() *DocumentChange {
1710	if x, ok := m.GetResponseType().(*ListenResponse_DocumentChange); ok {
1711		return x.DocumentChange
1712	}
1713	return nil
1714}
1715
1716func (m *ListenResponse) GetDocumentDelete() *DocumentDelete {
1717	if x, ok := m.GetResponseType().(*ListenResponse_DocumentDelete); ok {
1718		return x.DocumentDelete
1719	}
1720	return nil
1721}
1722
1723func (m *ListenResponse) GetDocumentRemove() *DocumentRemove {
1724	if x, ok := m.GetResponseType().(*ListenResponse_DocumentRemove); ok {
1725		return x.DocumentRemove
1726	}
1727	return nil
1728}
1729
1730func (m *ListenResponse) GetFilter() *ExistenceFilter {
1731	if x, ok := m.GetResponseType().(*ListenResponse_Filter); ok {
1732		return x.Filter
1733	}
1734	return nil
1735}
1736
1737// XXX_OneofWrappers is for the internal use of the proto package.
1738func (*ListenResponse) XXX_OneofWrappers() []interface{} {
1739	return []interface{}{
1740		(*ListenResponse_TargetChange)(nil),
1741		(*ListenResponse_DocumentChange)(nil),
1742		(*ListenResponse_DocumentDelete)(nil),
1743		(*ListenResponse_DocumentRemove)(nil),
1744		(*ListenResponse_Filter)(nil),
1745	}
1746}
1747
1748// A specification of a set of documents to listen to.
1749type Target struct {
1750	// The type of target to listen to.
1751	//
1752	// Types that are valid to be assigned to TargetType:
1753	//	*Target_Query
1754	//	*Target_Documents
1755	TargetType isTarget_TargetType `protobuf_oneof:"target_type"`
1756	// When to start listening.
1757	//
1758	// If not specified, all matching Documents are returned before any
1759	// subsequent changes.
1760	//
1761	// Types that are valid to be assigned to ResumeType:
1762	//	*Target_ResumeToken
1763	//	*Target_ReadTime
1764	ResumeType isTarget_ResumeType `protobuf_oneof:"resume_type"`
1765	// A client provided target ID.
1766	//
1767	// If not set, the server will assign an ID for the target.
1768	//
1769	// Used for resuming a target without changing IDs. The IDs can either be
1770	// client-assigned or be server-assigned in a previous stream. All targets
1771	// with client provided IDs must be added before adding a target that needs
1772	// a server-assigned id.
1773	TargetId int32 `protobuf:"varint,5,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
1774	// If the target should be removed once it is current and consistent.
1775	Once                 bool     `protobuf:"varint,6,opt,name=once,proto3" json:"once,omitempty"`
1776	XXX_NoUnkeyedLiteral struct{} `json:"-"`
1777	XXX_unrecognized     []byte   `json:"-"`
1778	XXX_sizecache        int32    `json:"-"`
1779}
1780
1781func (m *Target) Reset()         { *m = Target{} }
1782func (m *Target) String() string { return proto.CompactTextString(m) }
1783func (*Target) ProtoMessage()    {}
1784func (*Target) Descriptor() ([]byte, []int) {
1785	return fileDescriptor_9bc8b30a28454f4b, []int{19}
1786}
1787
1788func (m *Target) XXX_Unmarshal(b []byte) error {
1789	return xxx_messageInfo_Target.Unmarshal(m, b)
1790}
1791func (m *Target) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1792	return xxx_messageInfo_Target.Marshal(b, m, deterministic)
1793}
1794func (m *Target) XXX_Merge(src proto.Message) {
1795	xxx_messageInfo_Target.Merge(m, src)
1796}
1797func (m *Target) XXX_Size() int {
1798	return xxx_messageInfo_Target.Size(m)
1799}
1800func (m *Target) XXX_DiscardUnknown() {
1801	xxx_messageInfo_Target.DiscardUnknown(m)
1802}
1803
1804var xxx_messageInfo_Target proto.InternalMessageInfo
1805
1806type isTarget_TargetType interface {
1807	isTarget_TargetType()
1808}
1809
1810type Target_Query struct {
1811	Query *Target_QueryTarget `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
1812}
1813
1814type Target_Documents struct {
1815	Documents *Target_DocumentsTarget `protobuf:"bytes,3,opt,name=documents,proto3,oneof"`
1816}
1817
1818func (*Target_Query) isTarget_TargetType() {}
1819
1820func (*Target_Documents) isTarget_TargetType() {}
1821
1822func (m *Target) GetTargetType() isTarget_TargetType {
1823	if m != nil {
1824		return m.TargetType
1825	}
1826	return nil
1827}
1828
1829func (m *Target) GetQuery() *Target_QueryTarget {
1830	if x, ok := m.GetTargetType().(*Target_Query); ok {
1831		return x.Query
1832	}
1833	return nil
1834}
1835
1836func (m *Target) GetDocuments() *Target_DocumentsTarget {
1837	if x, ok := m.GetTargetType().(*Target_Documents); ok {
1838		return x.Documents
1839	}
1840	return nil
1841}
1842
1843type isTarget_ResumeType interface {
1844	isTarget_ResumeType()
1845}
1846
1847type Target_ResumeToken struct {
1848	ResumeToken []byte `protobuf:"bytes,4,opt,name=resume_token,json=resumeToken,proto3,oneof"`
1849}
1850
1851type Target_ReadTime struct {
1852	ReadTime *timestamp.Timestamp `protobuf:"bytes,11,opt,name=read_time,json=readTime,proto3,oneof"`
1853}
1854
1855func (*Target_ResumeToken) isTarget_ResumeType() {}
1856
1857func (*Target_ReadTime) isTarget_ResumeType() {}
1858
1859func (m *Target) GetResumeType() isTarget_ResumeType {
1860	if m != nil {
1861		return m.ResumeType
1862	}
1863	return nil
1864}
1865
1866func (m *Target) GetResumeToken() []byte {
1867	if x, ok := m.GetResumeType().(*Target_ResumeToken); ok {
1868		return x.ResumeToken
1869	}
1870	return nil
1871}
1872
1873func (m *Target) GetReadTime() *timestamp.Timestamp {
1874	if x, ok := m.GetResumeType().(*Target_ReadTime); ok {
1875		return x.ReadTime
1876	}
1877	return nil
1878}
1879
1880func (m *Target) GetTargetId() int32 {
1881	if m != nil {
1882		return m.TargetId
1883	}
1884	return 0
1885}
1886
1887func (m *Target) GetOnce() bool {
1888	if m != nil {
1889		return m.Once
1890	}
1891	return false
1892}
1893
1894// XXX_OneofWrappers is for the internal use of the proto package.
1895func (*Target) XXX_OneofWrappers() []interface{} {
1896	return []interface{}{
1897		(*Target_Query)(nil),
1898		(*Target_Documents)(nil),
1899		(*Target_ResumeToken)(nil),
1900		(*Target_ReadTime)(nil),
1901	}
1902}
1903
1904// A target specified by a set of documents names.
1905type Target_DocumentsTarget struct {
1906	// The names of the documents to retrieve. In the format:
1907	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
1908	// The request will fail if any of the document is not a child resource of
1909	// the given `database`. Duplicate names will be elided.
1910	Documents            []string `protobuf:"bytes,2,rep,name=documents,proto3" json:"documents,omitempty"`
1911	XXX_NoUnkeyedLiteral struct{} `json:"-"`
1912	XXX_unrecognized     []byte   `json:"-"`
1913	XXX_sizecache        int32    `json:"-"`
1914}
1915
1916func (m *Target_DocumentsTarget) Reset()         { *m = Target_DocumentsTarget{} }
1917func (m *Target_DocumentsTarget) String() string { return proto.CompactTextString(m) }
1918func (*Target_DocumentsTarget) ProtoMessage()    {}
1919func (*Target_DocumentsTarget) Descriptor() ([]byte, []int) {
1920	return fileDescriptor_9bc8b30a28454f4b, []int{19, 0}
1921}
1922
1923func (m *Target_DocumentsTarget) XXX_Unmarshal(b []byte) error {
1924	return xxx_messageInfo_Target_DocumentsTarget.Unmarshal(m, b)
1925}
1926func (m *Target_DocumentsTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1927	return xxx_messageInfo_Target_DocumentsTarget.Marshal(b, m, deterministic)
1928}
1929func (m *Target_DocumentsTarget) XXX_Merge(src proto.Message) {
1930	xxx_messageInfo_Target_DocumentsTarget.Merge(m, src)
1931}
1932func (m *Target_DocumentsTarget) XXX_Size() int {
1933	return xxx_messageInfo_Target_DocumentsTarget.Size(m)
1934}
1935func (m *Target_DocumentsTarget) XXX_DiscardUnknown() {
1936	xxx_messageInfo_Target_DocumentsTarget.DiscardUnknown(m)
1937}
1938
1939var xxx_messageInfo_Target_DocumentsTarget proto.InternalMessageInfo
1940
1941func (m *Target_DocumentsTarget) GetDocuments() []string {
1942	if m != nil {
1943		return m.Documents
1944	}
1945	return nil
1946}
1947
1948// A target specified by a query.
1949type Target_QueryTarget struct {
1950	// The parent resource name. In the format:
1951	// `projects/{project_id}/databases/{database_id}/documents` or
1952	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
1953	// For example:
1954	// `projects/my-project/databases/my-database/documents` or
1955	// `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
1956	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
1957	// The query to run.
1958	//
1959	// Types that are valid to be assigned to QueryType:
1960	//	*Target_QueryTarget_StructuredQuery
1961	QueryType            isTarget_QueryTarget_QueryType `protobuf_oneof:"query_type"`
1962	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
1963	XXX_unrecognized     []byte                         `json:"-"`
1964	XXX_sizecache        int32                          `json:"-"`
1965}
1966
1967func (m *Target_QueryTarget) Reset()         { *m = Target_QueryTarget{} }
1968func (m *Target_QueryTarget) String() string { return proto.CompactTextString(m) }
1969func (*Target_QueryTarget) ProtoMessage()    {}
1970func (*Target_QueryTarget) Descriptor() ([]byte, []int) {
1971	return fileDescriptor_9bc8b30a28454f4b, []int{19, 1}
1972}
1973
1974func (m *Target_QueryTarget) XXX_Unmarshal(b []byte) error {
1975	return xxx_messageInfo_Target_QueryTarget.Unmarshal(m, b)
1976}
1977func (m *Target_QueryTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1978	return xxx_messageInfo_Target_QueryTarget.Marshal(b, m, deterministic)
1979}
1980func (m *Target_QueryTarget) XXX_Merge(src proto.Message) {
1981	xxx_messageInfo_Target_QueryTarget.Merge(m, src)
1982}
1983func (m *Target_QueryTarget) XXX_Size() int {
1984	return xxx_messageInfo_Target_QueryTarget.Size(m)
1985}
1986func (m *Target_QueryTarget) XXX_DiscardUnknown() {
1987	xxx_messageInfo_Target_QueryTarget.DiscardUnknown(m)
1988}
1989
1990var xxx_messageInfo_Target_QueryTarget proto.InternalMessageInfo
1991
1992func (m *Target_QueryTarget) GetParent() string {
1993	if m != nil {
1994		return m.Parent
1995	}
1996	return ""
1997}
1998
1999type isTarget_QueryTarget_QueryType interface {
2000	isTarget_QueryTarget_QueryType()
2001}
2002
2003type Target_QueryTarget_StructuredQuery struct {
2004	StructuredQuery *StructuredQuery `protobuf:"bytes,2,opt,name=structured_query,json=structuredQuery,proto3,oneof"`
2005}
2006
2007func (*Target_QueryTarget_StructuredQuery) isTarget_QueryTarget_QueryType() {}
2008
2009func (m *Target_QueryTarget) GetQueryType() isTarget_QueryTarget_QueryType {
2010	if m != nil {
2011		return m.QueryType
2012	}
2013	return nil
2014}
2015
2016func (m *Target_QueryTarget) GetStructuredQuery() *StructuredQuery {
2017	if x, ok := m.GetQueryType().(*Target_QueryTarget_StructuredQuery); ok {
2018		return x.StructuredQuery
2019	}
2020	return nil
2021}
2022
2023// XXX_OneofWrappers is for the internal use of the proto package.
2024func (*Target_QueryTarget) XXX_OneofWrappers() []interface{} {
2025	return []interface{}{
2026		(*Target_QueryTarget_StructuredQuery)(nil),
2027	}
2028}
2029
2030// Targets being watched have changed.
2031type TargetChange struct {
2032	// The type of change that occurred.
2033	TargetChangeType TargetChange_TargetChangeType `protobuf:"varint,1,opt,name=target_change_type,json=targetChangeType,proto3,enum=google.firestore.v1beta1.TargetChange_TargetChangeType" json:"target_change_type,omitempty"`
2034	// The target IDs of targets that have changed.
2035	//
2036	// If empty, the change applies to all targets.
2037	//
2038	// For `target_change_type=ADD`, the order of the target IDs matches the order
2039	// of the requests to add the targets. This allows clients to unambiguously
2040	// associate server-assigned target IDs with added targets.
2041	//
2042	// For other states, the order of the target IDs is not defined.
2043	TargetIds []int32 `protobuf:"varint,2,rep,packed,name=target_ids,json=targetIds,proto3" json:"target_ids,omitempty"`
2044	// The error that resulted in this change, if applicable.
2045	Cause *status.Status `protobuf:"bytes,3,opt,name=cause,proto3" json:"cause,omitempty"`
2046	// A token that can be used to resume the stream for the given `target_ids`,
2047	// or all targets if `target_ids` is empty.
2048	//
2049	// Not set on every target change.
2050	ResumeToken []byte `protobuf:"bytes,4,opt,name=resume_token,json=resumeToken,proto3" json:"resume_token,omitempty"`
2051	// The consistent `read_time` for the given `target_ids` (omitted when the
2052	// target_ids are not at a consistent snapshot).
2053	//
2054	// The stream is guaranteed to send a `read_time` with `target_ids` empty
2055	// whenever the entire stream reaches a new consistent snapshot. ADD,
2056	// CURRENT, and RESET messages are guaranteed to (eventually) result in a
2057	// new consistent snapshot (while NO_CHANGE and REMOVE messages are not).
2058	//
2059	// For a given stream, `read_time` is guaranteed to be monotonically
2060	// increasing.
2061	ReadTime             *timestamp.Timestamp `protobuf:"bytes,6,opt,name=read_time,json=readTime,proto3" json:"read_time,omitempty"`
2062	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
2063	XXX_unrecognized     []byte               `json:"-"`
2064	XXX_sizecache        int32                `json:"-"`
2065}
2066
2067func (m *TargetChange) Reset()         { *m = TargetChange{} }
2068func (m *TargetChange) String() string { return proto.CompactTextString(m) }
2069func (*TargetChange) ProtoMessage()    {}
2070func (*TargetChange) Descriptor() ([]byte, []int) {
2071	return fileDescriptor_9bc8b30a28454f4b, []int{20}
2072}
2073
2074func (m *TargetChange) XXX_Unmarshal(b []byte) error {
2075	return xxx_messageInfo_TargetChange.Unmarshal(m, b)
2076}
2077func (m *TargetChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
2078	return xxx_messageInfo_TargetChange.Marshal(b, m, deterministic)
2079}
2080func (m *TargetChange) XXX_Merge(src proto.Message) {
2081	xxx_messageInfo_TargetChange.Merge(m, src)
2082}
2083func (m *TargetChange) XXX_Size() int {
2084	return xxx_messageInfo_TargetChange.Size(m)
2085}
2086func (m *TargetChange) XXX_DiscardUnknown() {
2087	xxx_messageInfo_TargetChange.DiscardUnknown(m)
2088}
2089
2090var xxx_messageInfo_TargetChange proto.InternalMessageInfo
2091
2092func (m *TargetChange) GetTargetChangeType() TargetChange_TargetChangeType {
2093	if m != nil {
2094		return m.TargetChangeType
2095	}
2096	return TargetChange_NO_CHANGE
2097}
2098
2099func (m *TargetChange) GetTargetIds() []int32 {
2100	if m != nil {
2101		return m.TargetIds
2102	}
2103	return nil
2104}
2105
2106func (m *TargetChange) GetCause() *status.Status {
2107	if m != nil {
2108		return m.Cause
2109	}
2110	return nil
2111}
2112
2113func (m *TargetChange) GetResumeToken() []byte {
2114	if m != nil {
2115		return m.ResumeToken
2116	}
2117	return nil
2118}
2119
2120func (m *TargetChange) GetReadTime() *timestamp.Timestamp {
2121	if m != nil {
2122		return m.ReadTime
2123	}
2124	return nil
2125}
2126
2127// The request for [Firestore.ListCollectionIds][google.firestore.v1beta1.Firestore.ListCollectionIds].
2128type ListCollectionIdsRequest struct {
2129	// The parent document. In the format:
2130	// `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
2131	// For example:
2132	// `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
2133	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
2134	// The maximum number of results to return.
2135	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
2136	// A page token. Must be a value from
2137	// [ListCollectionIdsResponse][google.firestore.v1beta1.ListCollectionIdsResponse].
2138	PageToken            string   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
2139	XXX_NoUnkeyedLiteral struct{} `json:"-"`
2140	XXX_unrecognized     []byte   `json:"-"`
2141	XXX_sizecache        int32    `json:"-"`
2142}
2143
2144func (m *ListCollectionIdsRequest) Reset()         { *m = ListCollectionIdsRequest{} }
2145func (m *ListCollectionIdsRequest) String() string { return proto.CompactTextString(m) }
2146func (*ListCollectionIdsRequest) ProtoMessage()    {}
2147func (*ListCollectionIdsRequest) Descriptor() ([]byte, []int) {
2148	return fileDescriptor_9bc8b30a28454f4b, []int{21}
2149}
2150
2151func (m *ListCollectionIdsRequest) XXX_Unmarshal(b []byte) error {
2152	return xxx_messageInfo_ListCollectionIdsRequest.Unmarshal(m, b)
2153}
2154func (m *ListCollectionIdsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
2155	return xxx_messageInfo_ListCollectionIdsRequest.Marshal(b, m, deterministic)
2156}
2157func (m *ListCollectionIdsRequest) XXX_Merge(src proto.Message) {
2158	xxx_messageInfo_ListCollectionIdsRequest.Merge(m, src)
2159}
2160func (m *ListCollectionIdsRequest) XXX_Size() int {
2161	return xxx_messageInfo_ListCollectionIdsRequest.Size(m)
2162}
2163func (m *ListCollectionIdsRequest) XXX_DiscardUnknown() {
2164	xxx_messageInfo_ListCollectionIdsRequest.DiscardUnknown(m)
2165}
2166
2167var xxx_messageInfo_ListCollectionIdsRequest proto.InternalMessageInfo
2168
2169func (m *ListCollectionIdsRequest) GetParent() string {
2170	if m != nil {
2171		return m.Parent
2172	}
2173	return ""
2174}
2175
2176func (m *ListCollectionIdsRequest) GetPageSize() int32 {
2177	if m != nil {
2178		return m.PageSize
2179	}
2180	return 0
2181}
2182
2183func (m *ListCollectionIdsRequest) GetPageToken() string {
2184	if m != nil {
2185		return m.PageToken
2186	}
2187	return ""
2188}
2189
2190// The response from [Firestore.ListCollectionIds][google.firestore.v1beta1.Firestore.ListCollectionIds].
2191type ListCollectionIdsResponse struct {
2192	// The collection ids.
2193	CollectionIds []string `protobuf:"bytes,1,rep,name=collection_ids,json=collectionIds,proto3" json:"collection_ids,omitempty"`
2194	// A page token that may be used to continue the list.
2195	NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
2196	XXX_NoUnkeyedLiteral struct{} `json:"-"`
2197	XXX_unrecognized     []byte   `json:"-"`
2198	XXX_sizecache        int32    `json:"-"`
2199}
2200
2201func (m *ListCollectionIdsResponse) Reset()         { *m = ListCollectionIdsResponse{} }
2202func (m *ListCollectionIdsResponse) String() string { return proto.CompactTextString(m) }
2203func (*ListCollectionIdsResponse) ProtoMessage()    {}
2204func (*ListCollectionIdsResponse) Descriptor() ([]byte, []int) {
2205	return fileDescriptor_9bc8b30a28454f4b, []int{22}
2206}
2207
2208func (m *ListCollectionIdsResponse) XXX_Unmarshal(b []byte) error {
2209	return xxx_messageInfo_ListCollectionIdsResponse.Unmarshal(m, b)
2210}
2211func (m *ListCollectionIdsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
2212	return xxx_messageInfo_ListCollectionIdsResponse.Marshal(b, m, deterministic)
2213}
2214func (m *ListCollectionIdsResponse) XXX_Merge(src proto.Message) {
2215	xxx_messageInfo_ListCollectionIdsResponse.Merge(m, src)
2216}
2217func (m *ListCollectionIdsResponse) XXX_Size() int {
2218	return xxx_messageInfo_ListCollectionIdsResponse.Size(m)
2219}
2220func (m *ListCollectionIdsResponse) XXX_DiscardUnknown() {
2221	xxx_messageInfo_ListCollectionIdsResponse.DiscardUnknown(m)
2222}
2223
2224var xxx_messageInfo_ListCollectionIdsResponse proto.InternalMessageInfo
2225
2226func (m *ListCollectionIdsResponse) GetCollectionIds() []string {
2227	if m != nil {
2228		return m.CollectionIds
2229	}
2230	return nil
2231}
2232
2233func (m *ListCollectionIdsResponse) GetNextPageToken() string {
2234	if m != nil {
2235		return m.NextPageToken
2236	}
2237	return ""
2238}
2239
2240func init() {
2241	proto.RegisterEnum("google.firestore.v1beta1.TargetChange_TargetChangeType", TargetChange_TargetChangeType_name, TargetChange_TargetChangeType_value)
2242	proto.RegisterType((*GetDocumentRequest)(nil), "google.firestore.v1beta1.GetDocumentRequest")
2243	proto.RegisterType((*ListDocumentsRequest)(nil), "google.firestore.v1beta1.ListDocumentsRequest")
2244	proto.RegisterType((*ListDocumentsResponse)(nil), "google.firestore.v1beta1.ListDocumentsResponse")
2245	proto.RegisterType((*CreateDocumentRequest)(nil), "google.firestore.v1beta1.CreateDocumentRequest")
2246	proto.RegisterType((*UpdateDocumentRequest)(nil), "google.firestore.v1beta1.UpdateDocumentRequest")
2247	proto.RegisterType((*DeleteDocumentRequest)(nil), "google.firestore.v1beta1.DeleteDocumentRequest")
2248	proto.RegisterType((*BatchGetDocumentsRequest)(nil), "google.firestore.v1beta1.BatchGetDocumentsRequest")
2249	proto.RegisterType((*BatchGetDocumentsResponse)(nil), "google.firestore.v1beta1.BatchGetDocumentsResponse")
2250	proto.RegisterType((*BeginTransactionRequest)(nil), "google.firestore.v1beta1.BeginTransactionRequest")
2251	proto.RegisterType((*BeginTransactionResponse)(nil), "google.firestore.v1beta1.BeginTransactionResponse")
2252	proto.RegisterType((*CommitRequest)(nil), "google.firestore.v1beta1.CommitRequest")
2253	proto.RegisterType((*CommitResponse)(nil), "google.firestore.v1beta1.CommitResponse")
2254	proto.RegisterType((*RollbackRequest)(nil), "google.firestore.v1beta1.RollbackRequest")
2255	proto.RegisterType((*RunQueryRequest)(nil), "google.firestore.v1beta1.RunQueryRequest")
2256	proto.RegisterType((*RunQueryResponse)(nil), "google.firestore.v1beta1.RunQueryResponse")
2257	proto.RegisterType((*WriteRequest)(nil), "google.firestore.v1beta1.WriteRequest")
2258	proto.RegisterMapType((map[string]string)(nil), "google.firestore.v1beta1.WriteRequest.LabelsEntry")
2259	proto.RegisterType((*WriteResponse)(nil), "google.firestore.v1beta1.WriteResponse")
2260	proto.RegisterType((*ListenRequest)(nil), "google.firestore.v1beta1.ListenRequest")
2261	proto.RegisterMapType((map[string]string)(nil), "google.firestore.v1beta1.ListenRequest.LabelsEntry")
2262	proto.RegisterType((*ListenResponse)(nil), "google.firestore.v1beta1.ListenResponse")
2263	proto.RegisterType((*Target)(nil), "google.firestore.v1beta1.Target")
2264	proto.RegisterType((*Target_DocumentsTarget)(nil), "google.firestore.v1beta1.Target.DocumentsTarget")
2265	proto.RegisterType((*Target_QueryTarget)(nil), "google.firestore.v1beta1.Target.QueryTarget")
2266	proto.RegisterType((*TargetChange)(nil), "google.firestore.v1beta1.TargetChange")
2267	proto.RegisterType((*ListCollectionIdsRequest)(nil), "google.firestore.v1beta1.ListCollectionIdsRequest")
2268	proto.RegisterType((*ListCollectionIdsResponse)(nil), "google.firestore.v1beta1.ListCollectionIdsResponse")
2269}
2270
2271func init() {
2272	proto.RegisterFile("google/firestore/v1beta1/firestore.proto", fileDescriptor_9bc8b30a28454f4b)
2273}
2274
2275var fileDescriptor_9bc8b30a28454f4b = []byte{
2276	// 2214 bytes of a gzipped FileDescriptorProto
2277	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x5a, 0xcd, 0x8f, 0x1b, 0x49,
2278	0x15, 0x77, 0xb5, 0x3f, 0xc6, 0x7e, 0xfe, 0x18, 0x6f, 0x91, 0x64, 0x1d, 0x27, 0x4b, 0x86, 0x5e,
2279	0x92, 0x18, 0x6b, 0x65, 0x27, 0x13, 0xa1, 0xb0, 0x0e, 0x59, 0x92, 0x99, 0xf1, 0x8c, 0x27, 0x24,
2280	0x33, 0x93, 0x9e, 0xd9, 0x44, 0x5a, 0x45, 0xb2, 0x7a, 0xba, 0x2b, 0x4e, 0xef, 0xd8, 0xdd, 0xde,
2281	0xee, 0x76, 0x66, 0x67, 0x57, 0x83, 0x80, 0x03, 0x1c, 0x90, 0xf6, 0xc2, 0x01, 0xf6, 0x02, 0x08,
2282	0x0e, 0x48, 0x7b, 0x80, 0x0b, 0x12, 0x17, 0x84, 0xc4, 0x6d, 0x05, 0x47, 0x24, 0x84, 0xc4, 0x01,
2283	0x0e, 0x9c, 0xb8, 0x21, 0xf1, 0x07, 0xa0, 0xae, 0xaa, 0x6e, 0x77, 0xb7, 0xbf, 0xda, 0x9e, 0x68,
2284	0x6f, 0x5d, 0xcf, 0xaf, 0x5e, 0xbd, 0x8f, 0xdf, 0x7b, 0xf5, 0xea, 0xcd, 0x40, 0xa5, 0x63, 0x18,
2285	0x9d, 0x2e, 0xa9, 0x3f, 0xd7, 0x4c, 0x62, 0xd9, 0x86, 0x49, 0xea, 0x2f, 0x6f, 0x1e, 0x12, 0x5b,
2286	0xbe, 0x39, 0xa4, 0xd4, 0xfa, 0xa6, 0x61, 0x1b, 0xb8, 0xc4, 0x38, 0x6b, 0x43, 0x3a, 0xe7, 0x2c,
2287	0x5f, 0xe6, 0x32, 0xe4, 0xbe, 0x56, 0x97, 0x75, 0xdd, 0xb0, 0x65, 0x5b, 0x33, 0x74, 0x8b, 0xed,
2288	0x2b, 0x5f, 0x9d, 0x78, 0x82, 0x62, 0xf4, 0x7a, 0x86, 0xce, 0xd9, 0xae, 0x4f, 0x64, 0x53, 0x0d,
2289	0x65, 0xd0, 0x23, 0xba, 0xcd, 0x19, 0xbf, 0x3a, 0x91, 0xf1, 0x83, 0x01, 0x31, 0x4f, 0x66, 0x72,
2290	0x1d, 0x9b, 0x9a, 0xcd, 0x6d, 0x2a, 0x5f, 0xe2, 0x5c, 0x74, 0x75, 0x38, 0x78, 0x5e, 0x27, 0xbd,
2291	0xbe, 0xed, 0x8a, 0xb8, 0x12, 0xfe, 0xd1, 0xd6, 0x7a, 0xc4, 0xb2, 0xe5, 0x5e, 0x9f, 0x33, 0xbc,
2292	0xce, 0x19, 0xcc, 0xbe, 0x52, 0xb7, 0x6c, 0xd9, 0x1e, 0x70, 0x93, 0xc5, 0x7f, 0x20, 0xc0, 0x5b,
2293	0xc4, 0xde, 0xe0, 0x8a, 0x4b, 0xe4, 0x83, 0x01, 0xb1, 0x6c, 0x8c, 0x21, 0xa1, 0xcb, 0x3d, 0x52,
2294	0x42, 0x2b, 0xa8, 0x92, 0x91, 0xe8, 0x37, 0x6e, 0x40, 0xa2, 0x27, 0x5b, 0x47, 0x25, 0x61, 0x05,
2295	0x55, 0xb2, 0xab, 0xd7, 0x6a, 0x93, 0x9c, 0x5c, 0x73, 0x85, 0x3d, 0x92, 0xad, 0x23, 0x89, 0xee,
2296	0xc1, 0x22, 0x64, 0x6d, 0x53, 0xd6, 0x2d, 0x59, 0x71, 0xfc, 0x5d, 0x8a, 0xaf, 0xa0, 0x4a, 0xae,
2297	0x15, 0x93, 0xfc, 0x44, 0xfc, 0x36, 0x64, 0x4c, 0x22, 0xab, 0x6d, 0x47, 0xf7, 0x52, 0x92, 0x1e,
2298	0x52, 0x76, 0x0f, 0x71, 0x0d, 0xab, 0x1d, 0xb8, 0x86, 0xb5, 0x62, 0x52, 0xda, 0x61, 0x77, 0x08,
2299	0x6b, 0x17, 0xe0, 0x9c, 0x62, 0xe8, 0x96, 0x66, 0xd9, 0x44, 0x57, 0x4e, 0xda, 0x16, 0xe9, 0x12,
2300	0xc5, 0x36, 0x4c, 0xf1, 0xbb, 0x71, 0x38, 0xf7, 0x50, 0xb3, 0x3c, 0xf3, 0x2c, 0xd7, 0xbe, 0x0b,
2301	0x90, 0xea, 0xcb, 0x26, 0xd1, 0x6d, 0x6e, 0x21, 0x5f, 0xe1, 0x37, 0x21, 0xaf, 0x18, 0x5d, 0x67,
2302	0xb7, 0x66, 0xe8, 0x6d, 0x4d, 0xa5, 0xc6, 0x66, 0xa4, 0xdc, 0x90, 0xb8, 0xad, 0xe2, 0x4b, 0x90,
2303	0xe9, 0xcb, 0x1d, 0xd2, 0xb6, 0xb4, 0x8f, 0x08, 0x35, 0x25, 0x29, 0xa5, 0x1d, 0xc2, 0xbe, 0xf6,
2304	0x11, 0xc1, 0x6f, 0x00, 0xd0, 0x1f, 0x6d, 0xe3, 0x88, 0xe8, 0xa5, 0x04, 0xdd, 0x4e, 0xd9, 0x0f,
2305	0x1c, 0x02, 0xbe, 0x08, 0x69, 0xc3, 0x54, 0x89, 0xd9, 0x3e, 0x3c, 0x29, 0xa5, 0xe8, 0x8f, 0x4b,
2306	0x74, 0xbd, 0x76, 0xe2, 0xf9, 0x77, 0xe9, 0xec, 0xfe, 0x4d, 0xcf, 0xf4, 0x2f, 0xcc, 0xe3, 0x5f,
2307	0xfc, 0x15, 0xc8, 0x59, 0x2f, 0x8c, 0xe3, 0x76, 0x4f, 0xb3, 0x2c, 0x4d, 0xef, 0x94, 0x72, 0x2b,
2308	0xa8, 0x92, 0x96, 0xb2, 0x0e, 0xed, 0x11, 0x23, 0x4d, 0x0c, 0xc1, 0xf7, 0x10, 0x9c, 0x0f, 0x85,
2309	0xc0, 0xea, 0x1b, 0xba, 0x45, 0xf0, 0x3d, 0xc8, 0xb8, 0xf9, 0x62, 0x95, 0xd0, 0x4a, 0xbc, 0x92,
2310	0x5d, 0x15, 0x67, 0x1b, 0x2d, 0x0d, 0x37, 0xe1, 0x6b, 0xb0, 0xac, 0x93, 0x0f, 0xed, 0xb6, 0xcf,
2311	0xe1, 0x2c, 0x5e, 0x79, 0x87, 0xbc, 0xe7, 0x3a, 0x5d, 0xfc, 0x2f, 0x82, 0xf3, 0xeb, 0x26, 0x91,
2312	0x6d, 0x12, 0xc6, 0xf9, 0x99, 0x70, 0x70, 0x05, 0xb2, 0xae, 0x2e, 0x0e, 0x4b, 0x9c, 0xb2, 0x80,
2313	0x4b, 0xda, 0x56, 0xf1, 0x3b, 0x90, 0x76, 0x57, 0x14, 0x09, 0xd1, 0x0c, 0xf4, 0xf6, 0x78, 0x88,
2314	0x48, 0xce, 0x8f, 0x08, 0xf1, 0xb7, 0x02, 0x9c, 0x7f, 0xb7, 0xaf, 0x8e, 0xb1, 0xd9, 0xaf, 0x15,
2315	0x5a, 0x40, 0xab, 0x2d, 0xc8, 0x0e, 0xa8, 0xe0, 0xf6, 0x02, 0xe5, 0x00, 0xd8, 0x56, 0xe7, 0xdb,
2316	0x33, 0x2f, 0xbe, 0x00, 0xe0, 0x1f, 0x43, 0x51, 0x19, 0x98, 0x4e, 0xac, 0xda, 0x21, 0x17, 0x4f,
2317	0x91, 0xb3, 0x67, 0x12, 0xc5, 0xd0, 0x55, 0xcd, 0x89, 0x9f, 0xb4, 0xcc, 0xf7, 0xbb, 0xc2, 0xc5,
2318	0xef, 0xc0, 0xf9, 0x0d, 0xd2, 0x25, 0xa3, 0x0e, 0x1b, 0x57, 0x0c, 0xc7, 0x9d, 0x2f, 0x9c, 0xed,
2319	0xfc, 0x7f, 0x09, 0x50, 0x5a, 0x93, 0x6d, 0xe5, 0x85, 0xaf, 0x1e, 0x7b, 0x05, 0xab, 0x0c, 0x69,
2320	0x55, 0xb6, 0xe5, 0x43, 0xd9, 0x72, 0xf5, 0xf0, 0xd6, 0xf8, 0xb2, 0x3f, 0x91, 0x84, 0x95, 0xb8,
2321	0x53, 0x71, 0x86, 0x49, 0x72, 0x16, 0x2f, 0x87, 0xca, 0x4a, 0x62, 0x5c, 0x59, 0x79, 0xea, 0x24,
2322	0xe1, 0x71, 0xdb, 0xcf, 0xc7, 0xf0, 0xfa, 0xd6, 0xe4, 0xa3, 0x0e, 0x86, 0xcc, 0xbb, 0x7d, 0x7a,
2323	0x03, 0xb7, 0x62, 0x52, 0x41, 0x27, 0xc7, 0x07, 0x93, 0xea, 0xd5, 0xd2, 0x2b, 0xb9, 0x0f, 0xfe,
2324	0x8e, 0xe0, 0xe2, 0x18, 0x17, 0xf3, 0x82, 0xd4, 0x80, 0xe4, 0x73, 0x63, 0xa0, 0xab, 0xd1, 0xb3,
2325	0xa2, 0x15, 0x93, 0xd8, 0x16, 0x5c, 0x86, 0x25, 0xb7, 0x38, 0xd2, 0x52, 0xd1, 0x8a, 0x49, 0x2e,
2326	0x01, 0xaf, 0x8c, 0xb9, 0xfc, 0x82, 0x3e, 0xbc, 0xed, 0x37, 0x35, 0x31, 0xcb, 0x54, 0x9f, 0xa1,
2327	0x69, 0x48, 0x99, 0xc4, 0x1a, 0x74, 0x6d, 0xf1, 0x14, 0x5e, 0x5f, 0x23, 0x1d, 0x4d, 0xf7, 0x79,
2328	0x30, 0x0a, 0x76, 0x36, 0x61, 0xc9, 0x60, 0x11, 0xe0, 0xf0, 0x9d, 0x2b, 0x6a, 0x92, 0xbb, 0x59,
2329	0xfc, 0x26, 0x94, 0x46, 0x8f, 0xe7, 0x7e, 0x0d, 0xd9, 0x8f, 0x46, 0xec, 0x17, 0x7f, 0x80, 0x20,
2330	0xbf, 0x6e, 0xf4, 0x7a, 0x9a, 0x1d, 0x45, 0xe7, 0xdb, 0x90, 0xa2, 0x9d, 0x11, 0x03, 0x7b, 0x76,
2331	0xf5, 0xca, 0x64, 0x95, 0x9f, 0x3a, 0x7c, 0x12, 0x67, 0x9f, 0x1d, 0x08, 0xf1, 0x53, 0x04, 0x05,
2332	0x57, 0x11, 0xae, 0xfd, 0x03, 0xc8, 0xd3, 0xed, 0x6d, 0xe6, 0x68, 0xf7, 0xaa, 0xba, 0x3a, 0xeb,
2333	0x50, 0xca, 0x2d, 0xe5, 0x8e, 0x87, 0x0b, 0x0b, 0xdf, 0x81, 0xac, 0x42, 0xa5, 0xb3, 0x48, 0x0b,
2334	0x33, 0x23, 0x0d, 0x8c, 0xdd, 0x21, 0x88, 0xbb, 0xb0, 0x2c, 0x19, 0xdd, 0xee, 0xa1, 0xac, 0x1c,
2335	0x45, 0xf1, 0x52, 0xc8, 0x58, 0x61, 0xd4, 0xd8, 0x7f, 0x0a, 0xb0, 0x2c, 0x0d, 0xf4, 0xc7, 0x4e,
2336	0x2f, 0x3a, 0xeb, 0x42, 0x7c, 0x02, 0x45, 0xcb, 0x36, 0x07, 0x8a, 0x3d, 0x30, 0x89, 0xda, 0xa6,
2337	0xed, 0x2b, 0x57, 0xff, 0x6b, 0x93, 0x1d, 0xb1, 0xef, 0xed, 0xa0, 0x67, 0xb4, 0x62, 0xd2, 0xb2,
2338	0x15, 0x24, 0x85, 0x2b, 0x4c, 0x92, 0x56, 0x18, 0x34, 0xb3, 0xc2, 0xa4, 0x16, 0xa8, 0x30, 0xe8,
2339	0xac, 0x15, 0x06, 0xf9, 0x12, 0x2f, 0x07, 0x40, 0x9d, 0xd0, 0xb6, 0x4f, 0xfa, 0x93, 0xeb, 0xcd,
2340	0xdf, 0x10, 0x14, 0x87, 0x1e, 0x1e, 0x9f, 0x0e, 0xa3, 0x81, 0x39, 0xf3, 0x0d, 0x1d, 0x28, 0x27,
2341	0xf1, 0xe8, 0xe5, 0x04, 0x5f, 0x87, 0x65, 0xeb, 0x48, 0xeb, 0xf7, 0x89, 0xea, 0xa1, 0x3d, 0x41,
2342	0xfb, 0xdb, 0x02, 0x27, 0x73, 0x20, 0x8b, 0x9f, 0x09, 0x90, 0xe3, 0x30, 0x9f, 0x8d, 0xc4, 0x4b,
2343	0x90, 0xb1, 0x6c, 0x93, 0xc8, 0xbd, 0x61, 0x23, 0x95, 0x66, 0x84, 0x6d, 0xd5, 0x97, 0xcc, 0xf1,
2344	0xf9, 0x92, 0xd9, 0xe9, 0x49, 0x99, 0xd4, 0x61, 0xab, 0x9d, 0x93, 0xb2, 0x8c, 0xc6, 0x9a, 0xed,
2345	0x07, 0x90, 0xea, 0xca, 0x87, 0xa4, 0x6b, 0x95, 0x92, 0x54, 0xf6, 0xea, 0xcc, 0x9c, 0xa5, 0xc6,
2346	0xd4, 0x1e, 0xd2, 0x4d, 0x4d, 0xdd, 0x36, 0x4f, 0x24, 0x2e, 0xa1, 0xfc, 0x36, 0x64, 0x7d, 0x64,
2347	0x5c, 0x84, 0xf8, 0x11, 0x39, 0xe1, 0xa6, 0x3a, 0x9f, 0xf8, 0x1c, 0x24, 0x5f, 0xca, 0xdd, 0x01,
2348	0xe1, 0x16, 0xb2, 0x45, 0x43, 0xf8, 0x06, 0x72, 0x6e, 0x9d, 0xbc, 0x5b, 0x13, 0x18, 0x04, 0x02,
2349	0x1e, 0x41, 0x21, 0x8f, 0x84, 0x0d, 0x13, 0xc6, 0x19, 0x16, 0xaa, 0x49, 0xf1, 0x57, 0x56, 0x93,
2350	0x12, 0x73, 0xd5, 0xa4, 0xdf, 0x08, 0x90, 0x7f, 0x48, 0x61, 0x1f, 0x05, 0x08, 0xf7, 0x01, 0x64,
2351	0x55, 0x6d, 0xdb, 0xb2, 0xd9, 0x21, 0x6e, 0xbb, 0xb4, 0x32, 0x25, 0x87, 0x29, 0x5f, 0x2b, 0x26,
2352	0x65, 0x64, 0x55, 0x65, 0x0b, 0x7c, 0x15, 0xf2, 0x26, 0xe9, 0x19, 0x2f, 0x89, 0x2b, 0x85, 0xbe,
2353	0xbf, 0x5a, 0x31, 0x29, 0xc7, 0xc8, 0x9c, 0xed, 0xdb, 0x5e, 0xe4, 0x13, 0xd4, 0x33, 0xb7, 0x26,
2354	0x9f, 0x12, 0x50, 0xff, 0x15, 0x87, 0x7e, 0x6d, 0x19, 0xf2, 0x4c, 0xcf, 0xb6, 0xf2, 0x42, 0xd6,
2355	0x3b, 0x44, 0xfc, 0x5d, 0x1c, 0x0a, 0xee, 0x89, 0x1c, 0x0c, 0x8f, 0x42, 0x3c, 0xb3, 0xfb, 0x48,
2356	0x66, 0xe4, 0x3a, 0xe5, 0x76, 0x4c, 0xb7, 0x7d, 0x6b, 0xbc, 0x0f, 0xcb, 0xde, 0xab, 0x84, 0x0b,
2357	0x64, 0x25, 0xa0, 0x32, 0xbb, 0x86, 0x78, 0x22, 0x0b, 0x6a, 0x80, 0x12, 0x10, 0xaa, 0xd2, 0x26,
2358	0x99, 0x03, 0x25, 0x82, 0x50, 0xd6, 0x54, 0xfb, 0x85, 0x32, 0x4a, 0x40, 0x28, 0x8b, 0x1e, 0xaf,
2359	0xeb, 0x11, 0x84, 0x4a, 0x94, 0xdf, 0x2f, 0x94, 0x51, 0xf0, 0x3a, 0xa4, 0x9e, 0x6b, 0x5d, 0x9b,
2360	0x98, 0xbc, 0x0b, 0x9d, 0x72, 0x3d, 0x35, 0x3f, 0x64, 0x05, 0x9b, 0x6c, 0xd2, 0x0d, 0xad, 0x98,
2361	0xc4, 0xb7, 0x3a, 0x61, 0x33, 0x79, 0x78, 0x68, 0x81, 0x17, 0x3f, 0x49, 0x40, 0x8a, 0x43, 0x6b,
2362	0x03, 0x92, 0xfe, 0xeb, 0xef, 0xad, 0x59, 0x61, 0xaa, 0xd1, 0xea, 0xef, 0x61, 0x99, 0x6d, 0xc6,
2363	0x7b, 0xfe, 0x9e, 0x9d, 0xc5, 0xe7, 0xc6, 0x4c, 0x49, 0x5e, 0xcb, 0x3a, 0xcc, 0x8c, 0x61, 0x9f,
2364	0xff, 0x26, 0xe4, 0x9c, 0x6a, 0xd0, 0xf3, 0x8f, 0x1e, 0xe8, 0x55, 0xca, 0xa8, 0xac, 0x70, 0x04,
2365	0x6e, 0xbc, 0xec, 0x3c, 0x37, 0x9e, 0x53, 0xb3, 0x38, 0x4c, 0x35, 0x95, 0xfa, 0x36, 0x29, 0xa5,
2366	0x19, 0x61, 0x5b, 0x75, 0x9e, 0x48, 0x86, 0xae, 0xb0, 0xf8, 0xa5, 0x25, 0xfa, 0x5d, 0xae, 0xc3,
2367	0x72, 0x48, 0xe1, 0xe9, 0x2f, 0x95, 0xf2, 0x8f, 0x10, 0x64, 0x7d, 0xce, 0xfa, 0xa2, 0x7b, 0x91,
2368	0xd0, 0x9d, 0x9e, 0x87, 0x2c, 0xb7, 0xd7, 0x5d, 0xba, 0xee, 0x75, 0x00, 0xf1, 0x1f, 0x01, 0x72,
2369	0xfe, 0x34, 0xc4, 0x04, 0x70, 0x20, 0x8b, 0x29, 0x1b, 0x55, 0xbc, 0xb0, 0x7a, 0x3b, 0x5a, 0x2a,
2370	0x07, 0x16, 0x07, 0x27, 0x7d, 0x22, 0x15, 0xed, 0x10, 0x05, 0xbf, 0x01, 0xe0, 0x45, 0x81, 0xb9,
2371	0x30, 0x29, 0x65, 0xdc, 0x30, 0x58, 0xb8, 0x02, 0x49, 0x45, 0x1e, 0x58, 0x6e, 0xca, 0x63, 0xf7,
2372	0x60, 0xb3, 0xaf, 0xd4, 0xf6, 0xe9, 0xdc, 0x4f, 0x62, 0x0c, 0xce, 0x2d, 0x33, 0x0a, 0x97, 0x20,
2373	0x58, 0x02, 0x6d, 0x44, 0x2a, 0x7a, 0x1b, 0x21, 0xee, 0x40, 0x31, 0x6c, 0x0a, 0xce, 0x43, 0x66,
2374	0x67, 0xb7, 0xbd, 0xde, 0xba, 0xbf, 0xb3, 0xd5, 0x2c, 0xc6, 0xf0, 0x12, 0xc4, 0xef, 0x6f, 0x6c,
2375	0x14, 0x11, 0x06, 0x48, 0x49, 0xcd, 0x47, 0xbb, 0x4f, 0x9a, 0x45, 0x01, 0x67, 0x61, 0x69, 0xfd,
2376	0x5d, 0x49, 0x6a, 0xee, 0x1c, 0x14, 0xe3, 0x38, 0x03, 0x49, 0xa9, 0xb9, 0xdf, 0x3c, 0x28, 0x26,
2377	0x44, 0x1d, 0x4a, 0x4e, 0xcd, 0x5c, 0xf7, 0x0d, 0x5f, 0x66, 0x4e, 0xf2, 0x02, 0x43, 0x3a, 0x61,
2378	0xea, 0x90, 0x2e, 0x1e, 0x1a, 0xd2, 0x89, 0xef, 0xc3, 0xc5, 0x31, 0xe7, 0xf1, 0x72, 0x7d, 0x15,
2379	0x0a, 0x81, 0xd1, 0x10, 0x7b, 0x10, 0x64, 0xa4, 0xbc, 0x7f, 0x36, 0x14, 0x79, 0x36, 0xb5, 0xfa,
2380	0xf9, 0x97, 0x20, 0xb3, 0xe9, 0xc2, 0x02, 0xff, 0x0c, 0x41, 0xd6, 0xf7, 0x36, 0xc5, 0x53, 0xaa,
2381	0xcb, 0xe8, 0xd4, 0xb6, 0x1c, 0xa1, 0x4b, 0x14, 0xef, 0x7e, 0xff, 0xaf, 0xff, 0xfe, 0xb1, 0x70,
2382	0x1b, 0x7f, 0xdd, 0x9b, 0x32, 0x7f, 0xac, 0xcb, 0x3d, 0x72, 0xb7, 0x6f, 0x1a, 0xef, 0x13, 0xc5,
2383	0xb6, 0xea, 0xd5, 0xba, 0x7b, 0x5f, 0xd3, 0x6f, 0x37, 0x3b, 0xeb, 0xd5, 0x7a, 0xb5, 0x7a, 0x8a,
2384	0xff, 0x84, 0xd8, 0x85, 0xef, 0x65, 0x36, 0xae, 0x4d, 0xbf, 0x5a, 0xc3, 0x93, 0x8c, 0x72, 0x3d,
2385	0x32, 0x3f, 0x73, 0xb8, 0xb8, 0x4b, 0x35, 0xde, 0xc6, 0x5b, 0x43, 0x8d, 0x59, 0x8c, 0x23, 0xea,
2386	0x5c, 0xff, 0x38, 0x10, 0xaf, 0x53, 0xfc, 0x47, 0xe7, 0x91, 0x17, 0x18, 0x07, 0xe2, 0x29, 0x4a,
2387	0x8d, 0x1d, 0x1c, 0x46, 0x72, 0xf5, 0x53, 0xaa, 0xf8, 0x63, 0xb1, 0xb9, 0x80, 0xe2, 0xa3, 0x6a,
2388	0x37, 0x86, 0xfd, 0xfd, 0xef, 0x11, 0x14, 0x82, 0xb3, 0xbd, 0x69, 0x06, 0x8c, 0x9d, 0x02, 0x46,
2389	0x32, 0x60, 0x8f, 0x1a, 0xf0, 0x60, 0xf5, 0x9d, 0xa1, 0x01, 0xde, 0x5f, 0x38, 0xe6, 0x00, 0x8d,
2390	0x4f, 0xf3, 0x9f, 0x22, 0x28, 0x04, 0x87, 0x6c, 0xd3, 0x34, 0x1f, 0x3b, 0x8e, 0x2b, 0x5f, 0x18,
2391	0xa9, 0x41, 0xcd, 0x5e, 0xdf, 0x3e, 0x71, 0x91, 0x5d, 0x5d, 0x10, 0xd9, 0x9f, 0x23, 0x78, 0x6d,
2392	0x64, 0x36, 0x84, 0xa7, 0x3c, 0x19, 0x26, 0xcd, 0xea, 0xca, 0xb7, 0xe6, 0xda, 0xc3, 0x51, 0xde,
2393	0xa2, 0xda, 0xaf, 0x89, 0x77, 0x7d, 0xbe, 0xe6, 0xda, 0x4e, 0xb0, 0xe0, 0x74, 0x68, 0x42, 0xe3,
2394	0x90, 0xcb, 0x6d, 0xa0, 0xea, 0x0d, 0x84, 0xff, 0x82, 0xa0, 0x18, 0x9e, 0xc6, 0xe0, 0x9b, 0x53,
2395	0xb4, 0x1a, 0x3f, 0x38, 0x2a, 0xaf, 0xce, 0xb3, 0x85, 0xdb, 0xc1, 0x31, 0xe3, 0x07, 0xfd, 0x3c,
2396	0x76, 0x84, 0xc4, 0x36, 0x50, 0x15, 0xff, 0x0a, 0x41, 0x8a, 0xcd, 0x64, 0xf0, 0xf5, 0x29, 0x69,
2397	0xea, 0x1f, 0x1f, 0x95, 0x2b, 0xb3, 0x19, 0xb9, 0xbe, 0x9b, 0x54, 0xdf, 0x7b, 0xe2, 0x9d, 0x85,
2398	0xf4, 0x65, 0x4f, 0x21, 0x47, 0xcb, 0x9f, 0x20, 0x48, 0xbb, 0xe3, 0x19, 0x3c, 0xa5, 0x0f, 0x09,
2399	0x8d, 0x70, 0x26, 0xa2, 0xf9, 0x6c, 0x78, 0x30, 0xf9, 0x29, 0x8e, 0x66, 0xff, 0x73, 0x34, 0xe3,
2400	0x43, 0x88, 0xa9, 0x9a, 0x05, 0x47, 0x41, 0xe5, 0x6a, 0x14, 0x56, 0xee, 0xc5, 0x4f, 0x10, 0x55,
2401	0xf7, 0x87, 0xc8, 0xef, 0xc7, 0x88, 0xc5, 0xee, 0xb4, 0x61, 0x72, 0x71, 0x0d, 0x54, 0x7d, 0xaf,
2402	0x29, 0xde, 0x5b, 0xb0, 0xce, 0xfb, 0xc5, 0xdc, 0x40, 0x0e, 0x6c, 0x92, 0xf4, 0xd5, 0x8b, 0xaf,
2403	0x45, 0x7b, 0xf6, 0x97, 0xaf, 0xcf, 0x7e, 0x3e, 0x33, 0x6b, 0x9b, 0xd4, 0xd8, 0x6f, 0x89, 0x8d,
2404	0x85, 0x62, 0x43, 0x5f, 0xdf, 0x0d, 0x54, 0xad, 0xa0, 0x1b, 0x08, 0xff, 0x1a, 0x41, 0x8a, 0xbd,
2405	0x07, 0xa7, 0x81, 0x3b, 0xf0, 0x46, 0x9d, 0x06, 0xee, 0xe0, 0xd3, 0xf2, 0x8c, 0xe0, 0xee, 0x52,
2406	0x61, 0xae, 0xa6, 0x3f, 0x17, 0xe0, 0xb5, 0x91, 0xae, 0x68, 0x5a, 0x7d, 0x9c, 0xd4, 0xb2, 0x95,
2407	0x6f, 0xcd, 0xb5, 0x87, 0x9b, 0xf2, 0x0b, 0x86, 0xb0, 0x4f, 0x91, 0xb8, 0xb1, 0x00, 0xc2, 0xba,
2408	0x61, 0xb9, 0x0e, 0xd4, 0x76, 0xc4, 0xed, 0x45, 0xa1, 0x36, 0x4e, 0xde, 0xda, 0x1f, 0x10, 0x5c,
2409	0x56, 0x8c, 0xde, 0x44, 0xeb, 0xd6, 0x0a, 0x5e, 0xa3, 0xb7, 0xe7, 0x24, 0xfb, 0x1e, 0x7a, 0xef,
2410	0x3e, 0xe7, 0xed, 0x18, 0x5d, 0x59, 0xef, 0xd4, 0x0c, 0xb3, 0x53, 0xef, 0x10, 0x9d, 0x96, 0x82,
2411	0x3a, 0xfb, 0x49, 0xee, 0x6b, 0xd6, 0xe8, 0xbf, 0x06, 0xdc, 0xf1, 0x28, 0xbf, 0x14, 0x12, 0x5b,
2412	0xeb, 0x9b, 0xfb, 0x9f, 0x09, 0x5f, 0xde, 0x62, 0xa2, 0xd6, 0xbb, 0xc6, 0x40, 0xad, 0x79, 0x27,
2413	0xd5, 0x9e, 0xdc, 0x5c, 0x73, 0x76, 0xfc, 0xd9, 0x65, 0x78, 0x46, 0x19, 0x9e, 0x79, 0x0c, 0xcf,
2414	0x9e, 0x30, 0x91, 0x87, 0x29, 0x7a, 0xec, 0xad, 0xff, 0x07, 0x00, 0x00, 0xff, 0xff, 0x53, 0x38,
2415	0xf0, 0x00, 0x68, 0x21, 0x00, 0x00,
2416}
2417
2418// Reference imports to suppress errors if they are not otherwise used.
2419var _ context.Context
2420var _ grpc.ClientConn
2421
2422// This is a compile-time assertion to ensure that this generated file
2423// is compatible with the grpc package it is being compiled against.
2424const _ = grpc.SupportPackageIsVersion4
2425
2426// FirestoreClient is the client API for Firestore service.
2427//
2428// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
2429type FirestoreClient interface {
2430	// Gets a single document.
2431	GetDocument(ctx context.Context, in *GetDocumentRequest, opts ...grpc.CallOption) (*Document, error)
2432	// Lists documents.
2433	ListDocuments(ctx context.Context, in *ListDocumentsRequest, opts ...grpc.CallOption) (*ListDocumentsResponse, error)
2434	// Creates a new document.
2435	CreateDocument(ctx context.Context, in *CreateDocumentRequest, opts ...grpc.CallOption) (*Document, error)
2436	// Updates or inserts a document.
2437	UpdateDocument(ctx context.Context, in *UpdateDocumentRequest, opts ...grpc.CallOption) (*Document, error)
2438	// Deletes a document.
2439	DeleteDocument(ctx context.Context, in *DeleteDocumentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
2440	// Gets multiple documents.
2441	//
2442	// Documents returned by this method are not guaranteed to be returned in the
2443	// same order that they were requested.
2444	BatchGetDocuments(ctx context.Context, in *BatchGetDocumentsRequest, opts ...grpc.CallOption) (Firestore_BatchGetDocumentsClient, error)
2445	// Starts a new transaction.
2446	BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error)
2447	// Commits a transaction, while optionally updating documents.
2448	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
2449	// Rolls back a transaction.
2450	Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*empty.Empty, error)
2451	// Runs a query.
2452	RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (Firestore_RunQueryClient, error)
2453	// Streams batches of document updates and deletes, in order.
2454	Write(ctx context.Context, opts ...grpc.CallOption) (Firestore_WriteClient, error)
2455	// Listens to changes.
2456	Listen(ctx context.Context, opts ...grpc.CallOption) (Firestore_ListenClient, error)
2457	// Lists all the collection IDs underneath a document.
2458	ListCollectionIds(ctx context.Context, in *ListCollectionIdsRequest, opts ...grpc.CallOption) (*ListCollectionIdsResponse, error)
2459}
2460
2461type firestoreClient struct {
2462	cc *grpc.ClientConn
2463}
2464
2465func NewFirestoreClient(cc *grpc.ClientConn) FirestoreClient {
2466	return &firestoreClient{cc}
2467}
2468
2469func (c *firestoreClient) GetDocument(ctx context.Context, in *GetDocumentRequest, opts ...grpc.CallOption) (*Document, error) {
2470	out := new(Document)
2471	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/GetDocument", in, out, opts...)
2472	if err != nil {
2473		return nil, err
2474	}
2475	return out, nil
2476}
2477
2478func (c *firestoreClient) ListDocuments(ctx context.Context, in *ListDocumentsRequest, opts ...grpc.CallOption) (*ListDocumentsResponse, error) {
2479	out := new(ListDocumentsResponse)
2480	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/ListDocuments", in, out, opts...)
2481	if err != nil {
2482		return nil, err
2483	}
2484	return out, nil
2485}
2486
2487func (c *firestoreClient) CreateDocument(ctx context.Context, in *CreateDocumentRequest, opts ...grpc.CallOption) (*Document, error) {
2488	out := new(Document)
2489	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/CreateDocument", in, out, opts...)
2490	if err != nil {
2491		return nil, err
2492	}
2493	return out, nil
2494}
2495
2496func (c *firestoreClient) UpdateDocument(ctx context.Context, in *UpdateDocumentRequest, opts ...grpc.CallOption) (*Document, error) {
2497	out := new(Document)
2498	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/UpdateDocument", in, out, opts...)
2499	if err != nil {
2500		return nil, err
2501	}
2502	return out, nil
2503}
2504
2505func (c *firestoreClient) DeleteDocument(ctx context.Context, in *DeleteDocumentRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
2506	out := new(empty.Empty)
2507	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/DeleteDocument", in, out, opts...)
2508	if err != nil {
2509		return nil, err
2510	}
2511	return out, nil
2512}
2513
2514func (c *firestoreClient) BatchGetDocuments(ctx context.Context, in *BatchGetDocumentsRequest, opts ...grpc.CallOption) (Firestore_BatchGetDocumentsClient, error) {
2515	stream, err := c.cc.NewStream(ctx, &_Firestore_serviceDesc.Streams[0], "/google.firestore.v1beta1.Firestore/BatchGetDocuments", opts...)
2516	if err != nil {
2517		return nil, err
2518	}
2519	x := &firestoreBatchGetDocumentsClient{stream}
2520	if err := x.ClientStream.SendMsg(in); err != nil {
2521		return nil, err
2522	}
2523	if err := x.ClientStream.CloseSend(); err != nil {
2524		return nil, err
2525	}
2526	return x, nil
2527}
2528
2529type Firestore_BatchGetDocumentsClient interface {
2530	Recv() (*BatchGetDocumentsResponse, error)
2531	grpc.ClientStream
2532}
2533
2534type firestoreBatchGetDocumentsClient struct {
2535	grpc.ClientStream
2536}
2537
2538func (x *firestoreBatchGetDocumentsClient) Recv() (*BatchGetDocumentsResponse, error) {
2539	m := new(BatchGetDocumentsResponse)
2540	if err := x.ClientStream.RecvMsg(m); err != nil {
2541		return nil, err
2542	}
2543	return m, nil
2544}
2545
2546func (c *firestoreClient) BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error) {
2547	out := new(BeginTransactionResponse)
2548	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/BeginTransaction", in, out, opts...)
2549	if err != nil {
2550		return nil, err
2551	}
2552	return out, nil
2553}
2554
2555func (c *firestoreClient) Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error) {
2556	out := new(CommitResponse)
2557	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/Commit", in, out, opts...)
2558	if err != nil {
2559		return nil, err
2560	}
2561	return out, nil
2562}
2563
2564func (c *firestoreClient) Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
2565	out := new(empty.Empty)
2566	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/Rollback", in, out, opts...)
2567	if err != nil {
2568		return nil, err
2569	}
2570	return out, nil
2571}
2572
2573func (c *firestoreClient) RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (Firestore_RunQueryClient, error) {
2574	stream, err := c.cc.NewStream(ctx, &_Firestore_serviceDesc.Streams[1], "/google.firestore.v1beta1.Firestore/RunQuery", opts...)
2575	if err != nil {
2576		return nil, err
2577	}
2578	x := &firestoreRunQueryClient{stream}
2579	if err := x.ClientStream.SendMsg(in); err != nil {
2580		return nil, err
2581	}
2582	if err := x.ClientStream.CloseSend(); err != nil {
2583		return nil, err
2584	}
2585	return x, nil
2586}
2587
2588type Firestore_RunQueryClient interface {
2589	Recv() (*RunQueryResponse, error)
2590	grpc.ClientStream
2591}
2592
2593type firestoreRunQueryClient struct {
2594	grpc.ClientStream
2595}
2596
2597func (x *firestoreRunQueryClient) Recv() (*RunQueryResponse, error) {
2598	m := new(RunQueryResponse)
2599	if err := x.ClientStream.RecvMsg(m); err != nil {
2600		return nil, err
2601	}
2602	return m, nil
2603}
2604
2605func (c *firestoreClient) Write(ctx context.Context, opts ...grpc.CallOption) (Firestore_WriteClient, error) {
2606	stream, err := c.cc.NewStream(ctx, &_Firestore_serviceDesc.Streams[2], "/google.firestore.v1beta1.Firestore/Write", opts...)
2607	if err != nil {
2608		return nil, err
2609	}
2610	x := &firestoreWriteClient{stream}
2611	return x, nil
2612}
2613
2614type Firestore_WriteClient interface {
2615	Send(*WriteRequest) error
2616	Recv() (*WriteResponse, error)
2617	grpc.ClientStream
2618}
2619
2620type firestoreWriteClient struct {
2621	grpc.ClientStream
2622}
2623
2624func (x *firestoreWriteClient) Send(m *WriteRequest) error {
2625	return x.ClientStream.SendMsg(m)
2626}
2627
2628func (x *firestoreWriteClient) Recv() (*WriteResponse, error) {
2629	m := new(WriteResponse)
2630	if err := x.ClientStream.RecvMsg(m); err != nil {
2631		return nil, err
2632	}
2633	return m, nil
2634}
2635
2636func (c *firestoreClient) Listen(ctx context.Context, opts ...grpc.CallOption) (Firestore_ListenClient, error) {
2637	stream, err := c.cc.NewStream(ctx, &_Firestore_serviceDesc.Streams[3], "/google.firestore.v1beta1.Firestore/Listen", opts...)
2638	if err != nil {
2639		return nil, err
2640	}
2641	x := &firestoreListenClient{stream}
2642	return x, nil
2643}
2644
2645type Firestore_ListenClient interface {
2646	Send(*ListenRequest) error
2647	Recv() (*ListenResponse, error)
2648	grpc.ClientStream
2649}
2650
2651type firestoreListenClient struct {
2652	grpc.ClientStream
2653}
2654
2655func (x *firestoreListenClient) Send(m *ListenRequest) error {
2656	return x.ClientStream.SendMsg(m)
2657}
2658
2659func (x *firestoreListenClient) Recv() (*ListenResponse, error) {
2660	m := new(ListenResponse)
2661	if err := x.ClientStream.RecvMsg(m); err != nil {
2662		return nil, err
2663	}
2664	return m, nil
2665}
2666
2667func (c *firestoreClient) ListCollectionIds(ctx context.Context, in *ListCollectionIdsRequest, opts ...grpc.CallOption) (*ListCollectionIdsResponse, error) {
2668	out := new(ListCollectionIdsResponse)
2669	err := c.cc.Invoke(ctx, "/google.firestore.v1beta1.Firestore/ListCollectionIds", in, out, opts...)
2670	if err != nil {
2671		return nil, err
2672	}
2673	return out, nil
2674}
2675
2676// FirestoreServer is the server API for Firestore service.
2677type FirestoreServer interface {
2678	// Gets a single document.
2679	GetDocument(context.Context, *GetDocumentRequest) (*Document, error)
2680	// Lists documents.
2681	ListDocuments(context.Context, *ListDocumentsRequest) (*ListDocumentsResponse, error)
2682	// Creates a new document.
2683	CreateDocument(context.Context, *CreateDocumentRequest) (*Document, error)
2684	// Updates or inserts a document.
2685	UpdateDocument(context.Context, *UpdateDocumentRequest) (*Document, error)
2686	// Deletes a document.
2687	DeleteDocument(context.Context, *DeleteDocumentRequest) (*empty.Empty, error)
2688	// Gets multiple documents.
2689	//
2690	// Documents returned by this method are not guaranteed to be returned in the
2691	// same order that they were requested.
2692	BatchGetDocuments(*BatchGetDocumentsRequest, Firestore_BatchGetDocumentsServer) error
2693	// Starts a new transaction.
2694	BeginTransaction(context.Context, *BeginTransactionRequest) (*BeginTransactionResponse, error)
2695	// Commits a transaction, while optionally updating documents.
2696	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
2697	// Rolls back a transaction.
2698	Rollback(context.Context, *RollbackRequest) (*empty.Empty, error)
2699	// Runs a query.
2700	RunQuery(*RunQueryRequest, Firestore_RunQueryServer) error
2701	// Streams batches of document updates and deletes, in order.
2702	Write(Firestore_WriteServer) error
2703	// Listens to changes.
2704	Listen(Firestore_ListenServer) error
2705	// Lists all the collection IDs underneath a document.
2706	ListCollectionIds(context.Context, *ListCollectionIdsRequest) (*ListCollectionIdsResponse, error)
2707}
2708
2709func RegisterFirestoreServer(s *grpc.Server, srv FirestoreServer) {
2710	s.RegisterService(&_Firestore_serviceDesc, srv)
2711}
2712
2713func _Firestore_GetDocument_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2714	in := new(GetDocumentRequest)
2715	if err := dec(in); err != nil {
2716		return nil, err
2717	}
2718	if interceptor == nil {
2719		return srv.(FirestoreServer).GetDocument(ctx, in)
2720	}
2721	info := &grpc.UnaryServerInfo{
2722		Server:     srv,
2723		FullMethod: "/google.firestore.v1beta1.Firestore/GetDocument",
2724	}
2725	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2726		return srv.(FirestoreServer).GetDocument(ctx, req.(*GetDocumentRequest))
2727	}
2728	return interceptor(ctx, in, info, handler)
2729}
2730
2731func _Firestore_ListDocuments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2732	in := new(ListDocumentsRequest)
2733	if err := dec(in); err != nil {
2734		return nil, err
2735	}
2736	if interceptor == nil {
2737		return srv.(FirestoreServer).ListDocuments(ctx, in)
2738	}
2739	info := &grpc.UnaryServerInfo{
2740		Server:     srv,
2741		FullMethod: "/google.firestore.v1beta1.Firestore/ListDocuments",
2742	}
2743	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2744		return srv.(FirestoreServer).ListDocuments(ctx, req.(*ListDocumentsRequest))
2745	}
2746	return interceptor(ctx, in, info, handler)
2747}
2748
2749func _Firestore_CreateDocument_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2750	in := new(CreateDocumentRequest)
2751	if err := dec(in); err != nil {
2752		return nil, err
2753	}
2754	if interceptor == nil {
2755		return srv.(FirestoreServer).CreateDocument(ctx, in)
2756	}
2757	info := &grpc.UnaryServerInfo{
2758		Server:     srv,
2759		FullMethod: "/google.firestore.v1beta1.Firestore/CreateDocument",
2760	}
2761	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2762		return srv.(FirestoreServer).CreateDocument(ctx, req.(*CreateDocumentRequest))
2763	}
2764	return interceptor(ctx, in, info, handler)
2765}
2766
2767func _Firestore_UpdateDocument_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2768	in := new(UpdateDocumentRequest)
2769	if err := dec(in); err != nil {
2770		return nil, err
2771	}
2772	if interceptor == nil {
2773		return srv.(FirestoreServer).UpdateDocument(ctx, in)
2774	}
2775	info := &grpc.UnaryServerInfo{
2776		Server:     srv,
2777		FullMethod: "/google.firestore.v1beta1.Firestore/UpdateDocument",
2778	}
2779	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2780		return srv.(FirestoreServer).UpdateDocument(ctx, req.(*UpdateDocumentRequest))
2781	}
2782	return interceptor(ctx, in, info, handler)
2783}
2784
2785func _Firestore_DeleteDocument_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2786	in := new(DeleteDocumentRequest)
2787	if err := dec(in); err != nil {
2788		return nil, err
2789	}
2790	if interceptor == nil {
2791		return srv.(FirestoreServer).DeleteDocument(ctx, in)
2792	}
2793	info := &grpc.UnaryServerInfo{
2794		Server:     srv,
2795		FullMethod: "/google.firestore.v1beta1.Firestore/DeleteDocument",
2796	}
2797	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2798		return srv.(FirestoreServer).DeleteDocument(ctx, req.(*DeleteDocumentRequest))
2799	}
2800	return interceptor(ctx, in, info, handler)
2801}
2802
2803func _Firestore_BatchGetDocuments_Handler(srv interface{}, stream grpc.ServerStream) error {
2804	m := new(BatchGetDocumentsRequest)
2805	if err := stream.RecvMsg(m); err != nil {
2806		return err
2807	}
2808	return srv.(FirestoreServer).BatchGetDocuments(m, &firestoreBatchGetDocumentsServer{stream})
2809}
2810
2811type Firestore_BatchGetDocumentsServer interface {
2812	Send(*BatchGetDocumentsResponse) error
2813	grpc.ServerStream
2814}
2815
2816type firestoreBatchGetDocumentsServer struct {
2817	grpc.ServerStream
2818}
2819
2820func (x *firestoreBatchGetDocumentsServer) Send(m *BatchGetDocumentsResponse) error {
2821	return x.ServerStream.SendMsg(m)
2822}
2823
2824func _Firestore_BeginTransaction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2825	in := new(BeginTransactionRequest)
2826	if err := dec(in); err != nil {
2827		return nil, err
2828	}
2829	if interceptor == nil {
2830		return srv.(FirestoreServer).BeginTransaction(ctx, in)
2831	}
2832	info := &grpc.UnaryServerInfo{
2833		Server:     srv,
2834		FullMethod: "/google.firestore.v1beta1.Firestore/BeginTransaction",
2835	}
2836	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2837		return srv.(FirestoreServer).BeginTransaction(ctx, req.(*BeginTransactionRequest))
2838	}
2839	return interceptor(ctx, in, info, handler)
2840}
2841
2842func _Firestore_Commit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2843	in := new(CommitRequest)
2844	if err := dec(in); err != nil {
2845		return nil, err
2846	}
2847	if interceptor == nil {
2848		return srv.(FirestoreServer).Commit(ctx, in)
2849	}
2850	info := &grpc.UnaryServerInfo{
2851		Server:     srv,
2852		FullMethod: "/google.firestore.v1beta1.Firestore/Commit",
2853	}
2854	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2855		return srv.(FirestoreServer).Commit(ctx, req.(*CommitRequest))
2856	}
2857	return interceptor(ctx, in, info, handler)
2858}
2859
2860func _Firestore_Rollback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2861	in := new(RollbackRequest)
2862	if err := dec(in); err != nil {
2863		return nil, err
2864	}
2865	if interceptor == nil {
2866		return srv.(FirestoreServer).Rollback(ctx, in)
2867	}
2868	info := &grpc.UnaryServerInfo{
2869		Server:     srv,
2870		FullMethod: "/google.firestore.v1beta1.Firestore/Rollback",
2871	}
2872	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2873		return srv.(FirestoreServer).Rollback(ctx, req.(*RollbackRequest))
2874	}
2875	return interceptor(ctx, in, info, handler)
2876}
2877
2878func _Firestore_RunQuery_Handler(srv interface{}, stream grpc.ServerStream) error {
2879	m := new(RunQueryRequest)
2880	if err := stream.RecvMsg(m); err != nil {
2881		return err
2882	}
2883	return srv.(FirestoreServer).RunQuery(m, &firestoreRunQueryServer{stream})
2884}
2885
2886type Firestore_RunQueryServer interface {
2887	Send(*RunQueryResponse) error
2888	grpc.ServerStream
2889}
2890
2891type firestoreRunQueryServer struct {
2892	grpc.ServerStream
2893}
2894
2895func (x *firestoreRunQueryServer) Send(m *RunQueryResponse) error {
2896	return x.ServerStream.SendMsg(m)
2897}
2898
2899func _Firestore_Write_Handler(srv interface{}, stream grpc.ServerStream) error {
2900	return srv.(FirestoreServer).Write(&firestoreWriteServer{stream})
2901}
2902
2903type Firestore_WriteServer interface {
2904	Send(*WriteResponse) error
2905	Recv() (*WriteRequest, error)
2906	grpc.ServerStream
2907}
2908
2909type firestoreWriteServer struct {
2910	grpc.ServerStream
2911}
2912
2913func (x *firestoreWriteServer) Send(m *WriteResponse) error {
2914	return x.ServerStream.SendMsg(m)
2915}
2916
2917func (x *firestoreWriteServer) Recv() (*WriteRequest, error) {
2918	m := new(WriteRequest)
2919	if err := x.ServerStream.RecvMsg(m); err != nil {
2920		return nil, err
2921	}
2922	return m, nil
2923}
2924
2925func _Firestore_Listen_Handler(srv interface{}, stream grpc.ServerStream) error {
2926	return srv.(FirestoreServer).Listen(&firestoreListenServer{stream})
2927}
2928
2929type Firestore_ListenServer interface {
2930	Send(*ListenResponse) error
2931	Recv() (*ListenRequest, error)
2932	grpc.ServerStream
2933}
2934
2935type firestoreListenServer struct {
2936	grpc.ServerStream
2937}
2938
2939func (x *firestoreListenServer) Send(m *ListenResponse) error {
2940	return x.ServerStream.SendMsg(m)
2941}
2942
2943func (x *firestoreListenServer) Recv() (*ListenRequest, error) {
2944	m := new(ListenRequest)
2945	if err := x.ServerStream.RecvMsg(m); err != nil {
2946		return nil, err
2947	}
2948	return m, nil
2949}
2950
2951func _Firestore_ListCollectionIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2952	in := new(ListCollectionIdsRequest)
2953	if err := dec(in); err != nil {
2954		return nil, err
2955	}
2956	if interceptor == nil {
2957		return srv.(FirestoreServer).ListCollectionIds(ctx, in)
2958	}
2959	info := &grpc.UnaryServerInfo{
2960		Server:     srv,
2961		FullMethod: "/google.firestore.v1beta1.Firestore/ListCollectionIds",
2962	}
2963	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2964		return srv.(FirestoreServer).ListCollectionIds(ctx, req.(*ListCollectionIdsRequest))
2965	}
2966	return interceptor(ctx, in, info, handler)
2967}
2968
2969var _Firestore_serviceDesc = grpc.ServiceDesc{
2970	ServiceName: "google.firestore.v1beta1.Firestore",
2971	HandlerType: (*FirestoreServer)(nil),
2972	Methods: []grpc.MethodDesc{
2973		{
2974			MethodName: "GetDocument",
2975			Handler:    _Firestore_GetDocument_Handler,
2976		},
2977		{
2978			MethodName: "ListDocuments",
2979			Handler:    _Firestore_ListDocuments_Handler,
2980		},
2981		{
2982			MethodName: "CreateDocument",
2983			Handler:    _Firestore_CreateDocument_Handler,
2984		},
2985		{
2986			MethodName: "UpdateDocument",
2987			Handler:    _Firestore_UpdateDocument_Handler,
2988		},
2989		{
2990			MethodName: "DeleteDocument",
2991			Handler:    _Firestore_DeleteDocument_Handler,
2992		},
2993		{
2994			MethodName: "BeginTransaction",
2995			Handler:    _Firestore_BeginTransaction_Handler,
2996		},
2997		{
2998			MethodName: "Commit",
2999			Handler:    _Firestore_Commit_Handler,
3000		},
3001		{
3002			MethodName: "Rollback",
3003			Handler:    _Firestore_Rollback_Handler,
3004		},
3005		{
3006			MethodName: "ListCollectionIds",
3007			Handler:    _Firestore_ListCollectionIds_Handler,
3008		},
3009	},
3010	Streams: []grpc.StreamDesc{
3011		{
3012			StreamName:    "BatchGetDocuments",
3013			Handler:       _Firestore_BatchGetDocuments_Handler,
3014			ServerStreams: true,
3015		},
3016		{
3017			StreamName:    "RunQuery",
3018			Handler:       _Firestore_RunQuery_Handler,
3019			ServerStreams: true,
3020		},
3021		{
3022			StreamName:    "Write",
3023			Handler:       _Firestore_Write_Handler,
3024			ServerStreams: true,
3025			ClientStreams: true,
3026		},
3027		{
3028			StreamName:    "Listen",
3029			Handler:       _Firestore_Listen_Handler,
3030			ServerStreams: true,
3031			ClientStreams: true,
3032		},
3033	},
3034	Metadata: "google/firestore/v1beta1/firestore.proto",
3035}
3036