service

package
v3.15.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 25, 2018 License: Apache-2.0, Apache-2.0 Imports: 21 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL