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