fs_monitor

Documentation

Index

• type FsMonitorTask
  • func NewFsMonitorTask(ctx context.Context, topic string, period int, store *storage.YigFsStorage, ...) (task *FsMonitorTask, err error)
  • func (mt *FsMonitorTask) Run()
  • func (mt *FsMonitorTask) ScanFsIndicators()
  • func (mt *FsMonitorTask) Stop()
• type MetricsResp
• type MonitorData
• type MonitorMetric
• type MonitorResp
• type MonitorResult

Types

type FsMonitorTask

type FsMonitorTask struct {
	Topic  string
	Period int
	Store  *storage.YigFsStorage

	Sender    message.MessageSender
	FsChan    chan *st.FsMetrics
	ThreadNum int
	// contains filtered or unexported fields
}

func NewFsMonitorTask

func NewFsMonitorTask(ctx context.Context, topic string, period int, store *storage.YigFsStorage, chanSize, threadNum int, msgBus helper.FsMonitorConfig,
	leadeMgr *tools.LeaderMgr, regionId string, wg *sync.WaitGroup, prometheusAddr string) (task *FsMonitorTask, err error)

func (*FsMonitorTask) Run

func (mt *FsMonitorTask) Run()

func (*FsMonitorTask) ScanFsIndicators

func (mt *FsMonitorTask) ScanFsIndicators()

func (*FsMonitorTask) Stop

func (mt *FsMonitorTask) Stop()

type MetricsResp

type MetricsResp struct {
}

type MonitorData

type MonitorData struct {
	ResultType string           `json:"resultType"`
	Result     []*MonitorResult `json:"result"`
}

type MonitorMetric

type MonitorMetric struct {
	Name     string `json:"__name__"`
	FsId     string `json:"fsid"`
	Instance string `json:"instance"`
	Job      string `json:"job"`
	NetType  string `json:"net_type"`
}

type MonitorResp

type MonitorResp struct {
	Status string       `json:"status"`
	Data   *MonitorData `json:"data"`
}

type MonitorResult

type MonitorResult struct {
	Metric *MonitorMetric `json:"metric"`
	Value  []interface{}  `json:"value"`
}