Documentation
¶
Index ¶
- type MockResponseWriter
- type MockTiDBServer
- func (s *MockTiDBServer) Listen() (addr string, err error)
- func (s *MockTiDBServer) PushRecords(records []tipb.TopSQLRecord)
- func (s *MockTiDBServer) Serve() error
- func (s *MockTiDBServer) Stop()
- func (s *MockTiDBServer) Subscribe(req *tipb.TopSQLSubRequest, stream tipb.TopSQLPubSub_SubscribeServer) error
- type MockTiKVServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockResponseWriter ¶
type MockResponseWriter struct {
StatusCode int
Body []byte
// contains filtered or unexported fields
}
func NewMockResponseWriter ¶
func NewMockResponseWriter() *MockResponseWriter
func (*MockResponseWriter) Header ¶
func (w *MockResponseWriter) Header() http.Header
func (*MockResponseWriter) WriteHeader ¶
func (w *MockResponseWriter) WriteHeader(statusCode int)
type MockTiDBServer ¶
type MockTiDBServer struct {
// contains filtered or unexported fields
}
func NewMockTiDBServer ¶
func NewMockTiDBServer() *MockTiDBServer
func (*MockTiDBServer) Listen ¶
func (s *MockTiDBServer) Listen() (addr string, err error)
func (*MockTiDBServer) PushRecords ¶
func (s *MockTiDBServer) PushRecords(records []tipb.TopSQLRecord)
func (*MockTiDBServer) Serve ¶
func (s *MockTiDBServer) Serve() error
func (*MockTiDBServer) Stop ¶
func (s *MockTiDBServer) Stop()
func (*MockTiDBServer) Subscribe ¶
func (s *MockTiDBServer) Subscribe(req *tipb.TopSQLSubRequest, stream tipb.TopSQLPubSub_SubscribeServer) error
type MockTiKVServer ¶
type MockTiKVServer struct {
// contains filtered or unexported fields
}
func NewMockTiKVServer ¶
func NewMockTiKVServer() *MockTiKVServer
func (*MockTiKVServer) Listen ¶
func (s *MockTiKVServer) Listen() (addr string, err error)
func (*MockTiKVServer) PushRecords ¶
func (s *MockTiKVServer) PushRecords(records []*rua.ResourceUsageRecord)
func (*MockTiKVServer) Serve ¶
func (s *MockTiKVServer) Serve() error
func (*MockTiKVServer) Stop ¶
func (s *MockTiKVServer) Stop()
func (*MockTiKVServer) Subscribe ¶
func (s *MockTiKVServer) Subscribe(req *rua.ResourceMeteringRequest, stream rua.ResourceMeteringPubSub_SubscribeServer) error
Source Files
Click to show internal directories.
Click to hide internal directories.