monitoring

Documentation

Index

• func InitConfig(cfg config.Monitoring)
• type OnceUponATimer
  • func NewOnceTimer(promTimer *prometheus.Timer) *OnceUponATimer
  • func (o *OnceUponATimer) ObserveDurationOnce()
• type PrometheusMetrics
  • func GetMetrics() *PrometheusMetrics
  • func (pm *PrometheusMetrics) DeleteClass(className string) error
  • func (pm *PrometheusMetrics) DeleteShard(className, shardName string) error
  • func (pm *PrometheusMetrics) FinishLoadingShard(className string) error
  • func (pm *PrometheusMetrics) FinishUnloadingShard(className string) error
  • func (pm *PrometheusMetrics) NewUnloadedshard(className string) error
  • func (pm *PrometheusMetrics) StartLoadingShard(className string) error
  • func (pm *PrometheusMetrics) StartUnloadingShard(className string) error

Functions

func InitConfig

func InitConfig(cfg config.Monitoring)

Types

type OnceUponATimer

type OnceUponATimer struct {
	sync.Once
	Timer *prometheus.Timer
}

func NewOnceTimer

func NewOnceTimer(promTimer *prometheus.Timer) *OnceUponATimer

func (*OnceUponATimer) ObserveDurationOnce

func (o *OnceUponATimer) ObserveDurationOnce()

type PrometheusMetrics

type PrometheusMetrics struct {
	BatchTime                          *prometheus.HistogramVec
	BatchDeleteTime                    *prometheus.SummaryVec
	ObjectsTime                        *prometheus.SummaryVec
	LSMBloomFilters                    *prometheus.SummaryVec
	AsyncOperations                    *prometheus.GaugeVec
	LSMSegmentCount                    *prometheus.GaugeVec
	LSMSegmentCountByLevel             *prometheus.GaugeVec
	LSMSegmentObjects                  *prometheus.GaugeVec
	LSMSegmentSize                     *prometheus.GaugeVec
	LSMMemtableSize                    *prometheus.GaugeVec
	LSMMemtableDurations               *prometheus.SummaryVec
	VectorIndexTombstones              *prometheus.GaugeVec
	VectorIndexTombstoneCleanupThreads *prometheus.GaugeVec
	VectorIndexTombstoneCleanedCount   *prometheus.CounterVec
	VectorIndexOperations              *prometheus.GaugeVec
	VectorIndexDurations               *prometheus.SummaryVec
	VectorIndexSize                    *prometheus.GaugeVec
	VectorIndexMaintenanceDurations    *prometheus.SummaryVec
	ObjectCount                        *prometheus.GaugeVec
	QueriesCount                       *prometheus.GaugeVec
	RequestsTotal                      *prometheus.GaugeVec
	QueriesDurations                   *prometheus.HistogramVec
	QueriesFilteredVectorDurations     *prometheus.SummaryVec
	QueryDimensions                    *prometheus.CounterVec
	QueryDimensionsCombined            prometheus.Counter
	GoroutinesCount                    *prometheus.GaugeVec
	BackupRestoreDurations             *prometheus.SummaryVec
	BackupStoreDurations               *prometheus.SummaryVec
	BucketPauseDurations               *prometheus.SummaryVec
	BackupRestoreClassDurations        *prometheus.SummaryVec
	BackupRestoreBackupInitDurations   *prometheus.SummaryVec
	BackupRestoreFromStorageDurations  *prometheus.SummaryVec
	BackupRestoreDataTransferred       *prometheus.CounterVec
	BackupStoreDataTransferred         *prometheus.CounterVec
	VectorDimensionsSum                *prometheus.GaugeVec
	VectorSegmentsSum                  *prometheus.GaugeVec

	StartupProgress  *prometheus.GaugeVec
	StartupDurations *prometheus.SummaryVec
	StartupDiskIO    *prometheus.SummaryVec

	ShardsLoaded    *prometheus.GaugeVec
	ShardsUnloaded  *prometheus.GaugeVec
	ShardsLoading   *prometheus.GaugeVec
	ShardsUnloading *prometheus.GaugeVec

	Group bool
}

func GetMetrics

func GetMetrics() *PrometheusMetrics

func (*PrometheusMetrics) DeleteClass

func (pm *PrometheusMetrics) DeleteClass(className string) error

DeleteClass deletes all metrics that match the class name, but do not have a shard-specific label. See [DeleteShard] for more information.

func (*PrometheusMetrics) DeleteShard

func (pm *PrometheusMetrics) DeleteShard(className, shardName string) error

Delete Shard deletes existing label combinations that match both the shard and class name. If a metric is not collected at the shard level it is unaffected. This is to make sure that deleting a single shard (e.g. multi-tenancy) does not affect metrics for existing shards.

In addition, there are some metrics that we explicitly keep, such as vector_dimensions_sum as they can be used in billing decisions.

func (*PrometheusMetrics) FinishLoadingShard

func (pm *PrometheusMetrics) FinishLoadingShard(className string) error

Move the shard from in progress to loaded

func (*PrometheusMetrics) FinishUnloadingShard

func (pm *PrometheusMetrics) FinishUnloadingShard(className string) error

Move the shard from in progress to unloaded

func (*PrometheusMetrics) NewUnloadedshard

func (pm *PrometheusMetrics) NewUnloadedshard(className string) error

Register a new, unloaded shard

func (*PrometheusMetrics) StartLoadingShard

func (pm *PrometheusMetrics) StartLoadingShard(className string) error

Move the shard from unloaded to in progress

func (*PrometheusMetrics) StartUnloadingShard

func (pm *PrometheusMetrics) StartUnloadingShard(className string) error

Move the shard from loaded to in progress