Versions in this module Expand all Collapse all v0 v0.7.0 Mar 10, 2017 Changes in this version + var KvMeta = sppb.ResultSetMetadata + func DecodeResumeToken(t []byte) (uint64, error) + func EncodeResumeToken(t uint64) []byte + type Action struct + func NewAction(m string, e error) Action + type MockCloudSpanner struct + func NewMockCloudSpanner(t *testing.T, ts time.Time) *MockCloudSpanner + func (m *MockCloudSpanner) AddMsg(err error, resumeToken bool) + func (m *MockCloudSpanner) Addr() string + func (m *MockCloudSpanner) BeginTransaction(c context.Context, r *sppb.BeginTransactionRequest) (*sppb.Transaction, error) + func (m *MockCloudSpanner) Commit(c context.Context, r *sppb.CommitRequest) (*sppb.CommitResponse, error) + func (m *MockCloudSpanner) CreateSession(c context.Context, r *sppb.CreateSessionRequest) (*sppb.Session, error) + func (m *MockCloudSpanner) DeleteSession(c context.Context, r *sppb.DeleteSessionRequest) (*empty.Empty, error) + func (m *MockCloudSpanner) Done() + func (m *MockCloudSpanner) ExecuteSql(c context.Context, r *sppb.ExecuteSqlRequest) (*sppb.ResultSet, error) + func (m *MockCloudSpanner) ExecuteStreamingSql(r *sppb.ExecuteSqlRequest, s sppb.Spanner_ExecuteStreamingSqlServer) error + func (m *MockCloudSpanner) GetSession(c context.Context, r *sppb.GetSessionRequest) (*sppb.Session, error) + func (m *MockCloudSpanner) Read(c context.Context, r *sppb.ReadRequest) (*sppb.ResultSet, error) + func (m *MockCloudSpanner) Rollback(c context.Context, r *sppb.RollbackRequest) (*empty.Empty, error) + func (m *MockCloudSpanner) Serve() + func (m *MockCloudSpanner) Stop() + func (m *MockCloudSpanner) StreamingRead(r *sppb.ReadRequest, s sppb.Spanner_StreamingReadServer) error + type MockCloudSpannerClient struct + func NewMockCloudSpannerClient(t *testing.T, acts ...Action) *MockCloudSpannerClient + func (m *MockCloudSpannerClient) BeginTransaction(c context.Context, r *sppb.BeginTransactionRequest, opts ...grpc.CallOption) (*sppb.Transaction, error) + func (m *MockCloudSpannerClient) Commit(c context.Context, r *sppb.CommitRequest, opts ...grpc.CallOption) (*sppb.CommitResponse, error) + func (m *MockCloudSpannerClient) CreateSession(c context.Context, r *sppb.CreateSessionRequest, opts ...grpc.CallOption) (*sppb.Session, error) + func (m *MockCloudSpannerClient) DeleteSession(c context.Context, r *sppb.DeleteSessionRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (m *MockCloudSpannerClient) DumpPings() []string + func (m *MockCloudSpannerClient) DumpSessions() map[string]bool + func (m *MockCloudSpannerClient) ExecuteSql(c context.Context, r *sppb.ExecuteSqlRequest, opts ...grpc.CallOption) (*sppb.ResultSet, error) + func (m *MockCloudSpannerClient) ExecuteStreamingSql(c context.Context, r *sppb.ExecuteSqlRequest, opts ...grpc.CallOption) (sppb.Spanner_ExecuteStreamingSqlClient, error) + func (m *MockCloudSpannerClient) GetSession(c context.Context, r *sppb.GetSessionRequest, opts ...grpc.CallOption) (*sppb.Session, error) + func (m *MockCloudSpannerClient) InjectError(method string, err error) + func (m *MockCloudSpannerClient) MakeNice() + func (m *MockCloudSpannerClient) MakeStrict() + func (m *MockCloudSpannerClient) Read(c context.Context, r *sppb.ReadRequest, opts ...grpc.CallOption) (*sppb.ResultSet, error) + func (m *MockCloudSpannerClient) Rollback(c context.Context, r *sppb.RollbackRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (m *MockCloudSpannerClient) SetActions(acts ...Action) + func (m *MockCloudSpannerClient) StreamingRead(c context.Context, r *sppb.ReadRequest, opts ...grpc.CallOption) (sppb.Spanner_StreamingReadClient, error) + type MockCtlMsg struct + Err error + ResumeToken bool
Go to main page