spannerpb

package

Go to main page

Versions in this module

v1

v1.73.0

Nov 14, 2024

v1.72.0

Nov 8, 2024

v1.71.0

Nov 1, 2024

v1.70.0

Oct 14, 2024

Changes in this version

type BeginTransactionRequest

+ MutationKey *Mutation

+ func (x *BeginTransactionRequest) GetMutationKey() *Mutation

type CommitRequest

+ PrecommitToken *MultiplexedSessionPrecommitToken

+ func (x *CommitRequest) GetPrecommitToken() *MultiplexedSessionPrecommitToken

type CommitResponse

+ MultiplexedSessionRetry isCommitResponse_MultiplexedSessionRetry

+ func (m *CommitResponse) GetMultiplexedSessionRetry() isCommitResponse_MultiplexedSessionRetry

+ func (x *CommitResponse) GetPrecommitToken() *MultiplexedSessionPrecommitToken

+ type CommitResponse_PrecommitToken struct

+ PrecommitToken *MultiplexedSessionPrecommitToken

type ExecuteBatchDmlResponse

+ PrecommitToken *MultiplexedSessionPrecommitToken

+ func (x *ExecuteBatchDmlResponse) GetPrecommitToken() *MultiplexedSessionPrecommitToken

type ExecuteSqlRequest_QueryMode

+ const ExecuteSqlRequest_WITH_PLAN_AND_STATS

+ const ExecuteSqlRequest_WITH_STATS

+ type MultiplexedSessionPrecommitToken struct

+ PrecommitToken []byte

+ SeqNum int32

+ func (*MultiplexedSessionPrecommitToken) Descriptor() ([]byte, []int)

+ func (*MultiplexedSessionPrecommitToken) ProtoMessage()

+ func (x *MultiplexedSessionPrecommitToken) GetPrecommitToken() []byte

+ func (x *MultiplexedSessionPrecommitToken) GetSeqNum() int32

+ func (x *MultiplexedSessionPrecommitToken) ProtoReflect() protoreflect.Message

+ func (x *MultiplexedSessionPrecommitToken) Reset()

+ func (x *MultiplexedSessionPrecommitToken) String() string

type PartialResultSet

+ PrecommitToken *MultiplexedSessionPrecommitToken

+ func (x *PartialResultSet) GetPrecommitToken() *MultiplexedSessionPrecommitToken

type ResultSet

+ PrecommitToken *MultiplexedSessionPrecommitToken

+ func (x *ResultSet) GetPrecommitToken() *MultiplexedSessionPrecommitToken

type Transaction

+ PrecommitToken *MultiplexedSessionPrecommitToken

+ func (x *Transaction) GetPrecommitToken() *MultiplexedSessionPrecommitToken

type TransactionOptions_ReadWrite

+ MultiplexedSessionPreviousTransactionId []byte

+ func (x *TransactionOptions_ReadWrite) GetMultiplexedSessionPreviousTransactionId() []byte

type TypeCode

+ const TypeCode_INTERVAL

v1.69.0

Oct 4, 2024

v1.68.0

Sep 25, 2024

v1.67.0

Aug 16, 2024

v1.66.0

Aug 7, 2024

v1.65.0

Jul 29, 2024

v1.64.0

Jul 1, 2024

Changes in this version

+ var ReadRequest_LockHint_name = map[int32]string

+ var ReadRequest_LockHint_value = map[string]int32

+ var ReadRequest_OrderBy_name = map[int32]string

+ var ReadRequest_OrderBy_value = map[string]int32

type ReadRequest

+ LockHint ReadRequest_LockHint

+ OrderBy ReadRequest_OrderBy

+ func (x *ReadRequest) GetLockHint() ReadRequest_LockHint

+ func (x *ReadRequest) GetOrderBy() ReadRequest_OrderBy

+ type ReadRequest_LockHint int32

+ const ReadRequest_LOCK_HINT_EXCLUSIVE

+ const ReadRequest_LOCK_HINT_SHARED

+ const ReadRequest_LOCK_HINT_UNSPECIFIED

+ func (ReadRequest_LockHint) Descriptor() protoreflect.EnumDescriptor

+ func (ReadRequest_LockHint) EnumDescriptor() ([]byte, []int)

+ func (ReadRequest_LockHint) Type() protoreflect.EnumType

+ func (x ReadRequest_LockHint) Enum() *ReadRequest_LockHint

+ func (x ReadRequest_LockHint) Number() protoreflect.EnumNumber

+ func (x ReadRequest_LockHint) String() string

+ type ReadRequest_OrderBy int32

+ const ReadRequest_ORDER_BY_NO_ORDER

+ const ReadRequest_ORDER_BY_PRIMARY_KEY

+ const ReadRequest_ORDER_BY_UNSPECIFIED

+ func (ReadRequest_OrderBy) Descriptor() protoreflect.EnumDescriptor

+ func (ReadRequest_OrderBy) EnumDescriptor() ([]byte, []int)

+ func (ReadRequest_OrderBy) Type() protoreflect.EnumType

+ func (x ReadRequest_OrderBy) Enum() *ReadRequest_OrderBy

+ func (x ReadRequest_OrderBy) Number() protoreflect.EnumNumber

+ func (x ReadRequest_OrderBy) String() string

v1.63.0

May 24, 2024

v1.62.0

May 15, 2024

v1.61.0

Apr 30, 2024

v1.60.0

Mar 19, 2024

v1.59.0

Mar 13, 2024

v1.58.0

Mar 6, 2024

Changes in this version

type BatchWriteRequest

+ ExcludeTxnFromChangeStreams bool

+ func (x *BatchWriteRequest) GetExcludeTxnFromChangeStreams() bool

type Session

+ Multiplexed bool

+ func (x *Session) GetMultiplexed() bool

type TransactionOptions

+ ExcludeTxnFromChangeStreams bool

+ func (x *TransactionOptions) GetExcludeTxnFromChangeStreams() bool

v1.57.0

Feb 13, 2024

v1.56.0

Jan 30, 2024

Changes in this version

type CommitRequest

+ MaxCommitDelay *durationpb.Duration

+ func (x *CommitRequest) GetMaxCommitDelay() *durationpb.Duration

type Type

+ ProtoTypeFqn string

+ func (x *Type) GetProtoTypeFqn() string

type TypeCode

+ const TypeCode_ENUM

+ const TypeCode_FLOAT32

+ const TypeCode_PROTO

v1.55.0

Jan 10, 2024

v1.54.0

Dec 14, 2023

v1.53.1

Dec 4, 2023

v1.53.0

Nov 15, 2023

v1.52.0

Nov 15, 2023

Changes in this version

+ var DirectedReadOptions_ReplicaSelection_Type_name = map[int32]string

+ var DirectedReadOptions_ReplicaSelection_Type_value = map[string]int32

+ type DirectedReadOptions struct

+ Replicas isDirectedReadOptions_Replicas

+ func (*DirectedReadOptions) Descriptor() ([]byte, []int)

+ func (*DirectedReadOptions) ProtoMessage()

+ func (m *DirectedReadOptions) GetReplicas() isDirectedReadOptions_Replicas

+ func (x *DirectedReadOptions) GetExcludeReplicas() *DirectedReadOptions_ExcludeReplicas

+ func (x *DirectedReadOptions) GetIncludeReplicas() *DirectedReadOptions_IncludeReplicas

+ func (x *DirectedReadOptions) ProtoReflect() protoreflect.Message

+ func (x *DirectedReadOptions) Reset()

+ func (x *DirectedReadOptions) String() string

+ type DirectedReadOptions_ExcludeReplicas struct

+ ReplicaSelections []*DirectedReadOptions_ReplicaSelection

+ func (*DirectedReadOptions_ExcludeReplicas) Descriptor() ([]byte, []int)

+ func (*DirectedReadOptions_ExcludeReplicas) ProtoMessage()

+ func (x *DirectedReadOptions_ExcludeReplicas) GetReplicaSelections() []*DirectedReadOptions_ReplicaSelection

+ func (x *DirectedReadOptions_ExcludeReplicas) ProtoReflect() protoreflect.Message

+ func (x *DirectedReadOptions_ExcludeReplicas) Reset()

+ func (x *DirectedReadOptions_ExcludeReplicas) String() string

+ type DirectedReadOptions_ExcludeReplicas_ struct

+ ExcludeReplicas *DirectedReadOptions_ExcludeReplicas

+ type DirectedReadOptions_IncludeReplicas struct

+ AutoFailoverDisabled bool

+ ReplicaSelections []*DirectedReadOptions_ReplicaSelection

+ func (*DirectedReadOptions_IncludeReplicas) Descriptor() ([]byte, []int)

+ func (*DirectedReadOptions_IncludeReplicas) ProtoMessage()

+ func (x *DirectedReadOptions_IncludeReplicas) GetAutoFailoverDisabled() bool

+ func (x *DirectedReadOptions_IncludeReplicas) GetReplicaSelections() []*DirectedReadOptions_ReplicaSelection

+ func (x *DirectedReadOptions_IncludeReplicas) ProtoReflect() protoreflect.Message

+ func (x *DirectedReadOptions_IncludeReplicas) Reset()

+ func (x *DirectedReadOptions_IncludeReplicas) String() string

+ type DirectedReadOptions_IncludeReplicas_ struct

+ IncludeReplicas *DirectedReadOptions_IncludeReplicas

+ type DirectedReadOptions_ReplicaSelection struct

+ Location string

+ Type DirectedReadOptions_ReplicaSelection_Type

+ func (*DirectedReadOptions_ReplicaSelection) Descriptor() ([]byte, []int)

+ func (*DirectedReadOptions_ReplicaSelection) ProtoMessage()

+ func (x *DirectedReadOptions_ReplicaSelection) GetLocation() string

+ func (x *DirectedReadOptions_ReplicaSelection) GetType() DirectedReadOptions_ReplicaSelection_Type

+ func (x *DirectedReadOptions_ReplicaSelection) ProtoReflect() protoreflect.Message

+ func (x *DirectedReadOptions_ReplicaSelection) Reset()

+ func (x *DirectedReadOptions_ReplicaSelection) String() string

+ type DirectedReadOptions_ReplicaSelection_Type int32

+ const DirectedReadOptions_ReplicaSelection_READ_ONLY

+ const DirectedReadOptions_ReplicaSelection_READ_WRITE

+ const DirectedReadOptions_ReplicaSelection_TYPE_UNSPECIFIED

+ func (DirectedReadOptions_ReplicaSelection_Type) Descriptor() protoreflect.EnumDescriptor

+ func (DirectedReadOptions_ReplicaSelection_Type) EnumDescriptor() ([]byte, []int)

+ func (DirectedReadOptions_ReplicaSelection_Type) Type() protoreflect.EnumType

+ func (x DirectedReadOptions_ReplicaSelection_Type) Enum() *DirectedReadOptions_ReplicaSelection_Type

+ func (x DirectedReadOptions_ReplicaSelection_Type) Number() protoreflect.EnumNumber

+ func (x DirectedReadOptions_ReplicaSelection_Type) String() string

type ExecuteSqlRequest

+ DirectedReadOptions *DirectedReadOptions

+ func (x *ExecuteSqlRequest) GetDirectedReadOptions() *DirectedReadOptions

type ReadRequest

+ DirectedReadOptions *DirectedReadOptions

+ func (x *ReadRequest) GetDirectedReadOptions() *DirectedReadOptions

type TypeAnnotationCode

+ const TypeAnnotationCode_PG_OID

v1.51.0

Oct 17, 2023

v1.50.0

Oct 4, 2023

Changes in this version

+ type BatchWriteRequest struct

+ MutationGroups []*BatchWriteRequest_MutationGroup

+ RequestOptions *RequestOptions

+ Session string

+ func (*BatchWriteRequest) Descriptor() ([]byte, []int)

+ func (*BatchWriteRequest) ProtoMessage()

+ func (x *BatchWriteRequest) GetMutationGroups() []*BatchWriteRequest_MutationGroup

+ func (x *BatchWriteRequest) GetRequestOptions() *RequestOptions

+ func (x *BatchWriteRequest) GetSession() string

+ func (x *BatchWriteRequest) ProtoReflect() protoreflect.Message

+ func (x *BatchWriteRequest) Reset()

+ func (x *BatchWriteRequest) String() string

+ type BatchWriteRequest_MutationGroup struct

+ Mutations []*Mutation

+ func (*BatchWriteRequest_MutationGroup) Descriptor() ([]byte, []int)

+ func (*BatchWriteRequest_MutationGroup) ProtoMessage()

+ func (x *BatchWriteRequest_MutationGroup) GetMutations() []*Mutation

+ func (x *BatchWriteRequest_MutationGroup) ProtoReflect() protoreflect.Message

+ func (x *BatchWriteRequest_MutationGroup) Reset()

+ func (x *BatchWriteRequest_MutationGroup) String() string

+ type BatchWriteResponse struct

+ CommitTimestamp *timestamppb.Timestamp

+ Indexes []int32

+ Status *status.Status

+ func (*BatchWriteResponse) Descriptor() ([]byte, []int)

+ func (*BatchWriteResponse) ProtoMessage()

+ func (x *BatchWriteResponse) GetCommitTimestamp() *timestamppb.Timestamp

+ func (x *BatchWriteResponse) GetIndexes() []int32

+ func (x *BatchWriteResponse) GetStatus() *status.Status

+ func (x *BatchWriteResponse) ProtoReflect() protoreflect.Message

+ func (x *BatchWriteResponse) Reset()

+ func (x *BatchWriteResponse) String() string

type SpannerClient

+ BatchWrite func(ctx context.Context, in *BatchWriteRequest, opts ...grpc.CallOption) (Spanner_BatchWriteClient, error)

type SpannerServer

+ BatchWrite func(*BatchWriteRequest, Spanner_BatchWriteServer) error

+ type Spanner_BatchWriteClient interface

+ Recv func() (*BatchWriteResponse, error)

+ type Spanner_BatchWriteServer interface

+ Send func(*BatchWriteResponse) error

type UnimplementedSpannerServer

+ func (*UnimplementedSpannerServer) BatchWrite(*BatchWriteRequest, Spanner_BatchWriteServer) error

v1.49.0

Aug 24, 2023

v1.48.0

Aug 18, 2023

v1.47.0

Jun 20, 2023

v1.46.0

May 15, 2023

v1.45.1

Apr 21, 2023

v1.45.0

Apr 10, 2023

Changes in this version

type ExecuteSqlRequest

+ DataBoostEnabled bool

+ func (x *ExecuteSqlRequest) GetDataBoostEnabled() bool

type ReadRequest

+ DataBoostEnabled bool

+ func (x *ReadRequest) GetDataBoostEnabled() bool

v1.44.0

Feb 2, 2023

v1.43.0

Jan 19, 2023

v1.42.0

Dec 14, 2022

v1.41.0

Dec 1, 2022

Changes in this version

+ var ExecuteSqlRequest_QueryMode_name = map[int32]string

+ var ExecuteSqlRequest_QueryMode_value = map[string]int32

+ var File_google_spanner_v1_commit_response_proto protoreflect.FileDescriptor

+ var File_google_spanner_v1_keys_proto protoreflect.FileDescriptor

+ var File_google_spanner_v1_mutation_proto protoreflect.FileDescriptor

+ var File_google_spanner_v1_query_plan_proto protoreflect.FileDescriptor

+ var File_google_spanner_v1_result_set_proto protoreflect.FileDescriptor

+ var File_google_spanner_v1_spanner_proto protoreflect.FileDescriptor

+ var File_google_spanner_v1_transaction_proto protoreflect.FileDescriptor

+ var File_google_spanner_v1_type_proto protoreflect.FileDescriptor

+ var PlanNode_Kind_name = map[int32]string

+ var PlanNode_Kind_value = map[string]int32

+ var RequestOptions_Priority_name = map[int32]string

+ var RequestOptions_Priority_value = map[string]int32

+ var TransactionOptions_ReadWrite_ReadLockMode_name = map[int32]string

+ var TransactionOptions_ReadWrite_ReadLockMode_value = map[string]int32

+ var TypeAnnotationCode_name = map[int32]string

+ var TypeAnnotationCode_value = map[string]int32

+ var TypeCode_name = map[int32]string

+ var TypeCode_value = map[string]int32

+ func RegisterSpannerServer(s *grpc.Server, srv SpannerServer)

+ type BatchCreateSessionsRequest struct

+ Database string

+ SessionCount int32

+ SessionTemplate *Session

+ func (*BatchCreateSessionsRequest) Descriptor() ([]byte, []int)

+ func (*BatchCreateSessionsRequest) ProtoMessage()

+ func (x *BatchCreateSessionsRequest) GetDatabase() string

+ func (x *BatchCreateSessionsRequest) GetSessionCount() int32

+ func (x *BatchCreateSessionsRequest) GetSessionTemplate() *Session

+ func (x *BatchCreateSessionsRequest) ProtoReflect() protoreflect.Message

+ func (x *BatchCreateSessionsRequest) Reset()

+ func (x *BatchCreateSessionsRequest) String() string

+ type BatchCreateSessionsResponse struct

+ Session []*Session

+ func (*BatchCreateSessionsResponse) Descriptor() ([]byte, []int)

+ func (*BatchCreateSessionsResponse) ProtoMessage()

+ func (x *BatchCreateSessionsResponse) GetSession() []*Session

+ func (x *BatchCreateSessionsResponse) ProtoReflect() protoreflect.Message

+ func (x *BatchCreateSessionsResponse) Reset()

+ func (x *BatchCreateSessionsResponse) String() string

+ type BeginTransactionRequest struct

+ Options *TransactionOptions

+ RequestOptions *RequestOptions

+ Session string

+ func (*BeginTransactionRequest) Descriptor() ([]byte, []int)

+ func (*BeginTransactionRequest) ProtoMessage()

+ func (x *BeginTransactionRequest) GetOptions() *TransactionOptions

+ func (x *BeginTransactionRequest) GetRequestOptions() *RequestOptions

+ func (x *BeginTransactionRequest) GetSession() string

+ func (x *BeginTransactionRequest) ProtoReflect() protoreflect.Message

+ func (x *BeginTransactionRequest) Reset()

+ func (x *BeginTransactionRequest) String() string

+ type CommitRequest struct

+ Mutations []*Mutation

+ RequestOptions *RequestOptions

+ ReturnCommitStats bool

+ Session string

+ Transaction isCommitRequest_Transaction

+ func (*CommitRequest) Descriptor() ([]byte, []int)

+ func (*CommitRequest) ProtoMessage()

+ func (m *CommitRequest) GetTransaction() isCommitRequest_Transaction

+ func (x *CommitRequest) GetMutations() []*Mutation

+ func (x *CommitRequest) GetRequestOptions() *RequestOptions

+ func (x *CommitRequest) GetReturnCommitStats() bool

+ func (x *CommitRequest) GetSession() string

+ func (x *CommitRequest) GetSingleUseTransaction() *TransactionOptions

+ func (x *CommitRequest) GetTransactionId() []byte

+ func (x *CommitRequest) ProtoReflect() protoreflect.Message

+ func (x *CommitRequest) Reset()

+ func (x *CommitRequest) String() string

+ type CommitRequest_SingleUseTransaction struct

+ SingleUseTransaction *TransactionOptions

+ type CommitRequest_TransactionId struct

+ TransactionId []byte

+ type CommitResponse struct

+ CommitStats *CommitResponse_CommitStats

+ CommitTimestamp *timestamppb.Timestamp

+ func (*CommitResponse) Descriptor() ([]byte, []int)

+ func (*CommitResponse) ProtoMessage()

+ func (x *CommitResponse) GetCommitStats() *CommitResponse_CommitStats

+ func (x *CommitResponse) GetCommitTimestamp() *timestamppb.Timestamp

+ func (x *CommitResponse) ProtoReflect() protoreflect.Message

+ func (x *CommitResponse) Reset()

+ func (x *CommitResponse) String() string

+ type CommitResponse_CommitStats struct

+ MutationCount int64

+ func (*CommitResponse_CommitStats) Descriptor() ([]byte, []int)

+ func (*CommitResponse_CommitStats) ProtoMessage()

+ func (x *CommitResponse_CommitStats) GetMutationCount() int64

+ func (x *CommitResponse_CommitStats) ProtoReflect() protoreflect.Message

+ func (x *CommitResponse_CommitStats) Reset()

+ func (x *CommitResponse_CommitStats) String() string

+ type CreateSessionRequest struct

+ Database string

+ Session *Session

+ func (*CreateSessionRequest) Descriptor() ([]byte, []int)

+ func (*CreateSessionRequest) ProtoMessage()

+ func (x *CreateSessionRequest) GetDatabase() string

+ func (x *CreateSessionRequest) GetSession() *Session

+ func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateSessionRequest) Reset()

+ func (x *CreateSessionRequest) String() string

+ type DeleteSessionRequest struct

+ Name string

+ func (*DeleteSessionRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSessionRequest) ProtoMessage()

+ func (x *DeleteSessionRequest) GetName() string

+ func (x *DeleteSessionRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSessionRequest) Reset()

+ func (x *DeleteSessionRequest) String() string

+ type ExecuteBatchDmlRequest struct

+ RequestOptions *RequestOptions

+ Seqno int64

+ Session string

+ Statements []*ExecuteBatchDmlRequest_Statement

+ Transaction *TransactionSelector

+ func (*ExecuteBatchDmlRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteBatchDmlRequest) ProtoMessage()

+ func (x *ExecuteBatchDmlRequest) GetRequestOptions() *RequestOptions

+ func (x *ExecuteBatchDmlRequest) GetSeqno() int64

+ func (x *ExecuteBatchDmlRequest) GetSession() string

+ func (x *ExecuteBatchDmlRequest) GetStatements() []*ExecuteBatchDmlRequest_Statement

+ func (x *ExecuteBatchDmlRequest) GetTransaction() *TransactionSelector

+ func (x *ExecuteBatchDmlRequest) ProtoReflect() protoreflect.Message

+ func (x *ExecuteBatchDmlRequest) Reset()

+ func (x *ExecuteBatchDmlRequest) String() string

+ type ExecuteBatchDmlRequest_Statement struct

+ ParamTypes map[string]*Type

+ Params *structpb.Struct

+ Sql string

+ func (*ExecuteBatchDmlRequest_Statement) Descriptor() ([]byte, []int)

+ func (*ExecuteBatchDmlRequest_Statement) ProtoMessage()

+ func (x *ExecuteBatchDmlRequest_Statement) GetParamTypes() map[string]*Type

+ func (x *ExecuteBatchDmlRequest_Statement) GetParams() *structpb.Struct

+ func (x *ExecuteBatchDmlRequest_Statement) GetSql() string

+ func (x *ExecuteBatchDmlRequest_Statement) ProtoReflect() protoreflect.Message

+ func (x *ExecuteBatchDmlRequest_Statement) Reset()

+ func (x *ExecuteBatchDmlRequest_Statement) String() string

+ type ExecuteBatchDmlResponse struct

+ ResultSets []*ResultSet

+ Status *status.Status

+ func (*ExecuteBatchDmlResponse) Descriptor() ([]byte, []int)

+ func (*ExecuteBatchDmlResponse) ProtoMessage()

+ func (x *ExecuteBatchDmlResponse) GetResultSets() []*ResultSet

+ func (x *ExecuteBatchDmlResponse) GetStatus() *status.Status

+ func (x *ExecuteBatchDmlResponse) ProtoReflect() protoreflect.Message

+ func (x *ExecuteBatchDmlResponse) Reset()

+ func (x *ExecuteBatchDmlResponse) String() string

+ type ExecuteSqlRequest struct

+ ParamTypes map[string]*Type

+ Params *structpb.Struct

+ PartitionToken []byte

+ QueryMode ExecuteSqlRequest_QueryMode

+ QueryOptions *ExecuteSqlRequest_QueryOptions

+ RequestOptions *RequestOptions

+ ResumeToken []byte

+ Seqno int64

+ Session string

+ Sql string

+ Transaction *TransactionSelector

+ func (*ExecuteSqlRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteSqlRequest) ProtoMessage()

+ func (x *ExecuteSqlRequest) GetParamTypes() map[string]*Type

+ func (x *ExecuteSqlRequest) GetParams() *structpb.Struct

+ func (x *ExecuteSqlRequest) GetPartitionToken() []byte

+ func (x *ExecuteSqlRequest) GetQueryMode() ExecuteSqlRequest_QueryMode

+ func (x *ExecuteSqlRequest) GetQueryOptions() *ExecuteSqlRequest_QueryOptions

+ func (x *ExecuteSqlRequest) GetRequestOptions() *RequestOptions

+ func (x *ExecuteSqlRequest) GetResumeToken() []byte

+ func (x *ExecuteSqlRequest) GetSeqno() int64

+ func (x *ExecuteSqlRequest) GetSession() string

+ func (x *ExecuteSqlRequest) GetSql() string

+ func (x *ExecuteSqlRequest) GetTransaction() *TransactionSelector

+ func (x *ExecuteSqlRequest) ProtoReflect() protoreflect.Message

+ func (x *ExecuteSqlRequest) Reset()

+ func (x *ExecuteSqlRequest) String() string

+ type ExecuteSqlRequest_QueryMode int32

+ const ExecuteSqlRequest_NORMAL

+ const ExecuteSqlRequest_PLAN

+ const ExecuteSqlRequest_PROFILE

+ func (ExecuteSqlRequest_QueryMode) Descriptor() protoreflect.EnumDescriptor

+ func (ExecuteSqlRequest_QueryMode) EnumDescriptor() ([]byte, []int)

+ func (ExecuteSqlRequest_QueryMode) Type() protoreflect.EnumType

+ func (x ExecuteSqlRequest_QueryMode) Enum() *ExecuteSqlRequest_QueryMode

+ func (x ExecuteSqlRequest_QueryMode) Number() protoreflect.EnumNumber

+ func (x ExecuteSqlRequest_QueryMode) String() string

+ type ExecuteSqlRequest_QueryOptions struct

+ OptimizerStatisticsPackage string

+ OptimizerVersion string

+ func (*ExecuteSqlRequest_QueryOptions) Descriptor() ([]byte, []int)

+ func (*ExecuteSqlRequest_QueryOptions) ProtoMessage()

+ func (x *ExecuteSqlRequest_QueryOptions) GetOptimizerStatisticsPackage() string

+ func (x *ExecuteSqlRequest_QueryOptions) GetOptimizerVersion() string

+ func (x *ExecuteSqlRequest_QueryOptions) ProtoReflect() protoreflect.Message

+ func (x *ExecuteSqlRequest_QueryOptions) Reset()

+ func (x *ExecuteSqlRequest_QueryOptions) String() string

+ type GetSessionRequest struct

+ Name string

+ func (*GetSessionRequest) Descriptor() ([]byte, []int)

+ func (*GetSessionRequest) ProtoMessage()

+ func (x *GetSessionRequest) GetName() string

+ func (x *GetSessionRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSessionRequest) Reset()

+ func (x *GetSessionRequest) String() string

+ type KeyRange struct

+ EndKeyType isKeyRange_EndKeyType

+ StartKeyType isKeyRange_StartKeyType

+ func (*KeyRange) Descriptor() ([]byte, []int)

+ func (*KeyRange) ProtoMessage()

+ func (m *KeyRange) GetEndKeyType() isKeyRange_EndKeyType

+ func (m *KeyRange) GetStartKeyType() isKeyRange_StartKeyType

+ func (x *KeyRange) GetEndClosed() *structpb.ListValue

+ func (x *KeyRange) GetEndOpen() *structpb.ListValue

+ func (x *KeyRange) GetStartClosed() *structpb.ListValue

+ func (x *KeyRange) GetStartOpen() *structpb.ListValue

+ func (x *KeyRange) ProtoReflect() protoreflect.Message

+ func (x *KeyRange) Reset()

+ func (x *KeyRange) String() string

+ type KeyRange_EndClosed struct

+ EndClosed *structpb.ListValue

+ type KeyRange_EndOpen struct

+ EndOpen *structpb.ListValue

+ type KeyRange_StartClosed struct

+ StartClosed *structpb.ListValue

+ type KeyRange_StartOpen struct

+ StartOpen *structpb.ListValue

+ type KeySet struct

+ All bool

+ Keys []*structpb.ListValue

+ Ranges []*KeyRange

+ func (*KeySet) Descriptor() ([]byte, []int)

+ func (*KeySet) ProtoMessage()

+ func (x *KeySet) GetAll() bool

+ func (x *KeySet) GetKeys() []*structpb.ListValue

+ func (x *KeySet) GetRanges() []*KeyRange

+ func (x *KeySet) ProtoReflect() protoreflect.Message

+ func (x *KeySet) Reset()

+ func (x *KeySet) String() string

+ type ListSessionsRequest struct

+ Database string

+ Filter string

+ PageSize int32

+ PageToken string

+ func (*ListSessionsRequest) Descriptor() ([]byte, []int)

+ func (*ListSessionsRequest) ProtoMessage()

+ func (x *ListSessionsRequest) GetDatabase() string

+ func (x *ListSessionsRequest) GetFilter() string

+ func (x *ListSessionsRequest) GetPageSize() int32

+ func (x *ListSessionsRequest) GetPageToken() string

+ func (x *ListSessionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSessionsRequest) Reset()

+ func (x *ListSessionsRequest) String() string

+ type ListSessionsResponse struct

+ NextPageToken string

+ Sessions []*Session

+ func (*ListSessionsResponse) Descriptor() ([]byte, []int)

+ func (*ListSessionsResponse) ProtoMessage()

+ func (x *ListSessionsResponse) GetNextPageToken() string

+ func (x *ListSessionsResponse) GetSessions() []*Session

+ func (x *ListSessionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSessionsResponse) Reset()

+ func (x *ListSessionsResponse) String() string

+ type Mutation struct

+ Operation isMutation_Operation

+ func (*Mutation) Descriptor() ([]byte, []int)

+ func (*Mutation) ProtoMessage()

+ func (m *Mutation) GetOperation() isMutation_Operation

+ func (x *Mutation) GetDelete() *Mutation_Delete

+ func (x *Mutation) GetInsert() *Mutation_Write

+ func (x *Mutation) GetInsertOrUpdate() *Mutation_Write

+ func (x *Mutation) GetReplace() *Mutation_Write

+ func (x *Mutation) GetUpdate() *Mutation_Write

+ func (x *Mutation) ProtoReflect() protoreflect.Message

+ func (x *Mutation) Reset()

+ func (x *Mutation) String() string

+ type Mutation_Delete struct

+ KeySet *KeySet

+ Table string

+ func (*Mutation_Delete) Descriptor() ([]byte, []int)

+ func (*Mutation_Delete) ProtoMessage()

+ func (x *Mutation_Delete) GetKeySet() *KeySet

+ func (x *Mutation_Delete) GetTable() string

+ func (x *Mutation_Delete) ProtoReflect() protoreflect.Message

+ func (x *Mutation_Delete) Reset()

+ func (x *Mutation_Delete) String() string

+ type Mutation_Delete_ struct

+ Delete *Mutation_Delete

+ type Mutation_Insert struct

+ Insert *Mutation_Write

+ type Mutation_InsertOrUpdate struct

+ InsertOrUpdate *Mutation_Write

+ type Mutation_Replace struct

+ Replace *Mutation_Write

+ type Mutation_Update struct

+ Update *Mutation_Write

+ type Mutation_Write struct

+ Columns []string

+ Table string

+ Values []*structpb.ListValue

+ func (*Mutation_Write) Descriptor() ([]byte, []int)

+ func (*Mutation_Write) ProtoMessage()

+ func (x *Mutation_Write) GetColumns() []string

+ func (x *Mutation_Write) GetTable() string

+ func (x *Mutation_Write) GetValues() []*structpb.ListValue

+ func (x *Mutation_Write) ProtoReflect() protoreflect.Message

+ func (x *Mutation_Write) Reset()

+ func (x *Mutation_Write) String() string

+ type PartialResultSet struct

+ ChunkedValue bool

+ Metadata *ResultSetMetadata

+ ResumeToken []byte

+ Stats *ResultSetStats

+ Values []*structpb.Value

+ func (*PartialResultSet) Descriptor() ([]byte, []int)

+ func (*PartialResultSet) ProtoMessage()

+ func (x *PartialResultSet) GetChunkedValue() bool

+ func (x *PartialResultSet) GetMetadata() *ResultSetMetadata

+ func (x *PartialResultSet) GetResumeToken() []byte

+ func (x *PartialResultSet) GetStats() *ResultSetStats

+ func (x *PartialResultSet) GetValues() []*structpb.Value

+ func (x *PartialResultSet) ProtoReflect() protoreflect.Message

+ func (x *PartialResultSet) Reset()

+ func (x *PartialResultSet) String() string

+ type Partition struct

+ PartitionToken []byte

+ func (*Partition) Descriptor() ([]byte, []int)

+ func (*Partition) ProtoMessage()

+ func (x *Partition) GetPartitionToken() []byte

+ func (x *Partition) ProtoReflect() protoreflect.Message

+ func (x *Partition) Reset()

+ func (x *Partition) String() string

+ type PartitionOptions struct

+ MaxPartitions int64

+ PartitionSizeBytes int64

+ func (*PartitionOptions) Descriptor() ([]byte, []int)

+ func (*PartitionOptions) ProtoMessage()

+ func (x *PartitionOptions) GetMaxPartitions() int64

+ func (x *PartitionOptions) GetPartitionSizeBytes() int64

+ func (x *PartitionOptions) ProtoReflect() protoreflect.Message

+ func (x *PartitionOptions) Reset()

+ func (x *PartitionOptions) String() string

+ type PartitionQueryRequest struct

+ ParamTypes map[string]*Type

+ Params *structpb.Struct

+ PartitionOptions *PartitionOptions

+ Session string

+ Sql string

+ Transaction *TransactionSelector

+ func (*PartitionQueryRequest) Descriptor() ([]byte, []int)

+ func (*PartitionQueryRequest) ProtoMessage()

+ func (x *PartitionQueryRequest) GetParamTypes() map[string]*Type

+ func (x *PartitionQueryRequest) GetParams() *structpb.Struct

+ func (x *PartitionQueryRequest) GetPartitionOptions() *PartitionOptions

+ func (x *PartitionQueryRequest) GetSession() string

+ func (x *PartitionQueryRequest) GetSql() string

+ func (x *PartitionQueryRequest) GetTransaction() *TransactionSelector

+ func (x *PartitionQueryRequest) ProtoReflect() protoreflect.Message

+ func (x *PartitionQueryRequest) Reset()

+ func (x *PartitionQueryRequest) String() string

+ type PartitionReadRequest struct

+ Columns []string

+ Index string

+ KeySet *KeySet

+ PartitionOptions *PartitionOptions

+ Session string

+ Table string

+ Transaction *TransactionSelector

+ func (*PartitionReadRequest) Descriptor() ([]byte, []int)

+ func (*PartitionReadRequest) ProtoMessage()

+ func (x *PartitionReadRequest) GetColumns() []string

+ func (x *PartitionReadRequest) GetIndex() string

+ func (x *PartitionReadRequest) GetKeySet() *KeySet

+ func (x *PartitionReadRequest) GetPartitionOptions() *PartitionOptions

+ func (x *PartitionReadRequest) GetSession() string

+ func (x *PartitionReadRequest) GetTable() string

+ func (x *PartitionReadRequest) GetTransaction() *TransactionSelector

+ func (x *PartitionReadRequest) ProtoReflect() protoreflect.Message

+ func (x *PartitionReadRequest) Reset()

+ func (x *PartitionReadRequest) String() string

+ type PartitionResponse struct

+ Partitions []*Partition

+ Transaction *Transaction

+ func (*PartitionResponse) Descriptor() ([]byte, []int)

+ func (*PartitionResponse) ProtoMessage()

+ func (x *PartitionResponse) GetPartitions() []*Partition

+ func (x *PartitionResponse) GetTransaction() *Transaction

+ func (x *PartitionResponse) ProtoReflect() protoreflect.Message

+ func (x *PartitionResponse) Reset()

+ func (x *PartitionResponse) String() string

+ type PlanNode struct

+ ChildLinks []*PlanNode_ChildLink

+ DisplayName string

+ ExecutionStats *structpb.Struct

+ Index int32

+ Kind PlanNode_Kind

+ Metadata *structpb.Struct

+ ShortRepresentation *PlanNode_ShortRepresentation

+ func (*PlanNode) Descriptor() ([]byte, []int)

+ func (*PlanNode) ProtoMessage()

+ func (x *PlanNode) GetChildLinks() []*PlanNode_ChildLink

+ func (x *PlanNode) GetDisplayName() string

+ func (x *PlanNode) GetExecutionStats() *structpb.Struct

+ func (x *PlanNode) GetIndex() int32

+ func (x *PlanNode) GetKind() PlanNode_Kind

+ func (x *PlanNode) GetMetadata() *structpb.Struct

+ func (x *PlanNode) GetShortRepresentation() *PlanNode_ShortRepresentation

+ func (x *PlanNode) ProtoReflect() protoreflect.Message

+ func (x *PlanNode) Reset()

+ func (x *PlanNode) String() string

+ type PlanNode_ChildLink struct

+ ChildIndex int32

+ Type string

+ Variable string

+ func (*PlanNode_ChildLink) Descriptor() ([]byte, []int)

+ func (*PlanNode_ChildLink) ProtoMessage()

+ func (x *PlanNode_ChildLink) GetChildIndex() int32

+ func (x *PlanNode_ChildLink) GetType() string

+ func (x *PlanNode_ChildLink) GetVariable() string

+ func (x *PlanNode_ChildLink) ProtoReflect() protoreflect.Message

+ func (x *PlanNode_ChildLink) Reset()

+ func (x *PlanNode_ChildLink) String() string

+ type PlanNode_Kind int32

+ const PlanNode_KIND_UNSPECIFIED

+ const PlanNode_RELATIONAL

+ const PlanNode_SCALAR

+ func (PlanNode_Kind) Descriptor() protoreflect.EnumDescriptor

+ func (PlanNode_Kind) EnumDescriptor() ([]byte, []int)

+ func (PlanNode_Kind) Type() protoreflect.EnumType

+ func (x PlanNode_Kind) Enum() *PlanNode_Kind

+ func (x PlanNode_Kind) Number() protoreflect.EnumNumber

+ func (x PlanNode_Kind) String() string

+ type PlanNode_ShortRepresentation struct

+ Description string

+ Subqueries map[string]int32

+ func (*PlanNode_ShortRepresentation) Descriptor() ([]byte, []int)

+ func (*PlanNode_ShortRepresentation) ProtoMessage()

+ func (x *PlanNode_ShortRepresentation) GetDescription() string

+ func (x *PlanNode_ShortRepresentation) GetSubqueries() map[string]int32

+ func (x *PlanNode_ShortRepresentation) ProtoReflect() protoreflect.Message

+ func (x *PlanNode_ShortRepresentation) Reset()

+ func (x *PlanNode_ShortRepresentation) String() string

+ type QueryPlan struct

+ PlanNodes []*PlanNode

+ func (*QueryPlan) Descriptor() ([]byte, []int)

+ func (*QueryPlan) ProtoMessage()

+ func (x *QueryPlan) GetPlanNodes() []*PlanNode

+ func (x *QueryPlan) ProtoReflect() protoreflect.Message

+ func (x *QueryPlan) Reset()

+ func (x *QueryPlan) String() string

+ type ReadRequest struct

+ Columns []string

+ Index string

+ KeySet *KeySet

+ Limit int64

+ PartitionToken []byte

+ RequestOptions *RequestOptions

+ ResumeToken []byte

+ Session string

+ Table string

+ Transaction *TransactionSelector

+ func (*ReadRequest) Descriptor() ([]byte, []int)

+ func (*ReadRequest) ProtoMessage()

+ func (x *ReadRequest) GetColumns() []string

+ func (x *ReadRequest) GetIndex() string

+ func (x *ReadRequest) GetKeySet() *KeySet

+ func (x *ReadRequest) GetLimit() int64

+ func (x *ReadRequest) GetPartitionToken() []byte

+ func (x *ReadRequest) GetRequestOptions() *RequestOptions

+ func (x *ReadRequest) GetResumeToken() []byte

+ func (x *ReadRequest) GetSession() string

+ func (x *ReadRequest) GetTable() string

+ func (x *ReadRequest) GetTransaction() *TransactionSelector

+ func (x *ReadRequest) ProtoReflect() protoreflect.Message

+ func (x *ReadRequest) Reset()

+ func (x *ReadRequest) String() string

+ type RequestOptions struct

+ Priority RequestOptions_Priority

+ RequestTag string

+ TransactionTag string

+ func (*RequestOptions) Descriptor() ([]byte, []int)

+ func (*RequestOptions) ProtoMessage()

+ func (x *RequestOptions) GetPriority() RequestOptions_Priority

+ func (x *RequestOptions) GetRequestTag() string

+ func (x *RequestOptions) GetTransactionTag() string

+ func (x *RequestOptions) ProtoReflect() protoreflect.Message

+ func (x *RequestOptions) Reset()

+ func (x *RequestOptions) String() string

+ type RequestOptions_Priority int32

+ const RequestOptions_PRIORITY_HIGH

+ const RequestOptions_PRIORITY_LOW

+ const RequestOptions_PRIORITY_MEDIUM

+ const RequestOptions_PRIORITY_UNSPECIFIED

+ func (RequestOptions_Priority) Descriptor() protoreflect.EnumDescriptor

+ func (RequestOptions_Priority) EnumDescriptor() ([]byte, []int)

+ func (RequestOptions_Priority) Type() protoreflect.EnumType

+ func (x RequestOptions_Priority) Enum() *RequestOptions_Priority

+ func (x RequestOptions_Priority) Number() protoreflect.EnumNumber

+ func (x RequestOptions_Priority) String() string

+ type ResultSet struct

+ Metadata *ResultSetMetadata

+ Rows []*structpb.ListValue

+ Stats *ResultSetStats

+ func (*ResultSet) Descriptor() ([]byte, []int)

+ func (*ResultSet) ProtoMessage()

+ func (x *ResultSet) GetMetadata() *ResultSetMetadata

+ func (x *ResultSet) GetRows() []*structpb.ListValue

+ func (x *ResultSet) GetStats() *ResultSetStats

+ func (x *ResultSet) ProtoReflect() protoreflect.Message

+ func (x *ResultSet) Reset()

+ func (x *ResultSet) String() string

+ type ResultSetMetadata struct

+ RowType *StructType

+ Transaction *Transaction

+ UndeclaredParameters *StructType

+ func (*ResultSetMetadata) Descriptor() ([]byte, []int)

+ func (*ResultSetMetadata) ProtoMessage()

+ func (x *ResultSetMetadata) GetRowType() *StructType

+ func (x *ResultSetMetadata) GetTransaction() *Transaction

+ func (x *ResultSetMetadata) GetUndeclaredParameters() *StructType

+ func (x *ResultSetMetadata) ProtoReflect() protoreflect.Message

+ func (x *ResultSetMetadata) Reset()

+ func (x *ResultSetMetadata) String() string

+ type ResultSetStats struct

+ QueryPlan *QueryPlan

+ QueryStats *structpb.Struct

+ RowCount isResultSetStats_RowCount

+ func (*ResultSetStats) Descriptor() ([]byte, []int)

+ func (*ResultSetStats) ProtoMessage()

+ func (m *ResultSetStats) GetRowCount() isResultSetStats_RowCount

+ func (x *ResultSetStats) GetQueryPlan() *QueryPlan

+ func (x *ResultSetStats) GetQueryStats() *structpb.Struct

+ func (x *ResultSetStats) GetRowCountExact() int64

+ func (x *ResultSetStats) GetRowCountLowerBound() int64

+ func (x *ResultSetStats) ProtoReflect() protoreflect.Message

+ func (x *ResultSetStats) Reset()

+ func (x *ResultSetStats) String() string

+ type ResultSetStats_RowCountExact struct

+ RowCountExact int64

+ type ResultSetStats_RowCountLowerBound struct

+ RowCountLowerBound int64

+ type RollbackRequest struct

+ Session string

+ TransactionId []byte

+ func (*RollbackRequest) Descriptor() ([]byte, []int)

+ func (*RollbackRequest) ProtoMessage()

+ func (x *RollbackRequest) GetSession() string

+ func (x *RollbackRequest) GetTransactionId() []byte

+ func (x *RollbackRequest) ProtoReflect() protoreflect.Message

+ func (x *RollbackRequest) Reset()

+ func (x *RollbackRequest) String() string

+ type Session struct

+ ApproximateLastUseTime *timestamppb.Timestamp

+ CreateTime *timestamppb.Timestamp

+ CreatorRole string

+ Labels map[string]string

+ Name string

+ func (*Session) Descriptor() ([]byte, []int)

+ func (*Session) ProtoMessage()

+ func (x *Session) GetApproximateLastUseTime() *timestamppb.Timestamp

+ func (x *Session) GetCreateTime() *timestamppb.Timestamp

+ func (x *Session) GetCreatorRole() string

+ func (x *Session) GetLabels() map[string]string

+ func (x *Session) GetName() string

+ func (x *Session) ProtoReflect() protoreflect.Message

+ func (x *Session) Reset()

+ func (x *Session) String() string

+ type SpannerClient interface

+ BatchCreateSessions func(ctx context.Context, in *BatchCreateSessionsRequest, opts ...grpc.CallOption) (*BatchCreateSessionsResponse, error)

+ BeginTransaction func(ctx context.Context, in *BeginTransactionRequest, opts ...grpc.CallOption) (*Transaction, error)

+ Commit func(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)

+ CreateSession func(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*Session, error)

+ DeleteSession func(ctx context.Context, in *DeleteSessionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ExecuteBatchDml func(ctx context.Context, in *ExecuteBatchDmlRequest, opts ...grpc.CallOption) (*ExecuteBatchDmlResponse, error)

+ ExecuteSql func(ctx context.Context, in *ExecuteSqlRequest, opts ...grpc.CallOption) (*ResultSet, error)

+ ExecuteStreamingSql func(ctx context.Context, in *ExecuteSqlRequest, opts ...grpc.CallOption) (Spanner_ExecuteStreamingSqlClient, error)

+ GetSession func(ctx context.Context, in *GetSessionRequest, opts ...grpc.CallOption) (*Session, error)

+ ListSessions func(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error)

+ PartitionQuery func(ctx context.Context, in *PartitionQueryRequest, opts ...grpc.CallOption) (*PartitionResponse, error)

+ PartitionRead func(ctx context.Context, in *PartitionReadRequest, opts ...grpc.CallOption) (*PartitionResponse, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ResultSet, error)

+ Rollback func(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ StreamingRead func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (Spanner_StreamingReadClient, error)

+ func NewSpannerClient(cc grpc.ClientConnInterface) SpannerClient

+ type SpannerServer interface

+ BatchCreateSessions func(context.Context, *BatchCreateSessionsRequest) (*BatchCreateSessionsResponse, error)

+ BeginTransaction func(context.Context, *BeginTransactionRequest) (*Transaction, error)

+ Commit func(context.Context, *CommitRequest) (*CommitResponse, error)

+ CreateSession func(context.Context, *CreateSessionRequest) (*Session, error)

+ DeleteSession func(context.Context, *DeleteSessionRequest) (*emptypb.Empty, error)

+ ExecuteBatchDml func(context.Context, *ExecuteBatchDmlRequest) (*ExecuteBatchDmlResponse, error)

+ ExecuteSql func(context.Context, *ExecuteSqlRequest) (*ResultSet, error)

+ ExecuteStreamingSql func(*ExecuteSqlRequest, Spanner_ExecuteStreamingSqlServer) error

+ GetSession func(context.Context, *GetSessionRequest) (*Session, error)

+ ListSessions func(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)

+ PartitionQuery func(context.Context, *PartitionQueryRequest) (*PartitionResponse, error)

+ PartitionRead func(context.Context, *PartitionReadRequest) (*PartitionResponse, error)

+ Read func(context.Context, *ReadRequest) (*ResultSet, error)

+ Rollback func(context.Context, *RollbackRequest) (*emptypb.Empty, error)

+ StreamingRead func(*ReadRequest, Spanner_StreamingReadServer) error

+ type Spanner_ExecuteStreamingSqlClient interface

+ Recv func() (*PartialResultSet, error)

+ type Spanner_ExecuteStreamingSqlServer interface

+ Send func(*PartialResultSet) error

+ type Spanner_StreamingReadClient interface

+ Recv func() (*PartialResultSet, error)

+ type Spanner_StreamingReadServer interface

+ Send func(*PartialResultSet) error

+ type StructType struct

+ Fields []*StructType_Field

+ func (*StructType) Descriptor() ([]byte, []int)

+ func (*StructType) ProtoMessage()

+ func (x *StructType) GetFields() []*StructType_Field

+ func (x *StructType) ProtoReflect() protoreflect.Message

+ func (x *StructType) Reset()

+ func (x *StructType) String() string

+ type StructType_Field struct

+ Name string

+ Type *Type

+ func (*StructType_Field) Descriptor() ([]byte, []int)

+ func (*StructType_Field) ProtoMessage()

+ func (x *StructType_Field) GetName() string

+ func (x *StructType_Field) GetType() *Type

+ func (x *StructType_Field) ProtoReflect() protoreflect.Message

+ func (x *StructType_Field) Reset()

+ func (x *StructType_Field) String() string

+ type Transaction struct

+ Id []byte

+ ReadTimestamp *timestamppb.Timestamp

+ func (*Transaction) Descriptor() ([]byte, []int)

+ func (*Transaction) ProtoMessage()

+ func (x *Transaction) GetId() []byte

+ func (x *Transaction) GetReadTimestamp() *timestamppb.Timestamp

+ func (x *Transaction) ProtoReflect() protoreflect.Message

+ func (x *Transaction) Reset()

+ func (x *Transaction) String() string

+ type TransactionOptions struct

+ Mode isTransactionOptions_Mode

+ func (*TransactionOptions) Descriptor() ([]byte, []int)

+ func (*TransactionOptions) ProtoMessage()

+ func (m *TransactionOptions) GetMode() isTransactionOptions_Mode

+ func (x *TransactionOptions) GetPartitionedDml() *TransactionOptions_PartitionedDml

+ func (x *TransactionOptions) GetReadOnly() *TransactionOptions_ReadOnly

+ func (x *TransactionOptions) GetReadWrite() *TransactionOptions_ReadWrite

+ func (x *TransactionOptions) ProtoReflect() protoreflect.Message

+ func (x *TransactionOptions) Reset()

+ func (x *TransactionOptions) String() string

+ type TransactionOptions_PartitionedDml struct

+ func (*TransactionOptions_PartitionedDml) Descriptor() ([]byte, []int)

+ func (*TransactionOptions_PartitionedDml) ProtoMessage()

+ func (x *TransactionOptions_PartitionedDml) ProtoReflect() protoreflect.Message

+ func (x *TransactionOptions_PartitionedDml) Reset()

+ func (x *TransactionOptions_PartitionedDml) String() string

+ type TransactionOptions_PartitionedDml_ struct

+ PartitionedDml *TransactionOptions_PartitionedDml

+ type TransactionOptions_ReadOnly struct

+ ReturnReadTimestamp bool

+ TimestampBound isTransactionOptions_ReadOnly_TimestampBound

+ func (*TransactionOptions_ReadOnly) Descriptor() ([]byte, []int)

+ func (*TransactionOptions_ReadOnly) ProtoMessage()

+ func (m *TransactionOptions_ReadOnly) GetTimestampBound() isTransactionOptions_ReadOnly_TimestampBound

+ func (x *TransactionOptions_ReadOnly) GetExactStaleness() *durationpb.Duration

+ func (x *TransactionOptions_ReadOnly) GetMaxStaleness() *durationpb.Duration

+ func (x *TransactionOptions_ReadOnly) GetMinReadTimestamp() *timestamppb.Timestamp

+ func (x *TransactionOptions_ReadOnly) GetReadTimestamp() *timestamppb.Timestamp

+ func (x *TransactionOptions_ReadOnly) GetReturnReadTimestamp() bool

+ func (x *TransactionOptions_ReadOnly) GetStrong() bool

+ func (x *TransactionOptions_ReadOnly) ProtoReflect() protoreflect.Message

+ func (x *TransactionOptions_ReadOnly) Reset()

+ func (x *TransactionOptions_ReadOnly) String() string

+ type TransactionOptions_ReadOnly_ struct

+ ReadOnly *TransactionOptions_ReadOnly

+ type TransactionOptions_ReadOnly_ExactStaleness struct

+ ExactStaleness *durationpb.Duration

+ type TransactionOptions_ReadOnly_MaxStaleness struct

+ MaxStaleness *durationpb.Duration

+ type TransactionOptions_ReadOnly_MinReadTimestamp struct

+ MinReadTimestamp *timestamppb.Timestamp

+ type TransactionOptions_ReadOnly_ReadTimestamp struct

+ ReadTimestamp *timestamppb.Timestamp

+ type TransactionOptions_ReadOnly_Strong struct

+ Strong bool

+ type TransactionOptions_ReadWrite struct

+ ReadLockMode TransactionOptions_ReadWrite_ReadLockMode

+ func (*TransactionOptions_ReadWrite) Descriptor() ([]byte, []int)

+ func (*TransactionOptions_ReadWrite) ProtoMessage()

+ func (x *TransactionOptions_ReadWrite) GetReadLockMode() TransactionOptions_ReadWrite_ReadLockMode

+ func (x *TransactionOptions_ReadWrite) ProtoReflect() protoreflect.Message

+ func (x *TransactionOptions_ReadWrite) Reset()

+ func (x *TransactionOptions_ReadWrite) String() string

+ type TransactionOptions_ReadWrite_ struct

+ ReadWrite *TransactionOptions_ReadWrite

+ type TransactionOptions_ReadWrite_ReadLockMode int32

+ const TransactionOptions_ReadWrite_OPTIMISTIC

+ const TransactionOptions_ReadWrite_PESSIMISTIC

+ const TransactionOptions_ReadWrite_READ_LOCK_MODE_UNSPECIFIED

+ func (TransactionOptions_ReadWrite_ReadLockMode) Descriptor() protoreflect.EnumDescriptor

+ func (TransactionOptions_ReadWrite_ReadLockMode) EnumDescriptor() ([]byte, []int)

+ func (TransactionOptions_ReadWrite_ReadLockMode) Type() protoreflect.EnumType

+ func (x TransactionOptions_ReadWrite_ReadLockMode) Enum() *TransactionOptions_ReadWrite_ReadLockMode

+ func (x TransactionOptions_ReadWrite_ReadLockMode) Number() protoreflect.EnumNumber

+ func (x TransactionOptions_ReadWrite_ReadLockMode) String() string

+ type TransactionSelector struct

+ Selector isTransactionSelector_Selector

+ func (*TransactionSelector) Descriptor() ([]byte, []int)

+ func (*TransactionSelector) ProtoMessage()

+ func (m *TransactionSelector) GetSelector() isTransactionSelector_Selector

+ func (x *TransactionSelector) GetBegin() *TransactionOptions

+ func (x *TransactionSelector) GetId() []byte

+ func (x *TransactionSelector) GetSingleUse() *TransactionOptions

+ func (x *TransactionSelector) ProtoReflect() protoreflect.Message

+ func (x *TransactionSelector) Reset()

+ func (x *TransactionSelector) String() string

+ type TransactionSelector_Begin struct

+ Begin *TransactionOptions

+ type TransactionSelector_Id struct

+ Id []byte

+ type TransactionSelector_SingleUse struct

+ SingleUse *TransactionOptions

+ type Type struct

+ ArrayElementType *Type

+ Code TypeCode

+ StructType *StructType

+ TypeAnnotation TypeAnnotationCode

+ func (*Type) Descriptor() ([]byte, []int)

+ func (*Type) ProtoMessage()

+ func (x *Type) GetArrayElementType() *Type

+ func (x *Type) GetCode() TypeCode

+ func (x *Type) GetStructType() *StructType

+ func (x *Type) GetTypeAnnotation() TypeAnnotationCode

+ func (x *Type) ProtoReflect() protoreflect.Message

+ func (x *Type) Reset()

+ func (x *Type) String() string

+ type TypeAnnotationCode int32

+ const TypeAnnotationCode_PG_JSONB

+ const TypeAnnotationCode_PG_NUMERIC

+ const TypeAnnotationCode_TYPE_ANNOTATION_CODE_UNSPECIFIED

+ func (TypeAnnotationCode) Descriptor() protoreflect.EnumDescriptor

+ func (TypeAnnotationCode) EnumDescriptor() ([]byte, []int)

+ func (TypeAnnotationCode) Type() protoreflect.EnumType

+ func (x TypeAnnotationCode) Enum() *TypeAnnotationCode

+ func (x TypeAnnotationCode) Number() protoreflect.EnumNumber

+ func (x TypeAnnotationCode) String() string

+ type TypeCode int32

+ const TypeCode_ARRAY

+ const TypeCode_BOOL

+ const TypeCode_BYTES

+ const TypeCode_DATE

+ const TypeCode_FLOAT64

+ const TypeCode_INT64

+ const TypeCode_JSON

+ const TypeCode_NUMERIC

+ const TypeCode_STRING

+ const TypeCode_STRUCT

+ const TypeCode_TIMESTAMP

+ const TypeCode_TYPE_CODE_UNSPECIFIED

+ func (TypeCode) Descriptor() protoreflect.EnumDescriptor

+ func (TypeCode) EnumDescriptor() ([]byte, []int)

+ func (TypeCode) Type() protoreflect.EnumType

+ func (x TypeCode) Enum() *TypeCode

+ func (x TypeCode) Number() protoreflect.EnumNumber

+ func (x TypeCode) String() string

+ type UnimplementedSpannerServer struct

+ func (*UnimplementedSpannerServer) BatchCreateSessions(context.Context, *BatchCreateSessionsRequest) (*BatchCreateSessionsResponse, error)

+ func (*UnimplementedSpannerServer) BeginTransaction(context.Context, *BeginTransactionRequest) (*Transaction, error)

+ func (*UnimplementedSpannerServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error)

+ func (*UnimplementedSpannerServer) CreateSession(context.Context, *CreateSessionRequest) (*Session, error)

+ func (*UnimplementedSpannerServer) DeleteSession(context.Context, *DeleteSessionRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSpannerServer) ExecuteBatchDml(context.Context, *ExecuteBatchDmlRequest) (*ExecuteBatchDmlResponse, error)

+ func (*UnimplementedSpannerServer) ExecuteSql(context.Context, *ExecuteSqlRequest) (*ResultSet, error)

+ func (*UnimplementedSpannerServer) ExecuteStreamingSql(*ExecuteSqlRequest, Spanner_ExecuteStreamingSqlServer) error

+ func (*UnimplementedSpannerServer) GetSession(context.Context, *GetSessionRequest) (*Session, error)

+ func (*UnimplementedSpannerServer) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)

+ func (*UnimplementedSpannerServer) PartitionQuery(context.Context, *PartitionQueryRequest) (*PartitionResponse, error)

+ func (*UnimplementedSpannerServer) PartitionRead(context.Context, *PartitionReadRequest) (*PartitionResponse, error)

+ func (*UnimplementedSpannerServer) Read(context.Context, *ReadRequest) (*ResultSet, error)

+ func (*UnimplementedSpannerServer) Rollback(context.Context, *RollbackRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSpannerServer) StreamingRead(*ReadRequest, Spanner_StreamingReadServer) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL