models

Documentation

Index

• Variables
• func Heartbeat()
• func InsertEs(dataType string, data ESSave)
• func InsertThread()
• func QueryLogLastTime(ip string) (string, error)
• type DataInfo
• type ESSave

Variables

var (
	// DB 数据库连接池
	DB *mgo.Database

	// Config 配置信息
	Config serverConfig
	// LocalIP 本机活动IP
	LocalIP string

	// RuleDB 存放在mongodb rule 的规则库
	RuleDB = []ruleInfo{}
)

var Client *elastic.Client

Client http请求client

Functions

func Heartbeat

func Heartbeat()

Heartbeat 心跳线程，定时刷新配置和规则

func InsertEs

func InsertEs(dataType string, data ESSave)

InsertEs 将数据插入es

func InsertThread

func InsertThread()

InsertThread ES异步写入线程

func QueryLogLastTime

func QueryLogLastTime(ip string) (string, error)

QueryLogLastTime 查询ip最后一条登录日志的时间

Types

type DataInfo

type DataInfo struct {
	IP     string
	Type   string
	System string
	Data   []map[string]string
	Uptime time.Time
}

DataInfo 从agent接收数据的结构

type ESSave

type ESSave struct {
	IP   string            `json:"ip"`
	Data map[string]string `json:"data"`
	Time time.Time         `json:"time"`
}

ESSave 插入es记录结构