Documentation
¶
Index ¶
- Variables
- func CheckAddr(addr string) string
- func GRPCPanicInc()
- func GetAppVersion() string
- func GetFreyaVersion() string
- func GetGoVersion() string
- func GetProtoVersion() string
- func KafkaConsumerGroupMetricsF(groupName, topic string, err error, duration float64)
- func KafkaConsumerMetricsF(topic string, err error, duration float64)
- func KafkaSyncProducerMetricsF(topic string, err error)
- func OutboxMetricsF(source, status string, count float64)
- func SetAppInfo(info *AppInfo)
- func SetApplicationMetrics()
- func StartServerWithWaiting(ctx context.Context, logger *zap.Logger, f func(errCh chan error)) error
- func WithConsulKVMetrics(requestName string, callFunc customFunc) error
- func WithCouchbaseMetrics(bucketName, collectionName, query, serviceName string, callFunc customFunc) error
- func WithElasticMetrics(requestName string, callFunc customFunc) error
- func WithHTTPMetrics(requestName string, callFunc customFunc) error
- func WithRedisMetrics(requestName string, callFunc customFunc) error
- func WithSQLMetrics(queryName, serviceName string, callFunc customFunc) error
- type AppInfo
- type Package
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DBMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "connections", Subsystem: "sql", Name: "call_duration_seconds", Help: "query duration seconds", Buckets: []float64{.005, .01, .025, .05, .075, .1, .15, .2, .25, .5, 1, 2.5}, }, []string{"query", "service", "error"}, ) DBErrorMetrics = promauto.NewCounterVec(prometheus.CounterOpts{ Namespace: "connections", Subsystem: "sql", Name: "error_total", Help: "Number of db errors.", }, []string{"query_name"}) CouchbaseMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "connections", Subsystem: "couchbase", Name: "call_duration_seconds", Help: "query duration seconds", Buckets: []float64{.005, .01, .025, .05, .075, .1, .15, .2, .25, .5, 1, 2.5}, }, []string{"bucket", "collection", "query", "service", "error"}, ) HTTPMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "http", Subsystem: "requests", Name: "call_duration_seconds", Help: "request duration seconds", Buckets: []float64{.005, .01, .025, .05, .075, .1, .15, .2, .25, .5, 1, 2.5}, }, []string{"request_name", "error"}, ) ElasticMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "connections", Subsystem: "elastic", Name: "call_duration_seconds", Help: "request duration seconds", Buckets: []float64{.005, .01, .025, .05, .075, .1, .15, .2, .25, .5, 1, 2.5}, }, []string{"query", "error"}, ) RedisMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "connections", Subsystem: "redis", Name: "call_duration_seconds", Help: "request duration seconds", Buckets: []float64{.005, .01, .025, .05, .075, .1, .15, .2, .25, .5, 1, 2.5}, }, []string{"query", "error"}, ) ConsulKVMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "connections", Subsystem: "consul_kv", Name: "call_duration_seconds", Help: "request duration seconds", Buckets: []float64{.005, .01, .025, .05, .075, .1, .15, .2, .25, .5, 1, 2.5}, }, []string{"query", "error"}, ) OutboxMetrics = promauto.NewCounterVec( prometheus.CounterOpts{ Namespace: "outbox", Subsystem: "messages", Name: "outbox_statistic", Help: "messages and statuses", }, []string{"source", "status"}, ) GRPCPanicMetrics = promauto.NewCounter(prometheus.CounterOpts{ Namespace: "grpc", Name: "panic_total", Help: "Number of grpc panic.", }) KafkaConsumerGroupMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "kafka", Subsystem: "consumer_group", Name: "duration_consume", Help: "Consumer group consume duration", }, []string{"consumer_group", "topic", "error"}, ) KafkaConsumerMetrics = promauto.NewHistogramVec( prometheus.HistogramOpts{ Namespace: "kafka", Subsystem: "consumer", Name: "duration_consume", Help: "Consumer consume duration", }, []string{"topic", "error"}, ) KafkaSyncProducerMetrics = promauto.NewCounterVec( prometheus.CounterOpts{ Namespace: "kafka", Subsystem: "sync_producer", Name: "produce_count", Help: "Sync producer produce count", }, []string{"topic", "error"}, ) GaugeAppState = promauto.NewGaugeVec( prometheus.GaugeOpts{ Namespace: "application", Subsystem: "app", Name: "state", Help: "Versions and env of application", }, []string{ "app_version", "go_version", "proto_version", "freya_version", "start_date", }, ) ServerGRPCMetrics = grpcprom.NewServerMetrics( grpcprom.WithServerHandlingTimeHistogram(), ) )
Functions ¶
func GRPCPanicInc ¶
func GRPCPanicInc()
func GetAppVersion ¶ added in v1.0.23
func GetAppVersion() string
func GetFreyaVersion ¶ added in v1.0.23
func GetFreyaVersion() string
func GetGoVersion ¶ added in v1.0.23
func GetGoVersion() string
func GetProtoVersion ¶ added in v1.0.23
func GetProtoVersion() string
func KafkaConsumerGroupMetricsF ¶ added in v1.0.9
func KafkaConsumerMetricsF ¶ added in v1.2.0
func KafkaSyncProducerMetricsF ¶ added in v1.0.9
func OutboxMetricsF ¶ added in v1.2.0
func SetAppInfo ¶ added in v1.0.23
func SetAppInfo(info *AppInfo)
func SetApplicationMetrics ¶ added in v1.0.21
func SetApplicationMetrics()
func StartServerWithWaiting ¶
func WithConsulKVMetrics ¶ added in v1.1.0
func WithCouchbaseMetrics ¶ added in v1.0.23
func WithElasticMetrics ¶ added in v1.0.23
func WithHTTPMetrics ¶ added in v1.0.23
func WithRedisMetrics ¶ added in v1.2.0
func WithSQLMetrics ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.