分类 go 下的文章
项目地址实现功能日志收集监控日志文件,将其新数据通过kafka中转存储在ES中目前实现的特性:实时从etcd获取最新配置,动态管控当前监听的对象根据ip自动获取不同的配置,方便进行区分动态创建ES index,无需提前手动创建监控数据收集运行你自定义的监控脚本,收集其数据并存储在influxdb中,方便后续的引用或者展示代码文件中已包含一个示例test_moni.go,以其为例
value, ok := x.(T)如果x的类型是T或者接口符合T,则会返回x的值和一个bool判断
监控脚本会定时去获取机器内存信息,并发送给kafka,kafka发送给influxdb存储,并通过grafana展示出来package main
import (
"fmt"
"sync"
"example.go/addrget"
"example.go/etcd"
&...
当etcd发送变更的时候,会根据新配置来新增、删除文件监控,并实现通过部署机的ip来区分加载不同的etcd简直对example.gopackage main
import (
"fmt"
"sync"
"example.go/addrget"
"example.go/etcd"...
ini读取基本的初始化配置,etcd通过key去获取对应的json字符串,tail解析其中的路径和对应的Kafka topic,监控对应的文件并把最新的内容发送到对应的topicexample.gopackage main
import (
"fmt"
"sync"
"example.go/etcd"
...
- 1
- 2
- 3
- 4
- 5
- 后一页 »