Versions in this module Expand all Collapse all v1 v1.61.0 Apr 30, 2024 Changes in this version + const MethodBatchCreateSession + const MethodBatchWrite + 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 + var KvMeta = spannerpb.ResultSetMetadata + var XGoogClientHeaderChecker = &HeaderChecker + func CanReplay(replayFilename string) bool + func Credentials(ctx context.Context, scopes ...string) *google.Credentials + func CredentialsEnv(ctx context.Context, envVar string, scopes ...string) *google.Credentials + func DecodeResumeToken(t []byte) (uint64, error) + func Diff(x, y interface{}, opts ...cmp.Option) string + func EncodeResumeToken(t uint64) []byte + func Equal(x, y interface{}, opts ...cmp.Option) bool + func JWTConfig() (*jwt.Config, error) + func NewRand(t time.Time) *rand.Rand + func PageBounds(pageSize int, pageToken string, length int) (from, to int, nextPageToken string, err error) + func ProjID() string + func Retry(t *testing.T, maxAttempts int, sleep time.Duration, f func(r *R)) bool + func RetryWithoutTest(maxAttempts int, sleep time.Duration, f func(r *R)) bool + func TokenSource(ctx context.Context, scopes ...string) oauth2.TokenSource + func TokenSourceEnv(ctx context.Context, envVar string, scopes ...string) oauth2.TokenSource + type ErroringTokenSource struct + func (fts ErroringTokenSource) Token() (*oauth2.Token, error) + type HeaderChecker struct + Key string + ValuesValidator func(values ...string) error + type HeadersEnforcer struct + Checkers []*HeaderChecker + OnFailure func(fmt_ string, args ...interface{}) + func DefaultHeadersEnforcer() *HeadersEnforcer + func (h *HeadersEnforcer) CallOptions() (copts []option.ClientOption) + func (h *HeadersEnforcer) DialOptions() []grpc.DialOption + func (h *HeadersEnforcer) StreamInterceptors() []grpc.StreamClientInterceptor + func (h *HeadersEnforcer) UnaryInterceptors() []grpc.UnaryClientInterceptor + 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() + 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 + ServerAddress string + TestInstanceAdmin InMemInstanceAdminServer + TestSpanner InMemSpannerServer + func NewMockedSpannerInMemTestServer(t *testing.T, sopt ...grpc.ServerOption) (mockedServer *MockedSpannerInMemTestServer, opts []option.ClientOption, ...) + func NewMockedSpannerInMemTestServerWithAddr(t *testing.T, addr string, sopt ...grpc.ServerOption) (mockedServer *MockedSpannerInMemTestServer, opts []option.ClientOption, ...) + func (s *MockedSpannerInMemTestServer) CreateSingleRowSingersResult(rowNum int64) *StatementResult + type OpenTelemetryTestExporter struct + func NewOpenTelemetryTestExporter() *OpenTelemetryTestExporter + func (te *OpenTelemetryTestExporter) Spans() tracetest.SpanStubs + func (te *OpenTelemetryTestExporter) Unregister(ctx context.Context) + type PartialResultSetExecutionTime struct + Err error + ExecutionTime time.Duration + ResumeToken []byte + type R struct + Attempt int + func (r *R) Errorf(s string, v ...interface{}) + func (r *R) Fail() + func (r *R) Logf(s string, v ...interface{}) + type Server struct + Addr string + Gsrv *grpc.Server + Port int + func NewServer(opts ...grpc.ServerOption) (*Server, error) + func NewServerWithPort(port int, opts ...grpc.ServerOption) (*Server, error) + func (s *Server) Close() + func (s *Server) Start() + 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 + type TestExporter struct + Spans []*trace.SpanData + Stats chan *view.Data + Views []*view.View + func NewTestExporter(views ...*view.View) *TestExporter + func (te *TestExporter) ExportSpan(s *trace.SpanData) + func (te *TestExporter) ExportView(vd *view.Data) + func (te *TestExporter) Unregister()
Go to main page