testutil

Jun 5, 2025

Changes in this version

+ func CreateSelectDialectResultSet(dialect databasepb.DatabaseDialect) *spannerpb.ResultSet

+ func CreateSingleColumnStringResultSet(values []string, name string) *spannerpb.ResultSet

type MockedSpannerInMemTestServer

+ func (s *MockedSpannerInMemTestServer) SetupSelectDialectResult(dialect databasepb.DatabaseDialect)

Jan 30, 2025

Changes in this version

+ func CreateSingleColumnInt64ResultSet(values []int64, name string) *spannerpb.ResultSet

+ func CreateSingleColumnProtoResultSet(values [][]byte, name string) *spannerpb.ResultSet

Sep 15, 2022

Changes in this version

+ const MethodBatchCreateSession

+ const MethodBeginTransaction

+ const MethodCommitTransaction

+ const MethodCreateSession

+ const MethodDeleteSession

+ const MethodExecuteBatchDml

+ const MethodExecuteSql

+ const MethodExecuteStreamingSql

+ const MethodGetSession

+ const MethodStreamingRead

+ const SelectFooFromBar

+ const SelectSingerIDAlbumIDAlbumTitleFromAlbums

+ const SelectSingerIDAlbumIDAlbumTitleFromAlbumsColCount

+ const SelectSingerIDAlbumIDAlbumTitleFromAlbumsRowCount

+ const UpdateBarSetFoo

+ const UpdateBarSetFooRowCount

+ const UpdateSingersSetLastName

+ const UpdateSingersSetLastNameRowCount

+ var KvMeta = spannerpb.ResultSetMetadata

+ func CreateResultSetWithAllTypes(nullValues bool) *spannerpb.ResultSet

+ func CreateSelect1ResultSet() *spannerpb.ResultSet

+ func CreateSingleColumnResultSet(values []int64, name string) *spannerpb.ResultSet

+ func CreateTwoColumnResultSet(values [][2]int64, name [2]string) *spannerpb.ResultSet

+ func DecodeResumeToken(t []byte) (uint64, error)

+ func EncodeResumeToken(t uint64) []byte

+ type InMemDatabaseAdminServer interface

+ Reqs func() []proto.Message

+ Resps func() []proto.Message

+ SetErr func(error)

+ SetReqs func([]proto.Message)

+ SetResps func([]proto.Message)

+ Stop func()

+ func NewInMemDatabaseAdminServer() InMemDatabaseAdminServer

+ type InMemInstanceAdminServer interface

+ Reqs func() []proto.Message

+ Resps func() []proto.Message

+ SetErr func(error)

+ SetReqs func([]proto.Message)

+ SetResps func([]proto.Message)

+ Stop func()

+ func NewInMemInstanceAdminServer() InMemInstanceAdminServer

+ type InMemSpannerServer interface

+ AbortTransaction func(id []byte)

+ AddPartialResultSetError func(sql string, err PartialResultSetExecutionTime)

+ ClearPings func()

+ DumpPings func() []string

+ DumpSessions func() map[string]bool

+ Freeze func()

+ IsPartitionedDmlTransaction func(id []byte) bool

+ PutExecutionTime func(method string, executionTime SimulatedExecutionTime)

+ PutPartitionResult func(partitionToken []byte, result *StatementResult) error

+ PutStatementResult func(sql string, result *StatementResult) error

+ ReceivedRequests func() chan interface{}

+ RemoveStatementResult func(sql string)

+ Reset func()

+ SetError func(err error)

+ SetMaxSessionsReturnedByServerInTotal func(sessionCount int32)

+ SetMaxSessionsReturnedByServerPerBatchRequest func(sessionCount int32)

+ Stop func()

+ TotalSessionsCreated func() uint

+ TotalSessionsDeleted func() uint

+ Unfreeze func()

+ func NewInMemSpannerServer() InMemSpannerServer

+ type MockedSpannerInMemTestServer struct

+ Address string

+ TestDatabaseAdmin InMemDatabaseAdminServer

+ TestInstanceAdmin InMemInstanceAdminServer

+ TestSpanner InMemSpannerServer

+ func NewMockedSpannerInMemTestServer(t *testing.T) (mockedServer *MockedSpannerInMemTestServer, opts []option.ClientOption, ...)

+ func NewMockedSpannerInMemTestServerWithAddr(t *testing.T, addr string) (mockedServer *MockedSpannerInMemTestServer, opts []option.ClientOption, ...)

+ func (s *MockedSpannerInMemTestServer) CreateSingleRowSingersResult(rowNum int64) *StatementResult

+ type PartialResultSetExecutionTime struct

+ Err error

+ ExecutionTime time.Duration

+ ResumeToken []byte

+ type SimulatedExecutionTime struct

+ Errors []error

+ KeepError bool

+ MinimumExecutionTime time.Duration

+ RandomExecutionTime time.Duration

+ type StatementResult struct

+ Err error

+ ResultSet *spannerpb.ResultSet

+ ResumeTokens [][]byte

+ Type StatementResultType

+ UpdateCount int64

+ func (s *StatementResult) ToPartialResultSets(resumeToken []byte) (result []*spannerpb.PartialResultSet, err error)

+ type StatementResultType int

+ const MaxRowsPerPartialResultSet

+ const StatementResultError

+ const StatementResultResultSet

+ const StatementResultUpdateCount