admin

Documentation

Index

• Constants
• func AddSecondMonitor(all NodeMonitorData)
• func PointRPCRequest(module, serviceName string)
• func QueryMonitor(writer http.ResponseWriter, request *http.Request)
• type ConsulData
• type ConsulRegistry
  • func (r *ConsulRegistry) ActivateService(writer http.ResponseWriter, request *http.Request)
  • func (r *ConsulRegistry) ConsulList(writer http.ResponseWriter, request *http.Request)
  • func (r *ConsulRegistry) DeactivateService(writer http.ResponseWriter, request *http.Request)
  • func (r *ConsulRegistry) InitRegistry()
  • func (r *ConsulRegistry) PauseService(writer http.ResponseWriter, request *http.Request)
• type KeyValueMonitor
  • func (s *KeyValueMonitor) Inr()
• type MetaData
• type MonitorData
• type MonitorItem
• type NodeMonitorData
  • func AllMonitor() NodeMonitorData

Constants

const (
	TimeGroup10  = 10
	TimeGroup50  = 51
	TimeGroup100 = 102
	TimeGroup300 = 303
	TimeGroupMax = 1 << 30
)

const (
	ServiceMonitor = "service_monitor"
)

Functions

func AddSecondMonitor

func AddSecondMonitor(all NodeMonitorData)

func PointRPCRequest

func PointRPCRequest(module, serviceName string)

func QueryMonitor

func QueryMonitor(writer http.ResponseWriter, request *http.Request)

Types

type ConsulData

type ConsulData struct {
	ID         string      `json:"id"`
	ModuleName string      `json:"moduleName"`
	Address    string      `json:"address"`
	NodeId     string      `json:"nodeId"`
	Group      string      `json:"group"`
	Metadata   []*MetaData `json:"metadata"`
	Tags       []string    `json:"tags"`
}

type ConsulRegistry

type ConsulRegistry struct {
	StateCallBack func(name, address string, state client.ConsulServerState)
	// contains filtered or unexported fields
}

func (*ConsulRegistry) ActivateService

func (r *ConsulRegistry) ActivateService(writer http.ResponseWriter, request *http.Request)

func (*ConsulRegistry) ConsulList

func (r *ConsulRegistry) ConsulList(writer http.ResponseWriter, request *http.Request)

func (*ConsulRegistry) DeactivateService

func (r *ConsulRegistry) DeactivateService(writer http.ResponseWriter, request *http.Request)

func (*ConsulRegistry) InitRegistry

func (r *ConsulRegistry) InitRegistry()

func (*ConsulRegistry) PauseService

func (r *ConsulRegistry) PauseService(writer http.ResponseWriter, request *http.Request)

type KeyValueMonitor

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

func (*KeyValueMonitor) Inr

func (s *KeyValueMonitor) Inr()

type MetaData

type MetaData struct {
	Key  string `json:"key"`
	Data string `json:"data"`
}

type MonitorData

type MonitorData struct {
	Group  string        `json:"group"`
	Values []MonitorItem `json:"values"`
}

type MonitorItem

type MonitorItem struct {
	Key   string `json:"key"`
	Count int64  `json:"count"`
}

type NodeMonitorData

type NodeMonitorData struct {
	NodeId string        `json:"nodeId"`
	Data   []MonitorData `json:"data"`
}

func AllMonitor

func AllMonitor() NodeMonitorData