mock

Documentation

Index

• type Component
• type MemStore
  • func NewMemStore() *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) error
  • func (m *MemStore) SQLMeta(meta *tipb.SQLMeta) error
  • func (m *MemStore) TopSQLRecord(instance, _ string, record *tipb.TopSQLRecord) error
• type MockPubSub
  • func NewMockPubSub() *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()

Types

type Component

type Component struct {
	Name string
	Addr string
}

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) Close

func (m *MemStore) Close()

func (*MemStore) Instances

func (m *MemStore) Instances(items []store.InstanceItem) error

func (*MemStore) PlanMeta

func (m *MemStore) PlanMeta(meta *tipb.PlanMeta) error

func (*MemStore) Pred

func (m *MemStore) Pred(pred func(*MemStore) bool, beginWaitTime time.Duration, maxWaitTime time.Duration) bool

func (*MemStore) ResourceMeteringRecord

func (m *MemStore) ResourceMeteringRecord(instance, _ string, record *rsmetering.ResourceUsageRecord) error

func (*MemStore) SQLMeta

func (m *MemStore) SQLMeta(meta *tipb.SQLMeta) error

func (*MemStore) TopSQLRecord

func (m *MemStore) TopSQLRecord(instance, _ string, record *tipb.TopSQLRecord) error

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) Listen

func (s *MockPubSub) Listen(addr string, tls *tls.Config) (ip string, port uint, err error)

func (*MockPubSub) Serve

func (s *MockPubSub) Serve() error

func (*MockPubSub) Stop

func (s *MockPubSub) Stop()