internal

Documentation

Index

• func AddMonitor(name string, init NewMonitor)
• func CloseExporter() error
• type ExportedStat
• type Monitor
  • func GetMonitor(name string) (Monitor, error)
• type NewMonitor
• type Output
• type StatsExporter
  • func NewStatsExporter() (*StatsExporter, error)
  • func (se *StatsExporter) AddMonitorStats(monName string, timestamp string, st interface{})
  • func (se *StatsExporter) Destroy()
  • func (se *StatsExporter) StatsExporter()

Functions

func AddMonitor

func AddMonitor(name string, init NewMonitor)

func CloseExporter

func CloseExporter() error

Types

type ExportedStat

type ExportedStat struct {
	Timestamp   string
	MonitorName string
	Stat        interface{}
}

type Monitor

type Monitor interface {
	GetName() string
	SetName(string)
	Monitor() error
	Validate() error
	ExportStats(string, interface{})
}

func GetMonitor

func GetMonitor(name string) (Monitor, error)

type NewMonitor

type NewMonitor func() Monitor

type Output

type Output struct {
	Timestamp string                  `json:"Timestamp,omitempty"`
	Bfs       []stats_manager.PipeMsg `json:"BlobfuseStats,omitempty"`
	FcEvent   []*hmcommon.CacheEvent  `json:"FileCache,omitempty"`
	Cpu       string                  `json:"CPUUsage,omitempty"`
	Mem       string                  `json:"MemoryUsage,omitempty"`
	Net       string                  `json:"NetworkUsage,omitempty"`
}

type StatsExporter

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

func NewStatsExporter

func NewStatsExporter() (*StatsExporter, error)

create single instance of StatsExporter

func (*StatsExporter) AddMonitorStats

func (se *StatsExporter) AddMonitorStats(monName string, timestamp string, st interface{})

func (*StatsExporter) Destroy

func (se *StatsExporter) Destroy()

func (*StatsExporter) StatsExporter

func (se *StatsExporter) StatsExporter()