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