| // Copyright 2018 Google Inc. |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // versions: |
| // protoc-gen-go v1.26.0 |
| // protoc v3.12.2 |
| // source: google/datastore/v1beta3/datastore.proto |
| |
| package datastore |
| |
| import ( |
| context "context" |
| reflect "reflect" |
| sync "sync" |
| |
| _ "google.golang.org/genproto/googleapis/api/annotations" |
| grpc "google.golang.org/grpc" |
| codes "google.golang.org/grpc/codes" |
| status "google.golang.org/grpc/status" |
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| ) |
| |
| const ( |
| // Verify that this generated code is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) |
| // Verify that runtime/protoimpl is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) |
| ) |
| |
| // The modes available for commits. |
| type CommitRequest_Mode int32 |
| |
| const ( |
| // Unspecified. This value must not be used. |
| CommitRequest_MODE_UNSPECIFIED CommitRequest_Mode = 0 |
| // Transactional: The mutations are either all applied, or none are applied. |
| // Learn about transactions |
| // [here](https://cloud.google.com/datastore/docs/concepts/transactions). |
| CommitRequest_TRANSACTIONAL CommitRequest_Mode = 1 |
| // Non-transactional: The mutations may not apply as all or none. |
| CommitRequest_NON_TRANSACTIONAL CommitRequest_Mode = 2 |
| ) |
| |
| // Enum value maps for CommitRequest_Mode. |
| var ( |
| CommitRequest_Mode_name = map[int32]string{ |
| 0: "MODE_UNSPECIFIED", |
| 1: "TRANSACTIONAL", |
| 2: "NON_TRANSACTIONAL", |
| } |
| CommitRequest_Mode_value = map[string]int32{ |
| "MODE_UNSPECIFIED": 0, |
| "TRANSACTIONAL": 1, |
| "NON_TRANSACTIONAL": 2, |
| } |
| ) |
| |
| func (x CommitRequest_Mode) Enum() *CommitRequest_Mode { |
| p := new(CommitRequest_Mode) |
| *p = x |
| return p |
| } |
| |
| func (x CommitRequest_Mode) String() string { |
| return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) |
| } |
| |
| func (CommitRequest_Mode) Descriptor() protoreflect.EnumDescriptor { |
| return file_google_datastore_v1beta3_datastore_proto_enumTypes[0].Descriptor() |
| } |
| |
| func (CommitRequest_Mode) Type() protoreflect.EnumType { |
| return &file_google_datastore_v1beta3_datastore_proto_enumTypes[0] |
| } |
| |
| func (x CommitRequest_Mode) Number() protoreflect.EnumNumber { |
| return protoreflect.EnumNumber(x) |
| } |
| |
| // Deprecated: Use CommitRequest_Mode.Descriptor instead. |
| func (CommitRequest_Mode) EnumDescriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{8, 0} |
| } |
| |
| // The possible values for read consistencies. |
| type ReadOptions_ReadConsistency int32 |
| |
| const ( |
| // Unspecified. This value must not be used. |
| ReadOptions_READ_CONSISTENCY_UNSPECIFIED ReadOptions_ReadConsistency = 0 |
| // Strong consistency. |
| ReadOptions_STRONG ReadOptions_ReadConsistency = 1 |
| // Eventual consistency. |
| ReadOptions_EVENTUAL ReadOptions_ReadConsistency = 2 |
| ) |
| |
| // Enum value maps for ReadOptions_ReadConsistency. |
| var ( |
| ReadOptions_ReadConsistency_name = map[int32]string{ |
| 0: "READ_CONSISTENCY_UNSPECIFIED", |
| 1: "STRONG", |
| 2: "EVENTUAL", |
| } |
| ReadOptions_ReadConsistency_value = map[string]int32{ |
| "READ_CONSISTENCY_UNSPECIFIED": 0, |
| "STRONG": 1, |
| "EVENTUAL": 2, |
| } |
| ) |
| |
| func (x ReadOptions_ReadConsistency) Enum() *ReadOptions_ReadConsistency { |
| p := new(ReadOptions_ReadConsistency) |
| *p = x |
| return p |
| } |
| |
| func (x ReadOptions_ReadConsistency) String() string { |
| return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) |
| } |
| |
| func (ReadOptions_ReadConsistency) Descriptor() protoreflect.EnumDescriptor { |
| return file_google_datastore_v1beta3_datastore_proto_enumTypes[1].Descriptor() |
| } |
| |
| func (ReadOptions_ReadConsistency) Type() protoreflect.EnumType { |
| return &file_google_datastore_v1beta3_datastore_proto_enumTypes[1] |
| } |
| |
| func (x ReadOptions_ReadConsistency) Number() protoreflect.EnumNumber { |
| return protoreflect.EnumNumber(x) |
| } |
| |
| // Deprecated: Use ReadOptions_ReadConsistency.Descriptor instead. |
| func (ReadOptions_ReadConsistency) EnumDescriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{16, 0} |
| } |
| |
| // The request for |
| // [Datastore.Lookup][google.datastore.v1beta3.Datastore.Lookup]. |
| type LookupRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The ID of the project against which to make the request. |
| ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` |
| // The options for this lookup request. |
| ReadOptions *ReadOptions `protobuf:"bytes,1,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"` |
| // Keys of entities to look up. |
| Keys []*Key `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"` |
| } |
| |
| func (x *LookupRequest) Reset() { |
| *x = LookupRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[0] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *LookupRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*LookupRequest) ProtoMessage() {} |
| |
| func (x *LookupRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[0] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use LookupRequest.ProtoReflect.Descriptor instead. |
| func (*LookupRequest) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{0} |
| } |
| |
| func (x *LookupRequest) GetProjectId() string { |
| if x != nil { |
| return x.ProjectId |
| } |
| return "" |
| } |
| |
| func (x *LookupRequest) GetReadOptions() *ReadOptions { |
| if x != nil { |
| return x.ReadOptions |
| } |
| return nil |
| } |
| |
| func (x *LookupRequest) GetKeys() []*Key { |
| if x != nil { |
| return x.Keys |
| } |
| return nil |
| } |
| |
| // The response for |
| // [Datastore.Lookup][google.datastore.v1beta3.Datastore.Lookup]. |
| type LookupResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // Entities found as `ResultType.FULL` entities. The order of results in this |
| // field is undefined and has no relation to the order of the keys in the |
| // input. |
| Found []*EntityResult `protobuf:"bytes,1,rep,name=found,proto3" json:"found,omitempty"` |
| // Entities not found as `ResultType.KEY_ONLY` entities. The order of results |
| // in this field is undefined and has no relation to the order of the keys |
| // in the input. |
| Missing []*EntityResult `protobuf:"bytes,2,rep,name=missing,proto3" json:"missing,omitempty"` |
| // A list of keys that were not looked up due to resource constraints. The |
| // order of results in this field is undefined and has no relation to the |
| // order of the keys in the input. |
| Deferred []*Key `protobuf:"bytes,3,rep,name=deferred,proto3" json:"deferred,omitempty"` |
| } |
| |
| func (x *LookupResponse) Reset() { |
| *x = LookupResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[1] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *LookupResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*LookupResponse) ProtoMessage() {} |
| |
| func (x *LookupResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[1] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use LookupResponse.ProtoReflect.Descriptor instead. |
| func (*LookupResponse) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{1} |
| } |
| |
| func (x *LookupResponse) GetFound() []*EntityResult { |
| if x != nil { |
| return x.Found |
| } |
| return nil |
| } |
| |
| func (x *LookupResponse) GetMissing() []*EntityResult { |
| if x != nil { |
| return x.Missing |
| } |
| return nil |
| } |
| |
| func (x *LookupResponse) GetDeferred() []*Key { |
| if x != nil { |
| return x.Deferred |
| } |
| return nil |
| } |
| |
| // The request for |
| // [Datastore.RunQuery][google.datastore.v1beta3.Datastore.RunQuery]. |
| type RunQueryRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The ID of the project against which to make the request. |
| ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` |
| // Entities are partitioned into subsets, identified by a partition ID. |
| // Queries are scoped to a single partition. |
| // This partition ID is normalized with the standard default context |
| // partition ID. |
| PartitionId *PartitionId `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` |
| // The options for this query. |
| ReadOptions *ReadOptions `protobuf:"bytes,1,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"` |
| // The type of query. |
| // |
| // Types that are assignable to QueryType: |
| // *RunQueryRequest_Query |
| // *RunQueryRequest_GqlQuery |
| QueryType isRunQueryRequest_QueryType `protobuf_oneof:"query_type"` |
| } |
| |
| func (x *RunQueryRequest) Reset() { |
| *x = RunQueryRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[2] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *RunQueryRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*RunQueryRequest) ProtoMessage() {} |
| |
| func (x *RunQueryRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[2] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use RunQueryRequest.ProtoReflect.Descriptor instead. |
| func (*RunQueryRequest) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{2} |
| } |
| |
| func (x *RunQueryRequest) GetProjectId() string { |
| if x != nil { |
| return x.ProjectId |
| } |
| return "" |
| } |
| |
| func (x *RunQueryRequest) GetPartitionId() *PartitionId { |
| if x != nil { |
| return x.PartitionId |
| } |
| return nil |
| } |
| |
| func (x *RunQueryRequest) GetReadOptions() *ReadOptions { |
| if x != nil { |
| return x.ReadOptions |
| } |
| return nil |
| } |
| |
| func (m *RunQueryRequest) GetQueryType() isRunQueryRequest_QueryType { |
| if m != nil { |
| return m.QueryType |
| } |
| return nil |
| } |
| |
| func (x *RunQueryRequest) GetQuery() *Query { |
| if x, ok := x.GetQueryType().(*RunQueryRequest_Query); ok { |
| return x.Query |
| } |
| return nil |
| } |
| |
| func (x *RunQueryRequest) GetGqlQuery() *GqlQuery { |
| if x, ok := x.GetQueryType().(*RunQueryRequest_GqlQuery); ok { |
| return x.GqlQuery |
| } |
| return nil |
| } |
| |
| type isRunQueryRequest_QueryType interface { |
| isRunQueryRequest_QueryType() |
| } |
| |
| type RunQueryRequest_Query struct { |
| // The query to run. |
| Query *Query `protobuf:"bytes,3,opt,name=query,proto3,oneof"` |
| } |
| |
| type RunQueryRequest_GqlQuery struct { |
| // The GQL query to run. |
| GqlQuery *GqlQuery `protobuf:"bytes,7,opt,name=gql_query,json=gqlQuery,proto3,oneof"` |
| } |
| |
| func (*RunQueryRequest_Query) isRunQueryRequest_QueryType() {} |
| |
| func (*RunQueryRequest_GqlQuery) isRunQueryRequest_QueryType() {} |
| |
| // The response for |
| // [Datastore.RunQuery][google.datastore.v1beta3.Datastore.RunQuery]. |
| type RunQueryResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // A batch of query results (always present). |
| Batch *QueryResultBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"` |
| // The parsed form of the `GqlQuery` from the request, if it was set. |
| Query *Query `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` |
| } |
| |
| func (x *RunQueryResponse) Reset() { |
| *x = RunQueryResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[3] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *RunQueryResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*RunQueryResponse) ProtoMessage() {} |
| |
| func (x *RunQueryResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[3] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use RunQueryResponse.ProtoReflect.Descriptor instead. |
| func (*RunQueryResponse) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{3} |
| } |
| |
| func (x *RunQueryResponse) GetBatch() *QueryResultBatch { |
| if x != nil { |
| return x.Batch |
| } |
| return nil |
| } |
| |
| func (x *RunQueryResponse) GetQuery() *Query { |
| if x != nil { |
| return x.Query |
| } |
| return nil |
| } |
| |
| // The request for |
| // [Datastore.BeginTransaction][google.datastore.v1beta3.Datastore.BeginTransaction]. |
| type BeginTransactionRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The ID of the project against which to make the request. |
| ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` |
| // Options for a new transaction. |
| TransactionOptions *TransactionOptions `protobuf:"bytes,10,opt,name=transaction_options,json=transactionOptions,proto3" json:"transaction_options,omitempty"` |
| } |
| |
| func (x *BeginTransactionRequest) Reset() { |
| *x = BeginTransactionRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[4] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *BeginTransactionRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*BeginTransactionRequest) ProtoMessage() {} |
| |
| func (x *BeginTransactionRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[4] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use BeginTransactionRequest.ProtoReflect.Descriptor instead. |
| func (*BeginTransactionRequest) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{4} |
| } |
| |
| func (x *BeginTransactionRequest) GetProjectId() string { |
| if x != nil { |
| return x.ProjectId |
| } |
| return "" |
| } |
| |
| func (x *BeginTransactionRequest) GetTransactionOptions() *TransactionOptions { |
| if x != nil { |
| return x.TransactionOptions |
| } |
| return nil |
| } |
| |
| // The response for |
| // [Datastore.BeginTransaction][google.datastore.v1beta3.Datastore.BeginTransaction]. |
| type BeginTransactionResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The transaction identifier (always present). |
| Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` |
| } |
| |
| func (x *BeginTransactionResponse) Reset() { |
| *x = BeginTransactionResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[5] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *BeginTransactionResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*BeginTransactionResponse) ProtoMessage() {} |
| |
| func (x *BeginTransactionResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[5] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use BeginTransactionResponse.ProtoReflect.Descriptor instead. |
| func (*BeginTransactionResponse) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{5} |
| } |
| |
| func (x *BeginTransactionResponse) GetTransaction() []byte { |
| if x != nil { |
| return x.Transaction |
| } |
| return nil |
| } |
| |
| // The request for |
| // [Datastore.Rollback][google.datastore.v1beta3.Datastore.Rollback]. |
| type RollbackRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The ID of the project against which to make the request. |
| ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` |
| // The transaction identifier, returned by a call to |
| // [Datastore.BeginTransaction][google.datastore.v1beta3.Datastore.BeginTransaction]. |
| Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` |
| } |
| |
| func (x *RollbackRequest) Reset() { |
| *x = RollbackRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[6] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *RollbackRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*RollbackRequest) ProtoMessage() {} |
| |
| func (x *RollbackRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[6] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use RollbackRequest.ProtoReflect.Descriptor instead. |
| func (*RollbackRequest) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{6} |
| } |
| |
| func (x *RollbackRequest) GetProjectId() string { |
| if x != nil { |
| return x.ProjectId |
| } |
| return "" |
| } |
| |
| func (x *RollbackRequest) GetTransaction() []byte { |
| if x != nil { |
| return x.Transaction |
| } |
| return nil |
| } |
| |
| // The response for |
| // [Datastore.Rollback][google.datastore.v1beta3.Datastore.Rollback]. (an empty |
| // message). |
| type RollbackResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| } |
| |
| func (x *RollbackResponse) Reset() { |
| *x = RollbackResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[7] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *RollbackResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*RollbackResponse) ProtoMessage() {} |
| |
| func (x *RollbackResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[7] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use RollbackResponse.ProtoReflect.Descriptor instead. |
| func (*RollbackResponse) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{7} |
| } |
| |
| // The request for |
| // [Datastore.Commit][google.datastore.v1beta3.Datastore.Commit]. |
| type CommitRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The ID of the project against which to make the request. |
| ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` |
| // The type of commit to perform. Defaults to `TRANSACTIONAL`. |
| Mode CommitRequest_Mode `protobuf:"varint,5,opt,name=mode,proto3,enum=google.datastore.v1beta3.CommitRequest_Mode" json:"mode,omitempty"` |
| // Must be set when mode is `TRANSACTIONAL`. |
| // |
| // Types that are assignable to TransactionSelector: |
| // *CommitRequest_Transaction |
| TransactionSelector isCommitRequest_TransactionSelector `protobuf_oneof:"transaction_selector"` |
| // The mutations to perform. |
| // |
| // When mode is `TRANSACTIONAL`, mutations affecting a single entity are |
| // applied in order. The following sequences of mutations affecting a single |
| // entity are not permitted in a single `Commit` request: |
| // |
| // - `insert` followed by `insert` |
| // - `update` followed by `insert` |
| // - `upsert` followed by `insert` |
| // - `delete` followed by `update` |
| // |
| // When mode is `NON_TRANSACTIONAL`, no two mutations may affect a single |
| // entity. |
| Mutations []*Mutation `protobuf:"bytes,6,rep,name=mutations,proto3" json:"mutations,omitempty"` |
| } |
| |
| func (x *CommitRequest) Reset() { |
| *x = CommitRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[8] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *CommitRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CommitRequest) ProtoMessage() {} |
| |
| func (x *CommitRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[8] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead. |
| func (*CommitRequest) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{8} |
| } |
| |
| func (x *CommitRequest) GetProjectId() string { |
| if x != nil { |
| return x.ProjectId |
| } |
| return "" |
| } |
| |
| func (x *CommitRequest) GetMode() CommitRequest_Mode { |
| if x != nil { |
| return x.Mode |
| } |
| return CommitRequest_MODE_UNSPECIFIED |
| } |
| |
| func (m *CommitRequest) GetTransactionSelector() isCommitRequest_TransactionSelector { |
| if m != nil { |
| return m.TransactionSelector |
| } |
| return nil |
| } |
| |
| func (x *CommitRequest) GetTransaction() []byte { |
| if x, ok := x.GetTransactionSelector().(*CommitRequest_Transaction); ok { |
| return x.Transaction |
| } |
| return nil |
| } |
| |
| func (x *CommitRequest) GetMutations() []*Mutation { |
| if x != nil { |
| return x.Mutations |
| } |
| return nil |
| } |
| |
| type isCommitRequest_TransactionSelector interface { |
| isCommitRequest_TransactionSelector() |
| } |
| |
| type CommitRequest_Transaction struct { |
| // The identifier of the transaction associated with the commit. A |
| // transaction identifier is returned by a call to |
| // [Datastore.BeginTransaction][google.datastore.v1beta3.Datastore.BeginTransaction]. |
| Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3,oneof"` |
| } |
| |
| func (*CommitRequest_Transaction) isCommitRequest_TransactionSelector() {} |
| |
| // The response for |
| // [Datastore.Commit][google.datastore.v1beta3.Datastore.Commit]. |
| type CommitResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The result of performing the mutations. |
| // The i-th mutation result corresponds to the i-th mutation in the request. |
| MutationResults []*MutationResult `protobuf:"bytes,3,rep,name=mutation_results,json=mutationResults,proto3" json:"mutation_results,omitempty"` |
| // The number of index entries updated during the commit, or zero if none were |
| // updated. |
| IndexUpdates int32 `protobuf:"varint,4,opt,name=index_updates,json=indexUpdates,proto3" json:"index_updates,omitempty"` |
| } |
| |
| func (x *CommitResponse) Reset() { |
| *x = CommitResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[9] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *CommitResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CommitResponse) ProtoMessage() {} |
| |
| func (x *CommitResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[9] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead. |
| func (*CommitResponse) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{9} |
| } |
| |
| func (x *CommitResponse) GetMutationResults() []*MutationResult { |
| if x != nil { |
| return x.MutationResults |
| } |
| return nil |
| } |
| |
| func (x *CommitResponse) GetIndexUpdates() int32 { |
| if x != nil { |
| return x.IndexUpdates |
| } |
| return 0 |
| } |
| |
| // The request for |
| // [Datastore.AllocateIds][google.datastore.v1beta3.Datastore.AllocateIds]. |
| type AllocateIdsRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The ID of the project against which to make the request. |
| ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` |
| // A list of keys with incomplete key paths for which to allocate IDs. |
| // No key may be reserved/read-only. |
| Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` |
| } |
| |
| func (x *AllocateIdsRequest) Reset() { |
| *x = AllocateIdsRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[10] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *AllocateIdsRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*AllocateIdsRequest) ProtoMessage() {} |
| |
| func (x *AllocateIdsRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[10] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use AllocateIdsRequest.ProtoReflect.Descriptor instead. |
| func (*AllocateIdsRequest) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{10} |
| } |
| |
| func (x *AllocateIdsRequest) GetProjectId() string { |
| if x != nil { |
| return x.ProjectId |
| } |
| return "" |
| } |
| |
| func (x *AllocateIdsRequest) GetKeys() []*Key { |
| if x != nil { |
| return x.Keys |
| } |
| return nil |
| } |
| |
| // The response for |
| // [Datastore.AllocateIds][google.datastore.v1beta3.Datastore.AllocateIds]. |
| type AllocateIdsResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The keys specified in the request (in the same order), each with |
| // its key path completed with a newly allocated ID. |
| Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` |
| } |
| |
| func (x *AllocateIdsResponse) Reset() { |
| *x = AllocateIdsResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[11] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *AllocateIdsResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*AllocateIdsResponse) ProtoMessage() {} |
| |
| func (x *AllocateIdsResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[11] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use AllocateIdsResponse.ProtoReflect.Descriptor instead. |
| func (*AllocateIdsResponse) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{11} |
| } |
| |
| func (x *AllocateIdsResponse) GetKeys() []*Key { |
| if x != nil { |
| return x.Keys |
| } |
| return nil |
| } |
| |
| // The request for |
| // [Datastore.ReserveIds][google.datastore.v1beta3.Datastore.ReserveIds]. |
| type ReserveIdsRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The ID of the project against which to make the request. |
| ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` |
| // If not empty, the ID of the database against which to make the request. |
| DatabaseId string `protobuf:"bytes,9,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"` |
| // A list of keys with complete key paths whose numeric IDs should not be |
| // auto-allocated. |
| Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` |
| } |
| |
| func (x *ReserveIdsRequest) Reset() { |
| *x = ReserveIdsRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[12] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ReserveIdsRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ReserveIdsRequest) ProtoMessage() {} |
| |
| func (x *ReserveIdsRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[12] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ReserveIdsRequest.ProtoReflect.Descriptor instead. |
| func (*ReserveIdsRequest) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{12} |
| } |
| |
| func (x *ReserveIdsRequest) GetProjectId() string { |
| if x != nil { |
| return x.ProjectId |
| } |
| return "" |
| } |
| |
| func (x *ReserveIdsRequest) GetDatabaseId() string { |
| if x != nil { |
| return x.DatabaseId |
| } |
| return "" |
| } |
| |
| func (x *ReserveIdsRequest) GetKeys() []*Key { |
| if x != nil { |
| return x.Keys |
| } |
| return nil |
| } |
| |
| // The response for |
| // [Datastore.ReserveIds][google.datastore.v1beta3.Datastore.ReserveIds]. |
| type ReserveIdsResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| } |
| |
| func (x *ReserveIdsResponse) Reset() { |
| *x = ReserveIdsResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[13] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ReserveIdsResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ReserveIdsResponse) ProtoMessage() {} |
| |
| func (x *ReserveIdsResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[13] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ReserveIdsResponse.ProtoReflect.Descriptor instead. |
| func (*ReserveIdsResponse) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{13} |
| } |
| |
| // A mutation to apply to an entity. |
| type Mutation struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The mutation operation. |
| // |
| // For `insert`, `update`, and `upsert`: |
| // - The entity's key must not be reserved/read-only. |
| // - No property in the entity may have a reserved name, |
| // not even a property in an entity in a value. |
| // - No value in the entity may have meaning 18, |
| // not even a value in an entity in another value. |
| // |
| // Types that are assignable to Operation: |
| // *Mutation_Insert |
| // *Mutation_Update |
| // *Mutation_Upsert |
| // *Mutation_Delete |
| Operation isMutation_Operation `protobuf_oneof:"operation"` |
| // When set, the server will detect whether or not this mutation conflicts |
| // with the current version of the entity on the server. Conflicting mutations |
| // are not applied, and are marked as such in MutationResult. |
| // |
| // Types that are assignable to ConflictDetectionStrategy: |
| // *Mutation_BaseVersion |
| ConflictDetectionStrategy isMutation_ConflictDetectionStrategy `protobuf_oneof:"conflict_detection_strategy"` |
| } |
| |
| func (x *Mutation) Reset() { |
| *x = Mutation{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[14] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Mutation) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Mutation) ProtoMessage() {} |
| |
| func (x *Mutation) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[14] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Mutation.ProtoReflect.Descriptor instead. |
| func (*Mutation) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{14} |
| } |
| |
| func (m *Mutation) GetOperation() isMutation_Operation { |
| if m != nil { |
| return m.Operation |
| } |
| return nil |
| } |
| |
| func (x *Mutation) GetInsert() *Entity { |
| if x, ok := x.GetOperation().(*Mutation_Insert); ok { |
| return x.Insert |
| } |
| return nil |
| } |
| |
| func (x *Mutation) GetUpdate() *Entity { |
| if x, ok := x.GetOperation().(*Mutation_Update); ok { |
| return x.Update |
| } |
| return nil |
| } |
| |
| func (x *Mutation) GetUpsert() *Entity { |
| if x, ok := x.GetOperation().(*Mutation_Upsert); ok { |
| return x.Upsert |
| } |
| return nil |
| } |
| |
| func (x *Mutation) GetDelete() *Key { |
| if x, ok := x.GetOperation().(*Mutation_Delete); ok { |
| return x.Delete |
| } |
| return nil |
| } |
| |
| func (m *Mutation) GetConflictDetectionStrategy() isMutation_ConflictDetectionStrategy { |
| if m != nil { |
| return m.ConflictDetectionStrategy |
| } |
| return nil |
| } |
| |
| func (x *Mutation) GetBaseVersion() int64 { |
| if x, ok := x.GetConflictDetectionStrategy().(*Mutation_BaseVersion); ok { |
| return x.BaseVersion |
| } |
| return 0 |
| } |
| |
| type isMutation_Operation interface { |
| isMutation_Operation() |
| } |
| |
| type Mutation_Insert struct { |
| // The entity to insert. The entity must not already exist. |
| // The entity key's final path element may be incomplete. |
| Insert *Entity `protobuf:"bytes,4,opt,name=insert,proto3,oneof"` |
| } |
| |
| type Mutation_Update struct { |
| // The entity to update. The entity must already exist. |
| // Must have a complete key path. |
| Update *Entity `protobuf:"bytes,5,opt,name=update,proto3,oneof"` |
| } |
| |
| type Mutation_Upsert struct { |
| // The entity to upsert. The entity may or may not already exist. |
| // The entity key's final path element may be incomplete. |
| Upsert *Entity `protobuf:"bytes,6,opt,name=upsert,proto3,oneof"` |
| } |
| |
| type Mutation_Delete struct { |
| // The key of the entity to delete. The entity may or may not already exist. |
| // Must have a complete key path and must not be reserved/read-only. |
| Delete *Key `protobuf:"bytes,7,opt,name=delete,proto3,oneof"` |
| } |
| |
| func (*Mutation_Insert) isMutation_Operation() {} |
| |
| func (*Mutation_Update) isMutation_Operation() {} |
| |
| func (*Mutation_Upsert) isMutation_Operation() {} |
| |
| func (*Mutation_Delete) isMutation_Operation() {} |
| |
| type isMutation_ConflictDetectionStrategy interface { |
| isMutation_ConflictDetectionStrategy() |
| } |
| |
| type Mutation_BaseVersion struct { |
| // The version of the entity that this mutation is being applied to. If this |
| // does not match the current version on the server, the mutation conflicts. |
| BaseVersion int64 `protobuf:"varint,8,opt,name=base_version,json=baseVersion,proto3,oneof"` |
| } |
| |
| func (*Mutation_BaseVersion) isMutation_ConflictDetectionStrategy() {} |
| |
| // The result of applying a mutation. |
| type MutationResult struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The automatically allocated key. |
| // Set only when the mutation allocated a key. |
| Key *Key `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` |
| // The version of the entity on the server after processing the mutation. If |
| // the mutation doesn't change anything on the server, then the version will |
| // be the version of the current entity or, if no entity is present, a version |
| // that is strictly greater than the version of any previous entity and less |
| // than the version of any possible future entity. |
| Version int64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` |
| // Whether a conflict was detected for this mutation. Always false when a |
| // conflict detection strategy field is not set in the mutation. |
| ConflictDetected bool `protobuf:"varint,5,opt,name=conflict_detected,json=conflictDetected,proto3" json:"conflict_detected,omitempty"` |
| } |
| |
| func (x *MutationResult) Reset() { |
| *x = MutationResult{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[15] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *MutationResult) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*MutationResult) ProtoMessage() {} |
| |
| func (x *MutationResult) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[15] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use MutationResult.ProtoReflect.Descriptor instead. |
| func (*MutationResult) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{15} |
| } |
| |
| func (x *MutationResult) GetKey() *Key { |
| if x != nil { |
| return x.Key |
| } |
| return nil |
| } |
| |
| func (x *MutationResult) GetVersion() int64 { |
| if x != nil { |
| return x.Version |
| } |
| return 0 |
| } |
| |
| func (x *MutationResult) GetConflictDetected() bool { |
| if x != nil { |
| return x.ConflictDetected |
| } |
| return false |
| } |
| |
| // The options shared by read requests. |
| type ReadOptions struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // If not specified, lookups and ancestor queries default to |
| // `read_consistency`=`STRONG`, global queries default to |
| // `read_consistency`=`EVENTUAL`. |
| // |
| // Types that are assignable to ConsistencyType: |
| // *ReadOptions_ReadConsistency_ |
| // *ReadOptions_Transaction |
| ConsistencyType isReadOptions_ConsistencyType `protobuf_oneof:"consistency_type"` |
| } |
| |
| func (x *ReadOptions) Reset() { |
| *x = ReadOptions{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[16] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ReadOptions) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ReadOptions) ProtoMessage() {} |
| |
| func (x *ReadOptions) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[16] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ReadOptions.ProtoReflect.Descriptor instead. |
| func (*ReadOptions) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{16} |
| } |
| |
| func (m *ReadOptions) GetConsistencyType() isReadOptions_ConsistencyType { |
| if m != nil { |
| return m.ConsistencyType |
| } |
| return nil |
| } |
| |
| func (x *ReadOptions) GetReadConsistency() ReadOptions_ReadConsistency { |
| if x, ok := x.GetConsistencyType().(*ReadOptions_ReadConsistency_); ok { |
| return x.ReadConsistency |
| } |
| return ReadOptions_READ_CONSISTENCY_UNSPECIFIED |
| } |
| |
| func (x *ReadOptions) GetTransaction() []byte { |
| if x, ok := x.GetConsistencyType().(*ReadOptions_Transaction); ok { |
| return x.Transaction |
| } |
| return nil |
| } |
| |
| type isReadOptions_ConsistencyType interface { |
| isReadOptions_ConsistencyType() |
| } |
| |
| type ReadOptions_ReadConsistency_ struct { |
| // The non-transactional read consistency to use. |
| // Cannot be set to `STRONG` for global queries. |
| ReadConsistency ReadOptions_ReadConsistency `protobuf:"varint,1,opt,name=read_consistency,json=readConsistency,proto3,enum=google.datastore.v1beta3.ReadOptions_ReadConsistency,oneof"` |
| } |
| |
| type ReadOptions_Transaction struct { |
| // The identifier of the transaction in which to read. A |
| // transaction identifier is returned by a call to |
| // [Datastore.BeginTransaction][google.datastore.v1beta3.Datastore.BeginTransaction]. |
| Transaction []byte `protobuf:"bytes,2,opt,name=transaction,proto3,oneof"` |
| } |
| |
| func (*ReadOptions_ReadConsistency_) isReadOptions_ConsistencyType() {} |
| |
| func (*ReadOptions_Transaction) isReadOptions_ConsistencyType() {} |
| |
| // Options for beginning a new transaction. |
| // |
| // Transactions can be created explicitly with calls to |
| // [Datastore.BeginTransaction][google.datastore.v1beta3.Datastore.BeginTransaction] |
| // or implicitly by setting |
| // [ReadOptions.new_transaction][google.datastore.v1beta3.ReadOptions.new_transaction] |
| // in read requests. |
| type TransactionOptions struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The `mode` of the transaction, indicating whether write operations are |
| // supported. |
| // |
| // Types that are assignable to Mode: |
| // *TransactionOptions_ReadWrite_ |
| // *TransactionOptions_ReadOnly_ |
| Mode isTransactionOptions_Mode `protobuf_oneof:"mode"` |
| } |
| |
| func (x *TransactionOptions) Reset() { |
| *x = TransactionOptions{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[17] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *TransactionOptions) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*TransactionOptions) ProtoMessage() {} |
| |
| func (x *TransactionOptions) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[17] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use TransactionOptions.ProtoReflect.Descriptor instead. |
| func (*TransactionOptions) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{17} |
| } |
| |
| func (m *TransactionOptions) GetMode() isTransactionOptions_Mode { |
| if m != nil { |
| return m.Mode |
| } |
| return nil |
| } |
| |
| func (x *TransactionOptions) GetReadWrite() *TransactionOptions_ReadWrite { |
| if x, ok := x.GetMode().(*TransactionOptions_ReadWrite_); ok { |
| return x.ReadWrite |
| } |
| return nil |
| } |
| |
| func (x *TransactionOptions) GetReadOnly() *TransactionOptions_ReadOnly { |
| if x, ok := x.GetMode().(*TransactionOptions_ReadOnly_); ok { |
| return x.ReadOnly |
| } |
| return nil |
| } |
| |
| type isTransactionOptions_Mode interface { |
| isTransactionOptions_Mode() |
| } |
| |
| type TransactionOptions_ReadWrite_ struct { |
| // The transaction should allow both reads and writes. |
| ReadWrite *TransactionOptions_ReadWrite `protobuf:"bytes,1,opt,name=read_write,json=readWrite,proto3,oneof"` |
| } |
| |
| type TransactionOptions_ReadOnly_ struct { |
| // The transaction should only allow reads. |
| ReadOnly *TransactionOptions_ReadOnly `protobuf:"bytes,2,opt,name=read_only,json=readOnly,proto3,oneof"` |
| } |
| |
| func (*TransactionOptions_ReadWrite_) isTransactionOptions_Mode() {} |
| |
| func (*TransactionOptions_ReadOnly_) isTransactionOptions_Mode() {} |
| |
| // Options specific to read / write transactions. |
| type TransactionOptions_ReadWrite struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The transaction identifier of the transaction being retried. |
| PreviousTransaction []byte `protobuf:"bytes,1,opt,name=previous_transaction,json=previousTransaction,proto3" json:"previous_transaction,omitempty"` |
| } |
| |
| func (x *TransactionOptions_ReadWrite) Reset() { |
| *x = TransactionOptions_ReadWrite{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[18] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *TransactionOptions_ReadWrite) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*TransactionOptions_ReadWrite) ProtoMessage() {} |
| |
| func (x *TransactionOptions_ReadWrite) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[18] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use TransactionOptions_ReadWrite.ProtoReflect.Descriptor instead. |
| func (*TransactionOptions_ReadWrite) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{17, 0} |
| } |
| |
| func (x *TransactionOptions_ReadWrite) GetPreviousTransaction() []byte { |
| if x != nil { |
| return x.PreviousTransaction |
| } |
| return nil |
| } |
| |
| // Options specific to read-only transactions. |
| type TransactionOptions_ReadOnly struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| } |
| |
| func (x *TransactionOptions_ReadOnly) Reset() { |
| *x = TransactionOptions_ReadOnly{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[19] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *TransactionOptions_ReadOnly) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*TransactionOptions_ReadOnly) ProtoMessage() {} |
| |
| func (x *TransactionOptions_ReadOnly) ProtoReflect() protoreflect.Message { |
| mi := &file_google_datastore_v1beta3_datastore_proto_msgTypes[19] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use TransactionOptions_ReadOnly.ProtoReflect.Descriptor instead. |
| func (*TransactionOptions_ReadOnly) Descriptor() ([]byte, []int) { |
| return file_google_datastore_v1beta3_datastore_proto_rawDescGZIP(), []int{17, 1} |
| } |
| |
| var File_google_datastore_v1beta3_datastore_proto protoreflect.FileDescriptor |
| |
| var file_google_datastore_v1beta3_datastore_proto_rawDesc = []byte{ |
| 0x0a, 0x28, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, |
| 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, |
| 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x18, 0x67, 0x6f, 0x6f, 0x67, |
| 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, |
| 0x65, 0x74, 0x61, 0x33, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, |
| 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, |
| 0x74, 0x6f, 0x1a, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, |
| 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x65, 0x6e, 0x74, |
| 0x69, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x24, 0x67, 0x6f, 0x6f, 0x67, 0x6c, |
| 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, |
| 0x74, 0x61, 0x33, 0x2f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, |
| 0xab, 0x01, 0x0a, 0x0d, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, |
| 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, |
| 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, |
| 0x12, 0x48, 0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, |
| 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, |
| 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, |
| 0x33, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x0b, 0x72, |
| 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x31, 0x0a, 0x04, 0x6b, 0x65, |
| 0x79, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, |
| 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, |
| 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x22, 0xcb, 0x01, |
| 0x0a, 0x0e, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, |
| 0x12, 0x3c, 0x0a, 0x05, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, |
| 0x26, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, |
| 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, |
| 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x05, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x12, 0x40, |
| 0x0a, 0x07, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, |
| 0x26, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, |
| 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, |
| 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x07, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, |
| 0x12, 0x39, 0x0a, 0x08, 0x64, 0x65, 0x66, 0x65, 0x72, 0x72, 0x65, 0x64, 0x18, 0x03, 0x20, 0x03, |
| 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, |
| 0x79, 0x52, 0x08, 0x64, 0x65, 0x66, 0x65, 0x72, 0x72, 0x65, 0x64, 0x22, 0xce, 0x02, 0x0a, 0x0f, |
| 0x52, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, |
| 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, |
| 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x48, |
| 0x0a, 0x0c, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x02, |
| 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, |
| 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, |
| 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x52, 0x0b, 0x70, 0x61, 0x72, |
| 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x48, 0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64, |
| 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, |
| 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, |
| 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, |
| 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x0b, 0x72, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, |
| 0x6e, 0x73, 0x12, 0x37, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, |
| 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, |
| 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, |
| 0x72, 0x79, 0x48, 0x00, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x41, 0x0a, 0x09, 0x67, |
| 0x71, 0x6c, 0x5f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, |
| 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, |
| 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x47, 0x71, 0x6c, 0x51, 0x75, 0x65, |
| 0x72, 0x79, 0x48, 0x00, 0x52, 0x08, 0x67, 0x71, 0x6c, 0x51, 0x75, 0x65, 0x72, 0x79, 0x42, 0x0c, |
| 0x0a, 0x0a, 0x71, 0x75, 0x65, 0x72, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x22, 0x8b, 0x01, 0x0a, |
| 0x10, 0x52, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, |
| 0x65, 0x12, 0x40, 0x0a, 0x05, 0x62, 0x61, 0x74, 0x63, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, |
| 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, |
| 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x72, |
| 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x42, 0x61, 0x74, 0x63, 0x68, 0x52, 0x05, 0x62, 0x61, |
| 0x74, 0x63, 0x68, 0x12, 0x35, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x02, 0x20, 0x01, |
| 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, |
| 0x65, 0x72, 0x79, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x22, 0x97, 0x01, 0x0a, 0x17, 0x42, |
| 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, |
| 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, |
| 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, |
| 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x5d, 0x0a, 0x13, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, |
| 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x0a, 0x20, 0x01, |
| 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x72, |
| 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, |
| 0x52, 0x12, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, |
| 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x3c, 0x0a, 0x18, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, |
| 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, |
| 0x12, 0x20, 0x0a, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, |
| 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, |
| 0x6f, 0x6e, 0x22, 0x52, 0x0a, 0x0f, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x52, 0x65, |
| 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, |
| 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, |
| 0x63, 0x74, 0x49, 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, |
| 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, |
| 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x12, 0x0a, 0x10, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, |
| 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xb6, 0x02, 0x0a, 0x0d, 0x43, |
| 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, |
| 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, |
| 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x40, 0x0a, 0x04, 0x6d, |
| 0x6f, 0x64, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, |
| 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, |
| 0x65, 0x74, 0x61, 0x33, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, |
| 0x73, 0x74, 0x2e, 0x4d, 0x6f, 0x64, 0x65, 0x52, 0x04, 0x6d, 0x6f, 0x64, 0x65, 0x12, 0x22, 0x0a, |
| 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, |
| 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, |
| 0x6e, 0x12, 0x40, 0x0a, 0x09, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x06, |
| 0x20, 0x03, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, |
| 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, |
| 0x4d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x69, |
| 0x6f, 0x6e, 0x73, 0x22, 0x46, 0x0a, 0x04, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x4d, |
| 0x4f, 0x44, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, |
| 0x00, 0x12, 0x11, 0x0a, 0x0d, 0x54, 0x52, 0x41, 0x4e, 0x53, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, |
| 0x41, 0x4c, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x4e, 0x4f, 0x4e, 0x5f, 0x54, 0x52, 0x41, 0x4e, |
| 0x53, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x41, 0x4c, 0x10, 0x02, 0x42, 0x16, 0x0a, 0x14, 0x74, |
| 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x65, 0x6c, 0x65, 0x63, |
| 0x74, 0x6f, 0x72, 0x22, 0x8a, 0x01, 0x0a, 0x0e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, |
| 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x53, 0x0a, 0x10, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x69, |
| 0x6f, 0x6e, 0x5f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, |
| 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, |
| 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4d, 0x75, 0x74, 0x61, |
| 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x0f, 0x6d, 0x75, 0x74, 0x61, |
| 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x69, |
| 0x6e, 0x64, 0x65, 0x78, 0x5f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x73, 0x18, 0x04, 0x20, 0x01, |
| 0x28, 0x05, 0x52, 0x0c, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x73, |
| 0x22, 0x66, 0x0a, 0x12, 0x41, 0x6c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52, |
| 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, |
| 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, |
| 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x31, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x18, 0x01, 0x20, |
| 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, |
| 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, |
| 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x22, 0x48, 0x0a, 0x13, 0x41, 0x6c, 0x6c, 0x6f, |
| 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, |
| 0x31, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, |
| 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, |
| 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65, |
| 0x79, 0x73, 0x22, 0x86, 0x01, 0x0a, 0x11, 0x52, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64, |
| 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, |
| 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, |
| 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x64, 0x61, 0x74, 0x61, 0x62, |
| 0x61, 0x73, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x64, 0x61, |
| 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x64, 0x12, 0x31, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, |
| 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, |
| 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, |
| 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x22, 0x14, 0x0a, 0x12, 0x52, |
| 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, |
| 0x65, 0x22, 0xc8, 0x02, 0x0a, 0x08, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3a, |
| 0x0a, 0x06, 0x69, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, |
| 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, |
| 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, |
| 0x48, 0x00, 0x52, 0x06, 0x69, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x12, 0x3a, 0x0a, 0x06, 0x75, 0x70, |
| 0x64, 0x61, 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, |
| 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, |
| 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x48, 0x00, 0x52, 0x06, |
| 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x3a, 0x0a, 0x06, 0x75, 0x70, 0x73, 0x65, 0x72, 0x74, |
| 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, |
| 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, |
| 0x33, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x48, 0x00, 0x52, 0x06, 0x75, 0x70, 0x73, 0x65, |
| 0x72, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x18, 0x07, 0x20, 0x01, |
| 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, |
| 0x79, 0x48, 0x00, 0x52, 0x06, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x62, |
| 0x61, 0x73, 0x65, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x08, 0x20, 0x01, 0x28, |
| 0x03, 0x48, 0x01, 0x52, 0x0b, 0x62, 0x61, 0x73, 0x65, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, |
| 0x42, 0x0b, 0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x1d, 0x0a, |
| 0x1b, 0x63, 0x6f, 0x6e, 0x66, 0x6c, 0x69, 0x63, 0x74, 0x5f, 0x64, 0x65, 0x74, 0x65, 0x63, 0x74, |
| 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x22, 0x88, 0x01, 0x0a, |
| 0x0e, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, |
| 0x2f, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, |
| 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, |
| 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, |
| 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, |
| 0x03, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x2b, 0x0a, 0x11, 0x63, 0x6f, |
| 0x6e, 0x66, 0x6c, 0x69, 0x63, 0x74, 0x5f, 0x64, 0x65, 0x74, 0x65, 0x63, 0x74, 0x65, 0x64, 0x18, |
| 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x10, 0x63, 0x6f, 0x6e, 0x66, 0x6c, 0x69, 0x63, 0x74, 0x44, |
| 0x65, 0x74, 0x65, 0x63, 0x74, 0x65, 0x64, 0x22, 0xf8, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x61, 0x64, |
| 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x62, 0x0a, 0x10, 0x72, 0x65, 0x61, 0x64, 0x5f, |
| 0x63, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, |
| 0x0e, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, |
| 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x65, 0x61, |
| 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x6e, |
| 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x48, 0x00, 0x52, 0x0f, 0x72, 0x65, 0x61, 0x64, |
| 0x43, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x12, 0x22, 0x0a, 0x0b, 0x74, |
| 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, |
| 0x48, 0x00, 0x52, 0x0b, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, |
| 0x4d, 0x0a, 0x0f, 0x52, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, |
| 0x63, 0x79, 0x12, 0x20, 0x0a, 0x1c, 0x52, 0x45, 0x41, 0x44, 0x5f, 0x43, 0x4f, 0x4e, 0x53, 0x49, |
| 0x53, 0x54, 0x45, 0x4e, 0x43, 0x59, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, |
| 0x45, 0x44, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x53, 0x54, 0x52, 0x4f, 0x4e, 0x47, 0x10, 0x01, |
| 0x12, 0x0c, 0x0a, 0x08, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x55, 0x41, 0x4c, 0x10, 0x02, 0x42, 0x12, |
| 0x0a, 0x10, 0x63, 0x6f, 0x6e, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x74, 0x79, |
| 0x70, 0x65, 0x22, 0x97, 0x02, 0x0a, 0x12, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, |
| 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x57, 0x0a, 0x0a, 0x72, 0x65, 0x61, |
| 0x64, 0x5f, 0x77, 0x72, 0x69, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e, |
| 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, |
| 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, |
| 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x52, 0x65, 0x61, 0x64, |
| 0x57, 0x72, 0x69, 0x74, 0x65, 0x48, 0x00, 0x52, 0x09, 0x72, 0x65, 0x61, 0x64, 0x57, 0x72, 0x69, |
| 0x74, 0x65, 0x12, 0x54, 0x0a, 0x09, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x6e, 0x6c, 0x79, 0x18, |
| 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, |
| 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, |
| 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, |
| 0x6f, 0x6e, 0x73, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x6e, 0x6c, 0x79, 0x48, 0x00, 0x52, 0x08, |
| 0x72, 0x65, 0x61, 0x64, 0x4f, 0x6e, 0x6c, 0x79, 0x1a, 0x3e, 0x0a, 0x09, 0x52, 0x65, 0x61, 0x64, |
| 0x57, 0x72, 0x69, 0x74, 0x65, 0x12, 0x31, 0x0a, 0x14, 0x70, 0x72, 0x65, 0x76, 0x69, 0x6f, 0x75, |
| 0x73, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, |
| 0x01, 0x28, 0x0c, 0x52, 0x13, 0x70, 0x72, 0x65, 0x76, 0x69, 0x6f, 0x75, 0x73, 0x54, 0x72, 0x61, |
| 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0x0a, 0x0a, 0x08, 0x52, 0x65, 0x61, 0x64, |
| 0x4f, 0x6e, 0x6c, 0x79, 0x42, 0x06, 0x0a, 0x04, 0x6d, 0x6f, 0x64, 0x65, 0x32, 0xd7, 0x08, 0x0a, |
| 0x09, 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x12, 0x8d, 0x01, 0x0a, 0x06, 0x4c, |
| 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x12, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, |
| 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, |
| 0x2e, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, |
| 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, |
| 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, |
| 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x30, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a, |
| 0x22, 0x25, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, |
| 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, |
| 0x3a, 0x6c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x3a, 0x01, 0x2a, 0x12, 0x95, 0x01, 0x0a, 0x08, 0x52, |
| 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x12, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, |
| 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, |
| 0x61, 0x33, 0x2e, 0x52, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, |
| 0x73, 0x74, 0x1a, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x75, |
| 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x32, |
| 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x22, 0x27, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, |
| 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, |
| 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x72, 0x75, 0x6e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x3a, |
| 0x01, 0x2a, 0x12, 0xb5, 0x01, 0x0a, 0x10, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, |
| 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, |
| 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, |
| 0x61, 0x33, 0x2e, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, |
| 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x67, 0x6f, 0x6f, |
| 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, |
| 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, 0x73, |
| 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x3a, |
| 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x22, 0x2f, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, |
| 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, |
| 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x62, 0x65, 0x67, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, |
| 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x3a, 0x01, 0x2a, 0x12, 0x8d, 0x01, 0x0a, 0x06, 0x43, |
| 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x12, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, |
| 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, |
| 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, |
| 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, |
| 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, |
| 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x30, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a, |
| 0x22, 0x25, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, |
| 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, |
| 0x3a, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x3a, 0x01, 0x2a, 0x12, 0x95, 0x01, 0x0a, 0x08, 0x52, |
| 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x12, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, |
| 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, |
| 0x61, 0x33, 0x2e, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, |
| 0x73, 0x74, 0x1a, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x6f, |
| 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x32, |
| 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x22, 0x27, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, |
| 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, |
| 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x72, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x3a, |
| 0x01, 0x2a, 0x12, 0xa1, 0x01, 0x0a, 0x0b, 0x41, 0x6c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65, 0x49, |
| 0x64, 0x73, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x6c, |
| 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, |
| 0x1a, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, |
| 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x6c, 0x6c, 0x6f, |
| 0x63, 0x61, 0x74, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, |
| 0x35, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2f, 0x22, 0x2a, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, |
| 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, |
| 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x61, 0x6c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x65, |
| 0x49, 0x64, 0x73, 0x3a, 0x01, 0x2a, 0x12, 0x9d, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x73, 0x65, 0x72, |
| 0x76, 0x65, 0x49, 0x64, 0x73, 0x12, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, |
| 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, |
| 0x2e, 0x52, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, |
| 0x73, 0x74, 0x1a, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x65, |
| 0x73, 0x65, 0x72, 0x76, 0x65, 0x49, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, |
| 0x22, 0x34, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2e, 0x22, 0x29, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, |
| 0x61, 0x33, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, |
| 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x72, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, |
| 0x49, 0x64, 0x73, 0x3a, 0x01, 0x2a, 0x42, 0xd9, 0x01, 0x0a, 0x1c, 0x63, 0x6f, 0x6d, 0x2e, 0x67, |
| 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, |
| 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x42, 0x0e, 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, |
| 0x72, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x41, 0x67, 0x6f, 0x6f, 0x67, 0x6c, |
| 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, |
| 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, |
| 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, |
| 0x61, 0x33, 0x3b, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0xaa, 0x02, 0x1e, 0x47, |
| 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x44, 0x61, 0x74, 0x61, |
| 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x56, 0x31, 0x42, 0x65, 0x74, 0x61, 0x33, 0xca, 0x02, 0x1e, |
| 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x44, 0x61, 0x74, |
| 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x5c, 0x56, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0xea, 0x02, |
| 0x21, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x3a, 0x3a, |
| 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x65, 0x74, |
| 0x61, 0x33, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, |
| } |
| |
| var ( |
| file_google_datastore_v1beta3_datastore_proto_rawDescOnce sync.Once |
| file_google_datastore_v1beta3_datastore_proto_rawDescData = file_google_datastore_v1beta3_datastore_proto_rawDesc |
| ) |
| |
| func file_google_datastore_v1beta3_datastore_proto_rawDescGZIP() []byte { |
| file_google_datastore_v1beta3_datastore_proto_rawDescOnce.Do(func() { |
| file_google_datastore_v1beta3_datastore_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_datastore_v1beta3_datastore_proto_rawDescData) |
| }) |
| return file_google_datastore_v1beta3_datastore_proto_rawDescData |
| } |
| |
| var file_google_datastore_v1beta3_datastore_proto_enumTypes = make([]protoimpl.EnumInfo, 2) |
| var file_google_datastore_v1beta3_datastore_proto_msgTypes = make([]protoimpl.MessageInfo, 20) |
| var file_google_datastore_v1beta3_datastore_proto_goTypes = []interface{}{ |
| (CommitRequest_Mode)(0), // 0: google.datastore.v1beta3.CommitRequest.Mode |
| (ReadOptions_ReadConsistency)(0), // 1: google.datastore.v1beta3.ReadOptions.ReadConsistency |
| (*LookupRequest)(nil), // 2: google.datastore.v1beta3.LookupRequest |
| (*LookupResponse)(nil), // 3: google.datastore.v1beta3.LookupResponse |
| (*RunQueryRequest)(nil), // 4: google.datastore.v1beta3.RunQueryRequest |
| (*RunQueryResponse)(nil), // 5: google.datastore.v1beta3.RunQueryResponse |
| (*BeginTransactionRequest)(nil), // 6: google.datastore.v1beta3.BeginTransactionRequest |
| (*BeginTransactionResponse)(nil), // 7: google.datastore.v1beta3.BeginTransactionResponse |
| (*RollbackRequest)(nil), // 8: google.datastore.v1beta3.RollbackRequest |
| (*RollbackResponse)(nil), // 9: google.datastore.v1beta3.RollbackResponse |
| (*CommitRequest)(nil), // 10: google.datastore.v1beta3.CommitRequest |
| (*CommitResponse)(nil), // 11: google.datastore.v1beta3.CommitResponse |
| (*AllocateIdsRequest)(nil), // 12: google.datastore.v1beta3.AllocateIdsRequest |
| (*AllocateIdsResponse)(nil), // 13: google.datastore.v1beta3.AllocateIdsResponse |
| (*ReserveIdsRequest)(nil), // 14: google.datastore.v1beta3.ReserveIdsRequest |
| (*ReserveIdsResponse)(nil), // 15: google.datastore.v1beta3.ReserveIdsResponse |
| (*Mutation)(nil), // 16: google.datastore.v1beta3.Mutation |
| (*MutationResult)(nil), // 17: google.datastore.v1beta3.MutationResult |
| (*ReadOptions)(nil), // 18: google.datastore.v1beta3.ReadOptions |
| (*TransactionOptions)(nil), // 19: google.datastore.v1beta3.TransactionOptions |
| (*TransactionOptions_ReadWrite)(nil), // 20: google.datastore.v1beta3.TransactionOptions.ReadWrite |
| (*TransactionOptions_ReadOnly)(nil), // 21: google.datastore.v1beta3.TransactionOptions.ReadOnly |
| (*Key)(nil), // 22: google.datastore.v1beta3.Key |
| (*EntityResult)(nil), // 23: google.datastore.v1beta3.EntityResult |
| (*PartitionId)(nil), // 24: google.datastore.v1beta3.PartitionId |
| (*Query)(nil), // 25: google.datastore.v1beta3.Query |
| (*GqlQuery)(nil), // 26: google.datastore.v1beta3.GqlQuery |
| (*QueryResultBatch)(nil), // 27: google.datastore.v1beta3.QueryResultBatch |
| (*Entity)(nil), // 28: google.datastore.v1beta3.Entity |
| } |
| var file_google_datastore_v1beta3_datastore_proto_depIdxs = []int32{ |
| 18, // 0: google.datastore.v1beta3.LookupRequest.read_options:type_name -> google.datastore.v1beta3.ReadOptions |
| 22, // 1: google.datastore.v1beta3.LookupRequest.keys:type_name -> google.datastore.v1beta3.Key |
| 23, // 2: google.datastore.v1beta3.LookupResponse.found:type_name -> google.datastore.v1beta3.EntityResult |
| 23, // 3: google.datastore.v1beta3.LookupResponse.missing:type_name -> google.datastore.v1beta3.EntityResult |
| 22, // 4: google.datastore.v1beta3.LookupResponse.deferred:type_name -> google.datastore.v1beta3.Key |
| 24, // 5: google.datastore.v1beta3.RunQueryRequest.partition_id:type_name -> google.datastore.v1beta3.PartitionId |
| 18, // 6: google.datastore.v1beta3.RunQueryRequest.read_options:type_name -> google.datastore.v1beta3.ReadOptions |
| 25, // 7: google.datastore.v1beta3.RunQueryRequest.query:type_name -> google.datastore.v1beta3.Query |
| 26, // 8: google.datastore.v1beta3.RunQueryRequest.gql_query:type_name -> google.datastore.v1beta3.GqlQuery |
| 27, // 9: google.datastore.v1beta3.RunQueryResponse.batch:type_name -> google.datastore.v1beta3.QueryResultBatch |
| 25, // 10: google.datastore.v1beta3.RunQueryResponse.query:type_name -> google.datastore.v1beta3.Query |
| 19, // 11: google.datastore.v1beta3.BeginTransactionRequest.transaction_options:type_name -> google.datastore.v1beta3.TransactionOptions |
| 0, // 12: google.datastore.v1beta3.CommitRequest.mode:type_name -> google.datastore.v1beta3.CommitRequest.Mode |
| 16, // 13: google.datastore.v1beta3.CommitRequest.mutations:type_name -> google.datastore.v1beta3.Mutation |
| 17, // 14: google.datastore.v1beta3.CommitResponse.mutation_results:type_name -> google.datastore.v1beta3.MutationResult |
| 22, // 15: google.datastore.v1beta3.AllocateIdsRequest.keys:type_name -> google.datastore.v1beta3.Key |
| 22, // 16: google.datastore.v1beta3.AllocateIdsResponse.keys:type_name -> google.datastore.v1beta3.Key |
| 22, // 17: google.datastore.v1beta3.ReserveIdsRequest.keys:type_name -> google.datastore.v1beta3.Key |
| 28, // 18: google.datastore.v1beta3.Mutation.insert:type_name -> google.datastore.v1beta3.Entity |
| 28, // 19: google.datastore.v1beta3.Mutation.update:type_name -> google.datastore.v1beta3.Entity |
| 28, // 20: google.datastore.v1beta3.Mutation.upsert:type_name -> google.datastore.v1beta3.Entity |
| 22, // 21: google.datastore.v1beta3.Mutation.delete:type_name -> google.datastore.v1beta3.Key |
| 22, // 22: google.datastore.v1beta3.MutationResult.key:type_name -> google.datastore.v1beta3.Key |
| 1, // 23: google.datastore.v1beta3.ReadOptions.read_consistency:type_name -> google.datastore.v1beta3.ReadOptions.ReadConsistency |
| 20, // 24: google.datastore.v1beta3.TransactionOptions.read_write:type_name -> google.datastore.v1beta3.TransactionOptions.ReadWrite |
| 21, // 25: google.datastore.v1beta3.TransactionOptions.read_only:type_name -> google.datastore.v1beta3.TransactionOptions.ReadOnly |
| 2, // 26: google.datastore.v1beta3.Datastore.Lookup:input_type -> google.datastore.v1beta3.LookupRequest |
| 4, // 27: google.datastore.v1beta3.Datastore.RunQuery:input_type -> google.datastore.v1beta3.RunQueryRequest |
| 6, // 28: google.datastore.v1beta3.Datastore.BeginTransaction:input_type -> google.datastore.v1beta3.BeginTransactionRequest |
| 10, // 29: google.datastore.v1beta3.Datastore.Commit:input_type -> google.datastore.v1beta3.CommitRequest |
| 8, // 30: google.datastore.v1beta3.Datastore.Rollback:input_type -> google.datastore.v1beta3.RollbackRequest |
| 12, // 31: google.datastore.v1beta3.Datastore.AllocateIds:input_type -> google.datastore.v1beta3.AllocateIdsRequest |
| 14, // 32: google.datastore.v1beta3.Datastore.ReserveIds:input_type -> google.datastore.v1beta3.ReserveIdsRequest |
| 3, // 33: google.datastore.v1beta3.Datastore.Lookup:output_type -> google.datastore.v1beta3.LookupResponse |
| 5, // 34: google.datastore.v1beta3.Datastore.RunQuery:output_type -> google.datastore.v1beta3.RunQueryResponse |
| 7, // 35: google.datastore.v1beta3.Datastore.BeginTransaction:output_type -> google.datastore.v1beta3.BeginTransactionResponse |
| 11, // 36: google.datastore.v1beta3.Datastore.Commit:output_type -> google.datastore.v1beta3.CommitResponse |
| 9, // 37: google.datastore.v1beta3.Datastore.Rollback:output_type -> google.datastore.v1beta3.RollbackResponse |
| 13, // 38: google.datastore.v1beta3.Datastore.AllocateIds:output_type -> google.datastore.v1beta3.AllocateIdsResponse |
| 15, // 39: google.datastore.v1beta3.Datastore.ReserveIds:output_type -> google.datastore.v1beta3.ReserveIdsResponse |
| 33, // [33:40] is the sub-list for method output_type |
| 26, // [26:33] is the sub-list for method input_type |
| 26, // [26:26] is the sub-list for extension type_name |
| 26, // [26:26] is the sub-list for extension extendee |
| 0, // [0:26] is the sub-list for field type_name |
| } |
| |
| func init() { file_google_datastore_v1beta3_datastore_proto_init() } |
| func file_google_datastore_v1beta3_datastore_proto_init() { |
| if File_google_datastore_v1beta3_datastore_proto != nil { |
| return |
| } |
| file_google_datastore_v1beta3_entity_proto_init() |
| file_google_datastore_v1beta3_query_proto_init() |
| if !protoimpl.UnsafeEnabled { |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*LookupRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*LookupResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*RunQueryRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*RunQueryResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*BeginTransactionRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*BeginTransactionResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*RollbackRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*RollbackResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*CommitRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*CommitResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*AllocateIdsRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*AllocateIdsResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ReserveIdsRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ReserveIdsResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Mutation); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*MutationResult); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ReadOptions); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*TransactionOptions); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*TransactionOptions_ReadWrite); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*TransactionOptions_ReadOnly); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[2].OneofWrappers = []interface{}{ |
| (*RunQueryRequest_Query)(nil), |
| (*RunQueryRequest_GqlQuery)(nil), |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[8].OneofWrappers = []interface{}{ |
| (*CommitRequest_Transaction)(nil), |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[14].OneofWrappers = []interface{}{ |
| (*Mutation_Insert)(nil), |
| (*Mutation_Update)(nil), |
| (*Mutation_Upsert)(nil), |
| (*Mutation_Delete)(nil), |
| (*Mutation_BaseVersion)(nil), |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[16].OneofWrappers = []interface{}{ |
| (*ReadOptions_ReadConsistency_)(nil), |
| (*ReadOptions_Transaction)(nil), |
| } |
| file_google_datastore_v1beta3_datastore_proto_msgTypes[17].OneofWrappers = []interface{}{ |
| (*TransactionOptions_ReadWrite_)(nil), |
| (*TransactionOptions_ReadOnly_)(nil), |
| } |
| type x struct{} |
| out := protoimpl.TypeBuilder{ |
| File: protoimpl.DescBuilder{ |
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| RawDescriptor: file_google_datastore_v1beta3_datastore_proto_rawDesc, |
| NumEnums: 2, |
| NumMessages: 20, |
| NumExtensions: 0, |
| NumServices: 1, |
| }, |
| GoTypes: file_google_datastore_v1beta3_datastore_proto_goTypes, |
| DependencyIndexes: file_google_datastore_v1beta3_datastore_proto_depIdxs, |
| EnumInfos: file_google_datastore_v1beta3_datastore_proto_enumTypes, |
| MessageInfos: file_google_datastore_v1beta3_datastore_proto_msgTypes, |
| }.Build() |
| File_google_datastore_v1beta3_datastore_proto = out.File |
| file_google_datastore_v1beta3_datastore_proto_rawDesc = nil |
| file_google_datastore_v1beta3_datastore_proto_goTypes = nil |
| file_google_datastore_v1beta3_datastore_proto_depIdxs = nil |
| } |
| |
| // Reference imports to suppress errors if they are not otherwise used. |
| var _ context.Context |
| var _ grpc.ClientConnInterface |
| |
| // This is a compile-time assertion to ensure that this generated file |
| // is compatible with the grpc package it is being compiled against. |
| const _ = grpc.SupportPackageIsVersion6 |
| |
| // DatastoreClient is the client API for Datastore service. |
| // |
| // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. |
| type DatastoreClient interface { |
| // Looks up entities by key. |
| Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error) |
| // Queries for entities. |
| RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (*RunQueryResponse, error) |
| // Begins a new transaction. |
| BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error) |
| // Commits a transaction, optionally creating, deleting or modifying some |
| // entities. |
| Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error) |
| // Rolls back a transaction. |
| Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error) |
| // Allocates IDs for the given keys, which is useful for referencing an entity |
| // before it is inserted. |
| AllocateIds(ctx context.Context, in *AllocateIdsRequest, opts ...grpc.CallOption) (*AllocateIdsResponse, error) |
| // Prevents the supplied keys' IDs from being auto-allocated by Cloud |
| // Datastore. |
| ReserveIds(ctx context.Context, in *ReserveIdsRequest, opts ...grpc.CallOption) (*ReserveIdsResponse, error) |
| } |
| |
| type datastoreClient struct { |
| cc grpc.ClientConnInterface |
| } |
| |
| func NewDatastoreClient(cc grpc.ClientConnInterface) DatastoreClient { |
| return &datastoreClient{cc} |
| } |
| |
| func (c *datastoreClient) Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error) { |
| out := new(LookupResponse) |
| err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/Lookup", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *datastoreClient) RunQuery(ctx context.Context, in *RunQueryRequest, opts ...grpc.CallOption) (*RunQueryResponse, error) { |
| out := new(RunQueryResponse) |
| err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/RunQuery", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *datastoreClient) BeginTransaction(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*BeginTransactionResponse, error) { |
| out := new(BeginTransactionResponse) |
| err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/BeginTransaction", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *datastoreClient) Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error) { |
| out := new(CommitResponse) |
| err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/Commit", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *datastoreClient) Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error) { |
| out := new(RollbackResponse) |
| err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/Rollback", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *datastoreClient) AllocateIds(ctx context.Context, in *AllocateIdsRequest, opts ...grpc.CallOption) (*AllocateIdsResponse, error) { |
| out := new(AllocateIdsResponse) |
| err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/AllocateIds", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *datastoreClient) ReserveIds(ctx context.Context, in *ReserveIdsRequest, opts ...grpc.CallOption) (*ReserveIdsResponse, error) { |
| out := new(ReserveIdsResponse) |
| err := c.cc.Invoke(ctx, "/google.datastore.v1beta3.Datastore/ReserveIds", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| // DatastoreServer is the server API for Datastore service. |
| type DatastoreServer interface { |
| // Looks up entities by key. |
| Lookup(context.Context, *LookupRequest) (*LookupResponse, error) |
| // Queries for entities. |
| RunQuery(context.Context, *RunQueryRequest) (*RunQueryResponse, error) |
| // Begins a new transaction. |
| BeginTransaction(context.Context, *BeginTransactionRequest) (*BeginTransactionResponse, error) |
| // Commits a transaction, optionally creating, deleting or modifying some |
| // entities. |
| Commit(context.Context, *CommitRequest) (*CommitResponse, error) |
| // Rolls back a transaction. |
| Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error) |
| // Allocates IDs for the given keys, which is useful for referencing an entity |
| // before it is inserted. |
| AllocateIds(context.Context, *AllocateIdsRequest) (*AllocateIdsResponse, error) |
| // Prevents the supplied keys' IDs from being auto-allocated by Cloud |
| // Datastore. |
| ReserveIds(context.Context, *ReserveIdsRequest) (*ReserveIdsResponse, error) |
| } |
| |
| // UnimplementedDatastoreServer can be embedded to have forward compatible implementations. |
| type UnimplementedDatastoreServer struct { |
| } |
| |
| func (*UnimplementedDatastoreServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method Lookup not implemented") |
| } |
| func (*UnimplementedDatastoreServer) RunQuery(context.Context, *RunQueryRequest) (*RunQueryResponse, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method RunQuery not implemented") |
| } |
| func (*UnimplementedDatastoreServer) BeginTransaction(context.Context, *BeginTransactionRequest) (*BeginTransactionResponse, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method BeginTransaction not implemented") |
| } |
| func (*UnimplementedDatastoreServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method Commit not implemented") |
| } |
| func (*UnimplementedDatastoreServer) Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method Rollback not implemented") |
| } |
| func (*UnimplementedDatastoreServer) AllocateIds(context.Context, *AllocateIdsRequest) (*AllocateIdsResponse, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method AllocateIds not implemented") |
| } |
| func (*UnimplementedDatastoreServer) ReserveIds(context.Context, *ReserveIdsRequest) (*ReserveIdsResponse, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method ReserveIds not implemented") |
| } |
| |
| func RegisterDatastoreServer(s *grpc.Server, srv DatastoreServer) { |
| s.RegisterService(&_Datastore_serviceDesc, srv) |
| } |
| |
| func _Datastore_Lookup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(LookupRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(DatastoreServer).Lookup(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/google.datastore.v1beta3.Datastore/Lookup", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(DatastoreServer).Lookup(ctx, req.(*LookupRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Datastore_RunQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(RunQueryRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(DatastoreServer).RunQuery(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/google.datastore.v1beta3.Datastore/RunQuery", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(DatastoreServer).RunQuery(ctx, req.(*RunQueryRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Datastore_BeginTransaction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(BeginTransactionRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(DatastoreServer).BeginTransaction(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/google.datastore.v1beta3.Datastore/BeginTransaction", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(DatastoreServer).BeginTransaction(ctx, req.(*BeginTransactionRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Datastore_Commit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(CommitRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(DatastoreServer).Commit(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/google.datastore.v1beta3.Datastore/Commit", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(DatastoreServer).Commit(ctx, req.(*CommitRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Datastore_Rollback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(RollbackRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(DatastoreServer).Rollback(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/google.datastore.v1beta3.Datastore/Rollback", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(DatastoreServer).Rollback(ctx, req.(*RollbackRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Datastore_AllocateIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(AllocateIdsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(DatastoreServer).AllocateIds(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/google.datastore.v1beta3.Datastore/AllocateIds", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(DatastoreServer).AllocateIds(ctx, req.(*AllocateIdsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Datastore_ReserveIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ReserveIdsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(DatastoreServer).ReserveIds(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/google.datastore.v1beta3.Datastore/ReserveIds", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(DatastoreServer).ReserveIds(ctx, req.(*ReserveIdsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| var _Datastore_serviceDesc = grpc.ServiceDesc{ |
| ServiceName: "google.datastore.v1beta3.Datastore", |
| HandlerType: (*DatastoreServer)(nil), |
| Methods: []grpc.MethodDesc{ |
| { |
| MethodName: "Lookup", |
| Handler: _Datastore_Lookup_Handler, |
| }, |
| { |
| MethodName: "RunQuery", |
| Handler: _Datastore_RunQuery_Handler, |
| }, |
| { |
| MethodName: "BeginTransaction", |
| Handler: _Datastore_BeginTransaction_Handler, |
| }, |
| { |
| MethodName: "Commit", |
| Handler: _Datastore_Commit_Handler, |
| }, |
| { |
| MethodName: "Rollback", |
| Handler: _Datastore_Rollback_Handler, |
| }, |
| { |
| MethodName: "AllocateIds", |
| Handler: _Datastore_AllocateIds_Handler, |
| }, |
| { |
| MethodName: "ReserveIds", |
| Handler: _Datastore_ReserveIds_Handler, |
| }, |
| }, |
| Streams: []grpc.StreamDesc{}, |
| Metadata: "google/datastore/v1beta3/datastore.proto", |
| } |