types

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 14, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

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 CheckAddr added in v1.0.8

func CheckAddr(addr string) string

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 KafkaConsumerGroupMetricsF(groupName, topic string, err error, duration float64)

func KafkaConsumerMetricsF added in v1.2.0

func KafkaConsumerMetricsF(topic string, err error, duration float64)

func KafkaSyncProducerMetricsF added in v1.0.9

func KafkaSyncProducerMetricsF(topic string, err error)

func OutboxMetricsF added in v1.2.0

func OutboxMetricsF(source, status string, count float64)

func SetAppInfo added in v1.0.23

func SetAppInfo(info *AppInfo)

func SetApplicationMetrics added in v1.0.21

func SetApplicationMetrics()

func StartServerWithWaiting

func StartServerWithWaiting(
	ctx context.Context,
	logger *zap.Logger,
	f func(errCh chan error),
) error

func WithConsulKVMetrics added in v1.1.0

func WithConsulKVMetrics(
	requestName string,
	callFunc customFunc,
) error

func WithCouchbaseMetrics added in v1.0.23

func WithCouchbaseMetrics(
	bucketName, collectionName, query, serviceName string,
	callFunc customFunc,
) error

func WithElasticMetrics added in v1.0.23

func WithElasticMetrics(
	requestName string,
	callFunc customFunc,
) error

func WithHTTPMetrics added in v1.0.23

func WithHTTPMetrics(
	requestName string,
	callFunc customFunc,
) error

func WithRedisMetrics added in v1.2.0

func WithRedisMetrics(
	requestName string,
	callFunc customFunc,
) error

func WithSQLMetrics

func WithSQLMetrics(
	queryName, serviceName string,
	callFunc customFunc,
) error

Types

type AppInfo added in v1.0.23

type AppInfo struct {
	Packages     []Package
	AppVersion   string
	GoVersion    string
	ProtoVersion string
	FreyaVersion string
}

func GetAppInfo added in v1.0.23

func GetAppInfo(gomod []byte, releaseID, protoPackage string) (*AppInfo, error)

type Package added in v1.0.23

type Package struct {
	Name    string
	Version string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL