|
|
|
|
//et_analyze 模块功能说明：
|
|
|
|
|
//
|
|
|
|
|
//1. 测量值阈值分析：
|
|
|
|
|
//集成方式：接入在 etNode 的处理环节中，实现 etNode.stage 的处理环节
|
|
|
|
|
//接收：ProcessData 类型数据
|
|
|
|
|
//输出：ProcessData 类型数据 、config.yaml 配置文件中的kafka.topics.alarm_anxinyun 主题消息
|
|
|
|
|
//处理：接收 ProcessData 数据，通过对 ProcessData.Staion[n].Data.ThemeData 进行阈值分析，向kafka服务器发布【阈值告警】和【恢复告警消息】，对 ProcessData.Staion[n].Data.AlarmLevel 进行更新。
|
|
|
|
|
//
|
|
|
|
|
//2. 变化速率阈值分析：
|
|
|
|
|
//集成方式：创建新的RPC服务 aggNode，无数据后处理环节
|
|
|
|
|
//接收：config.yaml 配置文件中的kafka.topics.data_agg 主题消息
|
|
|
|
|
//输出：config.yaml 配置文件中的kafka.topics.alarm_anxinyun 主题消息
|
|
|
|
|
//处理：将接收到的kafka消息转为AggData类型数据，对AggData.Changed 进行阈值分析，向kafka服务器发布【阈值告警】和【恢复告警消息】。
|
|
|
|
|
|
|
|
|
|
module et_analyze
|
|
|
|
|
|
|
|
|
|
go 1.23.1
|
|
|
|
|
|
|
|
|
|
require (
|
|
|
|
|
gitea.anxinyun.cn/container/common_models v0.0.10
|
|
|
|
|
gitea.anxinyun.cn/container/common_utils v0.0.8
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
require (
|
|
|
|
|
github.com/IBM/sarama v1.43.0 // indirect
|
|
|
|
|
github.com/allegro/bigcache v1.2.1 // indirect
|
|
|
|
|
github.com/beorn7/perks v1.0.1 // indirect
|
|
|
|
|
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
|
|
|
|
github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
|
|
|
|
|
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
|
|
|
|
|
github.com/eapache/go-resiliency v1.6.0 // indirect
|
|
|
|
|
github.com/eapache/go-xerial-snappy v0.0.0-20230731223053-c322873962e3 // indirect
|
|
|
|
|
github.com/eapache/queue v1.1.0 // indirect
|
|
|
|
|
github.com/eclipse/paho.mqtt.golang v1.4.3 // indirect
|
|
|
|
|
github.com/eko/gocache/lib/v4 v4.1.5 // indirect
|
|
|
|
|
github.com/eko/gocache/store/bigcache/v4 v4.2.1 // indirect
|
|
|
|
|
github.com/eko/gocache/store/redis/v4 v4.2.1 // indirect
|
|
|
|
|
github.com/fsnotify/fsnotify v1.7.0 // indirect
|
|
|
|
|
github.com/golang/mock v1.6.0 // indirect
|
|
|
|
|
github.com/golang/protobuf v1.5.3 // indirect
|
|
|
|
|
github.com/golang/snappy v0.0.4 // indirect
|
|
|
|
|
github.com/gorilla/websocket v1.5.0 // indirect
|
|
|
|
|
github.com/hashicorp/errwrap v1.0.0 // indirect
|
|
|
|
|
github.com/hashicorp/go-multierror v1.1.1 // indirect
|
|
|
|
|
github.com/hashicorp/go-uuid v1.0.3 // indirect
|
|
|
|
|
github.com/hashicorp/hcl v1.0.0 // indirect
|
|
|
|
|
github.com/jcmturner/aescts/v2 v2.0.0 // indirect
|
|
|
|
|
github.com/jcmturner/dnsutils/v2 v2.0.0 // indirect
|
|
|
|
|
github.com/jcmturner/gofork v1.7.6 // indirect
|
|
|
|
|
github.com/jcmturner/gokrb5/v8 v8.4.4 // indirect
|
|
|
|
|
github.com/jcmturner/rpc/v2 v2.0.3 // indirect
|
|
|
|
|
github.com/klauspost/compress v1.17.7 // indirect
|
|
|
|
|
github.com/magiconair/properties v1.8.7 // indirect
|
|
|
|
|
github.com/matttproud/golang_protobuf_extensions v1.0.1 // indirect
|
|
|
|
|
github.com/mitchellh/mapstructure v1.5.0 // indirect
|
|
|
|
|
github.com/pelletier/go-toml/v2 v2.1.0 // indirect
|
|
|
|
|
github.com/pierrec/lz4/v4 v4.1.21 // indirect
|
|
|
|
|
github.com/prometheus/client_golang v1.14.0 // indirect
|
|
|
|
|
github.com/prometheus/client_model v0.3.0 // indirect
|
|
|
|
|
github.com/prometheus/common v0.37.0 // indirect
|
|
|
|
|
github.com/prometheus/procfs v0.8.0 // indirect
|
|
|
|
|
github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect
|
|
|
|
|
github.com/redis/go-redis/v9 v9.5.1 // indirect
|
|
|
|
|
github.com/sagikazarmark/locafero v0.4.0 // indirect
|
|
|
|
|
github.com/sagikazarmark/slog-shim v0.1.0 // indirect
|
|
|
|
|
github.com/sourcegraph/conc v0.3.0 // indirect
|
|
|
|
|
github.com/spf13/afero v1.11.0 // indirect
|
|
|
|
|
github.com/spf13/cast v1.6.0 // indirect
|
|
|
|
|
github.com/spf13/pflag v1.0.5 // indirect
|
|
|
|
|
github.com/spf13/viper v1.18.2 // indirect
|
|
|
|
|
github.com/subosito/gotenv v1.6.0 // indirect
|
|
|
|
|
go.uber.org/atomic v1.9.0 // indirect
|
|
|
|
|
go.uber.org/multierr v1.9.0 // indirect
|
|
|
|
|
golang.org/x/crypto v0.19.0 // indirect
|
|
|
|
|
golang.org/x/exp v0.0.0-20230905200255-921286631fa9 // indirect
|
|
|
|
|
golang.org/x/net v0.21.0 // indirect
|
|
|
|
|
golang.org/x/sync v0.6.0 // indirect
|
|
|
|
|
golang.org/x/sys v0.17.0 // indirect
|
|
|
|
|
golang.org/x/text v0.14.0 // indirect
|
|
|
|
|
google.golang.org/protobuf v1.31.0 // indirect
|
|
|
|
|
gopkg.in/ini.v1 v1.67.0 // indirect
|
|
|
|
|
gopkg.in/yaml.v3 v3.0.1 // indirect
|
|
|
|
|
)
|
