agents

Documentation

Index

• Constants
• func SendMonitor(msg []byte)
• type AgentNsq
  • func (this *AgentNsq) RunDestoryAgent()
• type DestroyAgent
  • func (h *DestroyAgent) HandleMessage(m *nsq.Message) error
• type MonitorAgent
  • func (h *MonitorAgent) HandleMessage(m *nsq.Message) error
  • func (this *MonitorAgent) Run()
• type RetriAgent
  • func (this *RetriAgent) Run()
• type RetriMsg

Constants

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

Functions

func SendMonitor

func SendMonitor(msg []byte)

Types

type AgentNsq

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

func (*AgentNsq) RunDestoryAgent

func (this *AgentNsq) RunDestoryAgent()

type DestroyAgent

type DestroyAgent struct{}

func (*DestroyAgent) HandleMessage

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

type MonitorAgent

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

func (*MonitorAgent) HandleMessage

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

func (*MonitorAgent) Run

func (this *MonitorAgent) Run()

type RetriAgent

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

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

func (*RetriAgent) Run

func (this *RetriAgent) Run()

type RetriMsg

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