1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package datastore
22
23 import (
24 context "context"
25 reflect "reflect"
26 sync "sync"
27
28 _ "google.golang.org/genproto/googleapis/api/annotations"
29 grpc "google.golang.org/grpc"
30 codes "google.golang.org/grpc/codes"
31 status "google.golang.org/grpc/status"
32 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
33 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
34 )
35
36 const (
37
38 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
39
40 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
41 )
42
43
44 type CommitRequest_Mode int32
45
46 const (
47
48 CommitRequest_MODE_UNSPECIFIED CommitRequest_Mode = 0
49
50
51
52 CommitRequest_TRANSACTIONAL CommitRequest_Mode = 1
53
54 CommitRequest_NON_TRANSACTIONAL CommitRequest_Mode = 2
55 )
56
57
58 var (
59 CommitRequest_Mode_name = map[int32]string{
60 0: "MODE_UNSPECIFIED",
61 1: "TRANSACTIONAL",
62 2: "NON_TRANSACTIONAL",
63 }
64 CommitRequest_Mode_value = map[string]int32{
65 "MODE_UNSPECIFIED": 0,
66 "TRANSACTIONAL": 1,
67 "NON_TRANSACTIONAL": 2,
68 }
69 )
70
71 func (x CommitRequest_Mode) Enum() *CommitRequest_Mode {
72 p := new(CommitRequest_Mode)
73 *p = x
74 return p
75 }
76
77 func (x CommitRequest_Mode) String() string {
78 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
79 }
80
81 func (CommitRequest_Mode) Descriptor() protoreflect.EnumDescriptor {
82 return file_google_datastore_v1beta3_datastore_proto_enumTypes[0].Descriptor()
83 }
84
85 func (CommitRequest_Mode) Type() protoreflect.EnumType {
86 return &file_google_datastore_v1beta3_datastore_proto_enumTypes[0]
87 }
88
89 func (x CommitRequest_Mode) Number() protoreflect.EnumNumber {
90 return protoreflect.EnumNumber(x)
91 }
92
93
94 func (CommitRequest_Mode) EnumDescriptor() ([]byte, []int) {
95 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{8, 0}
96 }
97
98
99 type ReadOptions_ReadConsistency int32
100
101 const (
102
103 ReadOptions_READ_CONSISTENCY_UNSPECIFIED ReadOptions_ReadConsistency = 0
104
105 ReadOptions_STRONG ReadOptions_ReadConsistency = 1
106
107 ReadOptions_EVENTUAL ReadOptions_ReadConsistency = 2
108 )
109
110
111 var (
112 ReadOptions_ReadConsistency_name = map[int32]string{
113 0: "READ_CONSISTENCY_UNSPECIFIED",
114 1: "STRONG",
115 2: "EVENTUAL",
116 }
117 ReadOptions_ReadConsistency_value = map[string]int32{
118 "READ_CONSISTENCY_UNSPECIFIED": 0,
119 "STRONG": 1,
120 "EVENTUAL": 2,
121 }
122 )
123
124 func (x ReadOptions_ReadConsistency) Enum() *ReadOptions_ReadConsistency {
125 p := new(ReadOptions_ReadConsistency)
126 *p = x
127 return p
128 }
129
130 func (x ReadOptions_ReadConsistency) String() string {
131 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
132 }
133
134 func (ReadOptions_ReadConsistency) Descriptor() protoreflect.EnumDescriptor {
135 return file_google_datastore_v1beta3_datastore_proto_enumTypes[1].Descriptor()
136 }
137
138 func (ReadOptions_ReadConsistency) Type() protoreflect.EnumType {
139 return &file_google_datastore_v1beta3_datastore_proto_enumTypes[1]
140 }
141
142 func (x ReadOptions_ReadConsistency) Number() protoreflect.EnumNumber {
143 return protoreflect.EnumNumber(x)
144 }
145
146
147 func (ReadOptions_ReadConsistency) EnumDescriptor() ([]byte, []int) {
148 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{16, 0}
149 }
150
151
152
153 type LookupRequest struct {
154 state protoimpl.MessageState
155 sizeCache protoimpl.SizeCache
156 unknownFields protoimpl.UnknownFields
157
158
159 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
160
161 ReadOptions *ReadOptions `protobuf:"bytes,1,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`
162
163 Keys []*Key `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"`
164 }
165
166 func (x *LookupRequest) Reset() {
167 *x = LookupRequest{}
168 if protoimpl.UnsafeEnabled {
169 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[0]
170 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
171 ms.StoreMessageInfo(mi)
172 }
173 }
174
175 func (x *LookupRequest) String() string {
176 return protoimpl.X.MessageStringOf(x)
177 }
178
179 func (*LookupRequest) ProtoMessage() {}
180
181 func (x *LookupRequest) ProtoReflect() protoreflect.Message {
182 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[0]
183 if protoimpl.UnsafeEnabled && x != nil {
184 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
185 if ms.LoadMessageInfo() == nil {
186 ms.StoreMessageInfo(mi)
187 }
188 return ms
189 }
190 return mi.MessageOf(x)
191 }
192
193
194 func (*LookupRequest) Descriptor() ([]byte, []int) {
195 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{0}
196 }
197
198 func (x *LookupRequest) GetProjectId() string {
199 if x != nil {
200 return x.ProjectId
201 }
202 return ""
203 }
204
205 func (x *LookupRequest) GetReadOptions() *ReadOptions {
206 if x != nil {
207 return x.ReadOptions
208 }
209 return nil
210 }
211
212 func (x *LookupRequest) GetKeys() []*Key {
213 if x != nil {
214 return x.Keys
215 }
216 return nil
217 }
218
219
220
221 type LookupResponse struct {
222 state protoimpl.MessageState
223 sizeCache protoimpl.SizeCache
224 unknownFields protoimpl.UnknownFields
225
226
227
228
229 Found []*EntityResult `protobuf:"bytes,1,rep,name=found,proto3" json:"found,omitempty"`
230
231
232
233 Missing []*EntityResult `protobuf:"bytes,2,rep,name=missing,proto3" json:"missing,omitempty"`
234
235
236
237 Deferred []*Key `protobuf:"bytes,3,rep,name=deferred,proto3" json:"deferred,omitempty"`
238 }
239
240 func (x *LookupResponse) Reset() {
241 *x = LookupResponse{}
242 if protoimpl.UnsafeEnabled {
243 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[1]
244 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
245 ms.StoreMessageInfo(mi)
246 }
247 }
248
249 func (x *LookupResponse) String() string {
250 return protoimpl.X.MessageStringOf(x)
251 }
252
253 func (*LookupResponse) ProtoMessage() {}
254
255 func (x *LookupResponse) ProtoReflect() protoreflect.Message {
256 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[1]
257 if protoimpl.UnsafeEnabled && x != nil {
258 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
259 if ms.LoadMessageInfo() == nil {
260 ms.StoreMessageInfo(mi)
261 }
262 return ms
263 }
264 return mi.MessageOf(x)
265 }
266
267
268 func (*LookupResponse) Descriptor() ([]byte, []int) {
269 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{1}
270 }
271
272 func (x *LookupResponse) GetFound() []*EntityResult {
273 if x != nil {
274 return x.Found
275 }
276 return nil
277 }
278
279 func (x *LookupResponse) GetMissing() []*EntityResult {
280 if x != nil {
281 return x.Missing
282 }
283 return nil
284 }
285
286 func (x *LookupResponse) GetDeferred() []*Key {
287 if x != nil {
288 return x.Deferred
289 }
290 return nil
291 }
292
293
294
295 type RunQueryRequest struct {
296 state protoimpl.MessageState
297 sizeCache protoimpl.SizeCache
298 unknownFields protoimpl.UnknownFields
299
300
301 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
302
303
304
305
306 PartitionId *PartitionId `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
307
308 ReadOptions *ReadOptions `protobuf:"bytes,1,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`
309
310
311
312
313
314 QueryType isRunQueryRequest_QueryType `protobuf_oneof:"query_type"`
315 }
316
317 func (x *RunQueryRequest) Reset() {
318 *x = RunQueryRequest{}
319 if protoimpl.UnsafeEnabled {
320 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[2]
321 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
322 ms.StoreMessageInfo(mi)
323 }
324 }
325
326 func (x *RunQueryRequest) String() string {
327 return protoimpl.X.MessageStringOf(x)
328 }
329
330 func (*RunQueryRequest) ProtoMessage() {}
331
332 func (x *RunQueryRequest) ProtoReflect() protoreflect.Message {
333 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[2]
334 if protoimpl.UnsafeEnabled && x != nil {
335 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
336 if ms.LoadMessageInfo() == nil {
337 ms.StoreMessageInfo(mi)
338 }
339 return ms
340 }
341 return mi.MessageOf(x)
342 }
343
344
345 func (*RunQueryRequest) Descriptor() ([]byte, []int) {
346 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{2}
347 }
348
349 func (x *RunQueryRequest) GetProjectId() string {
350 if x != nil {
351 return x.ProjectId
352 }
353 return ""
354 }
355
356 func (x *RunQueryRequest) GetPartitionId() *PartitionId {
357 if x != nil {
358 return x.PartitionId
359 }
360 return nil
361 }
362
363 func (x *RunQueryRequest) GetReadOptions() *ReadOptions {
364 if x != nil {
365 return x.ReadOptions
366 }
367 return nil
368 }
369
370 func (m *RunQueryRequest) GetQueryType() isRunQueryRequest_QueryType {
371 if m != nil {
372 return m.QueryType
373 }
374 return nil
375 }
376
377 func (x *RunQueryRequest) GetQuery() *Query {
378 if x, ok := x.GetQueryType().(*RunQueryRequest_Query); ok {
379 return x.Query
380 }
381 return nil
382 }
383
384 func (x *RunQueryRequest) GetGqlQuery() *GqlQuery {
385 if x, ok := x.GetQueryType().(*RunQueryRequest_GqlQuery); ok {
386 return x.GqlQuery
387 }
388 return nil
389 }
390
391 type isRunQueryRequest_QueryType interface {
392 isRunQueryRequest_QueryType()
393 }
394
395 type RunQueryRequest_Query struct {
396
397 Query *Query `protobuf:"bytes,3,opt,name=query,proto3,oneof"`
398 }
399
400 type RunQueryRequest_GqlQuery struct {
401
402 GqlQuery *GqlQuery `protobuf:"bytes,7,opt,name=gql_query,json=gqlQuery,proto3,oneof"`
403 }
404
405 func (*RunQueryRequest_Query) isRunQueryRequest_QueryType() {}
406
407 func (*RunQueryRequest_GqlQuery) isRunQueryRequest_QueryType() {}
408
409
410
411 type RunQueryResponse struct {
412 state protoimpl.MessageState
413 sizeCache protoimpl.SizeCache
414 unknownFields protoimpl.UnknownFields
415
416
417 Batch *QueryResultBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
418
419 Query *Query `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
420 }
421
422 func (x *RunQueryResponse) Reset() {
423 *x = RunQueryResponse{}
424 if protoimpl.UnsafeEnabled {
425 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[3]
426 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
427 ms.StoreMessageInfo(mi)
428 }
429 }
430
431 func (x *RunQueryResponse) String() string {
432 return protoimpl.X.MessageStringOf(x)
433 }
434
435 func (*RunQueryResponse) ProtoMessage() {}
436
437 func (x *RunQueryResponse) ProtoReflect() protoreflect.Message {
438 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[3]
439 if protoimpl.UnsafeEnabled && x != nil {
440 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
441 if ms.LoadMessageInfo() == nil {
442 ms.StoreMessageInfo(mi)
443 }
444 return ms
445 }
446 return mi.MessageOf(x)
447 }
448
449
450 func (*RunQueryResponse) Descriptor() ([]byte, []int) {
451 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{3}
452 }
453
454 func (x *RunQueryResponse) GetBatch() *QueryResultBatch {
455 if x != nil {
456 return x.Batch
457 }
458 return nil
459 }
460
461 func (x *RunQueryResponse) GetQuery() *Query {
462 if x != nil {
463 return x.Query
464 }
465 return nil
466 }
467
468
469
470 type BeginTransactionRequest struct {
471 state protoimpl.MessageState
472 sizeCache protoimpl.SizeCache
473 unknownFields protoimpl.UnknownFields
474
475
476 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
477
478 TransactionOptions *TransactionOptions `protobuf:"bytes,10,opt,name=transaction_options,json=transactionOptions,proto3" json:"transaction_options,omitempty"`
479 }
480
481 func (x *BeginTransactionRequest) Reset() {
482 *x = BeginTransactionRequest{}
483 if protoimpl.UnsafeEnabled {
484 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[4]
485 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
486 ms.StoreMessageInfo(mi)
487 }
488 }
489
490 func (x *BeginTransactionRequest) String() string {
491 return protoimpl.X.MessageStringOf(x)
492 }
493
494 func (*BeginTransactionRequest) ProtoMessage() {}
495
496 func (x *BeginTransactionRequest) ProtoReflect() protoreflect.Message {
497 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[4]
498 if protoimpl.UnsafeEnabled && x != nil {
499 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
500 if ms.LoadMessageInfo() == nil {
501 ms.StoreMessageInfo(mi)
502 }
503 return ms
504 }
505 return mi.MessageOf(x)
506 }
507
508
509 func (*BeginTransactionRequest) Descriptor() ([]byte, []int) {
510 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{4}
511 }
512
513 func (x *BeginTransactionRequest) GetProjectId() string {
514 if x != nil {
515 return x.ProjectId
516 }
517 return ""
518 }
519
520 func (x *BeginTransactionRequest) GetTransactionOptions() *TransactionOptions {
521 if x != nil {
522 return x.TransactionOptions
523 }
524 return nil
525 }
526
527
528
529 type BeginTransactionResponse struct {
530 state protoimpl.MessageState
531 sizeCache protoimpl.SizeCache
532 unknownFields protoimpl.UnknownFields
533
534
535 Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
536 }
537
538 func (x *BeginTransactionResponse) Reset() {
539 *x = BeginTransactionResponse{}
540 if protoimpl.UnsafeEnabled {
541 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[5]
542 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
543 ms.StoreMessageInfo(mi)
544 }
545 }
546
547 func (x *BeginTransactionResponse) String() string {
548 return protoimpl.X.MessageStringOf(x)
549 }
550
551 func (*BeginTransactionResponse) ProtoMessage() {}
552
553 func (x *BeginTransactionResponse) ProtoReflect() protoreflect.Message {
554 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[5]
555 if protoimpl.UnsafeEnabled && x != nil {
556 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
557 if ms.LoadMessageInfo() == nil {
558 ms.StoreMessageInfo(mi)
559 }
560 return ms
561 }
562 return mi.MessageOf(x)
563 }
564
565
566 func (*BeginTransactionResponse) Descriptor() ([]byte, []int) {
567 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{5}
568 }
569
570 func (x *BeginTransactionResponse) GetTransaction() []byte {
571 if x != nil {
572 return x.Transaction
573 }
574 return nil
575 }
576
577
578
579 type RollbackRequest struct {
580 state protoimpl.MessageState
581 sizeCache protoimpl.SizeCache
582 unknownFields protoimpl.UnknownFields
583
584
585 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
586
587
588 Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
589 }
590
591 func (x *RollbackRequest) Reset() {
592 *x = RollbackRequest{}
593 if protoimpl.UnsafeEnabled {
594 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[6]
595 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
596 ms.StoreMessageInfo(mi)
597 }
598 }
599
600 func (x *RollbackRequest) String() string {
601 return protoimpl.X.MessageStringOf(x)
602 }
603
604 func (*RollbackRequest) ProtoMessage() {}
605
606 func (x *RollbackRequest) ProtoReflect() protoreflect.Message {
607 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[6]
608 if protoimpl.UnsafeEnabled && x != nil {
609 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
610 if ms.LoadMessageInfo() == nil {
611 ms.StoreMessageInfo(mi)
612 }
613 return ms
614 }
615 return mi.MessageOf(x)
616 }
617
618
619 func (*RollbackRequest) Descriptor() ([]byte, []int) {
620 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{6}
621 }
622
623 func (x *RollbackRequest) GetProjectId() string {
624 if x != nil {
625 return x.ProjectId
626 }
627 return ""
628 }
629
630 func (x *RollbackRequest) GetTransaction() []byte {
631 if x != nil {
632 return x.Transaction
633 }
634 return nil
635 }
636
637
638
639
640 type RollbackResponse struct {
641 state protoimpl.MessageState
642 sizeCache protoimpl.SizeCache
643 unknownFields protoimpl.UnknownFields
644 }
645
646 func (x *RollbackResponse) Reset() {
647 *x = RollbackResponse{}
648 if protoimpl.UnsafeEnabled {
649 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[7]
650 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
651 ms.StoreMessageInfo(mi)
652 }
653 }
654
655 func (x *RollbackResponse) String() string {
656 return protoimpl.X.MessageStringOf(x)
657 }
658
659 func (*RollbackResponse) ProtoMessage() {}
660
661 func (x *RollbackResponse) ProtoReflect() protoreflect.Message {
662 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[7]
663 if protoimpl.UnsafeEnabled && x != nil {
664 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
665 if ms.LoadMessageInfo() == nil {
666 ms.StoreMessageInfo(mi)
667 }
668 return ms
669 }
670 return mi.MessageOf(x)
671 }
672
673
674 func (*RollbackResponse) Descriptor() ([]byte, []int) {
675 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{7}
676 }
677
678
679
680 type CommitRequest struct {
681 state protoimpl.MessageState
682 sizeCache protoimpl.SizeCache
683 unknownFields protoimpl.UnknownFields
684
685
686 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
687
688 Mode CommitRequest_Mode `protobuf:"varint,5,opt,name=mode,proto3,enum=google.datastore.v1beta3.CommitRequest_Mode" json:"mode,omitempty"`
689
690
691
692
693 TransactionSelector isCommitRequest_TransactionSelector `protobuf_oneof:"transaction_selector"`
694
695
696
697
698
699
700
701
702
703
704
705
706
707 Mutations []*Mutation `protobuf:"bytes,6,rep,name=mutations,proto3" json:"mutations,omitempty"`
708 }
709
710 func (x *CommitRequest) Reset() {
711 *x = CommitRequest{}
712 if protoimpl.UnsafeEnabled {
713 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[8]
714 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
715 ms.StoreMessageInfo(mi)
716 }
717 }
718
719 func (x *CommitRequest) String() string {
720 return protoimpl.X.MessageStringOf(x)
721 }
722
723 func (*CommitRequest) ProtoMessage() {}
724
725 func (x *CommitRequest) ProtoReflect() protoreflect.Message {
726 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[8]
727 if protoimpl.UnsafeEnabled && x != nil {
728 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
729 if ms.LoadMessageInfo() == nil {
730 ms.StoreMessageInfo(mi)
731 }
732 return ms
733 }
734 return mi.MessageOf(x)
735 }
736
737
738 func (*CommitRequest) Descriptor() ([]byte, []int) {
739 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{8}
740 }
741
742 func (x *CommitRequest) GetProjectId() string {
743 if x != nil {
744 return x.ProjectId
745 }
746 return ""
747 }
748
749 func (x *CommitRequest) GetMode() CommitRequest_Mode {
750 if x != nil {
751 return x.Mode
752 }
753 return CommitRequest_MODE_UNSPECIFIED
754 }
755
756 func (m *CommitRequest) GetTransactionSelector() isCommitRequest_TransactionSelector {
757 if m != nil {
758 return m.TransactionSelector
759 }
760 return nil
761 }
762
763 func (x *CommitRequest) GetTransaction() []byte {
764 if x, ok := x.GetTransactionSelector().(*CommitRequest_Transaction); ok {
765 return x.Transaction
766 }
767 return nil
768 }
769
770 func (x *CommitRequest) GetMutations() []*Mutation {
771 if x != nil {
772 return x.Mutations
773 }
774 return nil
775 }
776
777 type isCommitRequest_TransactionSelector interface {
778 isCommitRequest_TransactionSelector()
779 }
780
781 type CommitRequest_Transaction struct {
782
783
784
785 Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3,oneof"`
786 }
787
788 func (*CommitRequest_Transaction) isCommitRequest_TransactionSelector() {}
789
790
791
792 type CommitResponse struct {
793 state protoimpl.MessageState
794 sizeCache protoimpl.SizeCache
795 unknownFields protoimpl.UnknownFields
796
797
798
799 MutationResults []*MutationResult `protobuf:"bytes,3,rep,name=mutation_results,json=mutationResults,proto3" json:"mutation_results,omitempty"`
800
801
802 IndexUpdates int32 `protobuf:"varint,4,opt,name=index_updates,json=indexUpdates,proto3" json:"index_updates,omitempty"`
803 }
804
805 func (x *CommitResponse) Reset() {
806 *x = CommitResponse{}
807 if protoimpl.UnsafeEnabled {
808 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[9]
809 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
810 ms.StoreMessageInfo(mi)
811 }
812 }
813
814 func (x *CommitResponse) String() string {
815 return protoimpl.X.MessageStringOf(x)
816 }
817
818 func (*CommitResponse) ProtoMessage() {}
819
820 func (x *CommitResponse) ProtoReflect() protoreflect.Message {
821 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[9]
822 if protoimpl.UnsafeEnabled && x != nil {
823 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
824 if ms.LoadMessageInfo() == nil {
825 ms.StoreMessageInfo(mi)
826 }
827 return ms
828 }
829 return mi.MessageOf(x)
830 }
831
832
833 func (*CommitResponse) Descriptor() ([]byte, []int) {
834 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{9}
835 }
836
837 func (x *CommitResponse) GetMutationResults() []*MutationResult {
838 if x != nil {
839 return x.MutationResults
840 }
841 return nil
842 }
843
844 func (x *CommitResponse) GetIndexUpdates() int32 {
845 if x != nil {
846 return x.IndexUpdates
847 }
848 return 0
849 }
850
851
852
853 type AllocateIdsRequest struct {
854 state protoimpl.MessageState
855 sizeCache protoimpl.SizeCache
856 unknownFields protoimpl.UnknownFields
857
858
859 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
860
861
862 Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
863 }
864
865 func (x *AllocateIdsRequest) Reset() {
866 *x = AllocateIdsRequest{}
867 if protoimpl.UnsafeEnabled {
868 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[10]
869 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
870 ms.StoreMessageInfo(mi)
871 }
872 }
873
874 func (x *AllocateIdsRequest) String() string {
875 return protoimpl.X.MessageStringOf(x)
876 }
877
878 func (*AllocateIdsRequest) ProtoMessage() {}
879
880 func (x *AllocateIdsRequest) ProtoReflect() protoreflect.Message {
881 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[10]
882 if protoimpl.UnsafeEnabled && x != nil {
883 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
884 if ms.LoadMessageInfo() == nil {
885 ms.StoreMessageInfo(mi)
886 }
887 return ms
888 }
889 return mi.MessageOf(x)
890 }
891
892
893 func (*AllocateIdsRequest) Descriptor() ([]byte, []int) {
894 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{10}
895 }
896
897 func (x *AllocateIdsRequest) GetProjectId() string {
898 if x != nil {
899 return x.ProjectId
900 }
901 return ""
902 }
903
904 func (x *AllocateIdsRequest) GetKeys() []*Key {
905 if x != nil {
906 return x.Keys
907 }
908 return nil
909 }
910
911
912
913 type AllocateIdsResponse struct {
914 state protoimpl.MessageState
915 sizeCache protoimpl.SizeCache
916 unknownFields protoimpl.UnknownFields
917
918
919
920 Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
921 }
922
923 func (x *AllocateIdsResponse) Reset() {
924 *x = AllocateIdsResponse{}
925 if protoimpl.UnsafeEnabled {
926 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[11]
927 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
928 ms.StoreMessageInfo(mi)
929 }
930 }
931
932 func (x *AllocateIdsResponse) String() string {
933 return protoimpl.X.MessageStringOf(x)
934 }
935
936 func (*AllocateIdsResponse) ProtoMessage() {}
937
938 func (x *AllocateIdsResponse) ProtoReflect() protoreflect.Message {
939 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[11]
940 if protoimpl.UnsafeEnabled && x != nil {
941 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
942 if ms.LoadMessageInfo() == nil {
943 ms.StoreMessageInfo(mi)
944 }
945 return ms
946 }
947 return mi.MessageOf(x)
948 }
949
950
951 func (*AllocateIdsResponse) Descriptor() ([]byte, []int) {
952 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{11}
953 }
954
955 func (x *AllocateIdsResponse) GetKeys() []*Key {
956 if x != nil {
957 return x.Keys
958 }
959 return nil
960 }
961
962
963
964 type ReserveIdsRequest struct {
965 state protoimpl.MessageState
966 sizeCache protoimpl.SizeCache
967 unknownFields protoimpl.UnknownFields
968
969
970 ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
971
972 DatabaseId string `protobuf:"bytes,9,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
973
974
975 Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
976 }
977
978 func (x *ReserveIdsRequest) Reset() {
979 *x = ReserveIdsRequest{}
980 if protoimpl.UnsafeEnabled {
981 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[12]
982 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
983 ms.StoreMessageInfo(mi)
984 }
985 }
986
987 func (x *ReserveIdsRequest) String() string {
988 return protoimpl.X.MessageStringOf(x)
989 }
990
991 func (*ReserveIdsRequest) ProtoMessage() {}
992
993 func (x *ReserveIdsRequest) ProtoReflect() protoreflect.Message {
994 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[12]
995 if protoimpl.UnsafeEnabled && x != nil {
996 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
997 if ms.LoadMessageInfo() == nil {
998 ms.StoreMessageInfo(mi)
999 }
1000 return ms
1001 }
1002 return mi.MessageOf(x)
1003 }
1004
1005
1006 func (*ReserveIdsRequest) Descriptor() ([]byte, []int) {
1007 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{12}
1008 }
1009
1010 func (x *ReserveIdsRequest) GetProjectId() string {
1011 if x != nil {
1012 return x.ProjectId
1013 }
1014 return ""
1015 }
1016
1017 func (x *ReserveIdsRequest) GetDatabaseId() string {
1018 if x != nil {
1019 return x.DatabaseId
1020 }
1021 return ""
1022 }
1023
1024 func (x *ReserveIdsRequest) GetKeys() []*Key {
1025 if x != nil {
1026 return x.Keys
1027 }
1028 return nil
1029 }
1030
1031
1032
1033 type ReserveIdsResponse struct {
1034 state protoimpl.MessageState
1035 sizeCache protoimpl.SizeCache
1036 unknownFields protoimpl.UnknownFields
1037 }
1038
1039 func (x *ReserveIdsResponse) Reset() {
1040 *x = ReserveIdsResponse{}
1041 if protoimpl.UnsafeEnabled {
1042 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[13]
1043 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1044 ms.StoreMessageInfo(mi)
1045 }
1046 }
1047
1048 func (x *ReserveIdsResponse) String() string {
1049 return protoimpl.X.MessageStringOf(x)
1050 }
1051
1052 func (*ReserveIdsResponse) ProtoMessage() {}
1053
1054 func (x *ReserveIdsResponse) ProtoReflect() protoreflect.Message {
1055 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[13]
1056 if protoimpl.UnsafeEnabled && x != nil {
1057 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1058 if ms.LoadMessageInfo() == nil {
1059 ms.StoreMessageInfo(mi)
1060 }
1061 return ms
1062 }
1063 return mi.MessageOf(x)
1064 }
1065
1066
1067 func (*ReserveIdsResponse) Descriptor() ([]byte, []int) {
1068 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{13}
1069 }
1070
1071
1072 type Mutation struct {
1073 state protoimpl.MessageState
1074 sizeCache protoimpl.SizeCache
1075 unknownFields protoimpl.UnknownFields
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091 Operation isMutation_Operation `protobuf_oneof:"operation"`
1092
1093
1094
1095
1096
1097
1098 ConflictDetectionStrategy isMutation_ConflictDetectionStrategy `protobuf_oneof:"conflict_detection_strategy"`
1099 }
1100
1101 func (x *Mutation) Reset() {
1102 *x = Mutation{}
1103 if protoimpl.UnsafeEnabled {
1104 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[14]
1105 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1106 ms.StoreMessageInfo(mi)
1107 }
1108 }
1109
1110 func (x *Mutation) String() string {
1111 return protoimpl.X.MessageStringOf(x)
1112 }
1113
1114 func (*Mutation) ProtoMessage() {}
1115
1116 func (x *Mutation) ProtoReflect() protoreflect.Message {
1117 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[14]
1118 if protoimpl.UnsafeEnabled && x != nil {
1119 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1120 if ms.LoadMessageInfo() == nil {
1121 ms.StoreMessageInfo(mi)
1122 }
1123 return ms
1124 }
1125 return mi.MessageOf(x)
1126 }
1127
1128
1129 func (*Mutation) Descriptor() ([]byte, []int) {
1130 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{14}
1131 }
1132
1133 func (m *Mutation) GetOperation() isMutation_Operation {
1134 if m != nil {
1135 return m.Operation
1136 }
1137 return nil
1138 }
1139
1140 func (x *Mutation) GetInsert() *Entity {
1141 if x, ok := x.GetOperation().(*Mutation_Insert); ok {
1142 return x.Insert
1143 }
1144 return nil
1145 }
1146
1147 func (x *Mutation) GetUpdate() *Entity {
1148 if x, ok := x.GetOperation().(*Mutation_Update); ok {
1149 return x.Update
1150 }
1151 return nil
1152 }
1153
1154 func (x *Mutation) GetUpsert() *Entity {
1155 if x, ok := x.GetOperation().(*Mutation_Upsert); ok {
1156 return x.Upsert
1157 }
1158 return nil
1159 }
1160
1161 func (x *Mutation) GetDelete() *Key {
1162 if x, ok := x.GetOperation().(*Mutation_Delete); ok {
1163 return x.Delete
1164 }
1165 return nil
1166 }
1167
1168 func (m *Mutation) GetConflictDetectionStrategy() isMutation_ConflictDetectionStrategy {
1169 if m != nil {
1170 return m.ConflictDetectionStrategy
1171 }
1172 return nil
1173 }
1174
1175 func (x *Mutation) GetBaseVersion() int64 {
1176 if x, ok := x.GetConflictDetectionStrategy().(*Mutation_BaseVersion); ok {
1177 return x.BaseVersion
1178 }
1179 return 0
1180 }
1181
1182 type isMutation_Operation interface {
1183 isMutation_Operation()
1184 }
1185
1186 type Mutation_Insert struct {
1187
1188
1189 Insert *Entity `protobuf:"bytes,4,opt,name=insert,proto3,oneof"`
1190 }
1191
1192 type Mutation_Update struct {
1193
1194
1195 Update *Entity `protobuf:"bytes,5,opt,name=update,proto3,oneof"`
1196 }
1197
1198 type Mutation_Upsert struct {
1199
1200
1201 Upsert *Entity `protobuf:"bytes,6,opt,name=upsert,proto3,oneof"`
1202 }
1203
1204 type Mutation_Delete struct {
1205
1206
1207 Delete *Key `protobuf:"bytes,7,opt,name=delete,proto3,oneof"`
1208 }
1209
1210 func (*Mutation_Insert) isMutation_Operation() {}
1211
1212 func (*Mutation_Update) isMutation_Operation() {}
1213
1214 func (*Mutation_Upsert) isMutation_Operation() {}
1215
1216 func (*Mutation_Delete) isMutation_Operation() {}
1217
1218 type isMutation_ConflictDetectionStrategy interface {
1219 isMutation_ConflictDetectionStrategy()
1220 }
1221
1222 type Mutation_BaseVersion struct {
1223
1224
1225 BaseVersion int64 `protobuf:"varint,8,opt,name=base_version,json=baseVersion,proto3,oneof"`
1226 }
1227
1228 func (*Mutation_BaseVersion) isMutation_ConflictDetectionStrategy() {}
1229
1230
1231 type MutationResult struct {
1232 state protoimpl.MessageState
1233 sizeCache protoimpl.SizeCache
1234 unknownFields protoimpl.UnknownFields
1235
1236
1237
1238 Key *Key `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
1239
1240
1241
1242
1243
1244 Version int64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
1245
1246
1247 ConflictDetected bool `protobuf:"varint,5,opt,name=conflict_detected,json=conflictDetected,proto3" json:"conflict_detected,omitempty"`
1248 }
1249
1250 func (x *MutationResult) Reset() {
1251 *x = MutationResult{}
1252 if protoimpl.UnsafeEnabled {
1253 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[15]
1254 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1255 ms.StoreMessageInfo(mi)
1256 }
1257 }
1258
1259 func (x *MutationResult) String() string {
1260 return protoimpl.X.MessageStringOf(x)
1261 }
1262
1263 func (*MutationResult) ProtoMessage() {}
1264
1265 func (x *MutationResult) ProtoReflect() protoreflect.Message {
1266 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[15]
1267 if protoimpl.UnsafeEnabled && x != nil {
1268 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1269 if ms.LoadMessageInfo() == nil {
1270 ms.StoreMessageInfo(mi)
1271 }
1272 return ms
1273 }
1274 return mi.MessageOf(x)
1275 }
1276
1277
1278 func (*MutationResult) Descriptor() ([]byte, []int) {
1279 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{15}
1280 }
1281
1282 func (x *MutationResult) GetKey() *Key {
1283 if x != nil {
1284 return x.Key
1285 }
1286 return nil
1287 }
1288
1289 func (x *MutationResult) GetVersion() int64 {
1290 if x != nil {
1291 return x.Version
1292 }
1293 return 0
1294 }
1295
1296 func (x *MutationResult) GetConflictDetected() bool {
1297 if x != nil {
1298 return x.ConflictDetected
1299 }
1300 return false
1301 }
1302
1303
1304 type ReadOptions struct {
1305 state protoimpl.MessageState
1306 sizeCache protoimpl.SizeCache
1307 unknownFields protoimpl.UnknownFields
1308
1309
1310
1311
1312
1313
1314
1315
1316 ConsistencyType isReadOptions_ConsistencyType `protobuf_oneof:"consistency_type"`
1317 }
1318
1319 func (x *ReadOptions) Reset() {
1320 *x = ReadOptions{}
1321 if protoimpl.UnsafeEnabled {
1322 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[16]
1323 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1324 ms.StoreMessageInfo(mi)
1325 }
1326 }
1327
1328 func (x *ReadOptions) String() string {
1329 return protoimpl.X.MessageStringOf(x)
1330 }
1331
1332 func (*ReadOptions) ProtoMessage() {}
1333
1334 func (x *ReadOptions) ProtoReflect() protoreflect.Message {
1335 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[16]
1336 if protoimpl.UnsafeEnabled && x != nil {
1337 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1338 if ms.LoadMessageInfo() == nil {
1339 ms.StoreMessageInfo(mi)
1340 }
1341 return ms
1342 }
1343 return mi.MessageOf(x)
1344 }
1345
1346
1347 func (*ReadOptions) Descriptor() ([]byte, []int) {
1348 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{16}
1349 }
1350
1351 func (m *ReadOptions) GetConsistencyType() isReadOptions_ConsistencyType {
1352 if m != nil {
1353 return m.ConsistencyType
1354 }
1355 return nil
1356 }
1357
1358 func (x *ReadOptions) GetReadConsistency() ReadOptions_ReadConsistency {
1359 if x, ok := x.GetConsistencyType().(*ReadOptions_ReadConsistency_); ok {
1360 return x.ReadConsistency
1361 }
1362 return ReadOptions_READ_CONSISTENCY_UNSPECIFIED
1363 }
1364
1365 func (x *ReadOptions) GetTransaction() []byte {
1366 if x, ok := x.GetConsistencyType().(*ReadOptions_Transaction); ok {
1367 return x.Transaction
1368 }
1369 return nil
1370 }
1371
1372 type isReadOptions_ConsistencyType interface {
1373 isReadOptions_ConsistencyType()
1374 }
1375
1376 type ReadOptions_ReadConsistency_ struct {
1377
1378
1379 ReadConsistency ReadOptions_ReadConsistency `protobuf:"varint,1,opt,name=read_consistency,json=readConsistency,proto3,enum=google.datastore.v1beta3.ReadOptions_ReadConsistency,oneof"`
1380 }
1381
1382 type ReadOptions_Transaction struct {
1383
1384
1385
1386 Transaction []byte `protobuf:"bytes,2,opt,name=transaction,proto3,oneof"`
1387 }
1388
1389 func (*ReadOptions_ReadConsistency_) isReadOptions_ConsistencyType() {}
1390
1391 func (*ReadOptions_Transaction) isReadOptions_ConsistencyType() {}
1392
1393
1394
1395
1396
1397
1398
1399
1400 type TransactionOptions struct {
1401 state protoimpl.MessageState
1402 sizeCache protoimpl.SizeCache
1403 unknownFields protoimpl.UnknownFields
1404
1405
1406
1407
1408
1409
1410
1411 Mode isTransactionOptions_Mode `protobuf_oneof:"mode"`
1412 }
1413
1414 func (x *TransactionOptions) Reset() {
1415 *x = TransactionOptions{}
1416 if protoimpl.UnsafeEnabled {
1417 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[17]
1418 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1419 ms.StoreMessageInfo(mi)
1420 }
1421 }
1422
1423 func (x *TransactionOptions) String() string {
1424 return protoimpl.X.MessageStringOf(x)
1425 }
1426
1427 func (*TransactionOptions) ProtoMessage() {}
1428
1429 func (x *TransactionOptions) ProtoReflect() protoreflect.Message {
1430 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[17]
1431 if protoimpl.UnsafeEnabled && x != nil {
1432 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1433 if ms.LoadMessageInfo() == nil {
1434 ms.StoreMessageInfo(mi)
1435 }
1436 return ms
1437 }
1438 return mi.MessageOf(x)
1439 }
1440
1441
1442 func (*TransactionOptions) Descriptor() ([]byte, []int) {
1443 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{17}
1444 }
1445
1446 func (m *TransactionOptions) GetMode() isTransactionOptions_Mode {
1447 if m != nil {
1448 return m.Mode
1449 }
1450 return nil
1451 }
1452
1453 func (x *TransactionOptions) GetReadWrite() *TransactionOptions_ReadWrite {
1454 if x, ok := x.GetMode().(*TransactionOptions_ReadWrite_); ok {
1455 return x.ReadWrite
1456 }
1457 return nil
1458 }
1459
1460 func (x *TransactionOptions) GetReadOnly() *TransactionOptions_ReadOnly {
1461 if x, ok := x.GetMode().(*TransactionOptions_ReadOnly_); ok {
1462 return x.ReadOnly
1463 }
1464 return nil
1465 }
1466
1467 type isTransactionOptions_Mode interface {
1468 isTransactionOptions_Mode()
1469 }
1470
1471 type TransactionOptions_ReadWrite_ struct {
1472
1473 ReadWrite *TransactionOptions_ReadWrite `protobuf:"bytes,1,opt,name=read_write,json=readWrite,proto3,oneof"`
1474 }
1475
1476 type TransactionOptions_ReadOnly_ struct {
1477
1478 ReadOnly *TransactionOptions_ReadOnly `protobuf:"bytes,2,opt,name=read_only,json=readOnly,proto3,oneof"`
1479 }
1480
1481 func (*TransactionOptions_ReadWrite_) isTransactionOptions_Mode() {}
1482
1483 func (*TransactionOptions_ReadOnly_) isTransactionOptions_Mode() {}
1484
1485
1486 type TransactionOptions_ReadWrite struct {
1487 state protoimpl.MessageState
1488 sizeCache protoimpl.SizeCache
1489 unknownFields protoimpl.UnknownFields
1490
1491
1492 PreviousTransaction []byte `protobuf:"bytes,1,opt,name=previous_transaction,json=previousTransaction,proto3" json:"previous_transaction,omitempty"`
1493 }
1494
1495 func (x *TransactionOptions_ReadWrite) Reset() {
1496 *x = TransactionOptions_ReadWrite{}
1497 if protoimpl.UnsafeEnabled {
1498 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[18]
1499 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1500 ms.StoreMessageInfo(mi)
1501 }
1502 }
1503
1504 func (x *TransactionOptions_ReadWrite) String() string {
1505 return protoimpl.X.MessageStringOf(x)
1506 }
1507
1508 func (*TransactionOptions_ReadWrite) ProtoMessage() {}
1509
1510 func (x *TransactionOptions_ReadWrite) ProtoReflect() protoreflect.Message {
1511 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[18]
1512 if protoimpl.UnsafeEnabled && x != nil {
1513 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1514 if ms.LoadMessageInfo() == nil {
1515 ms.StoreMessageInfo(mi)
1516 }
1517 return ms
1518 }
1519 return mi.MessageOf(x)
1520 }
1521
1522
1523 func (*TransactionOptions_ReadWrite) Descriptor() ([]byte, []int) {
1524 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{17, 0}
1525 }
1526
1527 func (x *TransactionOptions_ReadWrite) GetPreviousTransaction() []byte {
1528 if x != nil {
1529 return x.PreviousTransaction
1530 }
1531 return nil
1532 }
1533
1534
1535 type TransactionOptions_ReadOnly struct {
1536 state protoimpl.MessageState
1537 sizeCache protoimpl.SizeCache
1538 unknownFields protoimpl.UnknownFields
1539 }
1540
1541 func (x *TransactionOptions_ReadOnly) Reset() {
1542 *x = TransactionOptions_ReadOnly{}
1543 if protoimpl.UnsafeEnabled {
1544 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[19]
1545 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1546 ms.StoreMessageInfo(mi)
1547 }
1548 }
1549
1550 func (x *TransactionOptions_ReadOnly) String() string {
1551 return protoimpl.X.MessageStringOf(x)
1552 }
1553
1554 func (*TransactionOptions_ReadOnly) ProtoMessage() {}
1555
1556 func (x *TransactionOptions_ReadOnly) ProtoReflect() protoreflect.Message {
1557 mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[19]
1558 if protoimpl.UnsafeEnabled && x != nil {
1559 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1560 if ms.LoadMessageInfo() == nil {
1561 ms.StoreMessageInfo(mi)
1562 }
1563 return ms
1564 }
1565 return mi.MessageOf(x)
1566 }
1567
1568
1569 func (*TransactionOptions_ReadOnly) Descriptor() ([]byte, []int) {
1570 return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{17, 1}
1571 }
1572
1573 var File_google_datastore_v1beta3_datastore_proto protoreflect.FileDescriptor
1574
1575 var file_google_datastore_v1beta3_datastore_proto_rawDesc = []byte{
1576 0x0a, 0x28, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f,
1577 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73,
1578 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x18, 0x67, 0x6f, 0x6f, 0x67,
1579 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62,
1580 0x65, 0x74, 0x61, 0x33, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69,
1581 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f,
1582 0x74, 0x6f, 0x1a, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73,
1583 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x65, 0x6e, 0x74,
1584 0x69, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x24, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1585 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65,
1586 0x74, 0x61, 0x33, 0x2f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22,
1587 0xab, 0x01, 0x0a, 0x0d, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
1588 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18,
1589 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64,
1590 0x12, 0x48, 0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
1591 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
1592 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
1593 0x33, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x0b, 0x72,
1594 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x31, 0x0a, 0x04, 0x6b, 0x65,
1595 0x79, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1596 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
1597 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x22, 0xcb, 0x01,
1598 0x0a, 0x0e, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
1599 0x12, 0x3c, 0x0a, 0x05, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
1600 0x26, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f,
1601 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74,
1602 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x05, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x12, 0x40,
1603 0x0a, 0x07, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32,
1604 0x26, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f,
1605 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74,
1606 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x07, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67,
1607 0x12, 0x39, 0x0a, 0x08, 0x64, 0x65, 0x66, 0x65, 0x72, 0x72, 0x65, 0x64, 0x18, 0x03, 0x20, 0x03,
1608 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1609 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65,
1610 0x79, 0x52, 0x08, 0x64, 0x65, 0x66, 0x65, 0x72, 0x72, 0x65, 0x64, 0x22, 0xce, 0x02, 0x0a, 0x0f,
1611 0x52, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
1612 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20,
1613 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x48,
1614 0x0a, 0x0c, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x02,
1615 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61,
1616 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e,
1617 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x52, 0x0b, 0x70, 0x61, 0x72,
1618 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x48, 0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64,
1619 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25,
1620 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72,
1621 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70,
1622 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x0b, 0x72, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f,
1623 0x6e, 0x73, 0x12, 0x37, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28,
1624 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73,
1625 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65,
1626 0x72, 0x79, 0x48, 0x00, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x41, 0x0a, 0x09, 0x67,
1627 0x71, 0x6c, 0x5f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22,
1628 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72,
1629 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x47, 0x71, 0x6c, 0x51, 0x75, 0x65,
1630 0x72, 0x79, 0x48, 0x00, 0x52, 0x08, 0x67, 0x71, 0x6c, 0x51, 0x75, 0x65, 0x72, 0x79, 0x42, 0x0c,
1631 0x0a, 0x0a, 0x71, 0x75, 0x65, 0x72, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x22, 0x8b, 0x01, 0x0a,
1632 0x10, 0x52, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
1633 0x65, 0x12, 0x40, 0x0a, 0x05, 0x62, 0x61, 0x74, 0x63, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
1634 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74,
1635 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x72,
1636 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x42, 0x61, 0x74, 0x63, 0x68, 0x52, 0x05, 0x62, 0x61,
1637 0x74, 0x63, 0x68, 0x12, 0x35, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x02, 0x20, 0x01,
1638 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1639 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75,
1640 0x65, 0x72, 0x79, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x22, 0x97, 0x01, 0x0a, 0x17, 0x42,
1641 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52,
1642 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
1643 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a,
1644 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x5d, 0x0a, 0x13, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63,
1645 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x0a, 0x20, 0x01,
1646 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1647 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x72,
1648 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
1649 0x52, 0x12, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74,
1650 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x3c, 0x0a, 0x18, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61,
1651 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
1652 0x12, 0x20, 0x0a, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18,
1653 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69,
1654 0x6f, 0x6e, 0x22, 0x52, 0x0a, 0x0f, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x52, 0x65,
1655 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
1656 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1657 0x63, 0x74, 0x49, 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74,
1658 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73,
1659 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x12, 0x0a, 0x10, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61,
1660 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xb6, 0x02, 0x0a, 0x0d, 0x43,
1661 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a,
1662 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09,
1663 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x40, 0x0a, 0x04, 0x6d,
1664 0x6f, 0x64, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
1665 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62,
1666 0x65, 0x74, 0x61, 0x33, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65,
1667 0x73, 0x74, 0x2e, 0x4d, 0x6f, 0x64, 0x65, 0x52, 0x04, 0x6d, 0x6f, 0x64, 0x65, 0x12, 0x22, 0x0a,
1668 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01,
1669 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f,
1670 0x6e, 0x12, 0x40, 0x0a, 0x09, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x06,
1671 0x20, 0x03, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61,
1672 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e,
1673 0x4d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x69,
1674 0x6f, 0x6e, 0x73, 0x22, 0x46, 0x0a, 0x04, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x4d,
1675 0x4f, 0x44, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10,
1676 0x00, 0x12, 0x11, 0x0a, 0x0d, 0x54, 0x52, 0x41, 0x4e, 0x53, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e,
1677 0x41, 0x4c, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x4e, 0x4f, 0x4e, 0x5f, 0x54, 0x52, 0x41, 0x4e,
1678 0x53, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x41, 0x4c, 0x10, 0x02, 0x42, 0x16, 0x0a, 0x14, 0x74,
1679 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x65, 0x6c, 0x65, 0x63,
1680 0x74, 0x6f, 0x72, 0x22, 0x8a, 0x01, 0x0a, 0x0e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65,
1681 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x53, 0x0a, 0x10, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x69,
1682 0x6f, 0x6e, 0x5f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b,
1683 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74,
1684 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4d, 0x75, 0x74, 0x61,
1685 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x0f, 0x6d, 0x75, 0x74, 0x61,
1686 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x69,
1687 0x6e, 0x64, 0x65, 0x78, 0x5f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x73, 0x18, 0x04, 0x20, 0x01,
1688 0x28, 0x05, 0x52, 0x0c, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x73,
1689 0x22, 0x66, 0x0a, 0x12, 0x41, 0x6c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52,
1690 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
1691 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a,
1692 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x31, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x18, 0x01, 0x20,
1693 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74,
1694 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b,
1695 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x22, 0x48, 0x0a, 0x13, 0x41, 0x6c, 0x6c, 0x6f,
1696 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
1697 0x31, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e,
1698 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65,
1699 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65,
1700 0x79, 0x73, 0x22, 0x86, 0x01, 0x0a, 0x11, 0x52, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64,
1701 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a,
1702 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72,
1703 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x64, 0x61, 0x74, 0x61, 0x62,
1704 0x61, 0x73, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x64, 0x61,
1705 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x64, 0x12, 0x31, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73,
1706 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
1707 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
1708 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x22, 0x14, 0x0a, 0x12, 0x52,
1709 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
1710 0x65, 0x22, 0xc8, 0x02, 0x0a, 0x08, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3a,
1711 0x0a, 0x06, 0x69, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20,
1712 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72,
1713 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79,
1714 0x48, 0x00, 0x52, 0x06, 0x69, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x12, 0x3a, 0x0a, 0x06, 0x75, 0x70,
1715 0x64, 0x61, 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f,
1716 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31,
1717 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x48, 0x00, 0x52, 0x06,
1718 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x3a, 0x0a, 0x06, 0x75, 0x70, 0x73, 0x65, 0x72, 0x74,
1719 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
1720 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
1721 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x48, 0x00, 0x52, 0x06, 0x75, 0x70, 0x73, 0x65,
1722 0x72, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x18, 0x07, 0x20, 0x01,
1723 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1724 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65,
1725 0x79, 0x48, 0x00, 0x52, 0x06, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x62,
1726 0x61, 0x73, 0x65, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x08, 0x20, 0x01, 0x28,
1727 0x03, 0x48, 0x01, 0x52, 0x0b, 0x62, 0x61, 0x73, 0x65, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
1728 0x42, 0x0b, 0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x1d, 0x0a,
1729 0x1b, 0x63, 0x6f, 0x6e, 0x66, 0x6c, 0x69, 0x63, 0x74, 0x5f, 0x64, 0x65, 0x74, 0x65, 0x63, 0x74,
1730 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x22, 0x88, 0x01, 0x0a,
1731 0x0e, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12,
1732 0x2f, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67,
1733 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e,
1734 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79,
1735 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28,
1736 0x03, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x2b, 0x0a, 0x11, 0x63, 0x6f,
1737 0x6e, 0x66, 0x6c, 0x69, 0x63, 0x74, 0x5f, 0x64, 0x65, 0x74, 0x65, 0x63, 0x74, 0x65, 0x64, 0x18,
1738 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x10, 0x63, 0x6f, 0x6e, 0x66, 0x6c, 0x69, 0x63, 0x74, 0x44,
1739 0x65, 0x74, 0x65, 0x63, 0x74, 0x65, 0x64, 0x22, 0xf8, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x61, 0x64,
1740 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x62, 0x0a, 0x10, 0x72, 0x65, 0x61, 0x64, 0x5f,
1741 0x63, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28,
1742 0x0e, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73,
1743 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x65, 0x61,
1744 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x6e,
1745 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x48, 0x00, 0x52, 0x0f, 0x72, 0x65, 0x61, 0x64,
1746 0x43, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x12, 0x22, 0x0a, 0x0b, 0x74,
1747 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c,
1748 0x48, 0x00, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22,
1749 0x4d, 0x0a, 0x0f, 0x52, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e,
1750 0x63, 0x79, 0x12, 0x20, 0x0a, 0x1c, 0x52, 0x45, 0x41, 0x44, 0x5f, 0x43, 0x4f, 0x4e, 0x53, 0x49,
1751 0x53, 0x54, 0x45, 0x4e, 0x43, 0x59, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49,
1752 0x45, 0x44, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x53, 0x54, 0x52, 0x4f, 0x4e, 0x47, 0x10, 0x01,
1753 0x12, 0x0c, 0x0a, 0x08, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x55, 0x41, 0x4c, 0x10, 0x02, 0x42, 0x12,
1754 0x0a, 0x10, 0x63, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x74, 0x79,
1755 0x70, 0x65, 0x22, 0x97, 0x02, 0x0a, 0x12, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69,
1756 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x57, 0x0a, 0x0a, 0x72, 0x65, 0x61,
1757 0x64, 0x5f, 0x77, 0x72, 0x69, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e,
1758 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65,
1759 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63,
1760 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x52, 0x65, 0x61, 0x64,
1761 0x57, 0x72, 0x69, 0x74, 0x65, 0x48, 0x00, 0x52, 0x09, 0x72, 0x65, 0x61, 0x64, 0x57, 0x72, 0x69,
1762 0x74, 0x65, 0x12, 0x54, 0x0a, 0x09, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x6e, 0x6c, 0x79, 0x18,
1763 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64,
1764 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33,
1765 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69,
1766 0x6f, 0x6e, 0x73, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x6e, 0x6c, 0x79, 0x48, 0x00, 0x52, 0x08,
1767 0x72, 0x65, 0x61, 0x64, 0x4f, 0x6e, 0x6c, 0x79, 0x1a, 0x3e, 0x0a, 0x09, 0x52, 0x65, 0x61, 0x64,
1768 0x57, 0x72, 0x69, 0x74, 0x65, 0x12, 0x31, 0x0a, 0x14, 0x70, 0x72, 0x65, 0x76, 0x69, 0x6f, 0x75,
1769 0x73, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20,
1770 0x01, 0x28, 0x0c, 0x52, 0x13, 0x70, 0x72, 0x65, 0x76, 0x69, 0x6f, 0x75, 0x73, 0x54, 0x72, 0x61,
1771 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0x0a, 0x0a, 0x08, 0x52, 0x65, 0x61, 0x64,
1772 0x4f, 0x6e, 0x6c, 0x79, 0x42, 0x06, 0x0a, 0x04, 0x6d, 0x6f, 0x64, 0x65, 0x32, 0xd7, 0x08, 0x0a,
1773 0x09, 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x12, 0x8d, 0x01, 0x0a, 0x06, 0x4c,
1774 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x12, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64,
1775 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33,
1776 0x2e, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28,
1777 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72,
1778 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70,
1779 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x30, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a,
1780 0x22, 0x25, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1781 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d,
1782 0x3a, 0x6c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x3a, 0x01, 0x2a, 0x12, 0x95, 0x01, 0x0a, 0x08, 0x52,
1783 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x12, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
1784 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
1785 0x61, 0x33, 0x2e, 0x52, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65,
1786 0x73, 0x74, 0x1a, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1787 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x75,
1788 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x32,
1789 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x22, 0x27, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33,
1790 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1791 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x72, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x3a,
1792 0x01, 0x2a, 0x12, 0xb5, 0x01, 0x0a, 0x10, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e,
1793 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
1794 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
1795 0x61, 0x33, 0x2e, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74,
1796 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x67, 0x6f, 0x6f,
1797 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31,
1798 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, 0x73,
1799 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x3a,
1800 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x22, 0x2f, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33,
1801 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1802 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x62, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e,
1803 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x3a, 0x01, 0x2a, 0x12, 0x8d, 0x01, 0x0a, 0x06, 0x43,
1804 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x12, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64,
1805 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33,
1806 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28,
1807 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72,
1808 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74,
1809 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x30, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a,
1810 0x22, 0x25, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1811 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d,
1812 0x3a, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x3a, 0x01, 0x2a, 0x12, 0x95, 0x01, 0x0a, 0x08, 0x52,
1813 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x12, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
1814 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
1815 0x61, 0x33, 0x2e, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65,
1816 0x73, 0x74, 0x1a, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1817 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x6f,
1818 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x32,
1819 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x22, 0x27, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33,
1820 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1821 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x72, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x3a,
1822 0x01, 0x2a, 0x12, 0xa1, 0x01, 0x0a, 0x0b, 0x41, 0x6c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65, 0x49,
1823 0x64, 0x73, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1824 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x6c,
1825 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
1826 0x1a, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74,
1827 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x6c, 0x6c, 0x6f,
1828 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
1829 0x35, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2f, 0x22, 0x2a, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
1830 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a,
1831 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x61, 0x6c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65,
1832 0x49, 0x64, 0x73, 0x3a, 0x01, 0x2a, 0x12, 0x9d, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x73, 0x65, 0x72,
1833 0x76, 0x65, 0x49, 0x64, 0x73, 0x12, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64,
1834 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33,
1835 0x2e, 0x52, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
1836 0x73, 0x74, 0x1a, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61,
1837 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x65,
1838 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
1839 0x22, 0x34, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2e, 0x22, 0x29, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74,
1840 0x61, 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f,
1841 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x72, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65,
1842 0x49, 0x64, 0x73, 0x3a, 0x01, 0x2a, 0x42, 0xd9, 0x01, 0x0a, 0x1c, 0x63, 0x6f, 0x6d, 0x2e, 0x67,
1843 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e,
1844 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x42, 0x0e, 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f,
1845 0x72, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x41, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1846 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e,
1847 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
1848 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74,
1849 0x61, 0x33, 0x3b, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0xaa, 0x02, 0x1e, 0x47,
1850 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x44, 0x61, 0x74, 0x61,
1851 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x56, 0x31, 0x42, 0x65, 0x74, 0x61, 0x33, 0xca, 0x02, 0x1e,
1852 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x44, 0x61, 0x74,
1853 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x5c, 0x56, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0xea, 0x02,
1854 0x21, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x3a, 0x3a,
1855 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x65, 0x74,
1856 0x61, 0x33, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
1857 }
1858
1859 var (
1860 file_google_datastore_v1beta3_datastore_proto_rawDescOnce sync.Once
1861 file_google_datastore_v1beta3_datastore_proto_rawDescData = file_google_datastore_v1beta3_datastore_proto_rawDesc
1862 )
1863
1864 func file_google_datastore_v1beta3_datastore_proto_rawDescGZIP() []byte {
1865 file_google_datastore_v1beta3_datastore_proto_rawDescOnce.Do(func() {
1866 file_google_datastore_v1beta3_datastore_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_datastore_v1beta3_datastore_proto_rawDescData)
1867 })
1868 return file_google_datastore_v1beta3_datastore_proto_rawDescData
1869 }
1870
1871 var file_google_datastore_v1beta3_datastore_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
1872 var file_google_datastore_v1beta3_datastore_proto_msgTypes = make([]protoimpl.MessageInfo, 20)
1873 var file_google_datastore_v1beta3_datastore_proto_goTypes = []interface{}{
1874 (CommitRequest_Mode)(0),
1875 (ReadOptions_ReadConsistency)(0),
1876 (*LookupRequest)(nil),
1877 (*LookupResponse)(nil),
1878 (*RunQueryRequest)(nil),
1879 (*RunQueryResponse)(nil),
1880 (*BeginTransactionRequest)(nil),
1881 (*BeginTransactionResponse)(nil),
1882 (*RollbackRequest)(nil),
1883 (*RollbackResponse)(nil),
1884 (*CommitRequest)(nil),
1885 (*CommitResponse)(nil),
1886 (*AllocateIdsRequest)(nil),
1887 (*AllocateIdsResponse)(nil),
1888 (*ReserveIdsRequest)(nil),
1889 (*ReserveIdsResponse)(nil),
1890 (*Mutation)(nil),
1891 (*MutationResult)(nil),
1892 (*ReadOptions)(nil),
1893 (*TransactionOptions)(nil),
1894 (*TransactionOptions_ReadWrite)(nil),
1895 (*TransactionOptions_ReadOnly)(nil),
1896 (*Key)(nil),
1897 (*EntityResult)(nil),
1898 (*PartitionId)(nil),
1899 (*Query)(nil),
1900 (*GqlQuery)(nil),
1901 (*QueryResultBatch)(nil),
1902 (*Entity)(nil),
1903 }
1904 var file_google_datastore_v1beta3_datastore_proto_depIdxs = []int32{
1905 18,
1906 22,
1907 23,
1908 23,
1909 22,
1910 24,
1911 18,
1912 25,
1913 26,
1914 27,
1915 25,
1916 19,
1917 0,
1918 16,
1919 17,
1920 22,
1921 22,
1922 22,
1923 28,
1924 28,
1925 28,
1926 22,
1927 22,
1928 1,
1929 20,
1930 21,
1931 2,
1932 4,
1933 6,
1934 10,
1935 8,
1936 12,
1937 14,
1938 3,
1939 5,
1940 7,
1941 11,
1942 9,
1943 13,
1944 15,
1945 33,
1946 26,
1947 26,
1948 26,
1949 0,
1950 }
1951
1952 func init() { file_google_datastore_v1beta3_datastore_proto_init() }
1953 func file_google_datastore_v1beta3_datastore_proto_init() {
1954 if File_google_datastore_v1beta3_datastore_proto != nil {
1955 return
1956 }
1957 file_google_datastore_v1beta3_entity_proto_init()
1958 file_google_datastore_v1beta3_query_proto_init()
1959 if !protoimpl.UnsafeEnabled {
1960 file_google_datastore_v1beta3_datastore_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
1961 switch v := v.(*LookupRequest); i {
1962 case 0:
1963 return &v.state
1964 case 1:
1965 return &v.sizeCache
1966 case 2:
1967 return &v.unknownFields
1968 default:
1969 return nil
1970 }
1971 }
1972 file_google_datastore_v1beta3_datastore_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
1973 switch v := v.(*LookupResponse); i {
1974 case 0:
1975 return &v.state
1976 case 1:
1977 return &v.sizeCache
1978 case 2:
1979 return &v.unknownFields
1980 default:
1981 return nil
1982 }
1983 }
1984 file_google_datastore_v1beta3_datastore_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
1985 switch v := v.(*RunQueryRequest); i {
1986 case 0:
1987 return &v.state
1988 case 1:
1989 return &v.sizeCache
1990 case 2:
1991 return &v.unknownFields
1992 default:
1993 return nil
1994 }
1995 }
1996 file_google_datastore_v1beta3_datastore_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
1997 switch v := v.(*RunQueryResponse); i {
1998 case 0:
1999 return &v.state
2000 case 1:
2001 return &v.sizeCache
2002 case 2:
2003 return &v.unknownFields
2004 default:
2005 return nil
2006 }
2007 }
2008 file_google_datastore_v1beta3_datastore_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
2009 switch v := v.(*BeginTransactionRequest); i {
2010 case 0:
2011 return &v.state
2012 case 1:
2013 return &v.sizeCache
2014 case 2:
2015 return &v.unknownFields
2016 default:
2017 return nil
2018 }
2019 }
2020 file_google_datastore_v1beta3_datastore_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
2021 switch v := v.(*BeginTransactionResponse); i {
2022 case 0:
2023 return &v.state
2024 case 1:
2025 return &v.sizeCache
2026 case 2:
2027 return &v.unknownFields
2028 default:
2029 return nil
2030 }
2031 }
2032 file_google_datastore_v1beta3_datastore_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
2033 switch v := v.(*RollbackRequest); i {
2034 case 0:
2035 return &v.state
2036 case 1:
2037 return &v.sizeCache
2038 case 2:
2039 return &v.unknownFields
2040 default:
2041 return nil
2042 }
2043 }
2044 file_google_datastore_v1beta3_datastore_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
2045 switch v := v.(*RollbackResponse); i {
2046 case 0:
2047 return &v.state
2048 case 1:
2049 return &v.sizeCache
2050 case 2:
2051 return &v.unknownFields
2052 default:
2053 return nil
2054 }
2055 }
2056 file_google_datastore_v1beta3_datastore_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
2057 switch v := v.(*CommitRequest); i {
2058 case 0:
2059 return &v.state
2060 case 1:
2061 return &v.sizeCache
2062 case 2:
2063 return &v.unknownFields
2064 default:
2065 return nil
2066 }
2067 }
2068 file_google_datastore_v1beta3_datastore_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
2069 switch v := v.(*CommitResponse); i {
2070 case 0:
2071 return &v.state
2072 case 1:
2073 return &v.sizeCache
2074 case 2:
2075 return &v.unknownFields
2076 default:
2077 return nil
2078 }
2079 }
2080 file_google_datastore_v1beta3_datastore_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
2081 switch v := v.(*AllocateIdsRequest); i {
2082 case 0:
2083 return &v.state
2084 case 1:
2085 return &v.sizeCache
2086 case 2:
2087 return &v.unknownFields
2088 default:
2089 return nil
2090 }
2091 }
2092 file_google_datastore_v1beta3_datastore_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
2093 switch v := v.(*AllocateIdsResponse); i {
2094 case 0:
2095 return &v.state
2096 case 1:
2097 return &v.sizeCache
2098 case 2:
2099 return &v.unknownFields
2100 default:
2101 return nil
2102 }
2103 }
2104 file_google_datastore_v1beta3_datastore_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
2105 switch v := v.(*ReserveIdsRequest); i {
2106 case 0:
2107 return &v.state
2108 case 1:
2109 return &v.sizeCache
2110 case 2:
2111 return &v.unknownFields
2112 default:
2113 return nil
2114 }
2115 }
2116 file_google_datastore_v1beta3_datastore_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
2117 switch v := v.(*ReserveIdsResponse); i {
2118 case 0:
2119 return &v.state
2120 case 1:
2121 return &v.sizeCache
2122 case 2:
2123 return &v.unknownFields
2124 default:
2125 return nil
2126 }
2127 }
2128 file_google_datastore_v1beta3_datastore_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
2129 switch v := v.(*Mutation); i {
2130 case 0:
2131 return &v.state
2132 case 1:
2133 return &v.sizeCache
2134 case 2:
2135 return &v.unknownFields
2136 default:
2137 return nil
2138 }
2139 }
2140 file_google_datastore_v1beta3_datastore_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
2141 switch v := v.(*MutationResult); i {
2142 case 0:
2143 return &v.state
2144 case 1:
2145 return &v.sizeCache
2146 case 2:
2147 return &v.unknownFields
2148 default:
2149 return nil
2150 }
2151 }
2152 file_google_datastore_v1beta3_datastore_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
2153 switch v := v.(*ReadOptions); i {
2154 case 0:
2155 return &v.state
2156 case 1:
2157 return &v.sizeCache
2158 case 2:
2159 return &v.unknownFields
2160 default:
2161 return nil
2162 }
2163 }
2164 file_google_datastore_v1beta3_datastore_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
2165 switch v := v.(*TransactionOptions); i {
2166 case 0:
2167 return &v.state
2168 case 1:
2169 return &v.sizeCache
2170 case 2:
2171 return &v.unknownFields
2172 default:
2173 return nil
2174 }
2175 }
2176 file_google_datastore_v1beta3_datastore_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
2177 switch v := v.(*TransactionOptions_ReadWrite); i {
2178 case 0:
2179 return &v.state
2180 case 1:
2181 return &v.sizeCache
2182 case 2:
2183 return &v.unknownFields
2184 default:
2185 return nil
2186 }
2187 }
2188 file_google_datastore_v1beta3_datastore_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
2189 switch v := v.(*TransactionOptions_ReadOnly); i {
2190 case 0:
2191 return &v.state
2192 case 1:
2193 return &v.sizeCache
2194 case 2:
2195 return &v.unknownFields
2196 default:
2197 return nil
2198 }
2199 }
2200 }
2201 file_google_datastore_v1beta3_datastore_proto_msgTypes[2].OneofWrappers = []interface{}{
2202 (*RunQueryRequest_Query)(nil),
2203 (*RunQueryRequest_GqlQuery)(nil),
2204 }
2205 file_google_datastore_v1beta3_datastore_proto_msgTypes[8].OneofWrappers = []interface{}{
2206 (*CommitRequest_Transaction)(nil),
2207 }
2208 file_google_datastore_v1beta3_datastore_proto_msgTypes[14].OneofWrappers = []interface{}{
2209 (*Mutation_Insert)(nil),
2210 (*Mutation_Update)(nil),
2211 (*Mutation_Upsert)(nil),
2212 (*Mutation_Delete)(nil),
2213 (*Mutation_BaseVersion)(nil),
2214 }
2215 file_google_datastore_v1beta3_datastore_proto_msgTypes[16].OneofWrappers = []interface{}{
2216 (*ReadOptions_ReadConsistency_)(nil),
2217 (*ReadOptions_Transaction)(nil),
2218 }
2219 file_google_datastore_v1beta3_datastore_proto_msgTypes[17].OneofWrappers = []interface{}{
2220 (*TransactionOptions_ReadWrite_)(nil),
2221 (*TransactionOptions_ReadOnly_)(nil),
2222 }
2223 type x struct{}
2224 out := protoimpl.TypeBuilder{
2225 File: protoimpl.DescBuilder{
2226 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
2227 RawDescriptor: file_google_datastore_v1beta3_datastore_proto_rawDesc,
2228 NumEnums: 2,
2229 NumMessages: 20,
2230 NumExtensions: 0,
2231 NumServices: 1,
2232 },
2233 GoTypes: file_google_datastore_v1beta3_datastore_proto_goTypes,
2234 DependencyIndexes: file_google_datastore_v1beta3_datastore_proto_depIdxs,
2235 EnumInfos: file_google_datastore_v1beta3_datastore_proto_enumTypes,
2236 MessageInfos: file_google_datastore_v1beta3_datastore_proto_msgTypes,
2237 }.Build()
2238 File_google_datastore_v1beta3_datastore_proto = out.File
2239 file_google_datastore_v1beta3_datastore_proto_rawDesc = nil
2240 file_google_datastore_v1beta3_datastore_proto_goTypes = nil
2241 file_google_datastore_v1beta3_datastore_proto_depIdxs = nil
2242 }
2243
2244
2245 var _ context.Context
2246 var _ grpc.ClientConnInterface
2247
2248
2249
2250 const _ = grpc.SupportPackageIsVersion6
2251
2252
2253
2254
2255 type DatastoreClient interface {
2256
2257 Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
2258
2259 RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (*RunQueryResponse, error)
2260
2261 BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error)
2262
2263
2264 Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
2265
2266 Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error)
2267
2268
2269 AllocateIds(ctx context.Context, in *AllocateIdsRequest, opts ...grpc.CallOption) (*AllocateIdsResponse, error)
2270
2271
2272 ReserveIds(ctx context.Context, in *ReserveIdsRequest, opts ...grpc.CallOption) (*ReserveIdsResponse, error)
2273 }
2274
2275 type datastoreClient struct {
2276 cc grpc.ClientConnInterface
2277 }
2278
2279 func NewDatastoreClient(cc grpc.ClientConnInterface) DatastoreClient {
2280 return &datastoreClient{cc}
2281 }
2282
2283 func (c *datastoreClient) Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error) {
2284 out := new(LookupResponse)
2285 err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/Lookup", in, out, opts...)
2286 if err != nil {
2287 return nil, err
2288 }
2289 return out, nil
2290 }
2291
2292 func (c *datastoreClient) RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (*RunQueryResponse, error) {
2293 out := new(RunQueryResponse)
2294 err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/RunQuery", in, out, opts...)
2295 if err != nil {
2296 return nil, err
2297 }
2298 return out, nil
2299 }
2300
2301 func (c *datastoreClient) BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error) {
2302 out := new(BeginTransactionResponse)
2303 err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/BeginTransaction", in, out, opts...)
2304 if err != nil {
2305 return nil, err
2306 }
2307 return out, nil
2308 }
2309
2310 func (c *datastoreClient) Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error) {
2311 out := new(CommitResponse)
2312 err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/Commit", in, out, opts...)
2313 if err != nil {
2314 return nil, err
2315 }
2316 return out, nil
2317 }
2318
2319 func (c *datastoreClient) Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error) {
2320 out := new(RollbackResponse)
2321 err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/Rollback", in, out, opts...)
2322 if err != nil {
2323 return nil, err
2324 }
2325 return out, nil
2326 }
2327
2328 func (c *datastoreClient) AllocateIds(ctx context.Context, in *AllocateIdsRequest, opts ...grpc.CallOption) (*AllocateIdsResponse, error) {
2329 out := new(AllocateIdsResponse)
2330 err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/AllocateIds", in, out, opts...)
2331 if err != nil {
2332 return nil, err
2333 }
2334 return out, nil
2335 }
2336
2337 func (c *datastoreClient) ReserveIds(ctx context.Context, in *ReserveIdsRequest, opts ...grpc.CallOption) (*ReserveIdsResponse, error) {
2338 out := new(ReserveIdsResponse)
2339 err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/ReserveIds", in, out, opts...)
2340 if err != nil {
2341 return nil, err
2342 }
2343 return out, nil
2344 }
2345
2346
2347 type DatastoreServer interface {
2348
2349 Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
2350
2351 RunQuery(context.Context, *RunQueryRequest) (*RunQueryResponse, error)
2352
2353 BeginTransaction(context.Context, *BeginTransactionRequest) (*BeginTransactionResponse, error)
2354
2355
2356 Commit(context.Context, *CommitRequest) (*CommitResponse, error)
2357
2358 Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error)
2359
2360
2361 AllocateIds(context.Context, *AllocateIdsRequest) (*AllocateIdsResponse, error)
2362
2363
2364 ReserveIds(context.Context, *ReserveIdsRequest) (*ReserveIdsResponse, error)
2365 }
2366
2367
2368 type UnimplementedDatastoreServer struct {
2369 }
2370
2371 func (*UnimplementedDatastoreServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error) {
2372 return nil, status.Errorf(codes.Unimplemented, "method Lookup not implemented")
2373 }
2374 func (*UnimplementedDatastoreServer) RunQuery(context.Context, *RunQueryRequest) (*RunQueryResponse, error) {
2375 return nil, status.Errorf(codes.Unimplemented, "method RunQuery not implemented")
2376 }
2377 func (*UnimplementedDatastoreServer) BeginTransaction(context.Context, *BeginTransactionRequest) (*BeginTransactionResponse, error) {
2378 return nil, status.Errorf(codes.Unimplemented, "method BeginTransaction not implemented")
2379 }
2380 func (*UnimplementedDatastoreServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error) {
2381 return nil, status.Errorf(codes.Unimplemented, "method Commit not implemented")
2382 }
2383 func (*UnimplementedDatastoreServer) Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error) {
2384 return nil, status.Errorf(codes.Unimplemented, "method Rollback not implemented")
2385 }
2386 func (*UnimplementedDatastoreServer) AllocateIds(context.Context, *AllocateIdsRequest) (*AllocateIdsResponse, error) {
2387 return nil, status.Errorf(codes.Unimplemented, "method AllocateIds not implemented")
2388 }
2389 func (*UnimplementedDatastoreServer) ReserveIds(context.Context, *ReserveIdsRequest) (*ReserveIdsResponse, error) {
2390 return nil, status.Errorf(codes.Unimplemented, "method ReserveIds not implemented")
2391 }
2392
2393 func RegisterDatastoreServer(s *grpc.Server, srv DatastoreServer) {
2394 s.RegisterService(&_Datastore_serviceDesc, srv)
2395 }
2396
2397 func _Datastore_Lookup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2398 in := new(LookupRequest)
2399 if err := dec(in); err != nil {
2400 return nil, err
2401 }
2402 if interceptor == nil {
2403 return srv.(DatastoreServer).Lookup(ctx, in)
2404 }
2405 info := &grpc.UnaryServerInfo{
2406 Server: srv,
2407 FullMethod: "/google.datastore.v1beta3.Datastore/Lookup",
2408 }
2409 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2410 return srv.(DatastoreServer).Lookup(ctx, req.(*LookupRequest))
2411 }
2412 return interceptor(ctx, in, info, handler)
2413 }
2414
2415 func _Datastore_RunQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2416 in := new(RunQueryRequest)
2417 if err := dec(in); err != nil {
2418 return nil, err
2419 }
2420 if interceptor == nil {
2421 return srv.(DatastoreServer).RunQuery(ctx, in)
2422 }
2423 info := &grpc.UnaryServerInfo{
2424 Server: srv,
2425 FullMethod: "/google.datastore.v1beta3.Datastore/RunQuery",
2426 }
2427 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2428 return srv.(DatastoreServer).RunQuery(ctx, req.(*RunQueryRequest))
2429 }
2430 return interceptor(ctx, in, info, handler)
2431 }
2432
2433 func _Datastore_BeginTransaction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2434 in := new(BeginTransactionRequest)
2435 if err := dec(in); err != nil {
2436 return nil, err
2437 }
2438 if interceptor == nil {
2439 return srv.(DatastoreServer).BeginTransaction(ctx, in)
2440 }
2441 info := &grpc.UnaryServerInfo{
2442 Server: srv,
2443 FullMethod: "/google.datastore.v1beta3.Datastore/BeginTransaction",
2444 }
2445 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2446 return srv.(DatastoreServer).BeginTransaction(ctx, req.(*BeginTransactionRequest))
2447 }
2448 return interceptor(ctx, in, info, handler)
2449 }
2450
2451 func _Datastore_Commit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2452 in := new(CommitRequest)
2453 if err := dec(in); err != nil {
2454 return nil, err
2455 }
2456 if interceptor == nil {
2457 return srv.(DatastoreServer).Commit(ctx, in)
2458 }
2459 info := &grpc.UnaryServerInfo{
2460 Server: srv,
2461 FullMethod: "/google.datastore.v1beta3.Datastore/Commit",
2462 }
2463 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2464 return srv.(DatastoreServer).Commit(ctx, req.(*CommitRequest))
2465 }
2466 return interceptor(ctx, in, info, handler)
2467 }
2468
2469 func _Datastore_Rollback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2470 in := new(RollbackRequest)
2471 if err := dec(in); err != nil {
2472 return nil, err
2473 }
2474 if interceptor == nil {
2475 return srv.(DatastoreServer).Rollback(ctx, in)
2476 }
2477 info := &grpc.UnaryServerInfo{
2478 Server: srv,
2479 FullMethod: "/google.datastore.v1beta3.Datastore/Rollback",
2480 }
2481 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2482 return srv.(DatastoreServer).Rollback(ctx, req.(*RollbackRequest))
2483 }
2484 return interceptor(ctx, in, info, handler)
2485 }
2486
2487 func _Datastore_AllocateIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2488 in := new(AllocateIdsRequest)
2489 if err := dec(in); err != nil {
2490 return nil, err
2491 }
2492 if interceptor == nil {
2493 return srv.(DatastoreServer).AllocateIds(ctx, in)
2494 }
2495 info := &grpc.UnaryServerInfo{
2496 Server: srv,
2497 FullMethod: "/google.datastore.v1beta3.Datastore/AllocateIds",
2498 }
2499 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2500 return srv.(DatastoreServer).AllocateIds(ctx, req.(*AllocateIdsRequest))
2501 }
2502 return interceptor(ctx, in, info, handler)
2503 }
2504
2505 func _Datastore_ReserveIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2506 in := new(ReserveIdsRequest)
2507 if err := dec(in); err != nil {
2508 return nil, err
2509 }
2510 if interceptor == nil {
2511 return srv.(DatastoreServer).ReserveIds(ctx, in)
2512 }
2513 info := &grpc.UnaryServerInfo{
2514 Server: srv,
2515 FullMethod: "/google.datastore.v1beta3.Datastore/ReserveIds",
2516 }
2517 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2518 return srv.(DatastoreServer).ReserveIds(ctx, req.(*ReserveIdsRequest))
2519 }
2520 return interceptor(ctx, in, info, handler)
2521 }
2522
2523 var _Datastore_serviceDesc = grpc.ServiceDesc{
2524 ServiceName: "google.datastore.v1beta3.Datastore",
2525 HandlerType: (*DatastoreServer)(nil),
2526 Methods: []grpc.MethodDesc{
2527 {
2528 MethodName: "Lookup",
2529 Handler: _Datastore_Lookup_Handler,
2530 },
2531 {
2532 MethodName: "RunQuery",
2533 Handler: _Datastore_RunQuery_Handler,
2534 },
2535 {
2536 MethodName: "BeginTransaction",
2537 Handler: _Datastore_BeginTransaction_Handler,
2538 },
2539 {
2540 MethodName: "Commit",
2541 Handler: _Datastore_Commit_Handler,
2542 },
2543 {
2544 MethodName: "Rollback",
2545 Handler: _Datastore_Rollback_Handler,
2546 },
2547 {
2548 MethodName: "AllocateIds",
2549 Handler: _Datastore_AllocateIds_Handler,
2550 },
2551 {
2552 MethodName: "ReserveIds",
2553 Handler: _Datastore_ReserveIds_Handler,
2554 },
2555 },
2556 Streams: []grpc.StreamDesc{},
2557 Metadata: "google/datastore/v1beta3/datastore.proto",
2558 }
2559
View as plain text