Documentation
¶
Overview ¶
Package psutilsql execute SQL queries on system information.
psutilsql can process gopsutil results in SQL and output them in various formats.
Index ¶
- Constants
- Variables
- func CPUInfoQuery(query string, w trdsql.Writer) error
- func CPUInfoReader() (*trdsql.SliceReader, error)
- func CPUPercentQuery(total bool, query string, w trdsql.Writer) error
- func CPUPercentReader(total bool) (*trdsql.SliceReader, error)
- func CPUTimeQuery(total bool, query string, w trdsql.Writer) error
- func CPUTimeReader(total bool) (*trdsql.SliceReader, error)
- func DiskPartitionQuery(all bool, query string, w trdsql.Writer) error
- func DiskPartitionReader(all bool) (*trdsql.SliceReader, error)
- func DiskUsageQuery(usage string, query string, w trdsql.Writer) error
- func DiskUsageReader(usage string) (*trdsql.SliceReader, error)
- func DockerQuery(query string, w trdsql.Writer) error
- func DockerReader() (*trdsql.SliceReader, error)
- func HostInfoReader() (*trdsql.SliceReader, error)
- func HostQuery(tempera bool, users bool, query string, w trdsql.Writer) error
- func HostTemperatureReader() (*trdsql.SliceReader, error)
- func HostUsersReader() (*trdsql.SliceReader, error)
- func LoadAvgReader() (*trdsql.SliceReader, error)
- func LoadMiscReader() (*trdsql.SliceReader, error)
- func LoadQuery(misc bool, query string, w trdsql.Writer) error
- func MEMQuery(memory bool, query string, w trdsql.Writer) error
- func NetQuery(query string, w trdsql.Writer) error
- func NetReader() (*trdsql.SliceReader, error)
- func PSTableQuery(tableName string, query string, w trdsql.Writer) error
- func ProcessQuery(ex bool, query string, w trdsql.Writer) error
- func QueryExec(query string, writer trdsql.Writer) error
- func SwapMemoryReader() (*trdsql.SliceReader, error)
- func TableReader() (*trdsql.SliceReader, error)
- func VirtualMemoryReader() (*trdsql.SliceReader, error)
- type MultiImporter
- type ProcessReader
- type Reader
Constants ¶
const ( PID pColumnNum = iota NAME CPU MEM STATUS START USER CWD EXE TERMINAL IONICE NICE NUMFDS NUMTHREADS PPID TGID UIDS GIDS MEMORYINFOEX MEMORYINFO IOCOUNTERS FOREGROUND BACKGROUND ISRUNNING COMMAND )
Variables ¶
var ( ErrNotSupport = errors.New("not support") ErrNoSuchTable = errors.New("no such table") )
Functions ¶
func CPUInfoQuery ¶
CPUInfoQuery executes SQL on cpu.Info.
func CPUInfoReader ¶
func CPUInfoReader() (*trdsql.SliceReader, error)
CPUInfoReader returns cpu.Info result as trdsql.SliceReader.
func CPUPercentQuery ¶
CPUPercentQuery executes SQL on cpu.Percent.
func CPUPercentReader ¶
func CPUPercentReader(total bool) (*trdsql.SliceReader, error)
CPUPercentReader returns cpu.Percent result as trdsql.SliceReader.
func CPUTimeQuery ¶
CPUTimeQuery executes SQL on cpu.Time.
func CPUTimeReader ¶
func CPUTimeReader(total bool) (*trdsql.SliceReader, error)
CPUTimeReader returns cpu.Times result as trdsql.SliceReader.
func DiskPartitionQuery ¶
DiskPartitionQuery executes SQL on disk.Partitions.
func DiskPartitionReader ¶
func DiskPartitionReader(all bool) (*trdsql.SliceReader, error)
DiskPartitionReader returns disk.Partitions result as trdsql.SliceReader.
func DiskUsageQuery ¶
DiskUsageQuery executes SQL on disk.Usage.
func DiskUsageReader ¶
func DiskUsageReader(usage string) (*trdsql.SliceReader, error)
DiskUsageReader returns disk.Usage result as trdsql.SliceReader.
func DockerQuery ¶
DockerQuery executes SQL on docker.GetDockerStat.
func DockerReader ¶
func DockerReader() (*trdsql.SliceReader, error)
DockerReader returns docker.GetDockerStat result as trdsql.SliceReader.
func HostInfoReader ¶
func HostInfoReader() (*trdsql.SliceReader, error)
HostInfoReader returns host.Info result as trdsql.SliceReader.
func HostTemperatureReader ¶
func HostTemperatureReader() (*trdsql.SliceReader, error)
HostTemperatureReader returns host.SensorsTemperatures result as trdsql.SliceReader.
func HostUsersReader ¶
func HostUsersReader() (*trdsql.SliceReader, error)
HostUsersReader returns host.Users result as trdsql.SliceReader.
func LoadAvgReader ¶
func LoadAvgReader() (*trdsql.SliceReader, error)
LoadAvgReader returns load.Avg result as trdsql.SliceReader.
func LoadMiscReader ¶
func LoadMiscReader() (*trdsql.SliceReader, error)
LoadMiscReader returns load.Misc result as trdsql.SliceReader.
func NetReader ¶
func NetReader() (*trdsql.SliceReader, error)
NetReader returns net.Connections result as trdsql.SliceReader.
func PSTableQuery ¶
PSTableQuery executes SQL on tables.
func ProcessQuery ¶
ProcessQuery executes SQL on process.Processes.
func SwapMemoryReader ¶
func SwapMemoryReader() (*trdsql.SliceReader, error)
SwapMemoryReader returns mem.SwapMemory result as trdsql.SliceReader.
func TableReader ¶
func TableReader() (*trdsql.SliceReader, error)
TableReader return table name as trdsql.SliceReader.
func VirtualMemoryReader ¶
func VirtualMemoryReader() (*trdsql.SliceReader, error)
VirtualMemoryReader returns mem.VirtualMemory result as trdsql.SliceReader.
Types ¶
type MultiImporter ¶
type MultiImporter struct {
// contains filtered or unexported fields
}
MultiImporter is a structure for importing multiple readers.
func NewMultiImporter ¶
func NewMultiImporter(readers ...Reader) (*MultiImporter, error)
NewMultiImporter takes multiple readers as arguments and returns a MultiImporter.
func (*MultiImporter) ImportContext ¶ added in v0.0.2
func (i *MultiImporter) ImportContext(ctx context.Context, db *trdsql.DB, query string) (string, error)
ImportContext executes import.
type ProcessReader ¶
type ProcessReader struct {
// contains filtered or unexported fields
}
The ProcessReader structure represents a process and satisfies the trdsql.Reader interface.
func NewProcessReader ¶
func NewProcessReader(ex bool) (*ProcessReader, error)
NewProcessReader returns process.Processes result as ProcessReader.
func (*ProcessReader) Names ¶
func (p *ProcessReader) Names() ([]string, error)
Names returns column names.
func (*ProcessReader) PreReadRow ¶
func (p *ProcessReader) PreReadRow() [][]any
PreReadRow is returns entity of the data.
func (*ProcessReader) ReadRow ¶
func (p *ProcessReader) ReadRow(row []any) ([]any, error)
ReadRow only returns EOF.
func (*ProcessReader) TableName ¶
func (p *ProcessReader) TableName() (string, error)
TableName returns TableName.
func (*ProcessReader) Types ¶
func (p *ProcessReader) Types() ([]string, error)
Types returns column types.