g

package

v0.0.0-...-1476bde Latest Latest Go to latest Published: Jan 3, 2017 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/leonzyang/agent-1

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AutoUpdateChk(v string)
func DuPaths() []string
func GetCurrPluginVersion() string
func Hostname() (string, error)
func IP() string
func InitLocalIp()
func InitRootDir()
func InitRpcClients()
func IsTrustable(remoteAddr string) bool
func ParseConfig(cfg string)
func ReportPorts() []int64
func ReportProcs() map[string]map[int]string
func ReportUrls() map[string]string
func RestartDaemon()
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
func UnCompressAgent(filename, destdir string) error
func UnCompressAgentTest(filename string) error
func UnTarGz(srcFilePath string, destDirPath string) error
func UpdateAgent(filename string) error
type AutoUpdateConfig
type CollectorConfig
type GlobalConfig
- func Config() *GlobalConfig
type HeartbeatConfig
type HttpConfig
type PluginConfig
type SingleConnRpcClient
- func (this *SingleConnRpcClient) Call(method string, args interface{}, reply interface{}) error
type TransferConfig

Constants ¶

View Source

const (
	VERSION          = "5.1.1"
	COLLECT_INTERVAL = time.Second
	URL_CHECK_HEALTH = "url.check.health"
	NET_PORT_LISTEN  = "net.port.listen"
	DU_BS            = "du.bs"
	PROC_NUM         = "proc.num"
)

changelog: 3.1.3: code refactor 3.1.4: bugfix ignore configuration 5.0.0: 支持通过配置控制是否开启/run接口；收集udp流量数据；du某个目录的大小 5.1.0: 同步插件的时候不再使用checksum机制 5.1.1: 修复往多个transfer发送数据的时候crash的问题

View Source

const (
	ExecFile    = "falcon-agent"
	TmpExecFile = "falcon-agent-tmp"
)

Variables ¶

View Source

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

View Source

var (
	ConfigFile string
)

View Source

var LocalIp string

View Source

var Root string

Functions ¶

func AutoUpdateChk ¶

func AutoUpdateChk(v string)

func DuPaths ¶

func DuPaths() []string

func GetCurrPluginVersion ¶

func GetCurrPluginVersion() string

func Hostname ¶

func Hostname() (string, error)

func IP ¶

func IP() string

func InitLocalIp ¶

func InitLocalIp()

func InitRootDir ¶

func InitRootDir()

func InitRpcClients ¶

func InitRpcClients()

func IsTrustable ¶

func IsTrustable(remoteAddr string) bool

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 RestartDaemon ¶

func RestartDaemon()

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

func UnCompressAgent ¶

func UnCompressAgent(filename, destdir string) error

func UnCompressAgentTest ¶

func UnCompressAgentTest(filename string) error

func UnTarGz ¶

func UnTarGz(srcFilePath string, destDirPath string) error

func UpdateAgent ¶

func UpdateAgent(filename string) error

Types ¶

type AutoUpdateConfig ¶

type AutoUpdateConfig struct {
	Enabled  bool   `json:"enabled"`
	Dir      string `json:"dir"`
	Url      string `json:"url"`
	Tar      string `json:"tar"`
	Interval int    `json:"interval"`
	RandInt  int    `json:"randInt"`
	Timeout  int    `json:"timeout"`
}

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"`
	PidFile       string            `json:"pidfile"`
	Plugin        *PluginConfig     `json:"plugin"`
	AutoUpdate    *AutoUpdateConfig `json:"autoupdate"`
	Heartbeat     *HeartbeatConfig  `json:"heartbeat"`
	Transfer      *TransferConfig   `json:"transfer"`
	Http          *HttpConfig       `json:"http"`
	Collector     *CollectorConfig  `json:"collector"`
	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 PluginConfig ¶

type PluginConfig struct {
	Enabled bool   `json:"enabled"`
	Dir     string `json:"dir"`
	Git     string `json:"git"`
	LogDir  string `json:"logs"`
}

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"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL