mocksotrage

Documentation

Index

• type MockServer
  • func NewKVServer() (svr *MockServer, err error)
  • func (m *MockServer) Stop()
  • func (m *MockServer) Storage() *clientv3.Client
• type Storage
  • func New() *Storage
  • func (s *Storage) GetData() (data *pb.SyncData)
  • func (s *Storage) GetMapByCluster(clusterName string) (mapping pb.SyncMapping)
  • func (s *Storage) GetMaps() (mapping pb.SyncMapping)
  • func (s *Storage) UpdateData(data *pb.SyncData)
  • func (s *Storage) UpdateMapByCluster(clusterName string, mapping pb.SyncMapping)
  • func (s *Storage) UpdateMaps(maps pb.SyncMapping)

Types

type MockServer

type MockServer struct {
	// contains filtered or unexported fields
}

func NewKVServer

func NewKVServer() (svr *MockServer, err error)

func (*MockServer) Stop

func (m *MockServer) Stop()

func (*MockServer) Storage

func (m *MockServer) Storage() *clientv3.Client

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

Storage of Syncer

func New

func New() *Storage

func (*Storage) GetData

func (s *Storage) GetData() (data *pb.SyncData)

GetData Get data from storage

func (*Storage) GetMapByCluster

func (s *Storage) GetMapByCluster(clusterName string) (mapping pb.SyncMapping)

GetMapByCluster get map by clusterName of other cluster

func (*Storage) GetMaps

func (s *Storage) GetMaps() (mapping pb.SyncMapping)

GetMaps Get maps from storage

func (*Storage) UpdateData

func (s *Storage) UpdateData(data *pb.SyncData)

UpdateData Update data to storage

func (*Storage) UpdateMapByCluster

func (s *Storage) UpdateMapByCluster(clusterName string, mapping pb.SyncMapping)

UpdateMapByCluster update map to storage by clusterName of other cluster

func (*Storage) UpdateMaps

func (s *Storage) UpdateMaps(maps pb.SyncMapping)