From 7f59b4dbe0b1134f9bfb94063afa96c2c2ed627b Mon Sep 17 00:00:00 2001 From: "lin.huang" Date: Sat, 11 Nov 2023 18:53:02 +0800 Subject: [PATCH] delete not using files --- pkg/common/prom_metrics/func.go | 45 ---------------------- pkg/common/prom_metrics/gin-api.go | 16 -------- pkg/common/prom_metrics/grpc-auth.go | 12 ------ pkg/common/prom_metrics/grpc-msg.go | 24 ------------ pkg/common/prom_metrics/grpc-msggateway.go | 12 ------ pkg/common/prom_metrics/grpc_push.go | 12 ------ pkg/common/prom_metrics/transfer.go | 28 -------------- 7 files changed, 149 deletions(-) delete mode 100644 pkg/common/prom_metrics/func.go delete mode 100644 pkg/common/prom_metrics/gin-api.go delete mode 100644 pkg/common/prom_metrics/grpc-auth.go delete mode 100644 pkg/common/prom_metrics/grpc-msg.go delete mode 100644 pkg/common/prom_metrics/grpc-msggateway.go delete mode 100644 pkg/common/prom_metrics/grpc_push.go delete mode 100644 pkg/common/prom_metrics/transfer.go diff --git a/pkg/common/prom_metrics/func.go b/pkg/common/prom_metrics/func.go deleted file mode 100644 index e451c441b..000000000 --- a/pkg/common/prom_metrics/func.go +++ /dev/null @@ -1,45 +0,0 @@ -package prom_metrics - -import ( - grpc_prometheus "github.com/grpc-ecosystem/go-grpc-prometheus" - config2 "github.com/openimsdk/open-im-server/v3/pkg/common/config" - "github.com/openimsdk/open-im-server/v3/pkg/common/ginPrometheus" - "github.com/prometheus/client_golang/prometheus" - "github.com/prometheus/client_golang/prometheus/collectors" -) - -func NewGrpcPromObj(cusMetrics []prometheus.Collector) (*prometheus.Registry, *grpc_prometheus.ServerMetrics, error) { - //////////////////////////////////////////////////////// - reg := prometheus.NewRegistry() - grpcMetrics := grpc_prometheus.NewServerMetrics() - grpcMetrics.EnableHandlingTimeHistogram() - cusMetrics = append(cusMetrics, grpcMetrics, collectors.NewGoCollector()) - reg.MustRegister(cusMetrics...) - return reg, grpcMetrics, nil -} - -func GetGrpcCusMetrics(registerName string) []prometheus.Collector { - switch registerName { - case config2.Config.RpcRegisterName.OpenImMessageGatewayName: - return []prometheus.Collector{OnlineUserGauge} - case config2.Config.RpcRegisterName.OpenImMsgName: - return []prometheus.Collector{SingleChatMsgProcessSuccessCounter, SingleChatMsgProcessFailedCounter, GroupChatMsgProcessSuccessCounter, GroupChatMsgProcessFailedCounter} - case "Transfer": - return []prometheus.Collector{MsgInsertRedisSuccessCounter, MsgInsertRedisFailedCounter, MsgInsertMongoSuccessCounter, MsgInsertMongoFailedCounter, SeqSetFailedCounter} - case config2.Config.RpcRegisterName.OpenImPushName: - return []prometheus.Collector{MsgOfflinePushFailedCounter} - case config2.Config.RpcRegisterName.OpenImAuthName: - return []prometheus.Collector{UserLoginCounter} - default: - return nil - } -} - -func GetGinCusMetrics(name string) []*ginPrometheus.Metric { - switch name { - case "Api": - return []*ginPrometheus.Metric{ApiCustomCnt} - default: - return []*ginPrometheus.Metric{ApiCustomCnt} - } -} diff --git a/pkg/common/prom_metrics/gin-api.go b/pkg/common/prom_metrics/gin-api.go deleted file mode 100644 index 7aa3f959e..000000000 --- a/pkg/common/prom_metrics/gin-api.go +++ /dev/null @@ -1,16 +0,0 @@ -package prom_metrics - -import ginProm "github.com/openimsdk/open-im-server/v3/pkg/common/ginPrometheus" - -/* -labels := prometheus.Labels{"label_one": "any", "label_two": "value"} -ApiCustomCnt.MetricCollector.(*prometheus.CounterVec).With(labels).Inc() -*/ -var ( - ApiCustomCnt = &ginProm.Metric{ - Name: "custom_total", - Description: "Custom counter events.", - Type: "counter_vec", - Args: []string{"label_one", "label_two"}, - } -) diff --git a/pkg/common/prom_metrics/grpc-auth.go b/pkg/common/prom_metrics/grpc-auth.go deleted file mode 100644 index 7ca5f1f49..000000000 --- a/pkg/common/prom_metrics/grpc-auth.go +++ /dev/null @@ -1,12 +0,0 @@ -package prom_metrics - -import ( - "github.com/prometheus/client_golang/prometheus" -) - -var ( - UserLoginCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "user_login_total", - Help: "The number of user login", - }) -) diff --git a/pkg/common/prom_metrics/grpc-msg.go b/pkg/common/prom_metrics/grpc-msg.go deleted file mode 100644 index 14cb4d858..000000000 --- a/pkg/common/prom_metrics/grpc-msg.go +++ /dev/null @@ -1,24 +0,0 @@ -package prom_metrics - -import ( - "github.com/prometheus/client_golang/prometheus" -) - -var ( - SingleChatMsgProcessSuccessCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "single_chat_msg_process_success_total", - Help: "The number of single chat msg successful processed", - }) - SingleChatMsgProcessFailedCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "single_chat_msg_process_failed_total", - Help: "The number of single chat msg failed processed", - }) - GroupChatMsgProcessSuccessCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "group_chat_msg_process_success_total", - Help: "The number of group chat msg successful processed", - }) - GroupChatMsgProcessFailedCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "group_chat_msg_process_failed_total", - Help: "The number of group chat msg failed processed", - }) -) diff --git a/pkg/common/prom_metrics/grpc-msggateway.go b/pkg/common/prom_metrics/grpc-msggateway.go deleted file mode 100644 index add72e391..000000000 --- a/pkg/common/prom_metrics/grpc-msggateway.go +++ /dev/null @@ -1,12 +0,0 @@ -package prom_metrics - -import ( - "github.com/prometheus/client_golang/prometheus" -) - -var ( - OnlineUserGauge = prometheus.NewGauge(prometheus.GaugeOpts{ - Name: "online_user_num", - Help: "The number of online user num", - }) -) diff --git a/pkg/common/prom_metrics/grpc_push.go b/pkg/common/prom_metrics/grpc_push.go deleted file mode 100644 index c05dd6180..000000000 --- a/pkg/common/prom_metrics/grpc_push.go +++ /dev/null @@ -1,12 +0,0 @@ -package prom_metrics - -import ( - "github.com/prometheus/client_golang/prometheus" -) - -var ( - MsgOfflinePushFailedCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "msg_offline_push_failed_total", - Help: "The number of msg failed offline pushed", - }) -) diff --git a/pkg/common/prom_metrics/transfer.go b/pkg/common/prom_metrics/transfer.go deleted file mode 100644 index d3fec47d9..000000000 --- a/pkg/common/prom_metrics/transfer.go +++ /dev/null @@ -1,28 +0,0 @@ -package prom_metrics - -import ( - "github.com/prometheus/client_golang/prometheus" -) - -var ( - MsgInsertRedisSuccessCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "msg_insert_redis_success_total", - Help: "The number of successful insert msg to redis", - }) - MsgInsertRedisFailedCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "msg_insert_redis_failed_total", - Help: "The number of failed insert msg to redis", - }) - MsgInsertMongoSuccessCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "msg_insert_mongo_success_total", - Help: "The number of successful insert msg to mongo", - }) - MsgInsertMongoFailedCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "msg_insert_mongo_failed_total", - Help: "The number of failed insert msg to mongo", - }) - SeqSetFailedCounter = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "seq_set_failed_total", - Help: "The number of failed set seq", - }) -)