g

Documentation

Index

• Constants
• Variables
• func DuPaths() []string
• func Hostname() (string, error)
• func IP() string
• func InitLocalIps()
• func InitLog()
• func InitRootDir()
• func InitRpcClients()
• func IsTrustable(remoteAddr string) bool
• func Logger() *log.Logger
• func ParseConfig(cfg string)
• func ReportPorts() []int64
• func ReportProcs() map[string]map[int]string
• func ReportUrls() map[string]string
• func SendMetrics(metrics []*model.MetricValue, resp *model.TransferResponse)
• func SendToTransfer(metrics []*model.MetricValue)
• func SetDuPaths(paths []string)
• func SetReportPorts(ports []int64)
• func SetReportProcs(procs map[string]map[int]string)
• func SetReportUrls(urls map[string]string)
• func SetTrustableIps(ipStr string)
• func TrustableIps() []string
• type CollectorConfig
• type GlobalConfig
  • func Config() *GlobalConfig
• type HeartbeatConfig
• type HttpConfig
• type IIsConfig
• type MsSQLConfig
• type SingleConnRpcClient
  • func (this *SingleConnRpcClient) Call(method string, args interface{}, reply interface{}) error
• type TransferConfig

Constants

const (
	VERSION          = "1.0.3"
	COLLECT_INTERVAL = time.Second
	NET_PORT_LISTEN  = "net.port.listen"
	DU_BS            = "du.bs"
	PROC_NUM         = "proc.num"
)

changelog: 1.0.0 windows-agent 1.0.1 ifstat use ifname instead ifdescription 1.0.2 fix net.listen.port bug 1.0.3 add default tag ,fix net.listen.port bug

Variables

var (
	TransferClientsLock *sync.RWMutex                   = new(sync.RWMutex)
	TransferClients     map[string]*SingleConnRpcClient = map[string]*SingleConnRpcClient{}
)

var (
	ConfigFile string
)

var LocalIps []string

var (
	Root string
)

Functions

func DuPaths

func DuPaths() []string

func Hostname

func Hostname() (string, error)

func IP

func IP() string

func InitLocalIps

func InitLocalIps()

func InitLog

func InitLog()

func InitRootDir

func InitRootDir()

func InitRpcClients

func InitRpcClients()

func IsTrustable

func IsTrustable(remoteAddr string) bool

func Logger

func Logger() *log.Logger

func ParseConfig

func ParseConfig(cfg string)

func ReportPorts

func ReportPorts() []int64

func ReportProcs

func ReportProcs() map[string]map[int]string

func ReportUrls

func ReportUrls() map[string]string

func SendMetrics

func SendMetrics(metrics []*model.MetricValue, resp *model.TransferResponse)

func SendToTransfer

func SendToTransfer(metrics []*model.MetricValue)

func SetDuPaths

func SetDuPaths(paths []string)

func SetReportPorts

func SetReportPorts(ports []int64)

func SetReportProcs

func SetReportProcs(procs map[string]map[int]string)

func SetReportUrls

func SetReportUrls(urls map[string]string)

func SetTrustableIps

func SetTrustableIps(ipStr string)

func TrustableIps

func TrustableIps() []string

Types

type CollectorConfig

type CollectorConfig struct {
	IfacePrefix []string `json:"ifacePrefix"`
}

type GlobalConfig

type GlobalConfig struct {
	Debug         bool              `json:"debug"`
	Hostname      string            `json:"hostname"`
	IP            string            `json:"ip"`
	IIs           *IIsConfig        `json:"iis"`
	MsSQL         *MsSQLConfig      `json:"mssql"`
	Logfile       string            `json:"logfile"`
	Heartbeat     *HeartbeatConfig  `json:"heartbeat"`
	Transfer      *TransferConfig   `json:"transfer"`
	Http          *HttpConfig       `json:"http"`
	Collector     *CollectorConfig  `json:"collector"`
	DefaultTags   map[string]string `json:"default_tags"`
	IgnoreMetrics map[string]bool   `json:"ignore"`
}

func Config

func Config() *GlobalConfig

type HeartbeatConfig

type HeartbeatConfig struct {
	Enabled  bool   `json:"enabled"`
	Addr     string `json:"addr"`
	Interval int    `json:"interval"`
	Timeout  int    `json:"timeout"`
}

type HttpConfig

type HttpConfig struct {
	Enabled  bool   `json:"enabled"`
	Listen   string `json:"listen"`
	Backdoor bool   `json:"backdoor"`
}

type IIsConfig

type IIsConfig struct {
	Enabled  bool     `json:"enabled"`
	Websites []string `json:"websites"`
}

type MsSQLConfig

type MsSQLConfig struct {
	Enabled  bool     `json:"enabled"`
	Addr     string   `json:"addr"`
	Port     int      `json:"port"`
	Username string   `json:"username"`
	Password string   `json:"password"`
	Encrypt  string   `json:"encrypt"`
	Instance []string `json:"instance"`
}

type SingleConnRpcClient

type SingleConnRpcClient struct {
	sync.Mutex

	RpcServer string
	Timeout   time.Duration
	// contains filtered or unexported fields
}

var (
	HbsClient *SingleConnRpcClient
)

func (*SingleConnRpcClient) Call

func (this *SingleConnRpcClient) Call(method string, args interface{}, reply interface{}) error

type TransferConfig

type TransferConfig struct {
	Enabled  bool     `json:"enabled"`
	Addrs    []string `json:"addrs"`
	Interval int      `json:"interval"`
	Timeout  int      `json:"timeout"`
}