es

Documentation

Index

• Constants
• func ClearESLog()
• func CreateIndex(indexName string)
• func DeleteIndex(indexName string) interface{}
• func GetEsStatus() int
• func GetIndexPre() string
• func GroupField(indexName, field string, size, minCount int, excludeValues []string) []byte
• func Init()
• func InsertEsLog(logInfo interface{})
• func TestLog()
• type IndexInfo
  • func AllIndex() []IndexInfo
• type QueryParams
• type ServerLogData
  • func QueryLogs(indexName string, params []QueryParams, sortsDesc map[string]bool, ...) (total int64, data []ServerLogData)
  • func QueryLogsForApi(c *gin.Context, indexName string, params []QueryParams, ...) (total int64, data []ServerLogData)
• type ServerLogModel

Constants

const (
	NewTermQuery               = "NewTermQuery"
	NewMatchPhraseQuery        = "NewMatchPhraseQuery"
	NewRegexpQuery             = "NewRegexpQuery"
	NewTermQueryNotMust        = "NewTermQueryNotMust"
	NewMatchPhraseQueryNotMust = "NewMatchPhraseQueryNotMust"
	NewRegexpQueryNotMust      = "NewRegexpQueryNotMust"
)

Functions

func ClearESLog

func ClearESLog()

func CreateIndex

func CreateIndex(indexName string)

func DeleteIndex

func DeleteIndex(indexName string) interface{}

func GetEsStatus

func GetEsStatus() int

func GetIndexPre

func GetIndexPre() string

func GroupField

func GroupField(indexName, field string, size, minCount int, excludeValues []string) []byte

func Init

func Init()

func InsertEsLog

func InsertEsLog(logInfo interface{})

func TestLog

func TestLog()

Types

type IndexInfo

type IndexInfo struct {
	Name  string `json:"name"`
	Count int    `json:"count"`
	Size  string `json:"size"`
}

func AllIndex

func AllIndex() []IndexInfo

type QueryParams

type QueryParams struct {
	Name  string
	Value interface{}
	Type  string
}

type ServerLogData

type ServerLogData struct {
	Id           string `json:"id"`
	ServerName   string `json:"serverName"`
	Env          string `json:"env"`
	TimeStamp    int64  `json:"timeStamp"`
	ThreadNo     string `json:"threadNo"`
	ServerIp     string `json:"serverIp"`
	ClientIp     string `json:"clientIp"`
	Token        string `json:"token"`
	CustomerId   int32  `json:"customerId"`
	ClientSource string `json:"clientSource"` //请求中所有header信息
	Url          string `json:"url"`
	Method       string `json:"method"`
	Request      string `json:"request"`
	Response     string `json:"response"`
	DealTimes    int64  `json:"dealTimes"`
}

func QueryLogs

func QueryLogs(indexName string, params []QueryParams, sortsDesc map[string]bool, from, size int) (total int64, data []ServerLogData)

func QueryLogsForApi

func QueryLogsForApi(c *gin.Context, indexName string, params []QueryParams, sortsDesc map[string]bool, from, size int) (total int64, data []ServerLogData)

type ServerLogModel

type ServerLogModel struct {
	ServerName   string `json:"serverName"`
	Env          string `json:"env"`
	TimeStamp    int64  `json:"timeStamp"`
	ThreadNo     string `json:"threadNo"`
	ServerIp     string `json:"serverIp"`
	ClientIp     string `json:"clientIp"`
	Token        string `json:"token"`
	CustomerId   int32  `json:"customerId"`
	ClientSource string `json:"clientSource"`
	Url          string `json:"url"`
	Method       string `json:"method"`
	Request      string `json:"request"`
	Response     string `json:"response"`
	DealTimes    int64  `json:"dealTimes"`
}