agents

package

v0.6.7 Latest Latest Go to latest Published: Feb 26, 2018 License: GPL-3.0 Imports: 15 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	ModuleName       = "DDog-Agent-Nsq"
	DestoryAgent     = "DestoryAgent"
	MonitorAgentName = "MonitorAgent"
	RetriAgentName   = "RetriAgent"
)

This section is empty.

func SendMonitor(msg []byte)

type AgentNsq struct {
	Name        string
	NsqEndpoint string
	StopChan    chan int
}

func (this *AgentNsq) RunDestoryAgent()

type DestroyAgent struct{}

func (h *DestroyAgent) HandleMessage(m *nsq.Message) error

type MonitorAgent struct {
	Name        string
	NsqEndpoint string
	StopChan    chan int
}

func (h *MonitorAgent) HandleMessage(m *nsq.Message) error

func (this *MonitorAgent) Run()

type RetriAgent struct {
	Name        string
	NsqEndpoint string
	Namespace   []string
	StopChan    chan int
}

* RetriDog 在指定的命名空间中检索当前失败次数过多的服务实例当发现有失败次数太多的服务实例之后，RetriDog将会尝试获取失败原因，并且通知MonitorAgent.然后关闭异常服务实例，同时将服务实例状态调整为失败

func (this *RetriAgent) Run()

type RetriMsg struct {
	Name    string
	Svcname string
	Msg     string
	Count   int
}