service

Documentation

Index

• func InitPackage(cfg *config.MysqlApiConfig, hosts string)
• func NewSlingBase() *sling.Sling
• func NqmAgentHeartbeat(req *nqmModel.HeartbeatRequest) (*nqmModel.AgentView, error)
• func NqmAgentHeartbeatTargetList(agentID int32) ([]*nqmModel.HeartbeatTarget, error)
• type AgentHeartbeatService
  • func NewAgentHeartbeatService(config *cQueue.Config) *AgentHeartbeatService
  • func (s *AgentHeartbeatService) CumulativeAgentsDropped() int64
  • func (s *AgentHeartbeatService) CumulativeAgentsPut() int64
  • func (s *AgentHeartbeatService) CumulativeRowsAffected() int64
  • func (s *AgentHeartbeatService) CurrentSize() int
  • func (s *AgentHeartbeatService) Put(req *cModel.AgentReportRequest, updateTime int64)
  • func (s *AgentHeartbeatService) Start()
  • func (s *AgentHeartbeatService) Stop()

Functions

func InitPackage

func InitPackage(cfg *config.MysqlApiConfig, hosts string)

func NewSlingBase

func NewSlingBase() *sling.Sling

func NqmAgentHeartbeat

func NqmAgentHeartbeat(req *nqmModel.HeartbeatRequest) (*nqmModel.AgentView, error)

func NqmAgentHeartbeatTargetList

func NqmAgentHeartbeatTargetList(agentID int32) ([]*nqmModel.HeartbeatTarget, error)

Types

type AgentHeartbeatService

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

func NewAgentHeartbeatService

func NewAgentHeartbeatService(config *cQueue.Config) *AgentHeartbeatService

func (*AgentHeartbeatService) CumulativeAgentsDropped

func (s *AgentHeartbeatService) CumulativeAgentsDropped() int64

func (*AgentHeartbeatService) CumulativeAgentsPut

func (s *AgentHeartbeatService) CumulativeAgentsPut() int64

func (*AgentHeartbeatService) CumulativeRowsAffected

func (s *AgentHeartbeatService) CumulativeRowsAffected() int64

func (*AgentHeartbeatService) CurrentSize

func (s *AgentHeartbeatService) CurrentSize() int

func (*AgentHeartbeatService) Put

func (s *AgentHeartbeatService) Put(req *cModel.AgentReportRequest, updateTime int64)

func (*AgentHeartbeatService) Start

func (s *AgentHeartbeatService) Start()

func (*AgentHeartbeatService) Stop

func (s *AgentHeartbeatService) Stop()