本文整理汇总了Golang中github.com/elastic/beats/metricbeat/mb.BaseMetricSet类的典型用法代码示例。如果您正苦于以下问题:Golang BaseMetricSet类的具体用法?Golang BaseMetricSet怎么用?Golang BaseMetricSet使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了BaseMetricSet类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: New
// New creates new instance of MetricSet.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Additional configuration options
config := struct {
ServerStatusPath string `config:"server_status_path"`
Username string `config:"username"`
Password string `config:"password"`
}{
ServerStatusPath: defaultPath,
Username: "",
Password: "",
}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
u, err := getURL(config.Username, config.Password, config.ServerStatusPath, base.Host())
if err != nil {
return nil, err
}
debugf("apache-status URL=%s", redactPassword(*u))
return &MetricSet{
BaseMetricSet: base,
url: u.String(),
}, nil
}
开发者ID:tanlintan,项目名称:pingbeat,代码行数:27,代码来源:status.go
示例2: New
// New create a new instance of the MetricSet
// Part of new is also setting up the configuration by processing additional
// configuration entries if needed.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
logp.Warn("EXPERIMENTAL: The haproxy info metricset is experimental")
return &MetricSet{
BaseMetricSet: base,
statsAddr: base.Host(),
counter: 1,
}, nil
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:12,代码来源:info.go
示例3: New
// New create a new instance of the MetricSet
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
config := struct{}{}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
}, nil
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:13,代码来源:bgwriter.go
示例4: New
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
dialInfo, err := mgo.ParseURL(base.HostData().URI)
if err != nil {
return nil, err
}
dialInfo.Timeout = base.Module().Config().Timeout
return &MetricSet{
BaseMetricSet: base,
dialInfo: dialInfo,
}, nil
}
开发者ID:ruflin,项目名称:beats,代码行数:12,代码来源:status.go
示例5: New
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
config := struct {
Hosts []string `config:"hosts" validate:"nonzero,required"`
}{}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
}, nil
}
开发者ID:ChongFeng,项目名称:beats,代码行数:14,代码来源:status.go
示例6: New
// New create a new instance of the MetricSet
// Part of new is also setting up the configuration by processing additional
// configuration entries if needed.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
logp.Warn("EXPERIMENTAL: The couchbase cluster metricset is experimental")
config := struct{}{}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
client: &http.Client{Timeout: base.Module().Config().Timeout},
}, nil
}
开发者ID:urso,项目名称:beats,代码行数:17,代码来源:cluster.go
示例7: New
// New creates new instance of MetricSet
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Unpack additional configuration options.
config := struct {
Network string `config:"network"`
MaxConn int `config:"maxconn" validate:"min=1"`
Password string `config:"password"`
}{
Network: "tcp",
MaxConn: 10,
Password: "",
}
err := base.Module().UnpackConfig(&config)
if err != nil {
return nil, err
}
redisPools := make(map[string]*rd.Pool, len(base.Module().Config().Hosts))
for _, host := range base.Module().Config().Hosts {
redisPool := createPool(host, config.Password, config.Network,
config.MaxConn, base.Module().Config().Timeout)
redisPools[host] = redisPool
}
return &MetricSet{
BaseMetricSet: base,
redisPools: redisPools,
}, nil
}
开发者ID:yan2jared,项目名称:beats,代码行数:29,代码来源:info.go
示例8: New
// New create a new instance of the docker info MetricSet.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
logp.Warn("EXPERIMENTAL: The docker info metricset is experimental")
config := docker.Config{}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
client, err := docker.NewDockerClient(base.HostData().URI, config)
if err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
dockerClient: client,
}, nil
}
开发者ID:ruflin,项目名称:beats,代码行数:19,代码来源:info.go
示例9: New
// New is a mb.MetricSetFactory that returns a cpu.MetricSet.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
config := struct {
CpuTicks bool `config:"cpu_ticks"` // export CPU usage in ticks
}{
CpuTicks: false,
}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
cpu: &CPU{
CpuTicks: config.CpuTicks,
},
}, nil
}
开发者ID:ruflin,项目名称:beats,代码行数:20,代码来源:cpu.go
示例10: NewMetricSet
func NewMetricSet(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Unpack additional configuration options.
config := struct {
Username string `config:"username"`
Password string `config:"password"`
}{
Username: "",
Password: "",
}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
username: config.Username,
password: config.Password,
}, nil
}
开发者ID:ChongFeng,项目名称:beats,代码行数:19,代码来源:example_metricset_test.go
示例11: New
// New create a new instance of the container MetricSet
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
logp.Warn("EXPERIMENTAL: The container metricset is experimental")
config := docker.GetDefaultConf()
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
client, err := docker.NewDockerClient(&config)
if err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
dockerClient: client,
}, nil
}
开发者ID:andrewkroh,项目名称:beats,代码行数:20,代码来源:container.go
示例12: New
// New creates and returns a new MetricSet.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
config := struct {
Procs []string `config:"processes"` // collect all processes by default
Cgroups bool `config:"cgroups"`
}{
Procs: []string{".*"},
Cgroups: false,
}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
m := &MetricSet{
BaseMetricSet: base,
stats: &ProcStats{
ProcStats: true,
Procs: config.Procs,
},
}
err := m.stats.InitProcStats()
if err != nil {
return nil, err
}
if runtime.GOOS == "linux" {
systemModule, ok := base.Module().(*system.Module)
if !ok {
return nil, fmt.Errorf("unexpected module type")
}
if config.Cgroups {
logp.Warn("EXPERIMENTAL: Cgroup is enabled for the system.process MetricSet.")
m.cgroup, err = cgroup.NewReader(systemModule.HostFS, true)
if err != nil {
return nil, errors.Wrap(err, "error initializing cgroup reader")
}
}
}
return m, nil
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:43,代码来源:process.go
示例13: New
// New creates a new instance of the docker network MetricSet.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
logp.Warn("EXPERIMENTAL: The docker network metricset is experimental")
config := docker.Config{}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
client, err := docker.NewDockerClient(base.HostData().URI, config)
if err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
dockerClient: client,
netService: &NetService{
NetworkStatPerContainer: make(map[string]map[string]NetRaw),
},
}, nil
}
开发者ID:ruflin,项目名称:beats,代码行数:22,代码来源:network.go
示例14: New
// New creates and returns a new MetricSet instance.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Unpack additional configuration options.
config := struct {
Hosts []string `config:"hosts" validate:"nonzero,required"`
Username string `config:"username"`
Password string `config:"password"`
}{
Username: "",
Password: "",
}
err := base.Module().UnpackConfig(&config)
if err != nil {
return nil, err
}
// Create and validate the data source name.
dsn, err := mysql.CreateDSN(base.Host(), config.Username, config.Password, base.Module().Config().Timeout)
if err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
dsn: dsn,
}, nil
}
开发者ID:McStork,项目名称:beats,代码行数:27,代码来源:status.go
示例15: New
// New creates and returns a new MetricSet instance.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Unpack additional configuration options.
config := struct {
Username string `config:"username"`
Password string `config:"password"`
}{
Username: "",
Password: "",
}
err := base.Module().UnpackConfig(&config)
if err != nil {
return nil, err
}
hostToDSN := make(map[string]string, len(base.Module().Config().Hosts))
for _, host := range base.Module().Config().Hosts {
// TODO (akroh): Apply validation to the mysql DSN format.
dsn := mysql.CreateDSN(host, config.Username, config.Password)
hostToDSN[host] = dsn
}
return &MetricSet{
BaseMetricSet: base,
hostToDSN: hostToDSN,
connections: map[string]*sql.DB{},
}, nil
}
开发者ID:yan2jared,项目名称:beats,代码行数:28,代码来源:status.go
示例16: New
// New creates new instance of MetricSet
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Additional configuration options
config := struct {
ServerStatusPath string `config:"server_status_path"`
}{
ServerStatusPath: defaultPath,
}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
u, err := getURL(config.ServerStatusPath, base.Host())
if err != nil {
return nil, err
}
debugf("nginx-stubstatus URL=%s", u)
return &MetricSet{
BaseMetricSet: base,
url: u.String(),
client: &http.Client{Timeout: base.Module().Config().Timeout},
requests: 0,
}, nil
}
开发者ID:ChongFeng,项目名称:beats,代码行数:26,代码来源:stubstatus.go
示例17: New
// New creates new instance of MetricSet.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Additional configuration options
config := struct {
ServerStatusPath string `config:"server_status_path"`
Username string `config:"username"`
Password string `config:"password"`
}{
ServerStatusPath: defaultPath,
Username: "",
Password: "",
}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
metricSet := &MetricSet{
BaseMetricSet: base,
URLs: make(map[string]string, len(base.Module().Config().Hosts)),
}
// Parse the config, create URLs, and check for errors.
var errs multierror.Errors
for _, host := range base.Module().Config().Hosts {
u, err := getURL(config.Username, config.Password, config.ServerStatusPath, host)
if err != nil {
errs = append(errs, err)
continue
}
metricSet.URLs[host] = u.String()
debugf("apache-status URL=%s", redactPassword(*u))
}
return metricSet, errs.Err()
}
开发者ID:yan2jared,项目名称:beats,代码行数:36,代码来源:status.go
示例18: New
// New create a new instance of the MetricSet
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
config := struct {
Hosts []string `config:"hosts" validate:"nonzero,required"`
Username string `config:"username"`
Password string `config:"password"`
}{
Username: "",
Password: "",
}
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
url, err := postgresql.ParseURL(base.Host(), config.Username, config.Password,
base.Module().Config().Timeout)
if err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
connectionString: url,
}, nil
}
开发者ID:andrewkroh,项目名称:beats,代码行数:27,代码来源:database.go
示例19: New
// New creates and returns a new MetricSet instance.
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
// Unpack additional configuration options.
config := struct {
Username string `config:"username"`
Password string `config:"password"`
}{
Username: "",
Password: "",
}
err := base.Module().UnpackConfig(&config)
if err != nil {
return nil, err
}
// TODO (akroh): Apply validation to the mysql DSN format.
dsn := mysql.CreateDSN(base.Host(), config.Username, config.Password)
return &MetricSet{
BaseMetricSet: base,
dsn: dsn,
}, nil
}
开发者ID:tanlintan,项目名称:pingbeat,代码行数:23,代码来源:status.go
示例20: New
// New create a new instance of the docker diskio MetricSet
func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
logp.Warn("EXPERIMENTAL: The diskio metricset is experimental")
config := docker.GetDefaultConf()
if err := base.Module().UnpackConfig(&config); err != nil {
return nil, err
}
client, err := docker.NewDockerClient(&config)
if err != nil {
return nil, err
}
return &MetricSet{
BaseMetricSet: base,
dockerClient: client,
blkioService: &BLkioService{
BlkioSTatsPerContainer: make(map[string]BlkioRaw),
},
}, nil
}
开发者ID:andrewkroh,项目名称:beats,代码行数:24,代码来源:diskio.go
注:本文中的github.com/elastic/beats/metricbeat/mb.BaseMetricSet类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论