metrics

package

v1.0.0 Latest Latest Go to latest Published: Aug 4, 2023 License: LGPL-3.0 Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/DeBankDeFi/nodex

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type KafkaMetrics ¶

type KafkaMetrics struct {
	KafkaWriterOffset *prometheus.Counter
	KafkaReaderOffset *prometheus.Counter
	KafkaCurrentTopic *prometheus.Gauge
	KafkaLatency      *prometheus.Histogram
}

func NewKafkaMetrics ¶

func NewKafkaMetrics() *KafkaMetrics

func (*KafkaMetrics) IncreaseReaderOffset ¶

func (m *KafkaMetrics) IncreaseReaderOffset(topic string, offset int64)

func (*KafkaMetrics) IncreaseWriterOffset ¶

func (m *KafkaMetrics) IncreaseWriterOffset(topic string, offset int64)

func (*KafkaMetrics) ObserveLatency ¶

func (m *KafkaMetrics) ObserveLatency(topic string, latency float64)

func (*KafkaMetrics) SwitchTopic ¶

func (m *KafkaMetrics) SwitchTopic(origin, target string)

type S3Metrics ¶

type S3Metrics struct {
	S3WriteLatency *prometheus.Histogram
	S3ReadLatency  *prometheus.Histogram
	S3WriteSize    *prometheus.Counter
	S3ReadSize     *prometheus.Counter
}

func NewS3Metrics ¶

func NewS3Metrics() *S3Metrics

func (*S3Metrics) IncreaseReadSize ¶

func (m *S3Metrics) IncreaseReadSize(bucket string, size int64)

func (*S3Metrics) IncreaseWriteSize ¶

func (m *S3Metrics) IncreaseWriteSize(bucket string, size int64)

func (*S3Metrics) ObserveReadLatency ¶

func (m *S3Metrics) ObserveReadLatency(bucket string, latency float64)

func (*S3Metrics) ObserveWriteLatency ¶

func (m *S3Metrics) ObserveWriteLatency(bucket string, latency float64)

Source Files ¶

View all Source files

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