distribution

Documentation

Index

• type Distribution
  • func NewDistribution(etcdClient *clientv3.Client, conf conf.DiscoverConf, dis discover.Manager, ...) *Distribution
  • func (d *Distribution) GetSuitableInstance(serviceID string) *discover.Instance
  • func (d *Distribution) Start() error
  • func (d *Distribution) Stop()
  • func (d *Distribution) Update(m db.MonitorData)

Types

type Distribution

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

Distribution 数据分区

func NewDistribution

func NewDistribution(etcdClient *clientv3.Client, conf conf.DiscoverConf, dis discover.Manager, log *logrus.Entry) *Distribution

func (*Distribution) GetSuitableInstance

func (d *Distribution) GetSuitableInstance(serviceID string) *discover.Instance

GetSuitableInstance 获取推荐节点

func (*Distribution) Start

func (d *Distribution) Start() error

Start 开始健康监测

func (*Distribution) Stop

func (d *Distribution) Stop()

Stop 停止

func (*Distribution) Update

func (d *Distribution) Update(m db.MonitorData)

Update 更新监控数据