service

Documentation

Index

• Variables
• func BuiltinMetrics(hostname string, checksum string) (*model.NewBuiltinMetricResponse, error)
• func Expressions() ([]*model.NewExpression, error)
• func GetMysqlApiUrl() string
• func InitMysqlApiService(config *oHttp.RestfulClientConfig)
• func InitPackage(vpConfig *viper.Viper)
• func MinePlugins(hostname string) (*model.NewAgentPluginsResponse, error)
• func NewMysqlApiCli() *gentleman.Client
• func NewSlingBase() *sling.Sling
• func NqmAgentHeartbeat(req *nqmModel.HeartbeatRequest) (*nqmModel.AgentView, error)
• func NqmAgentHeartbeatTargetList(agentID int32) ([]*nqmModel.HeartbeatTarget, error)
• func Plugins(hostname string) ([]string, error)
• func SetMysqlApiUrl(cfg *oConfig.MysqlApiConfig)
• func Strategies() ([]*model.NewHostStrategy, error)
• func ToMysqlApiConfig(config *viper.Viper) *oConfig.MysqlApiConfig
• 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()

Variables

var (
	MysqlApiService oSrv.MysqlApiService
	ClientTimeout   = 3 * time.Second
)

Functions

func BuiltinMetrics

func BuiltinMetrics(hostname string, checksum string) (*model.NewBuiltinMetricResponse, error)

func Expressions

func Expressions() ([]*model.NewExpression, error)

func GetMysqlApiUrl

func GetMysqlApiUrl() string

func InitMysqlApiService

func InitMysqlApiService(config *oHttp.RestfulClientConfig)

func InitPackage

func InitPackage(vpConfig *viper.Viper)

func MinePlugins

func MinePlugins(hostname string) (*model.NewAgentPluginsResponse, error)

func NewMysqlApiCli

func NewMysqlApiCli() *gentleman.Client

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)

func Plugins

func Plugins(hostname string) ([]string, error)

func SetMysqlApiUrl

func SetMysqlApiUrl(cfg *oConfig.MysqlApiConfig)

func Strategies

func Strategies() ([]*model.NewHostStrategy, error)

func ToMysqlApiConfig

func ToMysqlApiConfig(config *viper.Viper) *oConfig.MysqlApiConfig

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()