1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/datastore/v1/datastore.proto 3 4package datastore 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 _ "google.golang.org/genproto/googleapis/api/annotations" 13 grpc "google.golang.org/grpc" 14) 15 16// Reference imports to suppress errors if they are not otherwise used. 17var _ = proto.Marshal 18var _ = fmt.Errorf 19var _ = math.Inf 20 21// This is a compile-time assertion to ensure that this generated file 22// is compatible with the proto package it is being compiled against. 23// A compilation error at this line likely means your copy of the 24// proto package needs to be updated. 25const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 26 27// The modes available for commits. 28type CommitRequest_Mode int32 29 30const ( 31 // Unspecified. This value must not be used. 32 CommitRequest_MODE_UNSPECIFIED CommitRequest_Mode = 0 33 // Transactional: The mutations are either all applied, or none are applied. 34 // Learn about transactions 35 // [here](https://cloud.google.com/datastore/docs/concepts/transactions). 36 CommitRequest_TRANSACTIONAL CommitRequest_Mode = 1 37 // Non-transactional: The mutations may not apply as all or none. 38 CommitRequest_NON_TRANSACTIONAL CommitRequest_Mode = 2 39) 40 41var CommitRequest_Mode_name = map[int32]string{ 42 0: "MODE_UNSPECIFIED", 43 1: "TRANSACTIONAL", 44 2: "NON_TRANSACTIONAL", 45} 46 47var CommitRequest_Mode_value = map[string]int32{ 48 "MODE_UNSPECIFIED": 0, 49 "TRANSACTIONAL": 1, 50 "NON_TRANSACTIONAL": 2, 51} 52 53func (x CommitRequest_Mode) String() string { 54 return proto.EnumName(CommitRequest_Mode_name, int32(x)) 55} 56 57func (CommitRequest_Mode) EnumDescriptor() ([]byte, []int) { 58 return fileDescriptor_9ad66bfcb30c1b57, []int{8, 0} 59} 60 61// The possible values for read consistencies. 62type ReadOptions_ReadConsistency int32 63 64const ( 65 // Unspecified. This value must not be used. 66 ReadOptions_READ_CONSISTENCY_UNSPECIFIED ReadOptions_ReadConsistency = 0 67 // Strong consistency. 68 ReadOptions_STRONG ReadOptions_ReadConsistency = 1 69 // Eventual consistency. 70 ReadOptions_EVENTUAL ReadOptions_ReadConsistency = 2 71) 72 73var ReadOptions_ReadConsistency_name = map[int32]string{ 74 0: "READ_CONSISTENCY_UNSPECIFIED", 75 1: "STRONG", 76 2: "EVENTUAL", 77} 78 79var ReadOptions_ReadConsistency_value = map[string]int32{ 80 "READ_CONSISTENCY_UNSPECIFIED": 0, 81 "STRONG": 1, 82 "EVENTUAL": 2, 83} 84 85func (x ReadOptions_ReadConsistency) String() string { 86 return proto.EnumName(ReadOptions_ReadConsistency_name, int32(x)) 87} 88 89func (ReadOptions_ReadConsistency) EnumDescriptor() ([]byte, []int) { 90 return fileDescriptor_9ad66bfcb30c1b57, []int{16, 0} 91} 92 93// The request for [Datastore.Lookup][google.datastore.v1.Datastore.Lookup]. 94type LookupRequest struct { 95 // The ID of the project against which to make the request. 96 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 97 // The options for this lookup request. 98 ReadOptions *ReadOptions `protobuf:"bytes,1,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"` 99 // Keys of entities to look up. 100 Keys []*Key `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"` 101 XXX_NoUnkeyedLiteral struct{} `json:"-"` 102 XXX_unrecognized []byte `json:"-"` 103 XXX_sizecache int32 `json:"-"` 104} 105 106func (m *LookupRequest) Reset() { *m = LookupRequest{} } 107func (m *LookupRequest) String() string { return proto.CompactTextString(m) } 108func (*LookupRequest) ProtoMessage() {} 109func (*LookupRequest) Descriptor() ([]byte, []int) { 110 return fileDescriptor_9ad66bfcb30c1b57, []int{0} 111} 112 113func (m *LookupRequest) XXX_Unmarshal(b []byte) error { 114 return xxx_messageInfo_LookupRequest.Unmarshal(m, b) 115} 116func (m *LookupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 117 return xxx_messageInfo_LookupRequest.Marshal(b, m, deterministic) 118} 119func (m *LookupRequest) XXX_Merge(src proto.Message) { 120 xxx_messageInfo_LookupRequest.Merge(m, src) 121} 122func (m *LookupRequest) XXX_Size() int { 123 return xxx_messageInfo_LookupRequest.Size(m) 124} 125func (m *LookupRequest) XXX_DiscardUnknown() { 126 xxx_messageInfo_LookupRequest.DiscardUnknown(m) 127} 128 129var xxx_messageInfo_LookupRequest proto.InternalMessageInfo 130 131func (m *LookupRequest) GetProjectId() string { 132 if m != nil { 133 return m.ProjectId 134 } 135 return "" 136} 137 138func (m *LookupRequest) GetReadOptions() *ReadOptions { 139 if m != nil { 140 return m.ReadOptions 141 } 142 return nil 143} 144 145func (m *LookupRequest) GetKeys() []*Key { 146 if m != nil { 147 return m.Keys 148 } 149 return nil 150} 151 152// The response for [Datastore.Lookup][google.datastore.v1.Datastore.Lookup]. 153type LookupResponse struct { 154 // Entities found as `ResultType.FULL` entities. The order of results in this 155 // field is undefined and has no relation to the order of the keys in the 156 // input. 157 Found []*EntityResult `protobuf:"bytes,1,rep,name=found,proto3" json:"found,omitempty"` 158 // Entities not found as `ResultType.KEY_ONLY` entities. The order of results 159 // in this field is undefined and has no relation to the order of the keys 160 // in the input. 161 Missing []*EntityResult `protobuf:"bytes,2,rep,name=missing,proto3" json:"missing,omitempty"` 162 // A list of keys that were not looked up due to resource constraints. The 163 // order of results in this field is undefined and has no relation to the 164 // order of the keys in the input. 165 Deferred []*Key `protobuf:"bytes,3,rep,name=deferred,proto3" json:"deferred,omitempty"` 166 XXX_NoUnkeyedLiteral struct{} `json:"-"` 167 XXX_unrecognized []byte `json:"-"` 168 XXX_sizecache int32 `json:"-"` 169} 170 171func (m *LookupResponse) Reset() { *m = LookupResponse{} } 172func (m *LookupResponse) String() string { return proto.CompactTextString(m) } 173func (*LookupResponse) ProtoMessage() {} 174func (*LookupResponse) Descriptor() ([]byte, []int) { 175 return fileDescriptor_9ad66bfcb30c1b57, []int{1} 176} 177 178func (m *LookupResponse) XXX_Unmarshal(b []byte) error { 179 return xxx_messageInfo_LookupResponse.Unmarshal(m, b) 180} 181func (m *LookupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 182 return xxx_messageInfo_LookupResponse.Marshal(b, m, deterministic) 183} 184func (m *LookupResponse) XXX_Merge(src proto.Message) { 185 xxx_messageInfo_LookupResponse.Merge(m, src) 186} 187func (m *LookupResponse) XXX_Size() int { 188 return xxx_messageInfo_LookupResponse.Size(m) 189} 190func (m *LookupResponse) XXX_DiscardUnknown() { 191 xxx_messageInfo_LookupResponse.DiscardUnknown(m) 192} 193 194var xxx_messageInfo_LookupResponse proto.InternalMessageInfo 195 196func (m *LookupResponse) GetFound() []*EntityResult { 197 if m != nil { 198 return m.Found 199 } 200 return nil 201} 202 203func (m *LookupResponse) GetMissing() []*EntityResult { 204 if m != nil { 205 return m.Missing 206 } 207 return nil 208} 209 210func (m *LookupResponse) GetDeferred() []*Key { 211 if m != nil { 212 return m.Deferred 213 } 214 return nil 215} 216 217// The request for [Datastore.RunQuery][google.datastore.v1.Datastore.RunQuery]. 218type RunQueryRequest struct { 219 // The ID of the project against which to make the request. 220 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 221 // Entities are partitioned into subsets, identified by a partition ID. 222 // Queries are scoped to a single partition. 223 // This partition ID is normalized with the standard default context 224 // partition ID. 225 PartitionId *PartitionId `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` 226 // The options for this query. 227 ReadOptions *ReadOptions `protobuf:"bytes,1,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"` 228 // The type of query. 229 // 230 // Types that are valid to be assigned to QueryType: 231 // *RunQueryRequest_Query 232 // *RunQueryRequest_GqlQuery 233 QueryType isRunQueryRequest_QueryType `protobuf_oneof:"query_type"` 234 XXX_NoUnkeyedLiteral struct{} `json:"-"` 235 XXX_unrecognized []byte `json:"-"` 236 XXX_sizecache int32 `json:"-"` 237} 238 239func (m *RunQueryRequest) Reset() { *m = RunQueryRequest{} } 240func (m *RunQueryRequest) String() string { return proto.CompactTextString(m) } 241func (*RunQueryRequest) ProtoMessage() {} 242func (*RunQueryRequest) Descriptor() ([]byte, []int) { 243 return fileDescriptor_9ad66bfcb30c1b57, []int{2} 244} 245 246func (m *RunQueryRequest) XXX_Unmarshal(b []byte) error { 247 return xxx_messageInfo_RunQueryRequest.Unmarshal(m, b) 248} 249func (m *RunQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 250 return xxx_messageInfo_RunQueryRequest.Marshal(b, m, deterministic) 251} 252func (m *RunQueryRequest) XXX_Merge(src proto.Message) { 253 xxx_messageInfo_RunQueryRequest.Merge(m, src) 254} 255func (m *RunQueryRequest) XXX_Size() int { 256 return xxx_messageInfo_RunQueryRequest.Size(m) 257} 258func (m *RunQueryRequest) XXX_DiscardUnknown() { 259 xxx_messageInfo_RunQueryRequest.DiscardUnknown(m) 260} 261 262var xxx_messageInfo_RunQueryRequest proto.InternalMessageInfo 263 264func (m *RunQueryRequest) GetProjectId() string { 265 if m != nil { 266 return m.ProjectId 267 } 268 return "" 269} 270 271func (m *RunQueryRequest) GetPartitionId() *PartitionId { 272 if m != nil { 273 return m.PartitionId 274 } 275 return nil 276} 277 278func (m *RunQueryRequest) GetReadOptions() *ReadOptions { 279 if m != nil { 280 return m.ReadOptions 281 } 282 return nil 283} 284 285type isRunQueryRequest_QueryType interface { 286 isRunQueryRequest_QueryType() 287} 288 289type RunQueryRequest_Query struct { 290 Query *Query `protobuf:"bytes,3,opt,name=query,proto3,oneof"` 291} 292 293type RunQueryRequest_GqlQuery struct { 294 GqlQuery *GqlQuery `protobuf:"bytes,7,opt,name=gql_query,json=gqlQuery,proto3,oneof"` 295} 296 297func (*RunQueryRequest_Query) isRunQueryRequest_QueryType() {} 298 299func (*RunQueryRequest_GqlQuery) isRunQueryRequest_QueryType() {} 300 301func (m *RunQueryRequest) GetQueryType() isRunQueryRequest_QueryType { 302 if m != nil { 303 return m.QueryType 304 } 305 return nil 306} 307 308func (m *RunQueryRequest) GetQuery() *Query { 309 if x, ok := m.GetQueryType().(*RunQueryRequest_Query); ok { 310 return x.Query 311 } 312 return nil 313} 314 315func (m *RunQueryRequest) GetGqlQuery() *GqlQuery { 316 if x, ok := m.GetQueryType().(*RunQueryRequest_GqlQuery); ok { 317 return x.GqlQuery 318 } 319 return nil 320} 321 322// XXX_OneofWrappers is for the internal use of the proto package. 323func (*RunQueryRequest) XXX_OneofWrappers() []interface{} { 324 return []interface{}{ 325 (*RunQueryRequest_Query)(nil), 326 (*RunQueryRequest_GqlQuery)(nil), 327 } 328} 329 330// The response for 331// [Datastore.RunQuery][google.datastore.v1.Datastore.RunQuery]. 332type RunQueryResponse struct { 333 // A batch of query results (always present). 334 Batch *QueryResultBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"` 335 // The parsed form of the `GqlQuery` from the request, if it was set. 336 Query *Query `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` 337 XXX_NoUnkeyedLiteral struct{} `json:"-"` 338 XXX_unrecognized []byte `json:"-"` 339 XXX_sizecache int32 `json:"-"` 340} 341 342func (m *RunQueryResponse) Reset() { *m = RunQueryResponse{} } 343func (m *RunQueryResponse) String() string { return proto.CompactTextString(m) } 344func (*RunQueryResponse) ProtoMessage() {} 345func (*RunQueryResponse) Descriptor() ([]byte, []int) { 346 return fileDescriptor_9ad66bfcb30c1b57, []int{3} 347} 348 349func (m *RunQueryResponse) XXX_Unmarshal(b []byte) error { 350 return xxx_messageInfo_RunQueryResponse.Unmarshal(m, b) 351} 352func (m *RunQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 353 return xxx_messageInfo_RunQueryResponse.Marshal(b, m, deterministic) 354} 355func (m *RunQueryResponse) XXX_Merge(src proto.Message) { 356 xxx_messageInfo_RunQueryResponse.Merge(m, src) 357} 358func (m *RunQueryResponse) XXX_Size() int { 359 return xxx_messageInfo_RunQueryResponse.Size(m) 360} 361func (m *RunQueryResponse) XXX_DiscardUnknown() { 362 xxx_messageInfo_RunQueryResponse.DiscardUnknown(m) 363} 364 365var xxx_messageInfo_RunQueryResponse proto.InternalMessageInfo 366 367func (m *RunQueryResponse) GetBatch() *QueryResultBatch { 368 if m != nil { 369 return m.Batch 370 } 371 return nil 372} 373 374func (m *RunQueryResponse) GetQuery() *Query { 375 if m != nil { 376 return m.Query 377 } 378 return nil 379} 380 381// The request for 382// [Datastore.BeginTransaction][google.datastore.v1.Datastore.BeginTransaction]. 383type BeginTransactionRequest struct { 384 // The ID of the project against which to make the request. 385 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 386 // Options for a new transaction. 387 TransactionOptions *TransactionOptions `protobuf:"bytes,10,opt,name=transaction_options,json=transactionOptions,proto3" json:"transaction_options,omitempty"` 388 XXX_NoUnkeyedLiteral struct{} `json:"-"` 389 XXX_unrecognized []byte `json:"-"` 390 XXX_sizecache int32 `json:"-"` 391} 392 393func (m *BeginTransactionRequest) Reset() { *m = BeginTransactionRequest{} } 394func (m *BeginTransactionRequest) String() string { return proto.CompactTextString(m) } 395func (*BeginTransactionRequest) ProtoMessage() {} 396func (*BeginTransactionRequest) Descriptor() ([]byte, []int) { 397 return fileDescriptor_9ad66bfcb30c1b57, []int{4} 398} 399 400func (m *BeginTransactionRequest) XXX_Unmarshal(b []byte) error { 401 return xxx_messageInfo_BeginTransactionRequest.Unmarshal(m, b) 402} 403func (m *BeginTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 404 return xxx_messageInfo_BeginTransactionRequest.Marshal(b, m, deterministic) 405} 406func (m *BeginTransactionRequest) XXX_Merge(src proto.Message) { 407 xxx_messageInfo_BeginTransactionRequest.Merge(m, src) 408} 409func (m *BeginTransactionRequest) XXX_Size() int { 410 return xxx_messageInfo_BeginTransactionRequest.Size(m) 411} 412func (m *BeginTransactionRequest) XXX_DiscardUnknown() { 413 xxx_messageInfo_BeginTransactionRequest.DiscardUnknown(m) 414} 415 416var xxx_messageInfo_BeginTransactionRequest proto.InternalMessageInfo 417 418func (m *BeginTransactionRequest) GetProjectId() string { 419 if m != nil { 420 return m.ProjectId 421 } 422 return "" 423} 424 425func (m *BeginTransactionRequest) GetTransactionOptions() *TransactionOptions { 426 if m != nil { 427 return m.TransactionOptions 428 } 429 return nil 430} 431 432// The response for 433// [Datastore.BeginTransaction][google.datastore.v1.Datastore.BeginTransaction]. 434type BeginTransactionResponse struct { 435 // The transaction identifier (always present). 436 Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` 437 XXX_NoUnkeyedLiteral struct{} `json:"-"` 438 XXX_unrecognized []byte `json:"-"` 439 XXX_sizecache int32 `json:"-"` 440} 441 442func (m *BeginTransactionResponse) Reset() { *m = BeginTransactionResponse{} } 443func (m *BeginTransactionResponse) String() string { return proto.CompactTextString(m) } 444func (*BeginTransactionResponse) ProtoMessage() {} 445func (*BeginTransactionResponse) Descriptor() ([]byte, []int) { 446 return fileDescriptor_9ad66bfcb30c1b57, []int{5} 447} 448 449func (m *BeginTransactionResponse) XXX_Unmarshal(b []byte) error { 450 return xxx_messageInfo_BeginTransactionResponse.Unmarshal(m, b) 451} 452func (m *BeginTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 453 return xxx_messageInfo_BeginTransactionResponse.Marshal(b, m, deterministic) 454} 455func (m *BeginTransactionResponse) XXX_Merge(src proto.Message) { 456 xxx_messageInfo_BeginTransactionResponse.Merge(m, src) 457} 458func (m *BeginTransactionResponse) XXX_Size() int { 459 return xxx_messageInfo_BeginTransactionResponse.Size(m) 460} 461func (m *BeginTransactionResponse) XXX_DiscardUnknown() { 462 xxx_messageInfo_BeginTransactionResponse.DiscardUnknown(m) 463} 464 465var xxx_messageInfo_BeginTransactionResponse proto.InternalMessageInfo 466 467func (m *BeginTransactionResponse) GetTransaction() []byte { 468 if m != nil { 469 return m.Transaction 470 } 471 return nil 472} 473 474// The request for [Datastore.Rollback][google.datastore.v1.Datastore.Rollback]. 475type RollbackRequest struct { 476 // The ID of the project against which to make the request. 477 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 478 // The transaction identifier, returned by a call to 479 // [Datastore.BeginTransaction][google.datastore.v1.Datastore.BeginTransaction]. 480 Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` 481 XXX_NoUnkeyedLiteral struct{} `json:"-"` 482 XXX_unrecognized []byte `json:"-"` 483 XXX_sizecache int32 `json:"-"` 484} 485 486func (m *RollbackRequest) Reset() { *m = RollbackRequest{} } 487func (m *RollbackRequest) String() string { return proto.CompactTextString(m) } 488func (*RollbackRequest) ProtoMessage() {} 489func (*RollbackRequest) Descriptor() ([]byte, []int) { 490 return fileDescriptor_9ad66bfcb30c1b57, []int{6} 491} 492 493func (m *RollbackRequest) XXX_Unmarshal(b []byte) error { 494 return xxx_messageInfo_RollbackRequest.Unmarshal(m, b) 495} 496func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 497 return xxx_messageInfo_RollbackRequest.Marshal(b, m, deterministic) 498} 499func (m *RollbackRequest) XXX_Merge(src proto.Message) { 500 xxx_messageInfo_RollbackRequest.Merge(m, src) 501} 502func (m *RollbackRequest) XXX_Size() int { 503 return xxx_messageInfo_RollbackRequest.Size(m) 504} 505func (m *RollbackRequest) XXX_DiscardUnknown() { 506 xxx_messageInfo_RollbackRequest.DiscardUnknown(m) 507} 508 509var xxx_messageInfo_RollbackRequest proto.InternalMessageInfo 510 511func (m *RollbackRequest) GetProjectId() string { 512 if m != nil { 513 return m.ProjectId 514 } 515 return "" 516} 517 518func (m *RollbackRequest) GetTransaction() []byte { 519 if m != nil { 520 return m.Transaction 521 } 522 return nil 523} 524 525// The response for 526// [Datastore.Rollback][google.datastore.v1.Datastore.Rollback]. (an empty 527// message). 528type RollbackResponse struct { 529 XXX_NoUnkeyedLiteral struct{} `json:"-"` 530 XXX_unrecognized []byte `json:"-"` 531 XXX_sizecache int32 `json:"-"` 532} 533 534func (m *RollbackResponse) Reset() { *m = RollbackResponse{} } 535func (m *RollbackResponse) String() string { return proto.CompactTextString(m) } 536func (*RollbackResponse) ProtoMessage() {} 537func (*RollbackResponse) Descriptor() ([]byte, []int) { 538 return fileDescriptor_9ad66bfcb30c1b57, []int{7} 539} 540 541func (m *RollbackResponse) XXX_Unmarshal(b []byte) error { 542 return xxx_messageInfo_RollbackResponse.Unmarshal(m, b) 543} 544func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 545 return xxx_messageInfo_RollbackResponse.Marshal(b, m, deterministic) 546} 547func (m *RollbackResponse) XXX_Merge(src proto.Message) { 548 xxx_messageInfo_RollbackResponse.Merge(m, src) 549} 550func (m *RollbackResponse) XXX_Size() int { 551 return xxx_messageInfo_RollbackResponse.Size(m) 552} 553func (m *RollbackResponse) XXX_DiscardUnknown() { 554 xxx_messageInfo_RollbackResponse.DiscardUnknown(m) 555} 556 557var xxx_messageInfo_RollbackResponse proto.InternalMessageInfo 558 559// The request for [Datastore.Commit][google.datastore.v1.Datastore.Commit]. 560type CommitRequest struct { 561 // The ID of the project against which to make the request. 562 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 563 // The type of commit to perform. Defaults to `TRANSACTIONAL`. 564 Mode CommitRequest_Mode `protobuf:"varint,5,opt,name=mode,proto3,enum=google.datastore.v1.CommitRequest_Mode" json:"mode,omitempty"` 565 // Must be set when mode is `TRANSACTIONAL`. 566 // 567 // Types that are valid to be assigned to TransactionSelector: 568 // *CommitRequest_Transaction 569 TransactionSelector isCommitRequest_TransactionSelector `protobuf_oneof:"transaction_selector"` 570 // The mutations to perform. 571 // 572 // When mode is `TRANSACTIONAL`, mutations affecting a single entity are 573 // applied in order. The following sequences of mutations affecting a single 574 // entity are not permitted in a single `Commit` request: 575 // 576 // - `insert` followed by `insert` 577 // - `update` followed by `insert` 578 // - `upsert` followed by `insert` 579 // - `delete` followed by `update` 580 // 581 // When mode is `NON_TRANSACTIONAL`, no two mutations may affect a single 582 // entity. 583 Mutations []*Mutation `protobuf:"bytes,6,rep,name=mutations,proto3" json:"mutations,omitempty"` 584 XXX_NoUnkeyedLiteral struct{} `json:"-"` 585 XXX_unrecognized []byte `json:"-"` 586 XXX_sizecache int32 `json:"-"` 587} 588 589func (m *CommitRequest) Reset() { *m = CommitRequest{} } 590func (m *CommitRequest) String() string { return proto.CompactTextString(m) } 591func (*CommitRequest) ProtoMessage() {} 592func (*CommitRequest) Descriptor() ([]byte, []int) { 593 return fileDescriptor_9ad66bfcb30c1b57, []int{8} 594} 595 596func (m *CommitRequest) XXX_Unmarshal(b []byte) error { 597 return xxx_messageInfo_CommitRequest.Unmarshal(m, b) 598} 599func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 600 return xxx_messageInfo_CommitRequest.Marshal(b, m, deterministic) 601} 602func (m *CommitRequest) XXX_Merge(src proto.Message) { 603 xxx_messageInfo_CommitRequest.Merge(m, src) 604} 605func (m *CommitRequest) XXX_Size() int { 606 return xxx_messageInfo_CommitRequest.Size(m) 607} 608func (m *CommitRequest) XXX_DiscardUnknown() { 609 xxx_messageInfo_CommitRequest.DiscardUnknown(m) 610} 611 612var xxx_messageInfo_CommitRequest proto.InternalMessageInfo 613 614func (m *CommitRequest) GetProjectId() string { 615 if m != nil { 616 return m.ProjectId 617 } 618 return "" 619} 620 621func (m *CommitRequest) GetMode() CommitRequest_Mode { 622 if m != nil { 623 return m.Mode 624 } 625 return CommitRequest_MODE_UNSPECIFIED 626} 627 628type isCommitRequest_TransactionSelector interface { 629 isCommitRequest_TransactionSelector() 630} 631 632type CommitRequest_Transaction struct { 633 Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3,oneof"` 634} 635 636func (*CommitRequest_Transaction) isCommitRequest_TransactionSelector() {} 637 638func (m *CommitRequest) GetTransactionSelector() isCommitRequest_TransactionSelector { 639 if m != nil { 640 return m.TransactionSelector 641 } 642 return nil 643} 644 645func (m *CommitRequest) GetTransaction() []byte { 646 if x, ok := m.GetTransactionSelector().(*CommitRequest_Transaction); ok { 647 return x.Transaction 648 } 649 return nil 650} 651 652func (m *CommitRequest) GetMutations() []*Mutation { 653 if m != nil { 654 return m.Mutations 655 } 656 return nil 657} 658 659// XXX_OneofWrappers is for the internal use of the proto package. 660func (*CommitRequest) XXX_OneofWrappers() []interface{} { 661 return []interface{}{ 662 (*CommitRequest_Transaction)(nil), 663 } 664} 665 666// The response for [Datastore.Commit][google.datastore.v1.Datastore.Commit]. 667type CommitResponse struct { 668 // The result of performing the mutations. 669 // The i-th mutation result corresponds to the i-th mutation in the request. 670 MutationResults []*MutationResult `protobuf:"bytes,3,rep,name=mutation_results,json=mutationResults,proto3" json:"mutation_results,omitempty"` 671 // The number of index entries updated during the commit, or zero if none were 672 // updated. 673 IndexUpdates int32 `protobuf:"varint,4,opt,name=index_updates,json=indexUpdates,proto3" json:"index_updates,omitempty"` 674 XXX_NoUnkeyedLiteral struct{} `json:"-"` 675 XXX_unrecognized []byte `json:"-"` 676 XXX_sizecache int32 `json:"-"` 677} 678 679func (m *CommitResponse) Reset() { *m = CommitResponse{} } 680func (m *CommitResponse) String() string { return proto.CompactTextString(m) } 681func (*CommitResponse) ProtoMessage() {} 682func (*CommitResponse) Descriptor() ([]byte, []int) { 683 return fileDescriptor_9ad66bfcb30c1b57, []int{9} 684} 685 686func (m *CommitResponse) XXX_Unmarshal(b []byte) error { 687 return xxx_messageInfo_CommitResponse.Unmarshal(m, b) 688} 689func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 690 return xxx_messageInfo_CommitResponse.Marshal(b, m, deterministic) 691} 692func (m *CommitResponse) XXX_Merge(src proto.Message) { 693 xxx_messageInfo_CommitResponse.Merge(m, src) 694} 695func (m *CommitResponse) XXX_Size() int { 696 return xxx_messageInfo_CommitResponse.Size(m) 697} 698func (m *CommitResponse) XXX_DiscardUnknown() { 699 xxx_messageInfo_CommitResponse.DiscardUnknown(m) 700} 701 702var xxx_messageInfo_CommitResponse proto.InternalMessageInfo 703 704func (m *CommitResponse) GetMutationResults() []*MutationResult { 705 if m != nil { 706 return m.MutationResults 707 } 708 return nil 709} 710 711func (m *CommitResponse) GetIndexUpdates() int32 { 712 if m != nil { 713 return m.IndexUpdates 714 } 715 return 0 716} 717 718// The request for 719// [Datastore.AllocateIds][google.datastore.v1.Datastore.AllocateIds]. 720type AllocateIdsRequest struct { 721 // The ID of the project against which to make the request. 722 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 723 // A list of keys with incomplete key paths for which to allocate IDs. 724 // No key may be reserved/read-only. 725 Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` 726 XXX_NoUnkeyedLiteral struct{} `json:"-"` 727 XXX_unrecognized []byte `json:"-"` 728 XXX_sizecache int32 `json:"-"` 729} 730 731func (m *AllocateIdsRequest) Reset() { *m = AllocateIdsRequest{} } 732func (m *AllocateIdsRequest) String() string { return proto.CompactTextString(m) } 733func (*AllocateIdsRequest) ProtoMessage() {} 734func (*AllocateIdsRequest) Descriptor() ([]byte, []int) { 735 return fileDescriptor_9ad66bfcb30c1b57, []int{10} 736} 737 738func (m *AllocateIdsRequest) XXX_Unmarshal(b []byte) error { 739 return xxx_messageInfo_AllocateIdsRequest.Unmarshal(m, b) 740} 741func (m *AllocateIdsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 742 return xxx_messageInfo_AllocateIdsRequest.Marshal(b, m, deterministic) 743} 744func (m *AllocateIdsRequest) XXX_Merge(src proto.Message) { 745 xxx_messageInfo_AllocateIdsRequest.Merge(m, src) 746} 747func (m *AllocateIdsRequest) XXX_Size() int { 748 return xxx_messageInfo_AllocateIdsRequest.Size(m) 749} 750func (m *AllocateIdsRequest) XXX_DiscardUnknown() { 751 xxx_messageInfo_AllocateIdsRequest.DiscardUnknown(m) 752} 753 754var xxx_messageInfo_AllocateIdsRequest proto.InternalMessageInfo 755 756func (m *AllocateIdsRequest) GetProjectId() string { 757 if m != nil { 758 return m.ProjectId 759 } 760 return "" 761} 762 763func (m *AllocateIdsRequest) GetKeys() []*Key { 764 if m != nil { 765 return m.Keys 766 } 767 return nil 768} 769 770// The response for 771// [Datastore.AllocateIds][google.datastore.v1.Datastore.AllocateIds]. 772type AllocateIdsResponse struct { 773 // The keys specified in the request (in the same order), each with 774 // its key path completed with a newly allocated ID. 775 Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` 776 XXX_NoUnkeyedLiteral struct{} `json:"-"` 777 XXX_unrecognized []byte `json:"-"` 778 XXX_sizecache int32 `json:"-"` 779} 780 781func (m *AllocateIdsResponse) Reset() { *m = AllocateIdsResponse{} } 782func (m *AllocateIdsResponse) String() string { return proto.CompactTextString(m) } 783func (*AllocateIdsResponse) ProtoMessage() {} 784func (*AllocateIdsResponse) Descriptor() ([]byte, []int) { 785 return fileDescriptor_9ad66bfcb30c1b57, []int{11} 786} 787 788func (m *AllocateIdsResponse) XXX_Unmarshal(b []byte) error { 789 return xxx_messageInfo_AllocateIdsResponse.Unmarshal(m, b) 790} 791func (m *AllocateIdsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 792 return xxx_messageInfo_AllocateIdsResponse.Marshal(b, m, deterministic) 793} 794func (m *AllocateIdsResponse) XXX_Merge(src proto.Message) { 795 xxx_messageInfo_AllocateIdsResponse.Merge(m, src) 796} 797func (m *AllocateIdsResponse) XXX_Size() int { 798 return xxx_messageInfo_AllocateIdsResponse.Size(m) 799} 800func (m *AllocateIdsResponse) XXX_DiscardUnknown() { 801 xxx_messageInfo_AllocateIdsResponse.DiscardUnknown(m) 802} 803 804var xxx_messageInfo_AllocateIdsResponse proto.InternalMessageInfo 805 806func (m *AllocateIdsResponse) GetKeys() []*Key { 807 if m != nil { 808 return m.Keys 809 } 810 return nil 811} 812 813// The request for 814// [Datastore.ReserveIds][google.datastore.v1.Datastore.ReserveIds]. 815type ReserveIdsRequest struct { 816 // The ID of the project against which to make the request. 817 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 818 // If not empty, the ID of the database against which to make the request. 819 DatabaseId string `protobuf:"bytes,9,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"` 820 // A list of keys with complete key paths whose numeric IDs should not be 821 // auto-allocated. 822 Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` 823 XXX_NoUnkeyedLiteral struct{} `json:"-"` 824 XXX_unrecognized []byte `json:"-"` 825 XXX_sizecache int32 `json:"-"` 826} 827 828func (m *ReserveIdsRequest) Reset() { *m = ReserveIdsRequest{} } 829func (m *ReserveIdsRequest) String() string { return proto.CompactTextString(m) } 830func (*ReserveIdsRequest) ProtoMessage() {} 831func (*ReserveIdsRequest) Descriptor() ([]byte, []int) { 832 return fileDescriptor_9ad66bfcb30c1b57, []int{12} 833} 834 835func (m *ReserveIdsRequest) XXX_Unmarshal(b []byte) error { 836 return xxx_messageInfo_ReserveIdsRequest.Unmarshal(m, b) 837} 838func (m *ReserveIdsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 839 return xxx_messageInfo_ReserveIdsRequest.Marshal(b, m, deterministic) 840} 841func (m *ReserveIdsRequest) XXX_Merge(src proto.Message) { 842 xxx_messageInfo_ReserveIdsRequest.Merge(m, src) 843} 844func (m *ReserveIdsRequest) XXX_Size() int { 845 return xxx_messageInfo_ReserveIdsRequest.Size(m) 846} 847func (m *ReserveIdsRequest) XXX_DiscardUnknown() { 848 xxx_messageInfo_ReserveIdsRequest.DiscardUnknown(m) 849} 850 851var xxx_messageInfo_ReserveIdsRequest proto.InternalMessageInfo 852 853func (m *ReserveIdsRequest) GetProjectId() string { 854 if m != nil { 855 return m.ProjectId 856 } 857 return "" 858} 859 860func (m *ReserveIdsRequest) GetDatabaseId() string { 861 if m != nil { 862 return m.DatabaseId 863 } 864 return "" 865} 866 867func (m *ReserveIdsRequest) GetKeys() []*Key { 868 if m != nil { 869 return m.Keys 870 } 871 return nil 872} 873 874// The response for 875// [Datastore.ReserveIds][google.datastore.v1.Datastore.ReserveIds]. 876type ReserveIdsResponse struct { 877 XXX_NoUnkeyedLiteral struct{} `json:"-"` 878 XXX_unrecognized []byte `json:"-"` 879 XXX_sizecache int32 `json:"-"` 880} 881 882func (m *ReserveIdsResponse) Reset() { *m = ReserveIdsResponse{} } 883func (m *ReserveIdsResponse) String() string { return proto.CompactTextString(m) } 884func (*ReserveIdsResponse) ProtoMessage() {} 885func (*ReserveIdsResponse) Descriptor() ([]byte, []int) { 886 return fileDescriptor_9ad66bfcb30c1b57, []int{13} 887} 888 889func (m *ReserveIdsResponse) XXX_Unmarshal(b []byte) error { 890 return xxx_messageInfo_ReserveIdsResponse.Unmarshal(m, b) 891} 892func (m *ReserveIdsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 893 return xxx_messageInfo_ReserveIdsResponse.Marshal(b, m, deterministic) 894} 895func (m *ReserveIdsResponse) XXX_Merge(src proto.Message) { 896 xxx_messageInfo_ReserveIdsResponse.Merge(m, src) 897} 898func (m *ReserveIdsResponse) XXX_Size() int { 899 return xxx_messageInfo_ReserveIdsResponse.Size(m) 900} 901func (m *ReserveIdsResponse) XXX_DiscardUnknown() { 902 xxx_messageInfo_ReserveIdsResponse.DiscardUnknown(m) 903} 904 905var xxx_messageInfo_ReserveIdsResponse proto.InternalMessageInfo 906 907// A mutation to apply to an entity. 908type Mutation struct { 909 // The mutation operation. 910 // 911 // For `insert`, `update`, and `upsert`: 912 // - The entity's key must not be reserved/read-only. 913 // - No property in the entity may have a reserved name, 914 // not even a property in an entity in a value. 915 // - No value in the entity may have meaning 18, 916 // not even a value in an entity in another value. 917 // 918 // Types that are valid to be assigned to Operation: 919 // *Mutation_Insert 920 // *Mutation_Update 921 // *Mutation_Upsert 922 // *Mutation_Delete 923 Operation isMutation_Operation `protobuf_oneof:"operation"` 924 // When set, the server will detect whether or not this mutation conflicts 925 // with the current version of the entity on the server. Conflicting mutations 926 // are not applied, and are marked as such in MutationResult. 927 // 928 // Types that are valid to be assigned to ConflictDetectionStrategy: 929 // *Mutation_BaseVersion 930 ConflictDetectionStrategy isMutation_ConflictDetectionStrategy `protobuf_oneof:"conflict_detection_strategy"` 931 XXX_NoUnkeyedLiteral struct{} `json:"-"` 932 XXX_unrecognized []byte `json:"-"` 933 XXX_sizecache int32 `json:"-"` 934} 935 936func (m *Mutation) Reset() { *m = Mutation{} } 937func (m *Mutation) String() string { return proto.CompactTextString(m) } 938func (*Mutation) ProtoMessage() {} 939func (*Mutation) Descriptor() ([]byte, []int) { 940 return fileDescriptor_9ad66bfcb30c1b57, []int{14} 941} 942 943func (m *Mutation) XXX_Unmarshal(b []byte) error { 944 return xxx_messageInfo_Mutation.Unmarshal(m, b) 945} 946func (m *Mutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 947 return xxx_messageInfo_Mutation.Marshal(b, m, deterministic) 948} 949func (m *Mutation) XXX_Merge(src proto.Message) { 950 xxx_messageInfo_Mutation.Merge(m, src) 951} 952func (m *Mutation) XXX_Size() int { 953 return xxx_messageInfo_Mutation.Size(m) 954} 955func (m *Mutation) XXX_DiscardUnknown() { 956 xxx_messageInfo_Mutation.DiscardUnknown(m) 957} 958 959var xxx_messageInfo_Mutation proto.InternalMessageInfo 960 961type isMutation_Operation interface { 962 isMutation_Operation() 963} 964 965type Mutation_Insert struct { 966 Insert *Entity `protobuf:"bytes,4,opt,name=insert,proto3,oneof"` 967} 968 969type Mutation_Update struct { 970 Update *Entity `protobuf:"bytes,5,opt,name=update,proto3,oneof"` 971} 972 973type Mutation_Upsert struct { 974 Upsert *Entity `protobuf:"bytes,6,opt,name=upsert,proto3,oneof"` 975} 976 977type Mutation_Delete struct { 978 Delete *Key `protobuf:"bytes,7,opt,name=delete,proto3,oneof"` 979} 980 981func (*Mutation_Insert) isMutation_Operation() {} 982 983func (*Mutation_Update) isMutation_Operation() {} 984 985func (*Mutation_Upsert) isMutation_Operation() {} 986 987func (*Mutation_Delete) isMutation_Operation() {} 988 989func (m *Mutation) GetOperation() isMutation_Operation { 990 if m != nil { 991 return m.Operation 992 } 993 return nil 994} 995 996func (m *Mutation) GetInsert() *Entity { 997 if x, ok := m.GetOperation().(*Mutation_Insert); ok { 998 return x.Insert 999 } 1000 return nil 1001} 1002 1003func (m *Mutation) GetUpdate() *Entity { 1004 if x, ok := m.GetOperation().(*Mutation_Update); ok { 1005 return x.Update 1006 } 1007 return nil 1008} 1009 1010func (m *Mutation) GetUpsert() *Entity { 1011 if x, ok := m.GetOperation().(*Mutation_Upsert); ok { 1012 return x.Upsert 1013 } 1014 return nil 1015} 1016 1017func (m *Mutation) GetDelete() *Key { 1018 if x, ok := m.GetOperation().(*Mutation_Delete); ok { 1019 return x.Delete 1020 } 1021 return nil 1022} 1023 1024type isMutation_ConflictDetectionStrategy interface { 1025 isMutation_ConflictDetectionStrategy() 1026} 1027 1028type Mutation_BaseVersion struct { 1029 BaseVersion int64 `protobuf:"varint,8,opt,name=base_version,json=baseVersion,proto3,oneof"` 1030} 1031 1032func (*Mutation_BaseVersion) isMutation_ConflictDetectionStrategy() {} 1033 1034func (m *Mutation) GetConflictDetectionStrategy() isMutation_ConflictDetectionStrategy { 1035 if m != nil { 1036 return m.ConflictDetectionStrategy 1037 } 1038 return nil 1039} 1040 1041func (m *Mutation) GetBaseVersion() int64 { 1042 if x, ok := m.GetConflictDetectionStrategy().(*Mutation_BaseVersion); ok { 1043 return x.BaseVersion 1044 } 1045 return 0 1046} 1047 1048// XXX_OneofWrappers is for the internal use of the proto package. 1049func (*Mutation) XXX_OneofWrappers() []interface{} { 1050 return []interface{}{ 1051 (*Mutation_Insert)(nil), 1052 (*Mutation_Update)(nil), 1053 (*Mutation_Upsert)(nil), 1054 (*Mutation_Delete)(nil), 1055 (*Mutation_BaseVersion)(nil), 1056 } 1057} 1058 1059// The result of applying a mutation. 1060type MutationResult struct { 1061 // The automatically allocated key. 1062 // Set only when the mutation allocated a key. 1063 Key *Key `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` 1064 // The version of the entity on the server after processing the mutation. If 1065 // the mutation doesn't change anything on the server, then the version will 1066 // be the version of the current entity or, if no entity is present, a version 1067 // that is strictly greater than the version of any previous entity and less 1068 // than the version of any possible future entity. 1069 Version int64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` 1070 // Whether a conflict was detected for this mutation. Always false when a 1071 // conflict detection strategy field is not set in the mutation. 1072 ConflictDetected bool `protobuf:"varint,5,opt,name=conflict_detected,json=conflictDetected,proto3" json:"conflict_detected,omitempty"` 1073 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1074 XXX_unrecognized []byte `json:"-"` 1075 XXX_sizecache int32 `json:"-"` 1076} 1077 1078func (m *MutationResult) Reset() { *m = MutationResult{} } 1079func (m *MutationResult) String() string { return proto.CompactTextString(m) } 1080func (*MutationResult) ProtoMessage() {} 1081func (*MutationResult) Descriptor() ([]byte, []int) { 1082 return fileDescriptor_9ad66bfcb30c1b57, []int{15} 1083} 1084 1085func (m *MutationResult) XXX_Unmarshal(b []byte) error { 1086 return xxx_messageInfo_MutationResult.Unmarshal(m, b) 1087} 1088func (m *MutationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1089 return xxx_messageInfo_MutationResult.Marshal(b, m, deterministic) 1090} 1091func (m *MutationResult) XXX_Merge(src proto.Message) { 1092 xxx_messageInfo_MutationResult.Merge(m, src) 1093} 1094func (m *MutationResult) XXX_Size() int { 1095 return xxx_messageInfo_MutationResult.Size(m) 1096} 1097func (m *MutationResult) XXX_DiscardUnknown() { 1098 xxx_messageInfo_MutationResult.DiscardUnknown(m) 1099} 1100 1101var xxx_messageInfo_MutationResult proto.InternalMessageInfo 1102 1103func (m *MutationResult) GetKey() *Key { 1104 if m != nil { 1105 return m.Key 1106 } 1107 return nil 1108} 1109 1110func (m *MutationResult) GetVersion() int64 { 1111 if m != nil { 1112 return m.Version 1113 } 1114 return 0 1115} 1116 1117func (m *MutationResult) GetConflictDetected() bool { 1118 if m != nil { 1119 return m.ConflictDetected 1120 } 1121 return false 1122} 1123 1124// The options shared by read requests. 1125type ReadOptions struct { 1126 // If not specified, lookups and ancestor queries default to 1127 // `read_consistency`=`STRONG`, global queries default to 1128 // `read_consistency`=`EVENTUAL`. 1129 // 1130 // Types that are valid to be assigned to ConsistencyType: 1131 // *ReadOptions_ReadConsistency_ 1132 // *ReadOptions_Transaction 1133 ConsistencyType isReadOptions_ConsistencyType `protobuf_oneof:"consistency_type"` 1134 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1135 XXX_unrecognized []byte `json:"-"` 1136 XXX_sizecache int32 `json:"-"` 1137} 1138 1139func (m *ReadOptions) Reset() { *m = ReadOptions{} } 1140func (m *ReadOptions) String() string { return proto.CompactTextString(m) } 1141func (*ReadOptions) ProtoMessage() {} 1142func (*ReadOptions) Descriptor() ([]byte, []int) { 1143 return fileDescriptor_9ad66bfcb30c1b57, []int{16} 1144} 1145 1146func (m *ReadOptions) XXX_Unmarshal(b []byte) error { 1147 return xxx_messageInfo_ReadOptions.Unmarshal(m, b) 1148} 1149func (m *ReadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1150 return xxx_messageInfo_ReadOptions.Marshal(b, m, deterministic) 1151} 1152func (m *ReadOptions) XXX_Merge(src proto.Message) { 1153 xxx_messageInfo_ReadOptions.Merge(m, src) 1154} 1155func (m *ReadOptions) XXX_Size() int { 1156 return xxx_messageInfo_ReadOptions.Size(m) 1157} 1158func (m *ReadOptions) XXX_DiscardUnknown() { 1159 xxx_messageInfo_ReadOptions.DiscardUnknown(m) 1160} 1161 1162var xxx_messageInfo_ReadOptions proto.InternalMessageInfo 1163 1164type isReadOptions_ConsistencyType interface { 1165 isReadOptions_ConsistencyType() 1166} 1167 1168type ReadOptions_ReadConsistency_ struct { 1169 ReadConsistency ReadOptions_ReadConsistency `protobuf:"varint,1,opt,name=read_consistency,json=readConsistency,proto3,enum=google.datastore.v1.ReadOptions_ReadConsistency,oneof"` 1170} 1171 1172type ReadOptions_Transaction struct { 1173 Transaction []byte `protobuf:"bytes,2,opt,name=transaction,proto3,oneof"` 1174} 1175 1176func (*ReadOptions_ReadConsistency_) isReadOptions_ConsistencyType() {} 1177 1178func (*ReadOptions_Transaction) isReadOptions_ConsistencyType() {} 1179 1180func (m *ReadOptions) GetConsistencyType() isReadOptions_ConsistencyType { 1181 if m != nil { 1182 return m.ConsistencyType 1183 } 1184 return nil 1185} 1186 1187func (m *ReadOptions) GetReadConsistency() ReadOptions_ReadConsistency { 1188 if x, ok := m.GetConsistencyType().(*ReadOptions_ReadConsistency_); ok { 1189 return x.ReadConsistency 1190 } 1191 return ReadOptions_READ_CONSISTENCY_UNSPECIFIED 1192} 1193 1194func (m *ReadOptions) GetTransaction() []byte { 1195 if x, ok := m.GetConsistencyType().(*ReadOptions_Transaction); ok { 1196 return x.Transaction 1197 } 1198 return nil 1199} 1200 1201// XXX_OneofWrappers is for the internal use of the proto package. 1202func (*ReadOptions) XXX_OneofWrappers() []interface{} { 1203 return []interface{}{ 1204 (*ReadOptions_ReadConsistency_)(nil), 1205 (*ReadOptions_Transaction)(nil), 1206 } 1207} 1208 1209// Options for beginning a new transaction. 1210// 1211// Transactions can be created explicitly with calls to 1212// [Datastore.BeginTransaction][google.datastore.v1.Datastore.BeginTransaction] 1213// or implicitly by setting 1214// [ReadOptions.new_transaction][google.datastore.v1.ReadOptions.new_transaction] 1215// in read requests. 1216type TransactionOptions struct { 1217 // The `mode` of the transaction, indicating whether write operations are 1218 // supported. 1219 // 1220 // Types that are valid to be assigned to Mode: 1221 // *TransactionOptions_ReadWrite_ 1222 // *TransactionOptions_ReadOnly_ 1223 Mode isTransactionOptions_Mode `protobuf_oneof:"mode"` 1224 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1225 XXX_unrecognized []byte `json:"-"` 1226 XXX_sizecache int32 `json:"-"` 1227} 1228 1229func (m *TransactionOptions) Reset() { *m = TransactionOptions{} } 1230func (m *TransactionOptions) String() string { return proto.CompactTextString(m) } 1231func (*TransactionOptions) ProtoMessage() {} 1232func (*TransactionOptions) Descriptor() ([]byte, []int) { 1233 return fileDescriptor_9ad66bfcb30c1b57, []int{17} 1234} 1235 1236func (m *TransactionOptions) XXX_Unmarshal(b []byte) error { 1237 return xxx_messageInfo_TransactionOptions.Unmarshal(m, b) 1238} 1239func (m *TransactionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1240 return xxx_messageInfo_TransactionOptions.Marshal(b, m, deterministic) 1241} 1242func (m *TransactionOptions) XXX_Merge(src proto.Message) { 1243 xxx_messageInfo_TransactionOptions.Merge(m, src) 1244} 1245func (m *TransactionOptions) XXX_Size() int { 1246 return xxx_messageInfo_TransactionOptions.Size(m) 1247} 1248func (m *TransactionOptions) XXX_DiscardUnknown() { 1249 xxx_messageInfo_TransactionOptions.DiscardUnknown(m) 1250} 1251 1252var xxx_messageInfo_TransactionOptions proto.InternalMessageInfo 1253 1254type isTransactionOptions_Mode interface { 1255 isTransactionOptions_Mode() 1256} 1257 1258type TransactionOptions_ReadWrite_ struct { 1259 ReadWrite *TransactionOptions_ReadWrite `protobuf:"bytes,1,opt,name=read_write,json=readWrite,proto3,oneof"` 1260} 1261 1262type TransactionOptions_ReadOnly_ struct { 1263 ReadOnly *TransactionOptions_ReadOnly `protobuf:"bytes,2,opt,name=read_only,json=readOnly,proto3,oneof"` 1264} 1265 1266func (*TransactionOptions_ReadWrite_) isTransactionOptions_Mode() {} 1267 1268func (*TransactionOptions_ReadOnly_) isTransactionOptions_Mode() {} 1269 1270func (m *TransactionOptions) GetMode() isTransactionOptions_Mode { 1271 if m != nil { 1272 return m.Mode 1273 } 1274 return nil 1275} 1276 1277func (m *TransactionOptions) GetReadWrite() *TransactionOptions_ReadWrite { 1278 if x, ok := m.GetMode().(*TransactionOptions_ReadWrite_); ok { 1279 return x.ReadWrite 1280 } 1281 return nil 1282} 1283 1284func (m *TransactionOptions) GetReadOnly() *TransactionOptions_ReadOnly { 1285 if x, ok := m.GetMode().(*TransactionOptions_ReadOnly_); ok { 1286 return x.ReadOnly 1287 } 1288 return nil 1289} 1290 1291// XXX_OneofWrappers is for the internal use of the proto package. 1292func (*TransactionOptions) XXX_OneofWrappers() []interface{} { 1293 return []interface{}{ 1294 (*TransactionOptions_ReadWrite_)(nil), 1295 (*TransactionOptions_ReadOnly_)(nil), 1296 } 1297} 1298 1299// Options specific to read / write transactions. 1300type TransactionOptions_ReadWrite struct { 1301 // The transaction identifier of the transaction being retried. 1302 PreviousTransaction []byte `protobuf:"bytes,1,opt,name=previous_transaction,json=previousTransaction,proto3" json:"previous_transaction,omitempty"` 1303 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1304 XXX_unrecognized []byte `json:"-"` 1305 XXX_sizecache int32 `json:"-"` 1306} 1307 1308func (m *TransactionOptions_ReadWrite) Reset() { *m = TransactionOptions_ReadWrite{} } 1309func (m *TransactionOptions_ReadWrite) String() string { return proto.CompactTextString(m) } 1310func (*TransactionOptions_ReadWrite) ProtoMessage() {} 1311func (*TransactionOptions_ReadWrite) Descriptor() ([]byte, []int) { 1312 return fileDescriptor_9ad66bfcb30c1b57, []int{17, 0} 1313} 1314 1315func (m *TransactionOptions_ReadWrite) XXX_Unmarshal(b []byte) error { 1316 return xxx_messageInfo_TransactionOptions_ReadWrite.Unmarshal(m, b) 1317} 1318func (m *TransactionOptions_ReadWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1319 return xxx_messageInfo_TransactionOptions_ReadWrite.Marshal(b, m, deterministic) 1320} 1321func (m *TransactionOptions_ReadWrite) XXX_Merge(src proto.Message) { 1322 xxx_messageInfo_TransactionOptions_ReadWrite.Merge(m, src) 1323} 1324func (m *TransactionOptions_ReadWrite) XXX_Size() int { 1325 return xxx_messageInfo_TransactionOptions_ReadWrite.Size(m) 1326} 1327func (m *TransactionOptions_ReadWrite) XXX_DiscardUnknown() { 1328 xxx_messageInfo_TransactionOptions_ReadWrite.DiscardUnknown(m) 1329} 1330 1331var xxx_messageInfo_TransactionOptions_ReadWrite proto.InternalMessageInfo 1332 1333func (m *TransactionOptions_ReadWrite) GetPreviousTransaction() []byte { 1334 if m != nil { 1335 return m.PreviousTransaction 1336 } 1337 return nil 1338} 1339 1340// Options specific to read-only transactions. 1341type TransactionOptions_ReadOnly struct { 1342 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1343 XXX_unrecognized []byte `json:"-"` 1344 XXX_sizecache int32 `json:"-"` 1345} 1346 1347func (m *TransactionOptions_ReadOnly) Reset() { *m = TransactionOptions_ReadOnly{} } 1348func (m *TransactionOptions_ReadOnly) String() string { return proto.CompactTextString(m) } 1349func (*TransactionOptions_ReadOnly) ProtoMessage() {} 1350func (*TransactionOptions_ReadOnly) Descriptor() ([]byte, []int) { 1351 return fileDescriptor_9ad66bfcb30c1b57, []int{17, 1} 1352} 1353 1354func (m *TransactionOptions_ReadOnly) XXX_Unmarshal(b []byte) error { 1355 return xxx_messageInfo_TransactionOptions_ReadOnly.Unmarshal(m, b) 1356} 1357func (m *TransactionOptions_ReadOnly) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1358 return xxx_messageInfo_TransactionOptions_ReadOnly.Marshal(b, m, deterministic) 1359} 1360func (m *TransactionOptions_ReadOnly) XXX_Merge(src proto.Message) { 1361 xxx_messageInfo_TransactionOptions_ReadOnly.Merge(m, src) 1362} 1363func (m *TransactionOptions_ReadOnly) XXX_Size() int { 1364 return xxx_messageInfo_TransactionOptions_ReadOnly.Size(m) 1365} 1366func (m *TransactionOptions_ReadOnly) XXX_DiscardUnknown() { 1367 xxx_messageInfo_TransactionOptions_ReadOnly.DiscardUnknown(m) 1368} 1369 1370var xxx_messageInfo_TransactionOptions_ReadOnly proto.InternalMessageInfo 1371 1372func init() { 1373 proto.RegisterEnum("google.datastore.v1.CommitRequest_Mode", CommitRequest_Mode_name, CommitRequest_Mode_value) 1374 proto.RegisterEnum("google.datastore.v1.ReadOptions_ReadConsistency", ReadOptions_ReadConsistency_name, ReadOptions_ReadConsistency_value) 1375 proto.RegisterType((*LookupRequest)(nil), "google.datastore.v1.LookupRequest") 1376 proto.RegisterType((*LookupResponse)(nil), "google.datastore.v1.LookupResponse") 1377 proto.RegisterType((*RunQueryRequest)(nil), "google.datastore.v1.RunQueryRequest") 1378 proto.RegisterType((*RunQueryResponse)(nil), "google.datastore.v1.RunQueryResponse") 1379 proto.RegisterType((*BeginTransactionRequest)(nil), "google.datastore.v1.BeginTransactionRequest") 1380 proto.RegisterType((*BeginTransactionResponse)(nil), "google.datastore.v1.BeginTransactionResponse") 1381 proto.RegisterType((*RollbackRequest)(nil), "google.datastore.v1.RollbackRequest") 1382 proto.RegisterType((*RollbackResponse)(nil), "google.datastore.v1.RollbackResponse") 1383 proto.RegisterType((*CommitRequest)(nil), "google.datastore.v1.CommitRequest") 1384 proto.RegisterType((*CommitResponse)(nil), "google.datastore.v1.CommitResponse") 1385 proto.RegisterType((*AllocateIdsRequest)(nil), "google.datastore.v1.AllocateIdsRequest") 1386 proto.RegisterType((*AllocateIdsResponse)(nil), "google.datastore.v1.AllocateIdsResponse") 1387 proto.RegisterType((*ReserveIdsRequest)(nil), "google.datastore.v1.ReserveIdsRequest") 1388 proto.RegisterType((*ReserveIdsResponse)(nil), "google.datastore.v1.ReserveIdsResponse") 1389 proto.RegisterType((*Mutation)(nil), "google.datastore.v1.Mutation") 1390 proto.RegisterType((*MutationResult)(nil), "google.datastore.v1.MutationResult") 1391 proto.RegisterType((*ReadOptions)(nil), "google.datastore.v1.ReadOptions") 1392 proto.RegisterType((*TransactionOptions)(nil), "google.datastore.v1.TransactionOptions") 1393 proto.RegisterType((*TransactionOptions_ReadWrite)(nil), "google.datastore.v1.TransactionOptions.ReadWrite") 1394 proto.RegisterType((*TransactionOptions_ReadOnly)(nil), "google.datastore.v1.TransactionOptions.ReadOnly") 1395} 1396 1397func init() { 1398 proto.RegisterFile("google/datastore/v1/datastore.proto", fileDescriptor_9ad66bfcb30c1b57) 1399} 1400 1401var fileDescriptor_9ad66bfcb30c1b57 = []byte{ 1402 // 1390 bytes of a gzipped FileDescriptorProto 1403 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x57, 0xdf, 0x6f, 0x1b, 0xc5, 1404 0x13, 0xcf, 0x3a, 0x89, 0x63, 0x8f, 0xf3, 0xc3, 0xd9, 0xe4, 0xfb, 0xad, 0x71, 0x5b, 0xd5, 0x5c, 1405 0x1a, 0x1a, 0xd2, 0xd6, 0x4e, 0x0c, 0x15, 0x52, 0x53, 0x21, 0xc5, 0x8e, 0xdb, 0x58, 0x34, 0x76, 1406 0xd8, 0xa4, 0xe1, 0x87, 0x8a, 0xac, 0x8b, 0x6f, 0x6b, 0x8e, 0x9c, 0x6f, 0x2f, 0x77, 0xeb, 0x80, 1407 0x85, 0xa8, 0x54, 0x10, 0xbc, 0xc1, 0x43, 0xf9, 0x0b, 0xfa, 0xc2, 0x03, 0xe2, 0x91, 0x27, 0xc4, 1408 0x5f, 0xc0, 0x2b, 0xff, 0x02, 0x8f, 0xbc, 0xf1, 0x0f, 0xa0, 0xdb, 0xdb, 0xb3, 0x7d, 0xce, 0x5d, 1409 0xec, 0x48, 0xbc, 0x79, 0x67, 0xe7, 0x33, 0xf3, 0x99, 0x99, 0xbd, 0x99, 0x31, 0xac, 0xb4, 0x18, 1410 0x6b, 0x19, 0xb4, 0xa0, 0xa9, 0x5c, 0x75, 0x38, 0xb3, 0x69, 0xe1, 0x6c, 0xb3, 0x7f, 0xc8, 0x5b, 1411 0x36, 0xe3, 0x0c, 0x2f, 0x79, 0x4a, 0xf9, 0xbe, 0xfc, 0x6c, 0x33, 0x7b, 0x4d, 0x22, 0x55, 0x4b, 1412 0x2f, 0xa8, 0xa6, 0xc9, 0xb8, 0xca, 0x75, 0x66, 0x3a, 0x1e, 0x24, 0x9b, 0x0b, 0xb3, 0x4b, 0x4d, 1413 0xae, 0xf3, 0xae, 0xd4, 0xb8, 0x11, 0xa6, 0x71, 0xda, 0xa1, 0xb6, 0x54, 0x50, 0x5e, 0x21, 0x98, 1414 0x7b, 0xcc, 0xd8, 0x49, 0xc7, 0x22, 0xf4, 0xb4, 0x43, 0x1d, 0x8e, 0xaf, 0x03, 0x58, 0x36, 0xfb, 1415 0x8c, 0x36, 0x79, 0x43, 0xd7, 0x32, 0x89, 0x1c, 0x5a, 0x4b, 0x92, 0xa4, 0x94, 0x54, 0x35, 0x5c, 1416 0x86, 0x59, 0x9b, 0xaa, 0x5a, 0x83, 0x59, 0x82, 0x49, 0x06, 0xe5, 0xd0, 0x5a, 0xaa, 0x98, 0xcb, 1417 0x87, 0xb0, 0xcf, 0x13, 0xaa, 0x6a, 0x75, 0x4f, 0x8f, 0xa4, 0xec, 0xfe, 0x01, 0xdf, 0x81, 0xa9, 1418 0x13, 0xda, 0x75, 0x32, 0x93, 0xb9, 0xc9, 0xb5, 0x54, 0x31, 0x13, 0x0a, 0x7e, 0x8f, 0x76, 0x89, 1419 0xd0, 0x52, 0x7e, 0x47, 0x30, 0xef, 0x73, 0x74, 0x2c, 0x66, 0x3a, 0x14, 0xbf, 0x03, 0xd3, 0xcf, 1420 0x58, 0xc7, 0xd4, 0x32, 0x48, 0x58, 0x78, 0x3d, 0xd4, 0x42, 0x45, 0x64, 0x82, 0x50, 0xa7, 0x63, 1421 0x70, 0xe2, 0xe9, 0xe3, 0x2d, 0x98, 0x69, 0xeb, 0x8e, 0xa3, 0x9b, 0xad, 0x4c, 0x6c, 0x5c, 0xa8, 1422 0x8f, 0xc0, 0x6f, 0x43, 0x42, 0xa3, 0xcf, 0xa8, 0x6d, 0x53, 0x6d, 0x24, 0xf5, 0x9e, 0xa6, 0xf2, 1423 0x5b, 0x0c, 0x16, 0x48, 0xc7, 0x7c, 0xdf, 0xcd, 0xfa, 0xf8, 0x49, 0xb6, 0x54, 0x9b, 0xeb, 0x6e, 1424 0xb6, 0x5c, 0x85, 0xd8, 0x05, 0x49, 0xde, 0xf7, 0x15, 0xab, 0x1a, 0x49, 0x59, 0xfd, 0xc3, 0x7f, 1425 0x53, 0xa9, 0x22, 0x4c, 0x8b, 0xe7, 0x92, 0x99, 0x14, 0xe8, 0x6c, 0x28, 0x5a, 0x84, 0xb6, 0x3b, 1426 0x41, 0x3c, 0x55, 0xfc, 0x00, 0x92, 0xad, 0x53, 0xa3, 0xe1, 0xe1, 0x66, 0x04, 0xee, 0x7a, 0x28, 1427 0xee, 0xd1, 0xa9, 0xe1, 0x43, 0x13, 0x2d, 0xf9, 0xbb, 0x34, 0x0b, 0x20, 0x90, 0x0d, 0xde, 0xb5, 1428 0xa8, 0xf2, 0x02, 0x41, 0xba, 0x9f, 0x3c, 0x59, 0xfd, 0x2d, 0x98, 0x3e, 0x56, 0x79, 0xf3, 0x53, 1429 0x19, 0xd2, 0x6a, 0x34, 0x29, 0xaf, 0x82, 0x25, 0x57, 0x99, 0x78, 0x18, 0xbc, 0xe1, 0x47, 0x14, 1430 0x1b, 0x15, 0x91, 0x8c, 0x47, 0x79, 0x89, 0xe0, 0x4a, 0x89, 0xb6, 0x74, 0xf3, 0xd0, 0x56, 0x4d, 1431 0x47, 0x6d, 0xba, 0x99, 0x19, 0xb3, 0x90, 0x1f, 0xc2, 0x12, 0xef, 0x83, 0x7a, 0xa5, 0x00, 0xe1, 1432 0xfa, 0x56, 0xa8, 0xeb, 0x01, 0x27, 0x7e, 0x45, 0x30, 0x3f, 0x27, 0x53, 0x1e, 0x40, 0xe6, 0x3c, 1433 0x27, 0x99, 0x9f, 0x1c, 0xa4, 0x06, 0x10, 0x22, 0x4b, 0xb3, 0x64, 0x50, 0xa4, 0x10, 0x58, 0x20, 1434 0xcc, 0x30, 0x8e, 0xd5, 0xe6, 0xc9, 0x98, 0x91, 0x8c, 0xb6, 0x89, 0x21, 0xdd, 0xb7, 0xe9, 0x31, 1435 0x51, 0x7e, 0x89, 0xc1, 0x5c, 0x99, 0xb5, 0xdb, 0x3a, 0x1f, 0xd3, 0xcd, 0x16, 0x4c, 0xb5, 0x99, 1436 0x46, 0x33, 0xd3, 0x39, 0xb4, 0x36, 0x1f, 0x91, 0xa1, 0x80, 0xc1, 0xfc, 0x1e, 0xd3, 0x28, 0x11, 1437 0x20, 0xac, 0x84, 0x70, 0xdc, 0x9d, 0x08, 0xb0, 0xc4, 0x5b, 0x90, 0x6c, 0x77, 0x64, 0x1b, 0xcd, 1438 0xc4, 0xc5, 0x47, 0x1c, 0xfe, 0x38, 0xf7, 0xa4, 0x16, 0xe9, 0xeb, 0x2b, 0x0f, 0x61, 0xca, 0x75, 1439 0x87, 0x97, 0x21, 0xbd, 0x57, 0xdf, 0xa9, 0x34, 0x9e, 0xd4, 0x0e, 0xf6, 0x2b, 0xe5, 0xea, 0xc3, 1440 0x6a, 0x65, 0x27, 0x3d, 0x81, 0x17, 0x61, 0xee, 0x90, 0x6c, 0xd7, 0x0e, 0xb6, 0xcb, 0x87, 0xd5, 1441 0x7a, 0x6d, 0xfb, 0x71, 0x1a, 0xe1, 0xff, 0xc1, 0x62, 0xad, 0x5e, 0x6b, 0x04, 0xc5, 0xb1, 0xd2, 1442 0xff, 0x61, 0x79, 0xf0, 0x59, 0x38, 0xd4, 0xa0, 0x4d, 0xce, 0x6c, 0xe5, 0x5b, 0x04, 0xf3, 0x7e, 1443 0x74, 0xb2, 0x96, 0x35, 0x48, 0xfb, 0xfe, 0x1b, 0xb6, 0x78, 0xcd, 0x7e, 0xdb, 0x5c, 0xb9, 0x98, 1444 0xb6, 0xd7, 0xbb, 0x16, 0xda, 0x81, 0xb3, 0x83, 0x57, 0x60, 0x4e, 0x37, 0x35, 0xfa, 0x45, 0xa3, 1445 0x63, 0x69, 0x2a, 0xa7, 0x4e, 0x66, 0x2a, 0x87, 0xd6, 0xa6, 0xc9, 0xac, 0x10, 0x3e, 0xf1, 0x64, 1446 0x8a, 0x0a, 0x78, 0xdb, 0x30, 0x58, 0x53, 0xe5, 0xb4, 0xaa, 0x39, 0x63, 0x96, 0xce, 0x6f, 0xea, 1447 0x68, 0xac, 0xa6, 0x5e, 0x86, 0xa5, 0x80, 0x0b, 0x19, 0xee, 0xe5, 0x8c, 0xbc, 0x40, 0xb0, 0x48, 1448 0xa8, 0x43, 0xed, 0xb3, 0x4b, 0xf0, 0xbc, 0x01, 0x29, 0xd7, 0xdc, 0xb1, 0xea, 0x50, 0xf7, 0x3e, 1449 0x29, 0xee, 0xc1, 0x17, 0x5d, 0x3a, 0x90, 0x65, 0xc0, 0x83, 0x14, 0xe4, 0xc3, 0xff, 0x35, 0x06, 1450 0x09, 0xbf, 0x14, 0xf8, 0x1e, 0xc4, 0x75, 0xd3, 0xa1, 0x36, 0x17, 0xc9, 0x4e, 0x15, 0xaf, 0x5e, 1451 0x30, 0x73, 0x76, 0x27, 0x88, 0x54, 0x76, 0x61, 0x5e, 0x91, 0xc4, 0xd7, 0x30, 0x1a, 0xe6, 0x29, 1452 0x7b, 0x30, 0xe1, 0x2d, 0x3e, 0x26, 0x4c, 0x78, 0x2b, 0x42, 0x5c, 0xa3, 0x06, 0xe5, 0x54, 0xb6, 1453 0xec, 0xc8, 0xb8, 0x5d, 0x8c, 0xa7, 0x89, 0x57, 0x60, 0x56, 0xa4, 0xf1, 0x8c, 0xda, 0x8e, 0xfb, 1454 0xc5, 0xb9, 0xb9, 0x9e, 0xdc, 0x45, 0x24, 0xe5, 0x4a, 0x8f, 0x3c, 0x61, 0x29, 0x05, 0x49, 0x66, 1455 0x51, 0x5b, 0xa4, 0xa2, 0x74, 0x1d, 0xae, 0x36, 0x99, 0xf9, 0xcc, 0xd0, 0x9b, 0xbc, 0xa1, 0x51, 1456 0x4e, 0xe5, 0x07, 0xc0, 0x6d, 0x95, 0xd3, 0x56, 0x57, 0xf9, 0x06, 0xc1, 0x7c, 0xf0, 0x05, 0xe3, 1457 0x75, 0x98, 0x3c, 0xa1, 0xfe, 0xfc, 0x89, 0x2e, 0x86, 0xab, 0x84, 0x33, 0x30, 0xe3, 0x53, 0x71, 1458 0x33, 0x3d, 0x49, 0xfc, 0x23, 0xbe, 0x0d, 0x8b, 0x43, 0x7e, 0xa9, 0x26, 0xd2, 0x9a, 0x20, 0x69, 1459 0xff, 0x62, 0x47, 0xca, 0x95, 0x7f, 0x10, 0xa4, 0x06, 0x26, 0x22, 0xfe, 0x04, 0xd2, 0x62, 0x92, 1460 0x36, 0x99, 0xe9, 0xe8, 0x0e, 0xa7, 0x66, 0xb3, 0x2b, 0x9a, 0xcb, 0x7c, 0x71, 0x63, 0xd4, 0x34, 1461 0x15, 0xbf, 0xcb, 0x7d, 0xdc, 0xee, 0x04, 0x59, 0xb0, 0x83, 0xa2, 0xe1, 0xb6, 0x15, 0x0b, 0x69, 1462 0x5b, 0xca, 0x1e, 0x2c, 0x0c, 0x59, 0xc2, 0x39, 0xb8, 0x46, 0x2a, 0xdb, 0x3b, 0x8d, 0x72, 0xbd, 1463 0x76, 0x50, 0x3d, 0x38, 0xac, 0xd4, 0xca, 0x1f, 0x0d, 0x35, 0x24, 0x80, 0xf8, 0xc1, 0x21, 0xa9, 1464 0xd7, 0x1e, 0xa5, 0x11, 0x9e, 0x85, 0x44, 0xe5, 0xa8, 0x52, 0x3b, 0x7c, 0x22, 0x1a, 0x10, 0x86, 1465 0xf4, 0x40, 0x30, 0xde, 0xa8, 0xfd, 0x3e, 0x06, 0xf8, 0xfc, 0xf0, 0xc1, 0x04, 0x40, 0x04, 0xff, 1466 0xb9, 0xad, 0x73, 0x2a, 0x27, 0xee, 0xe6, 0x98, 0x93, 0x4b, 0x44, 0xff, 0x81, 0x0b, 0xdc, 0x9d, 1467 0x20, 0x49, 0xdb, 0x3f, 0xe0, 0x3a, 0x24, 0xbd, 0xd5, 0xc4, 0x34, 0xfc, 0x39, 0xbc, 0x71, 0x19, 1468 0x93, 0x75, 0xd3, 0x10, 0x4b, 0x83, 0x2d, 0x7f, 0x67, 0xdf, 0x85, 0x64, 0xcf, 0x15, 0xde, 0x84, 1469 0x65, 0xcb, 0xa6, 0x67, 0x3a, 0xeb, 0x38, 0x8d, 0xf3, 0x33, 0x6b, 0xc9, 0xbf, 0x1b, 0xb0, 0x9d, 1470 0x05, 0x48, 0xf8, 0x76, 0x4b, 0x71, 0x6f, 0x04, 0x15, 0xff, 0x9e, 0x81, 0xe4, 0x8e, 0x4f, 0x06, 1471 0x3f, 0x87, 0xb8, 0xb7, 0x83, 0x62, 0x25, 0x94, 0x69, 0x60, 0x89, 0xce, 0xae, 0x5c, 0xa8, 0x23, 1472 0x7b, 0xc4, 0xed, 0xaf, 0xff, 0xfc, 0xeb, 0xc7, 0xd8, 0xaa, 0x92, 0x73, 0x97, 0x72, 0xd9, 0x9f, 1473 0x9c, 0xc2, 0x97, 0xfd, 0xde, 0xf5, 0xd5, 0x7d, 0x43, 0x20, 0xee, 0xa3, 0x75, 0xfc, 0x1d, 0x82, 1474 0x84, 0xbf, 0x08, 0xe1, 0x9b, 0xe1, 0xcf, 0x2e, 0xb8, 0x64, 0x66, 0x57, 0x47, 0x68, 0x49, 0x1a, 1475 0x77, 0x05, 0x8d, 0x5b, 0x8a, 0x12, 0x4d, 0xc3, 0x96, 0x18, 0x97, 0xc8, 0x4f, 0x08, 0xd2, 0xc3, 1476 0x9b, 0x07, 0xbe, 0x13, 0xea, 0x2a, 0x62, 0x69, 0xca, 0xde, 0x1d, 0x53, 0x5b, 0x12, 0xbc, 0x27, 1477 0x08, 0x16, 0x94, 0xf5, 0x68, 0x82, 0xc7, 0x43, 0x58, 0x97, 0xe8, 0x73, 0x88, 0x7b, 0xb3, 0x34, 1478 0xa2, 0x62, 0x81, 0x35, 0x22, 0xa2, 0x62, 0xc1, 0x61, 0x3c, 0x4e, 0xc5, 0x9a, 0x02, 0xd1, 0xab, 1479 0x98, 0x5c, 0x88, 0xa2, 0x2a, 0x16, 0xdc, 0xc1, 0xa2, 0x2a, 0x36, 0xbc, 0x55, 0x8d, 0x53, 0x31, 1480 0x89, 0x71, 0x89, 0xbc, 0x44, 0x90, 0x1a, 0x98, 0xb5, 0x38, 0x7c, 0xab, 0x3a, 0x3f, 0xf0, 0xb3, 1481 0x6b, 0xa3, 0x15, 0x25, 0xa3, 0x0d, 0xc1, 0x68, 0x5d, 0x59, 0x8d, 0x66, 0xa4, 0xf6, 0x61, 0x2e, 1482 0xa9, 0x1f, 0x10, 0x40, 0x7f, 0x6e, 0xe2, 0x37, 0x22, 0x1a, 0xe9, 0xd0, 0x6c, 0xcf, 0xde, 0x1a, 1483 0xa9, 0x27, 0x19, 0x15, 0x04, 0xa3, 0x37, 0x95, 0x9b, 0x17, 0xe4, 0xa8, 0x87, 0xba, 0x8f, 0xd6, 1484 0x4b, 0xaf, 0x10, 0x5c, 0x69, 0xb2, 0x76, 0x98, 0xfd, 0xd2, 0x7c, 0xaf, 0x0f, 0xec, 0xbb, 0xff, 1485 0x9a, 0xf7, 0xd1, 0xc7, 0x0f, 0xa4, 0x5a, 0x8b, 0x19, 0xaa, 0xd9, 0xca, 0x33, 0xbb, 0x55, 0x68, 1486 0x51, 0x53, 0xfc, 0xa7, 0x2e, 0x78, 0x57, 0xaa, 0xa5, 0x3b, 0x81, 0xff, 0xdd, 0x5b, 0xbd, 0xc3, 1487 0xcf, 0xb1, 0xd7, 0x1e, 0x79, 0xf0, 0xb2, 0xc1, 0x3a, 0x5a, 0xbe, 0x67, 0x3d, 0x7f, 0xb4, 0xf9, 1488 0x87, 0x7f, 0xf7, 0x54, 0xdc, 0x3d, 0xed, 0xdd, 0x3d, 0x3d, 0xda, 0x3c, 0x8e, 0x0b, 0x07, 0x6f, 1489 0xfd, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x25, 0x27, 0xe9, 0x95, 0x51, 0x10, 0x00, 0x00, 1490} 1491 1492// Reference imports to suppress errors if they are not otherwise used. 1493var _ context.Context 1494var _ grpc.ClientConn 1495 1496// This is a compile-time assertion to ensure that this generated file 1497// is compatible with the grpc package it is being compiled against. 1498const _ = grpc.SupportPackageIsVersion4 1499 1500// DatastoreClient is the client API for Datastore service. 1501// 1502// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1503type DatastoreClient interface { 1504 // Looks up entities by key. 1505 Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error) 1506 // Queries for entities. 1507 RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (*RunQueryResponse, error) 1508 // Begins a new transaction. 1509 BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error) 1510 // Commits a transaction, optionally creating, deleting or modifying some 1511 // entities. 1512 Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error) 1513 // Rolls back a transaction. 1514 Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error) 1515 // Allocates IDs for the given keys, which is useful for referencing an entity 1516 // before it is inserted. 1517 AllocateIds(ctx context.Context, in *AllocateIdsRequest, opts ...grpc.CallOption) (*AllocateIdsResponse, error) 1518 // Prevents the supplied keys' IDs from being auto-allocated by Cloud 1519 // Datastore. 1520 ReserveIds(ctx context.Context, in *ReserveIdsRequest, opts ...grpc.CallOption) (*ReserveIdsResponse, error) 1521} 1522 1523type datastoreClient struct { 1524 cc *grpc.ClientConn 1525} 1526 1527func NewDatastoreClient(cc *grpc.ClientConn) DatastoreClient { 1528 return &datastoreClient{cc} 1529} 1530 1531func (c *datastoreClient) Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error) { 1532 out := new(LookupResponse) 1533 err := c.cc.Invoke(ctx, "/google.datastore.v1.Datastore/Lookup", in, out, opts...) 1534 if err != nil { 1535 return nil, err 1536 } 1537 return out, nil 1538} 1539 1540func (c *datastoreClient) RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (*RunQueryResponse, error) { 1541 out := new(RunQueryResponse) 1542 err := c.cc.Invoke(ctx, "/google.datastore.v1.Datastore/RunQuery", in, out, opts...) 1543 if err != nil { 1544 return nil, err 1545 } 1546 return out, nil 1547} 1548 1549func (c *datastoreClient) BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error) { 1550 out := new(BeginTransactionResponse) 1551 err := c.cc.Invoke(ctx, "/google.datastore.v1.Datastore/BeginTransaction", in, out, opts...) 1552 if err != nil { 1553 return nil, err 1554 } 1555 return out, nil 1556} 1557 1558func (c *datastoreClient) Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error) { 1559 out := new(CommitResponse) 1560 err := c.cc.Invoke(ctx, "/google.datastore.v1.Datastore/Commit", in, out, opts...) 1561 if err != nil { 1562 return nil, err 1563 } 1564 return out, nil 1565} 1566 1567func (c *datastoreClient) Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error) { 1568 out := new(RollbackResponse) 1569 err := c.cc.Invoke(ctx, "/google.datastore.v1.Datastore/Rollback", in, out, opts...) 1570 if err != nil { 1571 return nil, err 1572 } 1573 return out, nil 1574} 1575 1576func (c *datastoreClient) AllocateIds(ctx context.Context, in *AllocateIdsRequest, opts ...grpc.CallOption) (*AllocateIdsResponse, error) { 1577 out := new(AllocateIdsResponse) 1578 err := c.cc.Invoke(ctx, "/google.datastore.v1.Datastore/AllocateIds", in, out, opts...) 1579 if err != nil { 1580 return nil, err 1581 } 1582 return out, nil 1583} 1584 1585func (c *datastoreClient) ReserveIds(ctx context.Context, in *ReserveIdsRequest, opts ...grpc.CallOption) (*ReserveIdsResponse, error) { 1586 out := new(ReserveIdsResponse) 1587 err := c.cc.Invoke(ctx, "/google.datastore.v1.Datastore/ReserveIds", in, out, opts...) 1588 if err != nil { 1589 return nil, err 1590 } 1591 return out, nil 1592} 1593 1594// DatastoreServer is the server API for Datastore service. 1595type DatastoreServer interface { 1596 // Looks up entities by key. 1597 Lookup(context.Context, *LookupRequest) (*LookupResponse, error) 1598 // Queries for entities. 1599 RunQuery(context.Context, *RunQueryRequest) (*RunQueryResponse, error) 1600 // Begins a new transaction. 1601 BeginTransaction(context.Context, *BeginTransactionRequest) (*BeginTransactionResponse, error) 1602 // Commits a transaction, optionally creating, deleting or modifying some 1603 // entities. 1604 Commit(context.Context, *CommitRequest) (*CommitResponse, error) 1605 // Rolls back a transaction. 1606 Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error) 1607 // Allocates IDs for the given keys, which is useful for referencing an entity 1608 // before it is inserted. 1609 AllocateIds(context.Context, *AllocateIdsRequest) (*AllocateIdsResponse, error) 1610 // Prevents the supplied keys' IDs from being auto-allocated by Cloud 1611 // Datastore. 1612 ReserveIds(context.Context, *ReserveIdsRequest) (*ReserveIdsResponse, error) 1613} 1614 1615func RegisterDatastoreServer(s *grpc.Server, srv DatastoreServer) { 1616 s.RegisterService(&_Datastore_serviceDesc, srv) 1617} 1618 1619func _Datastore_Lookup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1620 in := new(LookupRequest) 1621 if err := dec(in); err != nil { 1622 return nil, err 1623 } 1624 if interceptor == nil { 1625 return srv.(DatastoreServer).Lookup(ctx, in) 1626 } 1627 info := &grpc.UnaryServerInfo{ 1628 Server: srv, 1629 FullMethod: "/google.datastore.v1.Datastore/Lookup", 1630 } 1631 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1632 return srv.(DatastoreServer).Lookup(ctx, req.(*LookupRequest)) 1633 } 1634 return interceptor(ctx, in, info, handler) 1635} 1636 1637func _Datastore_RunQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1638 in := new(RunQueryRequest) 1639 if err := dec(in); err != nil { 1640 return nil, err 1641 } 1642 if interceptor == nil { 1643 return srv.(DatastoreServer).RunQuery(ctx, in) 1644 } 1645 info := &grpc.UnaryServerInfo{ 1646 Server: srv, 1647 FullMethod: "/google.datastore.v1.Datastore/RunQuery", 1648 } 1649 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1650 return srv.(DatastoreServer).RunQuery(ctx, req.(*RunQueryRequest)) 1651 } 1652 return interceptor(ctx, in, info, handler) 1653} 1654 1655func _Datastore_BeginTransaction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1656 in := new(BeginTransactionRequest) 1657 if err := dec(in); err != nil { 1658 return nil, err 1659 } 1660 if interceptor == nil { 1661 return srv.(DatastoreServer).BeginTransaction(ctx, in) 1662 } 1663 info := &grpc.UnaryServerInfo{ 1664 Server: srv, 1665 FullMethod: "/google.datastore.v1.Datastore/BeginTransaction", 1666 } 1667 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1668 return srv.(DatastoreServer).BeginTransaction(ctx, req.(*BeginTransactionRequest)) 1669 } 1670 return interceptor(ctx, in, info, handler) 1671} 1672 1673func _Datastore_Commit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1674 in := new(CommitRequest) 1675 if err := dec(in); err != nil { 1676 return nil, err 1677 } 1678 if interceptor == nil { 1679 return srv.(DatastoreServer).Commit(ctx, in) 1680 } 1681 info := &grpc.UnaryServerInfo{ 1682 Server: srv, 1683 FullMethod: "/google.datastore.v1.Datastore/Commit", 1684 } 1685 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1686 return srv.(DatastoreServer).Commit(ctx, req.(*CommitRequest)) 1687 } 1688 return interceptor(ctx, in, info, handler) 1689} 1690 1691func _Datastore_Rollback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1692 in := new(RollbackRequest) 1693 if err := dec(in); err != nil { 1694 return nil, err 1695 } 1696 if interceptor == nil { 1697 return srv.(DatastoreServer).Rollback(ctx, in) 1698 } 1699 info := &grpc.UnaryServerInfo{ 1700 Server: srv, 1701 FullMethod: "/google.datastore.v1.Datastore/Rollback", 1702 } 1703 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1704 return srv.(DatastoreServer).Rollback(ctx, req.(*RollbackRequest)) 1705 } 1706 return interceptor(ctx, in, info, handler) 1707} 1708 1709func _Datastore_AllocateIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1710 in := new(AllocateIdsRequest) 1711 if err := dec(in); err != nil { 1712 return nil, err 1713 } 1714 if interceptor == nil { 1715 return srv.(DatastoreServer).AllocateIds(ctx, in) 1716 } 1717 info := &grpc.UnaryServerInfo{ 1718 Server: srv, 1719 FullMethod: "/google.datastore.v1.Datastore/AllocateIds", 1720 } 1721 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1722 return srv.(DatastoreServer).AllocateIds(ctx, req.(*AllocateIdsRequest)) 1723 } 1724 return interceptor(ctx, in, info, handler) 1725} 1726 1727func _Datastore_ReserveIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1728 in := new(ReserveIdsRequest) 1729 if err := dec(in); err != nil { 1730 return nil, err 1731 } 1732 if interceptor == nil { 1733 return srv.(DatastoreServer).ReserveIds(ctx, in) 1734 } 1735 info := &grpc.UnaryServerInfo{ 1736 Server: srv, 1737 FullMethod: "/google.datastore.v1.Datastore/ReserveIds", 1738 } 1739 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1740 return srv.(DatastoreServer).ReserveIds(ctx, req.(*ReserveIdsRequest)) 1741 } 1742 return interceptor(ctx, in, info, handler) 1743} 1744 1745var _Datastore_serviceDesc = grpc.ServiceDesc{ 1746 ServiceName: "google.datastore.v1.Datastore", 1747 HandlerType: (*DatastoreServer)(nil), 1748 Methods: []grpc.MethodDesc{ 1749 { 1750 MethodName: "Lookup", 1751 Handler: _Datastore_Lookup_Handler, 1752 }, 1753 { 1754 MethodName: "RunQuery", 1755 Handler: _Datastore_RunQuery_Handler, 1756 }, 1757 { 1758 MethodName: "BeginTransaction", 1759 Handler: _Datastore_BeginTransaction_Handler, 1760 }, 1761 { 1762 MethodName: "Commit", 1763 Handler: _Datastore_Commit_Handler, 1764 }, 1765 { 1766 MethodName: "Rollback", 1767 Handler: _Datastore_Rollback_Handler, 1768 }, 1769 { 1770 MethodName: "AllocateIds", 1771 Handler: _Datastore_AllocateIds_Handler, 1772 }, 1773 { 1774 MethodName: "ReserveIds", 1775 Handler: _Datastore_ReserveIds_Handler, 1776 }, 1777 }, 1778 Streams: []grpc.StreamDesc{}, 1779 Metadata: "google/datastore/v1/datastore.proto", 1780} 1781