store

type CPUStat struct {
	UsageUsec     uint64
	UserUsec      uint64
	SystemUsec    uint64
	NrPeriods     uint64
	NrThrottled   uint64
	ThrottledUsec uint64
	NrBursts      uint64
	BurstUsec     uint64
}

type CgoupStat struct {
	NrDescendants      uint64
	NrDyingDescendants uint64
}

type CgroupFile int

type CgroupSample struct {
	Path        string
	Name        string
	Level       int
	Inode       uint64
	Child       map[string]*CgroupSample
	IsNotExist  map[CgroupFile]struct{}
	Controllers string
	CgoupStat
	CPUStat
	MemoryStat
	CpuSetCpus          string
	CpuSetCpusEffective string
	CpuSetMems          string
	CpuSetMemsEffective string
	CpuWeight           uint64
	CpuMax              string
	MemoryCurrent       uint64
	MemoryLow           uint64
	MemoryHigh          uint64
	MemoryMin           uint64
	MemoryMax           uint64
	MemoryPeak          uint64
	SwapCurrent         uint64
	SwapMax             uint64
	ZswapCurrent        uint64
	ZswapMax            uint64
	MemoryEvents
	IOStats        []IOStat
	CpuPressure    PSIStats
	MemoryPressure PSIStats
	IOPressure     PSIStats
}

type ExitProcess struct {
	sync.Mutex
	Samples map[int]ProcSample
	// contains filtered or unexported fields
}

type IOStat struct {
	Major  uint64
	Minor  uint64
	Rbytes uint64
	Wbytes uint64
	Rios   uint64
	Wios   uint64
	Dbytes uint64
	Dios   uint64
}

type Index struct {
	TimeStamp int64  // unix time when sample was generated
	Offset    int64  // offset of file where sample is exist
	Len       int64  // length of one sample
	Flag      uint32 // compress mode and dict offset
	CRC       uint32 // crc for whole index, except CRC self
}

type LocalStore struct {
	Path       string   // path which index and data file is stored
	Index      *os.File // current active index file
	Data       *os.File // current active data file
	Log        *slog.Logger
	DataOffset int64 // file offset which next sample was written to

	sync.Mutex
	// contains filtered or unexported fields
}

type MemoryEvents struct {
	Low     uint64
	High    uint64
	Max     uint64
	Oom     uint64
	OomKill uint64
}

type MemoryStat struct {
	Anon                  uint64
	File                  uint64
	KernelStack           uint64
	Slab                  uint64
	Sock                  uint64
	Shmem                 uint64
	Zswap                 uint64
	Zswapped              uint64
	FileMapped            uint64
	FileDirty             uint64
	FileWriteback         uint64
	AnonThp               uint64
	InactiveAnon          uint64
	ActiveAnon            uint64
	InactiveFile          uint64
	ActiveFile            uint64
	Unevictable           uint64
	SlabReclaimable       uint64
	SlabUnreclaimable     uint64
	Pgfault               uint64
	Pgmajfault            uint64
	WorkingsetRefault     uint64
	WorkingsetActivate    uint64
	WorkingsetNodereclaim uint64
	Pgrefill              uint64
	Pgscan                uint64
	Pgsteal               uint64
	Pgactivate            uint64
	Pgdeactivate          uint64
	Pglazyfree            uint64
	Pglazyfreed           uint64
	ZswpIn                uint64
	ZswpOut               uint64
	ThpFaultAlloc         uint64
	ThpCollapseAlloc      uint64
}

type NetStat struct {
	Ip       procfs.Ip
	Icmp     procfs.Icmp
	IcmpMsg  procfs.IcmpMsg
	Tcp      procfs.Tcp
	Udp      procfs.Udp
	UdpLite  procfs.UdpLite
	Ip6      procfs.Ip6
	Icmp6    procfs.Icmp6
	Udp6     procfs.Udp6
	UdpLite6 procfs.UdpLite6
	TcpExt   procfs.TcpExt
	IpExt    procfs.IpExt
}

type Option func(*LocalStore) error

type PSIData struct {
	Avg10  float64
	Avg60  float64
	Avg300 float64
	Total  uint64
}

type PSIStats struct {
	Some PSIData
	Full PSIData
}

type PidMap map[int]ProcSample

type ProcSample struct {
	procfs.ProcStat
	procfs.ProcIO
	CmdLine  string
	Cgroup   string
	EndTime  uint64
	ExitCode uint32
}

type Sample struct {
	TimeStamp    int64  // unix time when sample was generated
	SystemSample        // system information
	ProcSamples  PidMap // process information
	CgroupSample *CgroupSample
}

type Store interface {
	// if step is positive , advance the corresponding number of steps
	// otherwise back, then get sample
	NextSample(step int, sample *Sample) error
	// Get sample which collect at timestamp
	JumpSampleByTimeStamp(timestamp int64, sample *Sample) error
}

type SystemSample struct {
	HostName      string
	KernelVersion string
	PageSize      int
	BootTimeTick  uint64
	procfs.LoadAvg
	procfs.Stat
	procfs.Meminfo
	VmStat
	NetDevStats map[string]procfs.NetDevLine
	DiskStats   map[string]blockdevice.Diskstats
	NetStat
	procfs.NetProtocolStats
	SoftNetStats []procfs.SoftnetStat
}

type VmStat struct {
	PageIn          uint64
	PageOut         uint64
	SwapIn          uint64
	SwapOut         uint64
	PageScanKswapd  uint64
	PageScanDirect  uint64
	PageStealKswapd uint64
	PageStealDirect uint64
	OOMKill         uint64
}

type WriteOption struct {
	Interval   time.Duration
	RetainDay  int
	RetainSize int64
}