metrics

Documentation

Index

• func NewDMChannelFrom(channel *datapb.VchannelInfo) *metricsinfo.DmChannel
• func NewSegmentFrom(segment *datapb.SegmentInfo) *metricsinfo.Segment
• func NewThreadWatcher() *threadWatcher
• func NormalizeMetricFamilies(metricFamiliesByName map[string]*dto.MetricFamily) []*dto.MetricFamily
• type CRegistry
  • func NewCRegistry() *CRegistry
  • func (r *CRegistry) Gather() (res []*dto.MetricFamily, err error)
• type MilvusRegistry
  • func NewMilvusRegistry() *MilvusRegistry
  • func (r *MilvusRegistry) Gather() ([]*dto.MetricFamily, error)

Functions

func NewDMChannelFrom

func NewDMChannelFrom(channel *datapb.VchannelInfo) *metricsinfo.DmChannel

func NewSegmentFrom

func NewSegmentFrom(segment *datapb.SegmentInfo) *metricsinfo.Segment

func NewThreadWatcher

func NewThreadWatcher() *threadWatcher

func NormalizeMetricFamilies

func NormalizeMetricFamilies(metricFamiliesByName map[string]*dto.MetricFamily) []*dto.MetricFamily

NormalizeMetricFamilies returns a MetricFamily slice with empty MetricFamilies pruned and the remaining MetricFamilies sorted by name within the slice, with the contained Metrics sorted within each MetricFamily.

Types

type CRegistry

type CRegistry struct {
	*prometheus.Registry
	// contains filtered or unexported fields
}

only re-write the implementation of Gather()

func NewCRegistry

func NewCRegistry() *CRegistry

func (*CRegistry) Gather

func (r *CRegistry) Gather() (res []*dto.MetricFamily, err error)

Gather implements Gatherer.

type MilvusRegistry

type MilvusRegistry struct {
	GoRegistry *prometheus.Registry
	CRegistry  *CRegistry
}

re-write the implementation of Gather()

func NewMilvusRegistry

func NewMilvusRegistry() *MilvusRegistry

func (*MilvusRegistry) Gather

func (r *MilvusRegistry) Gather() ([]*dto.MetricFamily, error)

Gather implements Gatherer.