Documentation ¶
Index ¶
- type Component
- type MemStore
- func (m *MemStore) Close()
- func (m *MemStore) Instances(items []store.InstanceItem) error
- func (m *MemStore) PlanMeta(meta *tipb.PlanMeta) error
- func (m *MemStore) Pred(pred func(*MemStore) bool, beginWaitTime time.Duration, ...) bool
- func (m *MemStore) ResourceMeteringRecord(instance, _ string, record *rsmetering.ResourceUsageRecord, _ *sync.Map) error
- func (m *MemStore) SQLMeta(meta *tipb.SQLMeta) error
- func (m *MemStore) TopSQLRecord(instance, _ string, record *tipb.TopSQLRecord) error
- type MockPubSub
- func (s *MockPubSub) AccessTiDBStream(fn func(_ tipb.TopSQLPubSub_SubscribeServer) error)
- func (s *MockPubSub) AccessTiKVStream(fn func(_ rua.ResourceMeteringPubSub_SubscribeServer) error)
- func (s *MockPubSub) Listen(addr string, tls *tls.Config) (ip string, port uint, err error)
- func (s *MockPubSub) Serve() error
- func (s *MockPubSub) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MemStore ¶
type MemStore struct { sync.Mutex // instance -> value InstanceStore map[Component]struct{} // instance -> sql digest -> plan digest -> records TopSQLRecords map[string]map[string]map[string]*tipb.TopSQLRecord // instance -> resource tag -> records ResourceMeteringRecords map[string]map[string]*rsmetering.ResourceUsageRecord // SQL digest -> meta SQLMetas map[string]struct { Meta *tipb.SQLMeta } // plan digest -> meta PlanMetas map[string]struct { Meta *tipb.PlanMeta } }
func NewMemStore ¶
func NewMemStore() *MemStore
func (*MemStore) ResourceMeteringRecord ¶
func (m *MemStore) ResourceMeteringRecord(instance, _ string, record *rsmetering.ResourceUsageRecord, _ *sync.Map) error
func (*MemStore) TopSQLRecord ¶
type MockPubSub ¶
type MockPubSub struct {
// contains filtered or unexported fields
}
func NewMockPubSub ¶
func NewMockPubSub() *MockPubSub
func (*MockPubSub) AccessTiDBStream ¶
func (s *MockPubSub) AccessTiDBStream(fn func(_ tipb.TopSQLPubSub_SubscribeServer) error)
func (*MockPubSub) AccessTiKVStream ¶
func (s *MockPubSub) AccessTiKVStream(fn func(_ rua.ResourceMeteringPubSub_SubscribeServer) error)
func (*MockPubSub) Serve ¶
func (s *MockPubSub) Serve() error
func (*MockPubSub) Stop ¶
func (s *MockPubSub) Stop()
Click to show internal directories.
Click to hide internal directories.