Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotImplemented = errors.New("testutil: not implemented")
Functions ¶
This section is empty.
Types ¶
type Driver ¶
type Driver struct {
OnCall func(ctx context.Context, code MethodCode, req, res interface{}) error
OnStreamRead func(ctx context.Context, code MethodCode, req, res interface{}, process func(error)) error
OnClose func() error
}
type MethodCode ¶
type MethodCode uint
const ( UnknownMethod MethodCode = iota TableCreateSession TableDeleteSession TableKeepAlive TableCreateTable TableDropTable TableAlterTable TableCopyTable TableDescribeTable TableExplainDataQuery TablePrepareDataQuery TableExecuteDataQuery TableExecuteSchemeQuery TableBeginTransaction TableCommitTransaction TableRollbackTransaction TableDescribeTableOptions TableStreamReadTable TableStreamExecuteScanQuery )
func (MethodCode) String ¶
func (m MethodCode) String() string
type StubTicker ¶
type StubTicker struct {
// contains filtered or unexported fields
}
func (StubTicker) Destroy ¶
func (s StubTicker) Destroy()
func (*StubTicker) Emit ¶
func (s *StubTicker) Emit(t time.Time)
type TableBeginTransactionResult ¶
type TableBeginTransactionResult struct {
R interface{}
}
func (TableBeginTransactionResult) SetTransactionID ¶
func (t TableBeginTransactionResult) SetTransactionID(id string)
type TableCreateSessionResult ¶
type TableCreateSessionResult struct {
R interface{}
}
func (TableCreateSessionResult) SetSessionID ¶
func (t TableCreateSessionResult) SetSessionID(id string)
type TableExecuteDataQueryRequest ¶
type TableExecuteDataQueryRequest struct {
R interface{}
}
func (TableExecuteDataQueryRequest) KeepInCache ¶
func (t TableExecuteDataQueryRequest) KeepInCache() (keepInCache bool, ok bool)
func (TableExecuteDataQueryRequest) SessionID ¶
func (t TableExecuteDataQueryRequest) SessionID() (id string)
func (TableExecuteDataQueryRequest) TransactionID ¶
func (t TableExecuteDataQueryRequest) TransactionID() (id string, ok bool)
type TableExecuteDataQueryResult ¶
type TableExecuteDataQueryResult struct {
R interface{}
}
func (TableExecuteDataQueryResult) SetTransactionID ¶
func (t TableExecuteDataQueryResult) SetTransactionID(id string)
type TableKeepAliveResult ¶
type TableKeepAliveResult struct {
R interface{}
}
func (TableKeepAliveResult) SetSessionStatus ¶
func (t TableKeepAliveResult) SetSessionStatus(ready bool)
type TablePrepareDataQueryResult ¶
type TablePrepareDataQueryResult struct {
R interface{}
}
func (TablePrepareDataQueryResult) SetQueryID ¶
func (t TablePrepareDataQueryResult) SetQueryID(id string)
Source Files
Click to show internal directories.
Click to hide internal directories.