internal

Documentation

Index

• func GetUrl() string
• func Init() (bool, error)
• func InitConfig()
• func NewClient() *http.Client
• func RunLoop(start func() bool, stop func())
• type AgentType
• type Config
• type HeaderRoundTripper
  • func (h *HeaderRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
• type ProcessData
  • func (p *ProcessData) UnmarshalJSON(data []byte) error
• type ResponseData
  • func (r *ResponseData) UnmarshalJSON(data []byte) error
• type Tech

Functions

func GetUrl

func GetUrl() string

func Init

func Init() (bool, error)

func InitConfig

func InitConfig()

InitConfig 初始化配置，带文件监控功能

func NewClient

func NewClient() *http.Client

func RunLoop

func RunLoop(start func() bool, stop func())

RunLoop 循环检测配置文件变化，并按需启停采集 @param start 启动采集回调，返回值为是否继续检查 @param stop 停止采集回调

Types

type AgentType

type AgentType int32

type Config

type Config struct {
	Common struct {
		ControllerURL string `yaml:"controllerUrl"`
		AccountGUID   string `yaml:"accountGUID"`
	} `yaml:"common"`
}

type HeaderRoundTripper

type HeaderRoundTripper struct {
	Transport http.RoundTripper
	Headers   http.Header
}

func (*HeaderRoundTripper) RoundTrip

func (h *HeaderRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type ProcessData

type ProcessData struct {
	PID               int32    `json:"pid,omitempty"`
	PPID              int32    `json:"ppid,omitempty"`
	ProcessGroupName  string   `json:"processGroupName,omitempty"`
	ProcessGroupIndex int      `json:"processGroupIndex,omitempty"`
	DetectionType     string   `json:"detectionType,omitempty"`
	Type              int      `json:"type,omitempty"`
	Techs             []Tech   `json:"techs,omitempty"`
	State             string   `json:"state,omitempty"`
	StartTime         int64    `json:"startTime,omitempty"`
	Name              string   `json:"name,omitempty"`
	Cmd               string   `json:"cmd,omitempty"`
	ContainerId       string   `json:"containerId,omitempty"`
	ListenPorts       []string `json:"listenPorts,omitempty"`
	ProcessUID        string   `json:"processUID,omitempty"`
	AgentUID          string   `json:"agentUID,omitempty"`
	AgentVersion      string   `json:"agentVersion,omitempty"`
	Cpu               float64  `json:"cpu,omitempty"`
}

func (*ProcessData) UnmarshalJSON

func (p *ProcessData) UnmarshalJSON(data []byte) error

UnmarshalJSON for ProcessData to handle string to int conversion

type ResponseData

type ResponseData struct {
	Code int `json:"code,omitempty"`
	Data struct {
		QueryTime         string        `json:"queryTime,omitempty"`
		UniqueHost        string        `json:"uniqueHost,omitempty"`
		EnableHostMonitor string        `json:"enableHostMonitor,omitempty"`
		AccountGUID       string        `json:"accountGUID,omitempty"`
		EnvID             string        `json:"envId,omitempty"`
		Cluster           string        `json:"cluster,omitempty"`
		NetworkZone       string        `json:"networkzone,omitempty"`
		ContainerCount    string        `json:"containerCount,omitempty"`
		User              string        `json:"user,omitempty"`
		Group             string        `json:"group,omitempty"`
		Mode              string        `json:"mode,omitempty"`
		InjectMode        string        `json:"injectMode,omitempty"`
		Processes         []ProcessData `json:"processes,omitempty"`
	} `json:"data,omitempty"`
}

func (*ResponseData) UnmarshalJSON

func (r *ResponseData) UnmarshalJSON(data []byte) error

UnmarshalJSON for ResponseData to handle string to int conversion

type Tech

type Tech struct {
	Value   string `json:"value,omitempty"`
	Version string `json:"version,omitempty"`
}