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