blob: 61665912d53068020729b8dae36032dd1444dde4 [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: google/datastore/v1/datastore.proto
package datastore // import "google.golang.org/genproto/googleapis/datastore/v1"
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import _ "google.golang.org/genproto/googleapis/api/annotations"
import (
context "golang.org/x/net/context"
grpc "google.golang.org/grpc"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
// 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
)
var CommitRequest_Mode_name = map[int32]string{
0: "MODE_UNSPECIFIED",
1: "TRANSACTIONAL",
2: "NON_TRANSACTIONAL",
}
var CommitRequest_Mode_value = map[string]int32{
"MODE_UNSPECIFIED": 0,
"TRANSACTIONAL": 1,
"NON_TRANSACTIONAL": 2,
}
func (x CommitRequest_Mode) String() string {
return proto.EnumName(CommitRequest_Mode_name, int32(x))
}
func (CommitRequest_Mode) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []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
)
var ReadOptions_ReadConsistency_name = map[int32]string{
0: "READ_CONSISTENCY_UNSPECIFIED",
1: "STRONG",
2: "EVENTUAL",
}
var ReadOptions_ReadConsistency_value = map[string]int32{
"READ_CONSISTENCY_UNSPECIFIED": 0,
"STRONG": 1,
"EVENTUAL": 2,
}
func (x ReadOptions_ReadConsistency) String() string {
return proto.EnumName(ReadOptions_ReadConsistency_name, int32(x))
}
func (ReadOptions_ReadConsistency) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{16, 0}
}
// The request for [Datastore.Lookup][google.datastore.v1.Datastore.Lookup].
type LookupRequest struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *LookupRequest) Reset() { *m = LookupRequest{} }
func (m *LookupRequest) String() string { return proto.CompactTextString(m) }
func (*LookupRequest) ProtoMessage() {}
func (*LookupRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{0}
}
func (m *LookupRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_LookupRequest.Unmarshal(m, b)
}
func (m *LookupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_LookupRequest.Marshal(b, m, deterministic)
}
func (dst *LookupRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_LookupRequest.Merge(dst, src)
}
func (m *LookupRequest) XXX_Size() int {
return xxx_messageInfo_LookupRequest.Size(m)
}
func (m *LookupRequest) XXX_DiscardUnknown() {
xxx_messageInfo_LookupRequest.DiscardUnknown(m)
}
var xxx_messageInfo_LookupRequest proto.InternalMessageInfo
func (m *LookupRequest) GetProjectId() string {
if m != nil {
return m.ProjectId
}
return ""
}
func (m *LookupRequest) GetReadOptions() *ReadOptions {
if m != nil {
return m.ReadOptions
}
return nil
}
func (m *LookupRequest) GetKeys() []*Key {
if m != nil {
return m.Keys
}
return nil
}
// The response for [Datastore.Lookup][google.datastore.v1.Datastore.Lookup].
type LookupResponse struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *LookupResponse) Reset() { *m = LookupResponse{} }
func (m *LookupResponse) String() string { return proto.CompactTextString(m) }
func (*LookupResponse) ProtoMessage() {}
func (*LookupResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{1}
}
func (m *LookupResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_LookupResponse.Unmarshal(m, b)
}
func (m *LookupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_LookupResponse.Marshal(b, m, deterministic)
}
func (dst *LookupResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_LookupResponse.Merge(dst, src)
}
func (m *LookupResponse) XXX_Size() int {
return xxx_messageInfo_LookupResponse.Size(m)
}
func (m *LookupResponse) XXX_DiscardUnknown() {
xxx_messageInfo_LookupResponse.DiscardUnknown(m)
}
var xxx_messageInfo_LookupResponse proto.InternalMessageInfo
func (m *LookupResponse) GetFound() []*EntityResult {
if m != nil {
return m.Found
}
return nil
}
func (m *LookupResponse) GetMissing() []*EntityResult {
if m != nil {
return m.Missing
}
return nil
}
func (m *LookupResponse) GetDeferred() []*Key {
if m != nil {
return m.Deferred
}
return nil
}
// The request for [Datastore.RunQuery][google.datastore.v1.Datastore.RunQuery].
type RunQueryRequest struct {
// 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 valid to be assigned to QueryType:
// *RunQueryRequest_Query
// *RunQueryRequest_GqlQuery
QueryType isRunQueryRequest_QueryType `protobuf_oneof:"query_type"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RunQueryRequest) Reset() { *m = RunQueryRequest{} }
func (m *RunQueryRequest) String() string { return proto.CompactTextString(m) }
func (*RunQueryRequest) ProtoMessage() {}
func (*RunQueryRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{2}
}
func (m *RunQueryRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RunQueryRequest.Unmarshal(m, b)
}
func (m *RunQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RunQueryRequest.Marshal(b, m, deterministic)
}
func (dst *RunQueryRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_RunQueryRequest.Merge(dst, src)
}
func (m *RunQueryRequest) XXX_Size() int {
return xxx_messageInfo_RunQueryRequest.Size(m)
}
func (m *RunQueryRequest) XXX_DiscardUnknown() {
xxx_messageInfo_RunQueryRequest.DiscardUnknown(m)
}
var xxx_messageInfo_RunQueryRequest proto.InternalMessageInfo
func (m *RunQueryRequest) GetProjectId() string {
if m != nil {
return m.ProjectId
}
return ""
}
func (m *RunQueryRequest) GetPartitionId() *PartitionId {
if m != nil {
return m.PartitionId
}
return nil
}
func (m *RunQueryRequest) GetReadOptions() *ReadOptions {
if m != nil {
return m.ReadOptions
}
return nil
}
type isRunQueryRequest_QueryType interface {
isRunQueryRequest_QueryType()
}
type RunQueryRequest_Query struct {
Query *Query `protobuf:"bytes,3,opt,name=query,proto3,oneof"`
}
type RunQueryRequest_GqlQuery struct {
GqlQuery *GqlQuery `protobuf:"bytes,7,opt,name=gql_query,json=gqlQuery,proto3,oneof"`
}
func (*RunQueryRequest_Query) isRunQueryRequest_QueryType() {}
func (*RunQueryRequest_GqlQuery) isRunQueryRequest_QueryType() {}
func (m *RunQueryRequest) GetQueryType() isRunQueryRequest_QueryType {
if m != nil {
return m.QueryType
}
return nil
}
func (m *RunQueryRequest) GetQuery() *Query {
if x, ok := m.GetQueryType().(*RunQueryRequest_Query); ok {
return x.Query
}
return nil
}
func (m *RunQueryRequest) GetGqlQuery() *GqlQuery {
if x, ok := m.GetQueryType().(*RunQueryRequest_GqlQuery); ok {
return x.GqlQuery
}
return nil
}
// XXX_OneofFuncs is for the internal use of the proto package.
func (*RunQueryRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) {
return _RunQueryRequest_OneofMarshaler, _RunQueryRequest_OneofUnmarshaler, _RunQueryRequest_OneofSizer, []interface{}{
(*RunQueryRequest_Query)(nil),
(*RunQueryRequest_GqlQuery)(nil),
}
}
func _RunQueryRequest_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
m := msg.(*RunQueryRequest)
// query_type
switch x := m.QueryType.(type) {
case *RunQueryRequest_Query:
b.EncodeVarint(3<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.Query); err != nil {
return err
}
case *RunQueryRequest_GqlQuery:
b.EncodeVarint(7<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.GqlQuery); err != nil {
return err
}
case nil:
default:
return fmt.Errorf("RunQueryRequest.QueryType has unexpected type %T", x)
}
return nil
}
func _RunQueryRequest_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
m := msg.(*RunQueryRequest)
switch tag {
case 3: // query_type.query
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(Query)
err := b.DecodeMessage(msg)
m.QueryType = &RunQueryRequest_Query{msg}
return true, err
case 7: // query_type.gql_query
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(GqlQuery)
err := b.DecodeMessage(msg)
m.QueryType = &RunQueryRequest_GqlQuery{msg}
return true, err
default:
return false, nil
}
}
func _RunQueryRequest_OneofSizer(msg proto.Message) (n int) {
m := msg.(*RunQueryRequest)
// query_type
switch x := m.QueryType.(type) {
case *RunQueryRequest_Query:
s := proto.Size(x.Query)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case *RunQueryRequest_GqlQuery:
s := proto.Size(x.GqlQuery)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case nil:
default:
panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
}
return n
}
// The response for [Datastore.RunQuery][google.datastore.v1.Datastore.RunQuery].
type RunQueryResponse struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RunQueryResponse) Reset() { *m = RunQueryResponse{} }
func (m *RunQueryResponse) String() string { return proto.CompactTextString(m) }
func (*RunQueryResponse) ProtoMessage() {}
func (*RunQueryResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{3}
}
func (m *RunQueryResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RunQueryResponse.Unmarshal(m, b)
}
func (m *RunQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RunQueryResponse.Marshal(b, m, deterministic)
}
func (dst *RunQueryResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_RunQueryResponse.Merge(dst, src)
}
func (m *RunQueryResponse) XXX_Size() int {
return xxx_messageInfo_RunQueryResponse.Size(m)
}
func (m *RunQueryResponse) XXX_DiscardUnknown() {
xxx_messageInfo_RunQueryResponse.DiscardUnknown(m)
}
var xxx_messageInfo_RunQueryResponse proto.InternalMessageInfo
func (m *RunQueryResponse) GetBatch() *QueryResultBatch {
if m != nil {
return m.Batch
}
return nil
}
func (m *RunQueryResponse) GetQuery() *Query {
if m != nil {
return m.Query
}
return nil
}
// The request for [Datastore.BeginTransaction][google.datastore.v1.Datastore.BeginTransaction].
type BeginTransactionRequest struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BeginTransactionRequest) Reset() { *m = BeginTransactionRequest{} }
func (m *BeginTransactionRequest) String() string { return proto.CompactTextString(m) }
func (*BeginTransactionRequest) ProtoMessage() {}
func (*BeginTransactionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{4}
}
func (m *BeginTransactionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BeginTransactionRequest.Unmarshal(m, b)
}
func (m *BeginTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BeginTransactionRequest.Marshal(b, m, deterministic)
}
func (dst *BeginTransactionRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_BeginTransactionRequest.Merge(dst, src)
}
func (m *BeginTransactionRequest) XXX_Size() int {
return xxx_messageInfo_BeginTransactionRequest.Size(m)
}
func (m *BeginTransactionRequest) XXX_DiscardUnknown() {
xxx_messageInfo_BeginTransactionRequest.DiscardUnknown(m)
}
var xxx_messageInfo_BeginTransactionRequest proto.InternalMessageInfo
func (m *BeginTransactionRequest) GetProjectId() string {
if m != nil {
return m.ProjectId
}
return ""
}
func (m *BeginTransactionRequest) GetTransactionOptions() *TransactionOptions {
if m != nil {
return m.TransactionOptions
}
return nil
}
// The response for [Datastore.BeginTransaction][google.datastore.v1.Datastore.BeginTransaction].
type BeginTransactionResponse struct {
// The transaction identifier (always present).
Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BeginTransactionResponse) Reset() { *m = BeginTransactionResponse{} }
func (m *BeginTransactionResponse) String() string { return proto.CompactTextString(m) }
func (*BeginTransactionResponse) ProtoMessage() {}
func (*BeginTransactionResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{5}
}
func (m *BeginTransactionResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BeginTransactionResponse.Unmarshal(m, b)
}
func (m *BeginTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BeginTransactionResponse.Marshal(b, m, deterministic)
}
func (dst *BeginTransactionResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_BeginTransactionResponse.Merge(dst, src)
}
func (m *BeginTransactionResponse) XXX_Size() int {
return xxx_messageInfo_BeginTransactionResponse.Size(m)
}
func (m *BeginTransactionResponse) XXX_DiscardUnknown() {
xxx_messageInfo_BeginTransactionResponse.DiscardUnknown(m)
}
var xxx_messageInfo_BeginTransactionResponse proto.InternalMessageInfo
func (m *BeginTransactionResponse) GetTransaction() []byte {
if m != nil {
return m.Transaction
}
return nil
}
// The request for [Datastore.Rollback][google.datastore.v1.Datastore.Rollback].
type RollbackRequest struct {
// 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.v1.Datastore.BeginTransaction].
Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RollbackRequest) Reset() { *m = RollbackRequest{} }
func (m *RollbackRequest) String() string { return proto.CompactTextString(m) }
func (*RollbackRequest) ProtoMessage() {}
func (*RollbackRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{6}
}
func (m *RollbackRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RollbackRequest.Unmarshal(m, b)
}
func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RollbackRequest.Marshal(b, m, deterministic)
}
func (dst *RollbackRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_RollbackRequest.Merge(dst, src)
}
func (m *RollbackRequest) XXX_Size() int {
return xxx_messageInfo_RollbackRequest.Size(m)
}
func (m *RollbackRequest) XXX_DiscardUnknown() {
xxx_messageInfo_RollbackRequest.DiscardUnknown(m)
}
var xxx_messageInfo_RollbackRequest proto.InternalMessageInfo
func (m *RollbackRequest) GetProjectId() string {
if m != nil {
return m.ProjectId
}
return ""
}
func (m *RollbackRequest) GetTransaction() []byte {
if m != nil {
return m.Transaction
}
return nil
}
// The response for [Datastore.Rollback][google.datastore.v1.Datastore.Rollback].
// (an empty message).
type RollbackResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RollbackResponse) Reset() { *m = RollbackResponse{} }
func (m *RollbackResponse) String() string { return proto.CompactTextString(m) }
func (*RollbackResponse) ProtoMessage() {}
func (*RollbackResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{7}
}
func (m *RollbackResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RollbackResponse.Unmarshal(m, b)
}
func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RollbackResponse.Marshal(b, m, deterministic)
}
func (dst *RollbackResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_RollbackResponse.Merge(dst, src)
}
func (m *RollbackResponse) XXX_Size() int {
return xxx_messageInfo_RollbackResponse.Size(m)
}
func (m *RollbackResponse) XXX_DiscardUnknown() {
xxx_messageInfo_RollbackResponse.DiscardUnknown(m)
}
var xxx_messageInfo_RollbackResponse proto.InternalMessageInfo
// The request for [Datastore.Commit][google.datastore.v1.Datastore.Commit].
type CommitRequest struct {
// 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.v1.CommitRequest_Mode" json:"mode,omitempty"`
// Must be set when mode is `TRANSACTIONAL`.
//
// Types that are valid to be assigned 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CommitRequest) Reset() { *m = CommitRequest{} }
func (m *CommitRequest) String() string { return proto.CompactTextString(m) }
func (*CommitRequest) ProtoMessage() {}
func (*CommitRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{8}
}
func (m *CommitRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CommitRequest.Unmarshal(m, b)
}
func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CommitRequest.Marshal(b, m, deterministic)
}
func (dst *CommitRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_CommitRequest.Merge(dst, src)
}
func (m *CommitRequest) XXX_Size() int {
return xxx_messageInfo_CommitRequest.Size(m)
}
func (m *CommitRequest) XXX_DiscardUnknown() {
xxx_messageInfo_CommitRequest.DiscardUnknown(m)
}
var xxx_messageInfo_CommitRequest proto.InternalMessageInfo
func (m *CommitRequest) GetProjectId() string {
if m != nil {
return m.ProjectId
}
return ""
}
func (m *CommitRequest) GetMode() CommitRequest_Mode {
if m != nil {
return m.Mode
}
return CommitRequest_MODE_UNSPECIFIED
}
type isCommitRequest_TransactionSelector interface {
isCommitRequest_TransactionSelector()
}
type CommitRequest_Transaction struct {
Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3,oneof"`
}
func (*CommitRequest_Transaction) isCommitRequest_TransactionSelector() {}
func (m *CommitRequest) GetTransactionSelector() isCommitRequest_TransactionSelector {
if m != nil {
return m.TransactionSelector
}
return nil
}
func (m *CommitRequest) GetTransaction() []byte {
if x, ok := m.GetTransactionSelector().(*CommitRequest_Transaction); ok {
return x.Transaction
}
return nil
}
func (m *CommitRequest) GetMutations() []*Mutation {
if m != nil {
return m.Mutations
}
return nil
}
// XXX_OneofFuncs is for the internal use of the proto package.
func (*CommitRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) {
return _CommitRequest_OneofMarshaler, _CommitRequest_OneofUnmarshaler, _CommitRequest_OneofSizer, []interface{}{
(*CommitRequest_Transaction)(nil),
}
}
func _CommitRequest_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
m := msg.(*CommitRequest)
// transaction_selector
switch x := m.TransactionSelector.(type) {
case *CommitRequest_Transaction:
b.EncodeVarint(1<<3 | proto.WireBytes)
b.EncodeRawBytes(x.Transaction)
case nil:
default:
return fmt.Errorf("CommitRequest.TransactionSelector has unexpected type %T", x)
}
return nil
}
func _CommitRequest_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
m := msg.(*CommitRequest)
switch tag {
case 1: // transaction_selector.transaction
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
x, err := b.DecodeRawBytes(true)
m.TransactionSelector = &CommitRequest_Transaction{x}
return true, err
default:
return false, nil
}
}
func _CommitRequest_OneofSizer(msg proto.Message) (n int) {
m := msg.(*CommitRequest)
// transaction_selector
switch x := m.TransactionSelector.(type) {
case *CommitRequest_Transaction:
n += 1 // tag and wire
n += proto.SizeVarint(uint64(len(x.Transaction)))
n += len(x.Transaction)
case nil:
default:
panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
}
return n
}
// The response for [Datastore.Commit][google.datastore.v1.Datastore.Commit].
type CommitResponse struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CommitResponse) Reset() { *m = CommitResponse{} }
func (m *CommitResponse) String() string { return proto.CompactTextString(m) }
func (*CommitResponse) ProtoMessage() {}
func (*CommitResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{9}
}
func (m *CommitResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CommitResponse.Unmarshal(m, b)
}
func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CommitResponse.Marshal(b, m, deterministic)
}
func (dst *CommitResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_CommitResponse.Merge(dst, src)
}
func (m *CommitResponse) XXX_Size() int {
return xxx_messageInfo_CommitResponse.Size(m)
}
func (m *CommitResponse) XXX_DiscardUnknown() {
xxx_messageInfo_CommitResponse.DiscardUnknown(m)
}
var xxx_messageInfo_CommitResponse proto.InternalMessageInfo
func (m *CommitResponse) GetMutationResults() []*MutationResult {
if m != nil {
return m.MutationResults
}
return nil
}
func (m *CommitResponse) GetIndexUpdates() int32 {
if m != nil {
return m.IndexUpdates
}
return 0
}
// The request for [Datastore.AllocateIds][google.datastore.v1.Datastore.AllocateIds].
type AllocateIdsRequest struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AllocateIdsRequest) Reset() { *m = AllocateIdsRequest{} }
func (m *AllocateIdsRequest) String() string { return proto.CompactTextString(m) }
func (*AllocateIdsRequest) ProtoMessage() {}
func (*AllocateIdsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{10}
}
func (m *AllocateIdsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AllocateIdsRequest.Unmarshal(m, b)
}
func (m *AllocateIdsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AllocateIdsRequest.Marshal(b, m, deterministic)
}
func (dst *AllocateIdsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_AllocateIdsRequest.Merge(dst, src)
}
func (m *AllocateIdsRequest) XXX_Size() int {
return xxx_messageInfo_AllocateIdsRequest.Size(m)
}
func (m *AllocateIdsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_AllocateIdsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_AllocateIdsRequest proto.InternalMessageInfo
func (m *AllocateIdsRequest) GetProjectId() string {
if m != nil {
return m.ProjectId
}
return ""
}
func (m *AllocateIdsRequest) GetKeys() []*Key {
if m != nil {
return m.Keys
}
return nil
}
// The response for [Datastore.AllocateIds][google.datastore.v1.Datastore.AllocateIds].
type AllocateIdsResponse struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AllocateIdsResponse) Reset() { *m = AllocateIdsResponse{} }
func (m *AllocateIdsResponse) String() string { return proto.CompactTextString(m) }
func (*AllocateIdsResponse) ProtoMessage() {}
func (*AllocateIdsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{11}
}
func (m *AllocateIdsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AllocateIdsResponse.Unmarshal(m, b)
}
func (m *AllocateIdsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AllocateIdsResponse.Marshal(b, m, deterministic)
}
func (dst *AllocateIdsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_AllocateIdsResponse.Merge(dst, src)
}
func (m *AllocateIdsResponse) XXX_Size() int {
return xxx_messageInfo_AllocateIdsResponse.Size(m)
}
func (m *AllocateIdsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_AllocateIdsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_AllocateIdsResponse proto.InternalMessageInfo
func (m *AllocateIdsResponse) GetKeys() []*Key {
if m != nil {
return m.Keys
}
return nil
}
// The request for [Datastore.ReserveIds][google.datastore.v1.Datastore.ReserveIds].
type ReserveIdsRequest struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ReserveIdsRequest) Reset() { *m = ReserveIdsRequest{} }
func (m *ReserveIdsRequest) String() string { return proto.CompactTextString(m) }
func (*ReserveIdsRequest) ProtoMessage() {}
func (*ReserveIdsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{12}
}
func (m *ReserveIdsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ReserveIdsRequest.Unmarshal(m, b)
}
func (m *ReserveIdsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ReserveIdsRequest.Marshal(b, m, deterministic)
}
func (dst *ReserveIdsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ReserveIdsRequest.Merge(dst, src)
}
func (m *ReserveIdsRequest) XXX_Size() int {
return xxx_messageInfo_ReserveIdsRequest.Size(m)
}
func (m *ReserveIdsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ReserveIdsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ReserveIdsRequest proto.InternalMessageInfo
func (m *ReserveIdsRequest) GetProjectId() string {
if m != nil {
return m.ProjectId
}
return ""
}
func (m *ReserveIdsRequest) GetDatabaseId() string {
if m != nil {
return m.DatabaseId
}
return ""
}
func (m *ReserveIdsRequest) GetKeys() []*Key {
if m != nil {
return m.Keys
}
return nil
}
// The response for [Datastore.ReserveIds][google.datastore.v1.Datastore.ReserveIds].
type ReserveIdsResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ReserveIdsResponse) Reset() { *m = ReserveIdsResponse{} }
func (m *ReserveIdsResponse) String() string { return proto.CompactTextString(m) }
func (*ReserveIdsResponse) ProtoMessage() {}
func (*ReserveIdsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{13}
}
func (m *ReserveIdsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ReserveIdsResponse.Unmarshal(m, b)
}
func (m *ReserveIdsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ReserveIdsResponse.Marshal(b, m, deterministic)
}
func (dst *ReserveIdsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ReserveIdsResponse.Merge(dst, src)
}
func (m *ReserveIdsResponse) XXX_Size() int {
return xxx_messageInfo_ReserveIdsResponse.Size(m)
}
func (m *ReserveIdsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ReserveIdsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ReserveIdsResponse proto.InternalMessageInfo
// A mutation to apply to an entity.
type Mutation struct {
// 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 valid to be assigned 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 valid to be assigned to ConflictDetectionStrategy:
// *Mutation_BaseVersion
ConflictDetectionStrategy isMutation_ConflictDetectionStrategy `protobuf_oneof:"conflict_detection_strategy"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Mutation) Reset() { *m = Mutation{} }
func (m *Mutation) String() string { return proto.CompactTextString(m) }
func (*Mutation) ProtoMessage() {}
func (*Mutation) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{14}
}
func (m *Mutation) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Mutation.Unmarshal(m, b)
}
func (m *Mutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Mutation.Marshal(b, m, deterministic)
}
func (dst *Mutation) XXX_Merge(src proto.Message) {
xxx_messageInfo_Mutation.Merge(dst, src)
}
func (m *Mutation) XXX_Size() int {
return xxx_messageInfo_Mutation.Size(m)
}
func (m *Mutation) XXX_DiscardUnknown() {
xxx_messageInfo_Mutation.DiscardUnknown(m)
}
var xxx_messageInfo_Mutation proto.InternalMessageInfo
type isMutation_Operation interface {
isMutation_Operation()
}
type Mutation_Insert struct {
Insert *Entity `protobuf:"bytes,4,opt,name=insert,proto3,oneof"`
}
type Mutation_Update struct {
Update *Entity `protobuf:"bytes,5,opt,name=update,proto3,oneof"`
}
type Mutation_Upsert struct {
Upsert *Entity `protobuf:"bytes,6,opt,name=upsert,proto3,oneof"`
}
type Mutation_Delete struct {
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() {}
func (m *Mutation) GetOperation() isMutation_Operation {
if m != nil {
return m.Operation
}
return nil
}
func (m *Mutation) GetInsert() *Entity {
if x, ok := m.GetOperation().(*Mutation_Insert); ok {
return x.Insert
}
return nil
}
func (m *Mutation) GetUpdate() *Entity {
if x, ok := m.GetOperation().(*Mutation_Update); ok {
return x.Update
}
return nil
}
func (m *Mutation) GetUpsert() *Entity {
if x, ok := m.GetOperation().(*Mutation_Upsert); ok {
return x.Upsert
}
return nil
}
func (m *Mutation) GetDelete() *Key {
if x, ok := m.GetOperation().(*Mutation_Delete); ok {
return x.Delete
}
return nil
}
type isMutation_ConflictDetectionStrategy interface {
isMutation_ConflictDetectionStrategy()
}
type Mutation_BaseVersion struct {
BaseVersion int64 `protobuf:"varint,8,opt,name=base_version,json=baseVersion,proto3,oneof"`
}
func (*Mutation_BaseVersion) isMutation_ConflictDetectionStrategy() {}
func (m *Mutation) GetConflictDetectionStrategy() isMutation_ConflictDetectionStrategy {
if m != nil {
return m.ConflictDetectionStrategy
}
return nil
}
func (m *Mutation) GetBaseVersion() int64 {
if x, ok := m.GetConflictDetectionStrategy().(*Mutation_BaseVersion); ok {
return x.BaseVersion
}
return 0
}
// XXX_OneofFuncs is for the internal use of the proto package.
func (*Mutation) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) {
return _Mutation_OneofMarshaler, _Mutation_OneofUnmarshaler, _Mutation_OneofSizer, []interface{}{
(*Mutation_Insert)(nil),
(*Mutation_Update)(nil),
(*Mutation_Upsert)(nil),
(*Mutation_Delete)(nil),
(*Mutation_BaseVersion)(nil),
}
}
func _Mutation_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
m := msg.(*Mutation)
// operation
switch x := m.Operation.(type) {
case *Mutation_Insert:
b.EncodeVarint(4<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.Insert); err != nil {
return err
}
case *Mutation_Update:
b.EncodeVarint(5<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.Update); err != nil {
return err
}
case *Mutation_Upsert:
b.EncodeVarint(6<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.Upsert); err != nil {
return err
}
case *Mutation_Delete:
b.EncodeVarint(7<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.Delete); err != nil {
return err
}
case nil:
default:
return fmt.Errorf("Mutation.Operation has unexpected type %T", x)
}
// conflict_detection_strategy
switch x := m.ConflictDetectionStrategy.(type) {
case *Mutation_BaseVersion:
b.EncodeVarint(8<<3 | proto.WireVarint)
b.EncodeVarint(uint64(x.BaseVersion))
case nil:
default:
return fmt.Errorf("Mutation.ConflictDetectionStrategy has unexpected type %T", x)
}
return nil
}
func _Mutation_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
m := msg.(*Mutation)
switch tag {
case 4: // operation.insert
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(Entity)
err := b.DecodeMessage(msg)
m.Operation = &Mutation_Insert{msg}
return true, err
case 5: // operation.update
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(Entity)
err := b.DecodeMessage(msg)
m.Operation = &Mutation_Update{msg}
return true, err
case 6: // operation.upsert
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(Entity)
err := b.DecodeMessage(msg)
m.Operation = &Mutation_Upsert{msg}
return true, err
case 7: // operation.delete
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(Key)
err := b.DecodeMessage(msg)
m.Operation = &Mutation_Delete{msg}
return true, err
case 8: // conflict_detection_strategy.base_version
if wire != proto.WireVarint {
return true, proto.ErrInternalBadWireType
}
x, err := b.DecodeVarint()
m.ConflictDetectionStrategy = &Mutation_BaseVersion{int64(x)}
return true, err
default:
return false, nil
}
}
func _Mutation_OneofSizer(msg proto.Message) (n int) {
m := msg.(*Mutation)
// operation
switch x := m.Operation.(type) {
case *Mutation_Insert:
s := proto.Size(x.Insert)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case *Mutation_Update:
s := proto.Size(x.Update)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case *Mutation_Upsert:
s := proto.Size(x.Upsert)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case *Mutation_Delete:
s := proto.Size(x.Delete)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case nil:
default:
panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
}
// conflict_detection_strategy
switch x := m.ConflictDetectionStrategy.(type) {
case *Mutation_BaseVersion:
n += 1 // tag and wire
n += proto.SizeVarint(uint64(x.BaseVersion))
case nil:
default:
panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
}
return n
}
// The result of applying a mutation.
type MutationResult struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MutationResult) Reset() { *m = MutationResult{} }
func (m *MutationResult) String() string { return proto.CompactTextString(m) }
func (*MutationResult) ProtoMessage() {}
func (*MutationResult) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{15}
}
func (m *MutationResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MutationResult.Unmarshal(m, b)
}
func (m *MutationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MutationResult.Marshal(b, m, deterministic)
}
func (dst *MutationResult) XXX_Merge(src proto.Message) {
xxx_messageInfo_MutationResult.Merge(dst, src)
}
func (m *MutationResult) XXX_Size() int {
return xxx_messageInfo_MutationResult.Size(m)
}
func (m *MutationResult) XXX_DiscardUnknown() {
xxx_messageInfo_MutationResult.DiscardUnknown(m)
}
var xxx_messageInfo_MutationResult proto.InternalMessageInfo
func (m *MutationResult) GetKey() *Key {
if m != nil {
return m.Key
}
return nil
}
func (m *MutationResult) GetVersion() int64 {
if m != nil {
return m.Version
}
return 0
}
func (m *MutationResult) GetConflictDetected() bool {
if m != nil {
return m.ConflictDetected
}
return false
}
// The options shared by read requests.
type ReadOptions struct {
// If not specified, lookups and ancestor queries default to
// `read_consistency`=`STRONG`, global queries default to
// `read_consistency`=`EVENTUAL`.
//
// Types that are valid to be assigned to ConsistencyType:
// *ReadOptions_ReadConsistency_
// *ReadOptions_Transaction
ConsistencyType isReadOptions_ConsistencyType `protobuf_oneof:"consistency_type"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ReadOptions) Reset() { *m = ReadOptions{} }
func (m *ReadOptions) String() string { return proto.CompactTextString(m) }
func (*ReadOptions) ProtoMessage() {}
func (*ReadOptions) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{16}
}
func (m *ReadOptions) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ReadOptions.Unmarshal(m, b)
}
func (m *ReadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ReadOptions.Marshal(b, m, deterministic)
}
func (dst *ReadOptions) XXX_Merge(src proto.Message) {
xxx_messageInfo_ReadOptions.Merge(dst, src)
}
func (m *ReadOptions) XXX_Size() int {
return xxx_messageInfo_ReadOptions.Size(m)
}
func (m *ReadOptions) XXX_DiscardUnknown() {
xxx_messageInfo_ReadOptions.DiscardUnknown(m)
}
var xxx_messageInfo_ReadOptions proto.InternalMessageInfo
type isReadOptions_ConsistencyType interface {
isReadOptions_ConsistencyType()
}
type ReadOptions_ReadConsistency_ struct {
ReadConsistency ReadOptions_ReadConsistency `protobuf:"varint,1,opt,name=read_consistency,json=readConsistency,proto3,enum=google.datastore.v1.ReadOptions_ReadConsistency,oneof"`
}
type ReadOptions_Transaction struct {
Transaction []byte `protobuf:"bytes,2,opt,name=transaction,proto3,oneof"`
}
func (*ReadOptions_ReadConsistency_) isReadOptions_ConsistencyType() {}
func (*ReadOptions_Transaction) isReadOptions_ConsistencyType() {}
func (m *ReadOptions) GetConsistencyType() isReadOptions_ConsistencyType {
if m != nil {
return m.ConsistencyType
}
return nil
}
func (m *ReadOptions) GetReadConsistency() ReadOptions_ReadConsistency {
if x, ok := m.GetConsistencyType().(*ReadOptions_ReadConsistency_); ok {
return x.ReadConsistency
}
return ReadOptions_READ_CONSISTENCY_UNSPECIFIED
}
func (m *ReadOptions) GetTransaction() []byte {
if x, ok := m.GetConsistencyType().(*ReadOptions_Transaction); ok {
return x.Transaction
}
return nil
}
// XXX_OneofFuncs is for the internal use of the proto package.
func (*ReadOptions) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) {
return _ReadOptions_OneofMarshaler, _ReadOptions_OneofUnmarshaler, _ReadOptions_OneofSizer, []interface{}{
(*ReadOptions_ReadConsistency_)(nil),
(*ReadOptions_Transaction)(nil),
}
}
func _ReadOptions_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
m := msg.(*ReadOptions)
// consistency_type
switch x := m.ConsistencyType.(type) {
case *ReadOptions_ReadConsistency_:
b.EncodeVarint(1<<3 | proto.WireVarint)
b.EncodeVarint(uint64(x.ReadConsistency))
case *ReadOptions_Transaction:
b.EncodeVarint(2<<3 | proto.WireBytes)
b.EncodeRawBytes(x.Transaction)
case nil:
default:
return fmt.Errorf("ReadOptions.ConsistencyType has unexpected type %T", x)
}
return nil
}
func _ReadOptions_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
m := msg.(*ReadOptions)
switch tag {
case 1: // consistency_type.read_consistency
if wire != proto.WireVarint {
return true, proto.ErrInternalBadWireType
}
x, err := b.DecodeVarint()
m.ConsistencyType = &ReadOptions_ReadConsistency_{ReadOptions_ReadConsistency(x)}
return true, err
case 2: // consistency_type.transaction
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
x, err := b.DecodeRawBytes(true)
m.ConsistencyType = &ReadOptions_Transaction{x}
return true, err
default:
return false, nil
}
}
func _ReadOptions_OneofSizer(msg proto.Message) (n int) {
m := msg.(*ReadOptions)
// consistency_type
switch x := m.ConsistencyType.(type) {
case *ReadOptions_ReadConsistency_:
n += 1 // tag and wire
n += proto.SizeVarint(uint64(x.ReadConsistency))
case *ReadOptions_Transaction:
n += 1 // tag and wire
n += proto.SizeVarint(uint64(len(x.Transaction)))
n += len(x.Transaction)
case nil:
default:
panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
}
return n
}
// Options for beginning a new transaction.
//
// Transactions can be created explicitly with calls to
// [Datastore.BeginTransaction][google.datastore.v1.Datastore.BeginTransaction] or implicitly by setting
// [ReadOptions.new_transaction][google.datastore.v1.ReadOptions.new_transaction] in read requests.
type TransactionOptions struct {
// The `mode` of the transaction, indicating whether write operations are
// supported.
//
// Types that are valid to be assigned to Mode:
// *TransactionOptions_ReadWrite_
// *TransactionOptions_ReadOnly_
Mode isTransactionOptions_Mode `protobuf_oneof:"mode"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TransactionOptions) Reset() { *m = TransactionOptions{} }
func (m *TransactionOptions) String() string { return proto.CompactTextString(m) }
func (*TransactionOptions) ProtoMessage() {}
func (*TransactionOptions) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{17}
}
func (m *TransactionOptions) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TransactionOptions.Unmarshal(m, b)
}
func (m *TransactionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TransactionOptions.Marshal(b, m, deterministic)
}
func (dst *TransactionOptions) XXX_Merge(src proto.Message) {
xxx_messageInfo_TransactionOptions.Merge(dst, src)
}
func (m *TransactionOptions) XXX_Size() int {
return xxx_messageInfo_TransactionOptions.Size(m)
}
func (m *TransactionOptions) XXX_DiscardUnknown() {
xxx_messageInfo_TransactionOptions.DiscardUnknown(m)
}
var xxx_messageInfo_TransactionOptions proto.InternalMessageInfo
type isTransactionOptions_Mode interface {
isTransactionOptions_Mode()
}
type TransactionOptions_ReadWrite_ struct {
ReadWrite *TransactionOptions_ReadWrite `protobuf:"bytes,1,opt,name=read_write,json=readWrite,proto3,oneof"`
}
type TransactionOptions_ReadOnly_ struct {
ReadOnly *TransactionOptions_ReadOnly `protobuf:"bytes,2,opt,name=read_only,json=readOnly,proto3,oneof"`
}
func (*TransactionOptions_ReadWrite_) isTransactionOptions_Mode() {}
func (*TransactionOptions_ReadOnly_) isTransactionOptions_Mode() {}
func (m *TransactionOptions) GetMode() isTransactionOptions_Mode {
if m != nil {
return m.Mode
}
return nil
}
func (m *TransactionOptions) GetReadWrite() *TransactionOptions_ReadWrite {
if x, ok := m.GetMode().(*TransactionOptions_ReadWrite_); ok {
return x.ReadWrite
}
return nil
}
func (m *TransactionOptions) GetReadOnly() *TransactionOptions_ReadOnly {
if x, ok := m.GetMode().(*TransactionOptions_ReadOnly_); ok {
return x.ReadOnly
}
return nil
}
// XXX_OneofFuncs is for the internal use of the proto package.
func (*TransactionOptions) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) {
return _TransactionOptions_OneofMarshaler, _TransactionOptions_OneofUnmarshaler, _TransactionOptions_OneofSizer, []interface{}{
(*TransactionOptions_ReadWrite_)(nil),
(*TransactionOptions_ReadOnly_)(nil),
}
}
func _TransactionOptions_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
m := msg.(*TransactionOptions)
// mode
switch x := m.Mode.(type) {
case *TransactionOptions_ReadWrite_:
b.EncodeVarint(1<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.ReadWrite); err != nil {
return err
}
case *TransactionOptions_ReadOnly_:
b.EncodeVarint(2<<3 | proto.WireBytes)
if err := b.EncodeMessage(x.ReadOnly); err != nil {
return err
}
case nil:
default:
return fmt.Errorf("TransactionOptions.Mode has unexpected type %T", x)
}
return nil
}
func _TransactionOptions_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
m := msg.(*TransactionOptions)
switch tag {
case 1: // mode.read_write
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(TransactionOptions_ReadWrite)
err := b.DecodeMessage(msg)
m.Mode = &TransactionOptions_ReadWrite_{msg}
return true, err
case 2: // mode.read_only
if wire != proto.WireBytes {
return true, proto.ErrInternalBadWireType
}
msg := new(TransactionOptions_ReadOnly)
err := b.DecodeMessage(msg)
m.Mode = &TransactionOptions_ReadOnly_{msg}
return true, err
default:
return false, nil
}
}
func _TransactionOptions_OneofSizer(msg proto.Message) (n int) {
m := msg.(*TransactionOptions)
// mode
switch x := m.Mode.(type) {
case *TransactionOptions_ReadWrite_:
s := proto.Size(x.ReadWrite)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case *TransactionOptions_ReadOnly_:
s := proto.Size(x.ReadOnly)
n += 1 // tag and wire
n += proto.SizeVarint(uint64(s))
n += s
case nil:
default:
panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
}
return n
}
// Options specific to read / write transactions.
type TransactionOptions_ReadWrite struct {
// The transaction identifier of the transaction being retried.
PreviousTransaction []byte `protobuf:"bytes,1,opt,name=previous_transaction,json=previousTransaction,proto3" json:"previous_transaction,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TransactionOptions_ReadWrite) Reset() { *m = TransactionOptions_ReadWrite{} }
func (m *TransactionOptions_ReadWrite) String() string { return proto.CompactTextString(m) }
func (*TransactionOptions_ReadWrite) ProtoMessage() {}
func (*TransactionOptions_ReadWrite) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{17, 0}
}
func (m *TransactionOptions_ReadWrite) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TransactionOptions_ReadWrite.Unmarshal(m, b)
}
func (m *TransactionOptions_ReadWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TransactionOptions_ReadWrite.Marshal(b, m, deterministic)
}
func (dst *TransactionOptions_ReadWrite) XXX_Merge(src proto.Message) {
xxx_messageInfo_TransactionOptions_ReadWrite.Merge(dst, src)
}
func (m *TransactionOptions_ReadWrite) XXX_Size() int {
return xxx_messageInfo_TransactionOptions_ReadWrite.Size(m)
}
func (m *TransactionOptions_ReadWrite) XXX_DiscardUnknown() {
xxx_messageInfo_TransactionOptions_ReadWrite.DiscardUnknown(m)
}
var xxx_messageInfo_TransactionOptions_ReadWrite proto.InternalMessageInfo
func (m *TransactionOptions_ReadWrite) GetPreviousTransaction() []byte {
if m != nil {
return m.PreviousTransaction
}
return nil
}
// Options specific to read-only transactions.
type TransactionOptions_ReadOnly struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TransactionOptions_ReadOnly) Reset() { *m = TransactionOptions_ReadOnly{} }
func (m *TransactionOptions_ReadOnly) String() string { return proto.CompactTextString(m) }
func (*TransactionOptions_ReadOnly) ProtoMessage() {}
func (*TransactionOptions_ReadOnly) Descriptor() ([]byte, []int) {
return fileDescriptor_datastore_43db8ce3c69efb71, []int{17, 1}
}
func (m *TransactionOptions_ReadOnly) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TransactionOptions_ReadOnly.Unmarshal(m, b)
}
func (m *TransactionOptions_ReadOnly) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TransactionOptions_ReadOnly.Marshal(b, m, deterministic)
}
func (dst *TransactionOptions_ReadOnly) XXX_Merge(src proto.Message) {
xxx_messageInfo_TransactionOptions_ReadOnly.Merge(dst, src)
}
func (m *TransactionOptions_ReadOnly) XXX_Size() int {
return xxx_messageInfo_TransactionOptions_ReadOnly.Size(m)
}
func (m *TransactionOptions_ReadOnly) XXX_DiscardUnknown() {
xxx_messageInfo_TransactionOptions_ReadOnly.DiscardUnknown(m)
}
var xxx_messageInfo_TransactionOptions_ReadOnly proto.InternalMessageInfo
func init() {
proto.RegisterType((*LookupRequest)(nil), "google.datastore.v1.LookupRequest")
proto.RegisterType((*LookupResponse)(nil), "google.datastore.v1.LookupResponse")
proto.RegisterType((*RunQueryRequest)(nil), "google.datastore.v1.RunQueryRequest")
proto.RegisterType((*RunQueryResponse)(nil), "google.datastore.v1.RunQueryResponse")
proto.RegisterType((*BeginTransactionRequest)(nil), "google.datastore.v1.BeginTransactionRequest")
proto.RegisterType((*BeginTransactionResponse)(nil), "google.datastore.v1.BeginTransactionResponse")
proto.RegisterType((*RollbackRequest)(nil), "google.datastore.v1.RollbackRequest")
proto.RegisterType((*RollbackResponse)(nil), "google.datastore.v1.RollbackResponse")
proto.RegisterType((*CommitRequest)(nil), "google.datastore.v1.CommitRequest")
proto.RegisterType((*CommitResponse)(nil), "google.datastore.v1.CommitResponse")
proto.RegisterType((*AllocateIdsRequest)(nil), "google.datastore.v1.AllocateIdsRequest")
proto.RegisterType((*AllocateIdsResponse)(nil), "google.datastore.v1.AllocateIdsResponse")
proto.RegisterType((*ReserveIdsRequest)(nil), "google.datastore.v1.ReserveIdsRequest")
proto.RegisterType((*ReserveIdsResponse)(nil), "google.datastore.v1.ReserveIdsResponse")
proto.RegisterType((*Mutation)(nil), "google.datastore.v1.Mutation")
proto.RegisterType((*MutationResult)(nil), "google.datastore.v1.MutationResult")
proto.RegisterType((*ReadOptions)(nil), "google.datastore.v1.ReadOptions")
proto.RegisterType((*TransactionOptions)(nil), "google.datastore.v1.TransactionOptions")
proto.RegisterType((*TransactionOptions_ReadWrite)(nil), "google.datastore.v1.TransactionOptions.ReadWrite")
proto.RegisterType((*TransactionOptions_ReadOnly)(nil), "google.datastore.v1.TransactionOptions.ReadOnly")
proto.RegisterEnum("google.datastore.v1.CommitRequest_Mode", CommitRequest_Mode_name, CommitRequest_Mode_value)
proto.RegisterEnum("google.datastore.v1.ReadOptions_ReadConsistency", ReadOptions_ReadConsistency_name, ReadOptions_ReadConsistency_value)
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// 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.SupportPackageIsVersion4
// 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.ClientConn
}
func NewDatastoreClient(cc *grpc.ClientConn) 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.v1.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.v1.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.v1.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.v1.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.v1.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.v1.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.v1.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)
}
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.v1.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.v1.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.v1.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.v1.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.v1.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.v1.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.v1.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.v1.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/v1/datastore.proto",
}
func init() {
proto.RegisterFile("google/datastore/v1/datastore.proto", fileDescriptor_datastore_43db8ce3c69efb71)
}
var fileDescriptor_datastore_43db8ce3c69efb71 = []byte{
// 1390 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x57, 0xdf, 0x6f, 0x1b, 0xc5,
0x13, 0xcf, 0x3a, 0x89, 0x63, 0x8f, 0xf3, 0xc3, 0xd9, 0xe4, 0xfb, 0xad, 0x71, 0x5b, 0xd5, 0x5c,
0x1a, 0x1a, 0xd2, 0xd6, 0x4e, 0x0c, 0x15, 0x52, 0x53, 0x21, 0xc5, 0x8e, 0xdb, 0x58, 0x34, 0x76,
0xd8, 0xa4, 0xe1, 0x87, 0x8a, 0xac, 0x8b, 0x6f, 0x6b, 0x8e, 0x9c, 0x6f, 0x2f, 0x77, 0xeb, 0x80,
0x85, 0xa8, 0x54, 0x10, 0xbc, 0xc1, 0x43, 0xf9, 0x0b, 0xfa, 0xc2, 0x03, 0xe2, 0x91, 0x27, 0xc4,
0x5f, 0xc0, 0x2b, 0xff, 0x02, 0x8f, 0xbc, 0xf1, 0x0f, 0xa0, 0xdb, 0xdb, 0xb3, 0x7d, 0xce, 0x5d,
0xec, 0x48, 0xbc, 0x79, 0x67, 0xe7, 0x33, 0xf3, 0x99, 0x99, 0xbd, 0x99, 0x31, 0xac, 0xb4, 0x18,
0x6b, 0x19, 0xb4, 0xa0, 0xa9, 0x5c, 0x75, 0x38, 0xb3, 0x69, 0xe1, 0x6c, 0xb3, 0x7f, 0xc8, 0x5b,
0x36, 0xe3, 0x0c, 0x2f, 0x79, 0x4a, 0xf9, 0xbe, 0xfc, 0x6c, 0x33, 0x7b, 0x4d, 0x22, 0x55, 0x4b,
0x2f, 0xa8, 0xa6, 0xc9, 0xb8, 0xca, 0x75, 0x66, 0x3a, 0x1e, 0x24, 0x9b, 0x0b, 0xb3, 0x4b, 0x4d,
0xae, 0xf3, 0xae, 0xd4, 0xb8, 0x11, 0xa6, 0x71, 0xda, 0xa1, 0xb6, 0x54, 0x50, 0x5e, 0x21, 0x98,
0x7b, 0xcc, 0xd8, 0x49, 0xc7, 0x22, 0xf4, 0xb4, 0x43, 0x1d, 0x8e, 0xaf, 0x03, 0x58, 0x36, 0xfb,
0x8c, 0x36, 0x79, 0x43, 0xd7, 0x32, 0x89, 0x1c, 0x5a, 0x4b, 0x92, 0xa4, 0x94, 0x54, 0x35, 0x5c,
0x86, 0x59, 0x9b, 0xaa, 0x5a, 0x83, 0x59, 0x82, 0x49, 0x06, 0xe5, 0xd0, 0x5a, 0xaa, 0x98, 0xcb,
0x87, 0xb0, 0xcf, 0x13, 0xaa, 0x6a, 0x75, 0x4f, 0x8f, 0xa4, 0xec, 0xfe, 0x01, 0xdf, 0x81, 0xa9,
0x13, 0xda, 0x75, 0x32, 0x93, 0xb9, 0xc9, 0xb5, 0x54, 0x31, 0x13, 0x0a, 0x7e, 0x8f, 0x76, 0x89,
0xd0, 0x52, 0x7e, 0x47, 0x30, 0xef, 0x73, 0x74, 0x2c, 0x66, 0x3a, 0x14, 0xbf, 0x03, 0xd3, 0xcf,
0x58, 0xc7, 0xd4, 0x32, 0x48, 0x58, 0x78, 0x3d, 0xd4, 0x42, 0x45, 0x64, 0x82, 0x50, 0xa7, 0x63,
0x70, 0xe2, 0xe9, 0xe3, 0x2d, 0x98, 0x69, 0xeb, 0x8e, 0xa3, 0x9b, 0xad, 0x4c, 0x6c, 0x5c, 0xa8,
0x8f, 0xc0, 0x6f, 0x43, 0x42, 0xa3, 0xcf, 0xa8, 0x6d, 0x53, 0x6d, 0x24, 0xf5, 0x9e, 0xa6, 0xf2,
0x5b, 0x0c, 0x16, 0x48, 0xc7, 0x7c, 0xdf, 0xcd, 0xfa, 0xf8, 0x49, 0xb6, 0x54, 0x9b, 0xeb, 0x6e,
0xb6, 0x5c, 0x85, 0xd8, 0x05, 0x49, 0xde, 0xf7, 0x15, 0xab, 0x1a, 0x49, 0x59, 0xfd, 0xc3, 0x7f,
0x53, 0xa9, 0x22, 0x4c, 0x8b, 0xe7, 0x92, 0x99, 0x14, 0xe8, 0x6c, 0x28, 0x5a, 0x84, 0xb6, 0x3b,
0x41, 0x3c, 0x55, 0xfc, 0x00, 0x92, 0xad, 0x53, 0xa3, 0xe1, 0xe1, 0x66, 0x04, 0xee, 0x7a, 0x28,
0xee, 0xd1, 0xa9, 0xe1, 0x43, 0x13, 0x2d, 0xf9, 0xbb, 0x34, 0x0b, 0x20, 0x90, 0x0d, 0xde, 0xb5,
0xa8, 0xf2, 0x02, 0x41, 0xba, 0x9f, 0x3c, 0x59, 0xfd, 0x2d, 0x98, 0x3e, 0x56, 0x79, 0xf3, 0x53,
0x19, 0xd2, 0x6a, 0x34, 0x29, 0xaf, 0x82, 0x25, 0x57, 0x99, 0x78, 0x18, 0xbc, 0xe1, 0x47, 0x14,
0x1b, 0x15, 0x91, 0x8c, 0x47, 0x79, 0x89, 0xe0, 0x4a, 0x89, 0xb6, 0x74, 0xf3, 0xd0, 0x56, 0x4d,
0x47, 0x6d, 0xba, 0x99, 0x19, 0xb3, 0x90, 0x1f, 0xc2, 0x12, 0xef, 0x83, 0x7a, 0xa5, 0x00, 0xe1,
0xfa, 0x56, 0xa8, 0xeb, 0x01, 0x27, 0x7e, 0x45, 0x30, 0x3f, 0x27, 0x53, 0x1e, 0x40, 0xe6, 0x3c,
0x27, 0x99, 0x9f, 0x1c, 0xa4, 0x06, 0x10, 0x22, 0x4b, 0xb3, 0x64, 0x50, 0xa4, 0x10, 0x58, 0x20,
0xcc, 0x30, 0x8e, 0xd5, 0xe6, 0xc9, 0x98, 0x91, 0x8c, 0xb6, 0x89, 0x21, 0xdd, 0xb7, 0xe9, 0x31,
0x51, 0x7e, 0x89, 0xc1, 0x5c, 0x99, 0xb5, 0xdb, 0x3a, 0x1f, 0xd3, 0xcd, 0x16, 0x4c, 0xb5, 0x99,
0x46, 0x33, 0xd3, 0x39, 0xb4, 0x36, 0x1f, 0x91, 0xa1, 0x80, 0xc1, 0xfc, 0x1e, 0xd3, 0x28, 0x11,
0x20, 0xac, 0x84, 0x70, 0xdc, 0x9d, 0x08, 0xb0, 0xc4, 0x5b, 0x90, 0x6c, 0x77, 0x64, 0x1b, 0xcd,
0xc4, 0xc5, 0x47, 0x1c, 0xfe, 0x38, 0xf7, 0xa4, 0x16, 0xe9, 0xeb, 0x2b, 0x0f, 0x61, 0xca, 0x75,
0x87, 0x97, 0x21, 0xbd, 0x57, 0xdf, 0xa9, 0x34, 0x9e, 0xd4, 0x0e, 0xf6, 0x2b, 0xe5, 0xea, 0xc3,
0x6a, 0x65, 0x27, 0x3d, 0x81, 0x17, 0x61, 0xee, 0x90, 0x6c, 0xd7, 0x0e, 0xb6, 0xcb, 0x87, 0xd5,
0x7a, 0x6d, 0xfb, 0x71, 0x1a, 0xe1, 0xff, 0xc1, 0x62, 0xad, 0x5e, 0x6b, 0x04, 0xc5, 0xb1, 0xd2,
0xff, 0x61, 0x79, 0xf0, 0x59, 0x38, 0xd4, 0xa0, 0x4d, 0xce, 0x6c, 0xe5, 0x5b, 0x04, 0xf3, 0x7e,
0x74, 0xb2, 0x96, 0x35, 0x48, 0xfb, 0xfe, 0x1b, 0xb6, 0x78, 0xcd, 0x7e, 0xdb, 0x5c, 0xb9, 0x98,
0xb6, 0xd7, 0xbb, 0x16, 0xda, 0x81, 0xb3, 0x83, 0x57, 0x60, 0x4e, 0x37, 0x35, 0xfa, 0x45, 0xa3,
0x63, 0x69, 0x2a, 0xa7, 0x4e, 0x66, 0x2a, 0x87, 0xd6, 0xa6, 0xc9, 0xac, 0x10, 0x3e, 0xf1, 0x64,
0x8a, 0x0a, 0x78, 0xdb, 0x30, 0x58, 0x53, 0xe5, 0xb4, 0xaa, 0x39, 0x63, 0x96, 0xce, 0x6f, 0xea,
0x68, 0xac, 0xa6, 0x5e, 0x86, 0xa5, 0x80, 0x0b, 0x19, 0xee, 0xe5, 0x8c, 0xbc, 0x40, 0xb0, 0x48,
0xa8, 0x43, 0xed, 0xb3, 0x4b, 0xf0, 0xbc, 0x01, 0x29, 0xd7, 0xdc, 0xb1, 0xea, 0x50, 0xf7, 0x3e,
0x29, 0xee, 0xc1, 0x17, 0x5d, 0x3a, 0x90, 0x65, 0xc0, 0x83, 0x14, 0xe4, 0xc3, 0xff, 0x35, 0x06,
0x09, 0xbf, 0x14, 0xf8, 0x1e, 0xc4, 0x75, 0xd3, 0xa1, 0x36, 0x17, 0xc9, 0x4e, 0x15, 0xaf, 0x5e,
0x30, 0x73, 0x76, 0x27, 0x88, 0x54, 0x76, 0x61, 0x5e, 0x91, 0xc4, 0xd7, 0x30, 0x1a, 0xe6, 0x29,
0x7b, 0x30, 0xe1, 0x2d, 0x3e, 0x26, 0x4c, 0x78, 0x2b, 0x42, 0x5c, 0xa3, 0x06, 0xe5, 0x54, 0xb6,
0xec, 0xc8, 0xb8, 0x5d, 0x8c, 0xa7, 0x89, 0x57, 0x60, 0x56, 0xa4, 0xf1, 0x8c, 0xda, 0x8e, 0xfb,
0xc5, 0xb9, 0xb9, 0x9e, 0xdc, 0x45, 0x24, 0xe5, 0x4a, 0x8f, 0x3c, 0x61, 0x29, 0x05, 0x49, 0x66,
0x51, 0x5b, 0xa4, 0xa2, 0x74, 0x1d, 0xae, 0x36, 0x99, 0xf9, 0xcc, 0xd0, 0x9b, 0xbc, 0xa1, 0x51,
0x4e, 0xe5, 0x07, 0xc0, 0x6d, 0x95, 0xd3, 0x56, 0x57, 0xf9, 0x06, 0xc1, 0x7c, 0xf0, 0x05, 0xe3,
0x75, 0x98, 0x3c, 0xa1, 0xfe, 0xfc, 0x89, 0x2e, 0x86, 0xab, 0x84, 0x33, 0x30, 0xe3, 0x53, 0x71,
0x33, 0x3d, 0x49, 0xfc, 0x23, 0xbe, 0x0d, 0x8b, 0x43, 0x7e, 0xa9, 0x26, 0xd2, 0x9a, 0x20, 0x69,
0xff, 0x62, 0x47, 0xca, 0x95, 0x7f, 0x10, 0xa4, 0x06, 0x26, 0x22, 0xfe, 0x04, 0xd2, 0x62, 0x92,
0x36, 0x99, 0xe9, 0xe8, 0x0e, 0xa7, 0x66, 0xb3, 0x2b, 0x9a, 0xcb, 0x7c, 0x71, 0x63, 0xd4, 0x34,
0x15, 0xbf, 0xcb, 0x7d, 0xdc, 0xee, 0x04, 0x59, 0xb0, 0x83, 0xa2, 0xe1, 0xb6, 0x15, 0x0b, 0x69,
0x5b, 0xca, 0x1e, 0x2c, 0x0c, 0x59, 0xc2, 0x39, 0xb8, 0x46, 0x2a, 0xdb, 0x3b, 0x8d, 0x72, 0xbd,
0x76, 0x50, 0x3d, 0x38, 0xac, 0xd4, 0xca, 0x1f, 0x0d, 0x35, 0x24, 0x80, 0xf8, 0xc1, 0x21, 0xa9,
0xd7, 0x1e, 0xa5, 0x11, 0x9e, 0x85, 0x44, 0xe5, 0xa8, 0x52, 0x3b, 0x7c, 0x22, 0x1a, 0x10, 0x86,
0xf4, 0x40, 0x30, 0xde, 0xa8, 0xfd, 0x3e, 0x06, 0xf8, 0xfc, 0xf0, 0xc1, 0x04, 0x40, 0x04, 0xff,
0xb9, 0xad, 0x73, 0x2a, 0x27, 0xee, 0xe6, 0x98, 0x93, 0x4b, 0x44, 0xff, 0x81, 0x0b, 0xdc, 0x9d,
0x20, 0x49, 0xdb, 0x3f, 0xe0, 0x3a, 0x24, 0xbd, 0xd5, 0xc4, 0x34, 0xfc, 0x39, 0xbc, 0x71, 0x19,
0x93, 0x75, 0xd3, 0x10, 0x4b, 0x83, 0x2d, 0x7f, 0x67, 0xdf, 0x85, 0x64, 0xcf, 0x15, 0xde, 0x84,
0x65, 0xcb, 0xa6, 0x67, 0x3a, 0xeb, 0x38, 0x8d, 0xf3, 0x33, 0x6b, 0xc9, 0xbf, 0x1b, 0xb0, 0x9d,
0x05, 0x48, 0xf8, 0x76, 0x4b, 0x71, 0x6f, 0x04, 0x15, 0xff, 0x9e, 0x81, 0xe4, 0x8e, 0x4f, 0x06,
0x3f, 0x87, 0xb8, 0xb7, 0x83, 0x62, 0x25, 0x94, 0x69, 0x60, 0x89, 0xce, 0xae, 0x5c, 0xa8, 0x23,
0x7b, 0xc4, 0xed, 0xaf, 0xff, 0xfc, 0xeb, 0xc7, 0xd8, 0xaa, 0x92, 0x73, 0x97, 0x72, 0xd9, 0x9f,
0x9c, 0xc2, 0x97, 0xfd, 0xde, 0xf5, 0xd5, 0x7d, 0x43, 0x20, 0xee, 0xa3, 0x75, 0xfc, 0x1d, 0x82,
0x84, 0xbf, 0x08, 0xe1, 0x9b, 0xe1, 0xcf, 0x2e, 0xb8, 0x64, 0x66, 0x57, 0x47, 0x68, 0x49, 0x1a,
0x77, 0x05, 0x8d, 0x5b, 0x8a, 0x12, 0x4d, 0xc3, 0x96, 0x18, 0x97, 0xc8, 0x4f, 0x08, 0xd2, 0xc3,
0x9b, 0x07, 0xbe, 0x13, 0xea, 0x2a, 0x62, 0x69, 0xca, 0xde, 0x1d, 0x53, 0x5b, 0x12, 0xbc, 0x27,
0x08, 0x16, 0x94, 0xf5, 0x68, 0x82, 0xc7, 0x43, 0x58, 0x97, 0xe8, 0x73, 0x88, 0x7b, 0xb3, 0x34,
0xa2, 0x62, 0x81, 0x35, 0x22, 0xa2, 0x62, 0xc1, 0x61, 0x3c, 0x4e, 0xc5, 0x9a, 0x02, 0xd1, 0xab,
0x98, 0x5c, 0x88, 0xa2, 0x2a, 0x16, 0xdc, 0xc1, 0xa2, 0x2a, 0x36, 0xbc, 0x55, 0x8d, 0x53, 0x31,
0x89, 0x71, 0x89, 0xbc, 0x44, 0x90, 0x1a, 0x98, 0xb5, 0x38, 0x7c, 0xab, 0x3a, 0x3f, 0xf0, 0xb3,
0x6b, 0xa3, 0x15, 0x25, 0xa3, 0x0d, 0xc1, 0x68, 0x5d, 0x59, 0x8d, 0x66, 0xa4, 0xf6, 0x61, 0x2e,
0xa9, 0x1f, 0x10, 0x40, 0x7f, 0x6e, 0xe2, 0x37, 0x22, 0x1a, 0xe9, 0xd0, 0x6c, 0xcf, 0xde, 0x1a,
0xa9, 0x27, 0x19, 0x15, 0x04, 0xa3, 0x37, 0x95, 0x9b, 0x17, 0xe4, 0xa8, 0x87, 0xba, 0x8f, 0xd6,
0x4b, 0xaf, 0x10, 0x5c, 0x69, 0xb2, 0x76, 0x98, 0xfd, 0xd2, 0x7c, 0xaf, 0x0f, 0xec, 0xbb, 0xff,
0x9a, 0xf7, 0xd1, 0xc7, 0x0f, 0xa4, 0x5a, 0x8b, 0x19, 0xaa, 0xd9, 0xca, 0x33, 0xbb, 0x55, 0x68,
0x51, 0x53, 0xfc, 0xa7, 0x2e, 0x78, 0x57, 0xaa, 0xa5, 0x3b, 0x81, 0xff, 0xdd, 0x5b, 0xbd, 0xc3,
0xcf, 0xb1, 0xd7, 0x1e, 0x79, 0xf0, 0xb2, 0xc1, 0x3a, 0x5a, 0xbe, 0x67, 0x3d, 0x7f, 0xb4, 0xf9,
0x87, 0x7f, 0xf7, 0x54, 0xdc, 0x3d, 0xed, 0xdd, 0x3d, 0x3d, 0xda, 0x3c, 0x8e, 0x0b, 0x07, 0x6f,
0xfd, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x25, 0x27, 0xe9, 0x95, 0x51, 0x10, 0x00, 0x00,
}