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