p17860254
/
categraf
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

rename InputName to inputName

This commit is contained in:
Ulric Qin 2022-04-17 08:02:33 +08:00
parent f849f8c7b9
commit 53ea839771
9 changed files with 27 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
inputs/cpu/cpu.go
View File

@ -10,7 +10,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "cpu" const inputName = "cpu"
type CPUStats struct { type CPUStats struct {
ps system.PS ps system.PS
@ -23,7 +23,7 @@ type CPUStats struct {
func init() { func init() {
ps := system.NewSystemPS() ps := system.NewSystemPS()
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &CPUStats{ return &CPUStats{
ps: ps, ps: ps,
} }
@ -31,7 +31,7 @@ func init() {
} }
func (s *CPUStats) GetInputName() string { func (s *CPUStats) GetInputName() string {
return InputName return inputName
} }
func (s *CPUStats) GetIntervalSeconds() int64 { func (s *CPUStats) GetIntervalSeconds() int64 {

6
inputs/disk/disk.go
View File

@ -9,7 +9,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "disk" const inputName = "disk"
type DiskStats struct { type DiskStats struct {
ps system.PS ps system.PS
@ -22,7 +22,7 @@ type DiskStats struct {
func init() { func init() {
ps := system.NewSystemPS() ps := system.NewSystemPS()
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &DiskStats{ return &DiskStats{
ps: ps, ps: ps,
} }
@ -30,7 +30,7 @@ func init() {
} }
func (s *DiskStats) GetInputName() string { func (s *DiskStats) GetInputName() string {
return InputName return inputName
} }
func (s *DiskStats) GetIntervalSeconds() int64 { func (s *DiskStats) GetIntervalSeconds() int64 {

6
inputs/diskio/diskio.go
View File

@ -10,7 +10,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "diskio" const inputName = "diskio"
type DiskIO struct { type DiskIO struct {
ps system.PS ps system.PS
@ -23,7 +23,7 @@ type DiskIO struct {
func init() { func init() {
ps := system.NewSystemPS() ps := system.NewSystemPS()
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &DiskIO{ return &DiskIO{
ps: ps, ps: ps,
} }
@ -31,7 +31,7 @@ func init() {
} }
func (d *DiskIO) GetInputName() string { func (d *DiskIO) GetInputName() string {
return InputName return inputName
} }
func (d *DiskIO) GetIntervalSeconds() int64 { func (d *DiskIO) GetIntervalSeconds() int64 {

6
inputs/kernel/kernel.go
View File

@ -15,7 +15,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "kernel" const inputName = "kernel"
// /proc/stat file line prefixes to gather stats on: // /proc/stat file line prefixes to gather stats on:
var ( var (
@ -35,7 +35,7 @@ type KernelStats struct {
} }
func init() { func init() {
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &KernelStats{ return &KernelStats{
statFile: "/proc/stat", statFile: "/proc/stat",
entropyStatFile: "/proc/sys/kernel/random/entropy_avail", entropyStatFile: "/proc/sys/kernel/random/entropy_avail",
@ -44,7 +44,7 @@ func init() {
} }
func (s *KernelStats) GetInputName() string { func (s *KernelStats) GetInputName() string {
return InputName return inputName
} }
func (s *KernelStats) GetIntervalSeconds() int64 { func (s *KernelStats) GetIntervalSeconds() int64 {

6
inputs/kernel/kernel_notlinux.go
View File

@ -8,7 +8,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "kernel" const inputName = "kernel"
type KernelStats struct { type KernelStats struct {
PrintConfigs bool `toml:"print_configs"` PrintConfigs bool `toml:"print_configs"`
@ -16,13 +16,13 @@ type KernelStats struct {
} }
func init() { func init() {
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &KernelStats{} return &KernelStats{}
}) })
} }
func (s *KernelStats) GetInputName() string { func (s *KernelStats) GetInputName() string {
return InputName return inputName
} }
func (s *KernelStats) GetIntervalSeconds() int64 { func (s *KernelStats) GetIntervalSeconds() int64 {

6
inputs/mem/mem.go
View File

@ -9,7 +9,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "mem" const inputName = "mem"
type MemStats struct { type MemStats struct {
ps system.PS ps system.PS
@ -22,7 +22,7 @@ type MemStats struct {
func init() { func init() {
ps := system.NewSystemPS() ps := system.NewSystemPS()
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &MemStats{ return &MemStats{
ps: ps, ps: ps,
} }
@ -30,7 +30,7 @@ func init() {
} }
func (s *MemStats) GetInputName() string { func (s *MemStats) GetInputName() string {
return InputName return inputName
} }
func (s *MemStats) GetIntervalSeconds() int64 { func (s *MemStats) GetIntervalSeconds() int64 {

6
inputs/net/net.go
View File

@ -11,7 +11,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "net" const inputName = "net"
type NetIOStats struct { type NetIOStats struct {
ps system.PS ps system.PS
@ -26,7 +26,7 @@ type NetIOStats struct {
func init() { func init() {
ps := system.NewSystemPS() ps := system.NewSystemPS()
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &NetIOStats{ return &NetIOStats{
ps: ps, ps: ps,
} }
@ -34,7 +34,7 @@ func init() {
} }
func (s *NetIOStats) GetInputName() string { func (s *NetIOStats) GetInputName() string {
return InputName return inputName
} }
func (s *NetIOStats) GetIntervalSeconds() int64 { func (s *NetIOStats) GetIntervalSeconds() int64 {

6
inputs/netstat/netstat.go
View File

@ -9,7 +9,7 @@ import (
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
) )
const InputName = "netstat" const inputName = "netstat"
type NetStats struct { type NetStats struct {
ps system.PS ps system.PS
@ -20,7 +20,7 @@ type NetStats struct {
func init() { func init() {
ps := system.NewSystemPS() ps := system.NewSystemPS()
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &NetStats{ return &NetStats{
ps: ps, ps: ps,
} }
@ -28,7 +28,7 @@ func init() {
} }
func (s *NetStats) GetInputName() string { func (s *NetStats) GetInputName() string {
return InputName return inputName
} }
func (s *NetStats) GetIntervalSeconds() int64 { func (s *NetStats) GetIntervalSeconds() int64 {

6
inputs/system/system.go
View File

@ -12,7 +12,7 @@ import (
"github.com/shirou/gopsutil/v3/load" "github.com/shirou/gopsutil/v3/load"
) )
const InputName = "system" const inputName = "system"
type SystemStats struct { type SystemStats struct {
PrintConfigs bool `toml:"print_configs"` PrintConfigs bool `toml:"print_configs"`
@ -21,13 +21,13 @@ type SystemStats struct {
} }
func init() { func init() {
inputs.Add(InputName, func() inputs.Input { inputs.Add(inputName, func() inputs.Input {
return &SystemStats{} return &SystemStats{}
}) })
} }
func (s *SystemStats) GetInputName() string { func (s *SystemStats) GetInputName() string {
return InputName return inputName
} }
func (s *SystemStats) GetIntervalSeconds() int64 { func (s *SystemStats) GetIntervalSeconds() int64 {