output

Documentation

Index

• Constants
• func GetDevIDFileID(keyStr uint64) (string, string)
• func ProcessEvents(coll *ebpf.Collection, ctx context.Context, addr2name bpf.Addr2Name)
• func ProcessFiles(coll *ebpf.Collection, ctx context.Context)
• func ProcessMetrics(coll *ebpf.Collection, ctx context.Context, isOutMetrics bool)
• type NFSMetrics
  • func NewNFSMetrics(performanceMap *sync.Map, fileInfoMap *sync.Map) *NFSMetrics
  • func (m *NFSMetrics) MetricsHandler() gin.HandlerFunc
  • func (m *NFSMetrics) UpdateMetricsFromCache(nodeName string)
• type PathCache
  • func NewPathCache() *PathCache
  • func (pc *PathCache) Get(devID, fileID uint64) (string, bool)
  • func (pc *PathCache) Set(devID, fileID uint64, path string)

Constants

const (
	NFSReadCount      = "nfs_read_count"
	NFSWriteCount     = "nfs_write_count"
	NFSReadSize       = "nfs_read_size"
	NFSWriteSize      = "nfs_write_size"
	NFSReadLatencies  = "nfs_read_latencies"
	NFSWriteLatencies = "nfs_write_latencies"
)

Functions

func GetDevIDFileID

func GetDevIDFileID(keyStr uint64) (string, string)

func ProcessEvents

func ProcessEvents(coll *ebpf.Collection, ctx context.Context, addr2name bpf.Addr2Name)

func ProcessFiles

func ProcessFiles(coll *ebpf.Collection, ctx context.Context)

func ProcessMetrics

func ProcessMetrics(coll *ebpf.Collection, ctx context.Context, isOutMetrics bool)

Types

type NFSMetrics

type NFSMetrics struct {
	ReadCount      *prometheus.GaugeVec
	WriteCount     *prometheus.GaugeVec
	ReadSize       *prometheus.GaugeVec
	WriteSize      *prometheus.GaugeVec
	ReadLatencies  *prometheus.GaugeVec
	WriteLatencies *prometheus.GaugeVec
	NFSFileDetail  *prometheus.GaugeVec
	// contains filtered or unexported fields
}

NFSMetrics holds all the NFS related metrics

func NewNFSMetrics

func NewNFSMetrics(performanceMap *sync.Map, fileInfoMap *sync.Map) *NFSMetrics

NewNFSMetrics 创建并注册 NFS 指标

func (*NFSMetrics) MetricsHandler

func (m *NFSMetrics) MetricsHandler() gin.HandlerFunc

func (*NFSMetrics) UpdateMetricsFromCache

func (m *NFSMetrics) UpdateMetricsFromCache(nodeName string)

UpdateMetricsFromCache updates the Prometheus metrics from the NFSPerformanceMap

type PathCache

type PathCache struct {
	// contains filtered or unexported fields
}

func NewPathCache

func NewPathCache() *PathCache

func (*PathCache) Get

func (pc *PathCache) Get(devID, fileID uint64) (string, bool)

func (*PathCache) Set

func (pc *PathCache) Set(devID, fileID uint64, path string)