Documentation
¶
Index ¶
- Variables
- func DecodeResumeToken(t []byte) (uint64, error)
- func EncodeResumeToken(t uint64) []byte
- type MockCloudSpanner
- func (m *MockCloudSpanner) AddMsg(err error, resumeToken bool)
- func (m *MockCloudSpanner) Addr() string
- func (m *MockCloudSpanner) BeginTransaction(_ context.Context, r *sppb.BeginTransactionRequest) (*sppb.Transaction, 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) 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) Serve()
- func (m *MockCloudSpanner) Stop()
- func (m *MockCloudSpanner) StreamingRead(r *sppb.ReadRequest, s sppb.Spanner_StreamingReadServer) error
- type MockCtlMsg
Constants ¶
This section is empty.
Variables ¶
var ( // KvMeta is the Metadata for mocked KV table. KvMeta = sppb.ResultSetMetadata{ RowType: &sppb.StructType{ Fields: []*sppb.StructType_Field{ { Name: "Key", Type: &sppb.Type{Code: sppb.TypeCode_STRING}, }, { Name: "Value", Type: &sppb.Type{Code: sppb.TypeCode_STRING}, }, }, }, } )
Functions ¶
func DecodeResumeToken ¶
DecodeResumeToken decodes a mock resume token into an uint64 integer.
func EncodeResumeToken ¶
EncodeResumeToken return mock resume token encoding for an uint64 integer.
Types ¶
type MockCloudSpanner ¶
type MockCloudSpanner struct {
sppb.SpannerServer
// contains filtered or unexported fields
}
MockCloudSpanner is a mock implementation of SpannerServer interface. TODO: make MockCloudSpanner a full-fleged Cloud Spanner implementation.
func NewMockCloudSpanner ¶
func NewMockCloudSpanner(t *testing.T, ts time.Time) *MockCloudSpanner
NewMockCloudSpanner creates a new MockCloudSpanner instance.
func (*MockCloudSpanner) AddMsg ¶
func (m *MockCloudSpanner) AddMsg(err error, resumeToken bool)
AddMsg generates a new mocked row which can be received by client.
func (*MockCloudSpanner) Addr ¶
func (m *MockCloudSpanner) Addr() string
Addr returns the listening address of mock server.
func (*MockCloudSpanner) BeginTransaction ¶
func (m *MockCloudSpanner) BeginTransaction(_ context.Context, r *sppb.BeginTransactionRequest) (*sppb.Transaction, error)
BeginTransaction is a placeholder for SpannerServer.BeginTransaction.
func (*MockCloudSpanner) CreateSession ¶
func (m *MockCloudSpanner) CreateSession(c context.Context, r *sppb.CreateSessionRequest) (*sppb.Session, error)
CreateSession is a placeholder for SpannerServer.CreateSession.
func (*MockCloudSpanner) DeleteSession ¶
func (m *MockCloudSpanner) DeleteSession(c context.Context, r *sppb.DeleteSessionRequest) (*empty.Empty, error)
DeleteSession is a placeholder for SpannerServer.DeleteSession.
func (*MockCloudSpanner) Done ¶
func (m *MockCloudSpanner) Done()
Done signals an end to a mocked stream.
func (*MockCloudSpanner) ExecuteStreamingSql ¶
func (m *MockCloudSpanner) ExecuteStreamingSql(r *sppb.ExecuteSqlRequest, s sppb.Spanner_ExecuteStreamingSqlServer) error
ExecuteStreamingSql is a mock implementation of SpannerServer.ExecuteStreamingSql.
func (*MockCloudSpanner) GetSession ¶
func (m *MockCloudSpanner) GetSession(c context.Context, r *sppb.GetSessionRequest) (*sppb.Session, error)
GetSession is a placeholder for SpannerServer.GetSession.
func (*MockCloudSpanner) Serve ¶
func (m *MockCloudSpanner) Serve()
Serve runs a MockCloudSpanner listening on a random localhost address.
func (*MockCloudSpanner) Stop ¶
func (m *MockCloudSpanner) Stop()
Stop terminates MockCloudSpanner and closes the serving port.
func (*MockCloudSpanner) StreamingRead ¶
func (m *MockCloudSpanner) StreamingRead(r *sppb.ReadRequest, s sppb.Spanner_StreamingReadServer) error
StreamingRead is a placeholder for SpannerServer.StreamingRead.
type MockCtlMsg ¶
type MockCtlMsg struct {
// If ResumeToken == true, mock server will generate a row with
// resume token.
ResumeToken bool
// If Err != nil, mock server will return error in RPC response.
Err error
}
MockCtlMsg encapsulates PartialResultSet/error that might be sent to client
Source Files