discoverlocal

README

统计服务发现请求到本地

测试

1. 功能测试： 正常

2. 压力测试： 存入服务数量及写入文件耗时：

   === RUN   TestWriteFile
          local_test.go:52: total num is 250000, duration is 175.246112ms
          local_test.go:52: total num is 500000, duration is 361.50121ms
          local_test.go:52: total num is 1000000, duration is 842.463092ms
          local_test.go:52: total num is 1500000, duration is 1.305463751s
      --- PASS: TestWriteFile (5.66s)
      PASS
   
      Process finished with exit code 0
   

   写入channel测试： channel大小为1024，并发1000，可以支持10w/s的AddDiscoverCall请求

Documentation

Index

• Constants
• type DiscoverCall
• type DiscoverCallStatis
• type DiscoverStatisWorker
  • func (d *DiscoverStatisWorker) AddDiscoverCall(service, namespace string, tt time.Time) error
  • func (d *DiscoverStatisWorker) Destroy() error
  • func (d *DiscoverStatisWorker) Initialize(conf *plugin.ConfigEntry) error
  • func (d *DiscoverStatisWorker) Name() string
  • func (d *DiscoverStatisWorker) Run()
• type Service

Constants

const (
	PluginName = "discoverLocal"
)

Types

type DiscoverCall

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

DiscoverCall 服务发现统计

type DiscoverCallStatis

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

DiscoverCallStatis 服务发现统计条目

type DiscoverStatisWorker

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

DiscoverStatisWorker 服务发现统计插件

func (*DiscoverStatisWorker) AddDiscoverCall

func (d *DiscoverStatisWorker) AddDiscoverCall(service, namespace string, tt time.Time) error

AddDiscoverCall 上报请求

func (*DiscoverStatisWorker) Destroy

func (d *DiscoverStatisWorker) Destroy() error

Destroy 销毁服务发现统计插件

func (*DiscoverStatisWorker) Initialize

func (d *DiscoverStatisWorker) Initialize(conf *plugin.ConfigEntry) error

Initialize 初始化服务发现统计插件

func (*DiscoverStatisWorker) Name

func (d *DiscoverStatisWorker) Name() string

Name 获取插件名称

func (*DiscoverStatisWorker) Run

func (d *DiscoverStatisWorker) Run()

Run 运行服务发现统计插件

type Service

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

Service 服务