collector

package
v0.1.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 23, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNoData = errors.New("no data")

ErrNoData 表示采集成功但当前周期无有效数据可上报（如 GPU 不存在、磁盘列表为空）。 调用方应静默跳过，不视为错误。

Functions

This section is empty.

Types

type CPUCollector 

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

CPUCollector CPU 监控采集器

func NewCPUCollector 

func NewCPUCollector() *CPUCollector

NewCPUCollector 创建 CPU 采集器

func (*CPUCollector) Collect 

func (c *CPUCollector) Collect() (*protocol.CPUData, error)

Collect 采集 CPU 数据(返回完整数据,包括静态和动态信息)

type DDNSCollector 

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

DDNSCollector DDNS IP 地址采集器

func NewDDNSCollector 

func NewDDNSCollector(config *protocol.DDNSConfigData) *DDNSCollector

NewDDNSCollector 创建 DDNS 采集器

func (*DDNSCollector) Collect 

func (d *DDNSCollector) Collect() (*protocol.DDNSIPReportData, error)

Collect 采集 IP 地址

func (*DDNSCollector) GetIPFromAPI 

func (d *DDNSCollector) GetIPFromAPI(apiURL string, isIPv6 bool) (string, error)

GetIPFromAPI 通过 API 获取 IP 地址（支持轮询多个 API）

func (*DDNSCollector) GetIPFromInterface 

func (d *DDNSCollector) GetIPFromInterface(interfaceName string, isIPv6 bool) (string, error)

GetIPFromInterface 从网卡获取 IP 地址

func (*DDNSCollector) UpdateConfig 

func (d *DDNSCollector) UpdateConfig(config *protocol.DDNSConfigData)

UpdateConfig 更新配置

type DiskCollector 

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

DiskCollector 磁盘监控采集器

func NewDiskCollector 

func NewDiskCollector(cfg *config.Config) *DiskCollector

NewDiskCollector 创建磁盘采集器

func (*DiskCollector) Collect 

func (d *DiskCollector) Collect() ([]protocol.DiskData, error)

Collect 采集磁盘数据 只采集配置的 DiskInclude 白名单中的挂载点

type DiskIOCollector 

type DiskIOCollector struct {
}

DiskIOCollector 磁盘 IO 监控采集器

func NewDiskIOCollector 

func NewDiskIOCollector() *DiskIOCollector

NewDiskIOCollector 创建磁盘 IO 采集器

func (*DiskIOCollector) Collect 

func (d *DiskIOCollector) Collect() ([]protocol.DiskIOData, error)

Collect 采集磁盘 IO 数据(间隔1秒采集两次计算速率)

type GPUCollector 

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

GPUCollector GPU 监控采集器

func NewGPUCollector 

func NewGPUCollector() *GPUCollector

NewGPUCollector 创建 GPU 采集器

func (*GPUCollector) Collect 

func (g *GPUCollector) Collect() ([]*protocol.GPUData, error)

Collect 采集 GPU 数据(合并静态和动态数据)

type HostCollector 

type HostCollector struct{}

HostCollector 主机信息采集器

func NewHostCollector 

func NewHostCollector() *HostCollector

NewHostCollector 创建主机信息采集器

func (*HostCollector) Collect 

func (h *HostCollector) Collect() (*protocol.HostInfoData, error)

Collect 采集主机信息（定期采集以检测主机名等变化）

type Manager 

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

Manager 采集器管理器：纯采集，不做 I/O

func NewManager 

func NewManager(cfg *config.Config) *Manager

NewManager 创建采集器管理器

func (*Manager) CollectCPU added in v0.1.9 

func (m *Manager) CollectCPU() (protocol.MetricSample, error)

CollectCPU 采集 CPU 指标

func (*Manager) CollectDisk added in v0.1.9 

func (m *Manager) CollectDisk() (protocol.MetricSample, error)

CollectDisk 采集磁盘指标。无有效数据时返回 ErrNoData。

func (*Manager) CollectDiskIO added in v0.1.9 

func (m *Manager) CollectDiskIO() (protocol.MetricSample, error)

CollectDiskIO 采集磁盘 IO 指标

func (*Manager) CollectGPU added in v0.1.9 

func (m *Manager) CollectGPU() (protocol.MetricSample, error)

CollectGPU 采集 GPU 指标。无 GPU 时返回 ErrNoData（GPU 不是必备）

func (*Manager) CollectHost added in v0.1.9 

func (m *Manager) CollectHost() (protocol.MetricSample, error)

CollectHost 采集主机信息（含 Load）

func (*Manager) CollectMemory added in v0.1.9 

func (m *Manager) CollectMemory() (protocol.MetricSample, error)

CollectMemory 采集内存指标

func (*Manager) CollectMonitor added in v0.1.9 

func (m *Manager) CollectMonitor(items []protocol.MonitorItem) protocol.MetricSample

CollectMonitor 采集服务监控数据（HTTP/TCP 探活）

func (*Manager) CollectNetwork added in v0.1.9 

func (m *Manager) CollectNetwork() (protocol.MetricSample, error)

CollectNetwork 采集网络指标。无有效数据时返回 ErrNoData。

func (*Manager) CollectNetworkConnection added in v0.1.9 

func (m *Manager) CollectNetworkConnection() (protocol.MetricSample, error)

CollectNetworkConnection 采集网络连接统计

func (*Manager) CollectTemperature added in v0.1.9 

func (m *Manager) CollectTemperature() (protocol.MetricSample, error)

CollectTemperature 采集温度信息。无传感器时返回 ErrNoData（温度不是必备）

func (*Manager) GetInterfaceIP 

func (m *Manager) GetInterfaceIP(interfaceName string, isIPv6 bool) (string, error)

GetInterfaceIP 从网络接口获取 IP 地址

func (*Manager) GetPublicIP 

func (m *Manager) GetPublicIP(apiURL string, isIPv6 bool) (string, error)

GetPublicIP 通过 API 获取公网 IP 地址

type MemoryCollector 

type MemoryCollector struct {
}

MemoryCollector 内存监控采集器

func NewMemoryCollector 

func NewMemoryCollector() *MemoryCollector

NewMemoryCollector 创建内存采集器

func (*MemoryCollector) Collect 

func (m *MemoryCollector) Collect() (*protocol.MemoryData, error)

Collect 采集内存数据(返回完整数据,包括静态和动态信息)

type MonitorCollector 

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

MonitorCollector 监控采集器

func NewMonitorCollector 

func NewMonitorCollector() *MonitorCollector

NewMonitorCollector 创建监控采集器

func (*MonitorCollector) Collect 

func (c *MonitorCollector) Collect(items []protocol.MonitorItem) []protocol.MonitorData

Collect 采集所有监控项数据

type NetworkCollector 

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

NetworkCollector 网络监控采集器

func NewNetworkCollector 

func NewNetworkCollector(cfg *config.Config) *NetworkCollector

NewNetworkCollector 创建网络采集器

func (*NetworkCollector) Collect 

func (n *NetworkCollector) Collect() ([]protocol.NetworkData, error)

Collect 采集网络数据(间隔1秒采集两次计算速率)

type NetworkConnectionCollector 

type NetworkConnectionCollector struct {
}

NetworkConnectionCollector 网络连接统计采集器

func NewNetworkConnectionCollector 

func NewNetworkConnectionCollector() *NetworkConnectionCollector

NewNetworkConnectionCollector 创建网络连接统计采集器

func (*NetworkConnectionCollector) Collect 

func (n *NetworkConnectionCollector) Collect() (*protocol.NetworkConnectionData, error)

Collect 采集网络连接统计数据

type TemperatureCollector 

type TemperatureCollector struct{}

TemperatureCollector 温度监控采集器

func NewTemperatureCollector 

func NewTemperatureCollector() *TemperatureCollector

NewTemperatureCollector 创建温度采集器

func (*TemperatureCollector) Collect 

func (t *TemperatureCollector) Collect() ([]*protocol.TemperatureData, error)

Collect 采集温度数据（某些系统可能不支持）

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.