scrape

type Alert struct {
	URL              string
	IgnoreTimeString []string
	// contains filtered or unexported fields
}

type Annotations struct {
	Summary     string `json:"summary"`
	Description string `json:"description"`
}

type CachePort struct {
	Number string `json:"number"`
	State  int64  `json:"state"`
}

type CacheProcess struct {
	Name      string      `json:"name"`
	Host      string      `json:"host"`
	Path      string      `json:"path"`
	Flag      string      `json:"flag"`
	Ports     []CachePort `json:"ports"`
	State     int64       `json:"state"`
	StartTime string      `json:"start_time"`
	TimeStamp string      `json:"time_stamp"`
	Suspend   bool        `json:"suspend"`
}

type Collector interface {
	// Start 开启后台收集任务
	Start() error
	// Stop 停止收集
	Stop()
	// Refresh 负责手动刷新
	Refresh()
	// Peek Peek返回未加工的数据
	Peek() render.Rows
	Running() bool
	// AddListener 注册数据订阅者
	AddListener(TableListener)
	// RemoveListener 移除订阅者
	RemoveListener(TableListener)
	SendCommand(int64)
}

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

type Config struct {
	Processes []ProcessConfig
}

type Group struct {
	Name      string          `json:"name"`
	Processes []*CacheProcess `json:"processes"`
}

type Instances struct {
	sync.RWMutex
	Set map[string]Target
}

type Labels struct {
	AlertName string `json:"alertname"`
	Service   string `json:"service"`
	Severity  string `json:"severity"`
	Instance  string `json:"instance"`
}

type Message struct {
	Status      string      `json:"status"`
	Labels      Labels      `json:"labels"`
	Annotations Annotations `json:"annotations"`
}

type NSWrapper struct {
	serialize.Serializable
	// contains filtered or unexported fields
}

type NameSpace struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Port struct {
	Number string
	State  int64
}

type PortState struct {
	Process
	States    []*Port
	Timestamp int64
}

type ProcStat struct {
	// The process ID.
	PID int
	// The filename of the executable.
	Comm string
	// The process state.
	State string
	// The PID of the parent of this process.
	PPID int
	// The process group ID of the process.
	PGRP int
	// The session ID of the process.
	Session int
	// The controlling terminal of the process.
	TTY int
	// The ID of the foreground process group of the controlling terminal of
	// the process.
	TPGID int
	// The kernel flags word of the process.
	Flags uint
	// The number of minor faults the process has made which have not required
	// loading a memory page from disk.
	MinFlt uint
	// The number of minor faults that the process's waited-for children have
	// made.
	CMinFlt uint
	// The number of major faults the process has made which have required
	// loading a memory page from disk.
	MajFlt uint
	// The number of major faults that the process's waited-for children have
	// made.
	CMajFlt uint
	// Amount of time that this process has been scheduled in user mode,
	// measured in clock ticks.
	UTime uint
	// Amount of time that this process has been scheduled in kernel mode,
	// measured in clock ticks.
	STime uint
	// Amount of time that this process's waited-for children have been
	// scheduled in user mode, measured in clock ticks.
	CUTime uint
	// Amount of time that this process's waited-for children have been
	// scheduled in kernel mode, measured in clock ticks.
	CSTime uint
	// For processes running a real-time scheduling policy, this is the negated
	// scheduling priority, minus one.
	Priority int
	// The nice value, a value in the range 19 (low priority) to -20 (high
	// priority).
	Nice int
	// Number of threads in this process.
	NumThreads int
	// The time the process started after system boot, the value is expressed
	// in clock ticks.
	Starttime uint64
	// Virtual memory size in bytes.
	VSize uint
	// Resident set size in pages.
	RSS int
}

type Process struct {
	OSUser  string
	Name    string
	Path    string
	Ports   []int64
	Group   string
	Host    string
	PIDFile string
	Flag    string
	Suspend bool
}

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

type ProcessConfig struct {
	Host    string
	Process []Process
}

type ProcessDetail struct {
	*ProcessCache

	sync.RWMutex
	// contains filtered or unexported fields
}

type ProcessState struct {
	Process
	State         int64
	StateDescribe string
	StartTime     int64
	Timestamp     int64
}

type Report struct {
	Title              string
	ReportName         string
	ReportDate         string
	Reporter           string
	NormalCount        int
	PlanStopCount      int
	PortExceptionCount int
	PIDExceptionCount  int
	Groups             []Group
}

type Result struct {
	Status string `json:"status"`
}

type State struct{}

type TableListener interface {
	// TableDataChanged notifies the model data changed.
	TableDataChanged(rows render.Rows)

	// TableLoadFailed notifies the load failed.
	TableLoadFailed(error)

	Chan() chan []byte
}

type Target struct {
	Conn *ssh.Connection
	// used to compute process start time
	BootTime int64
}

type Wrapper struct {
	serialize.Serializable
	// contains filtered or unexported fields
}

type WrapperFunc func(serialize.Serializable) TableListener