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