es

Documentation

Index

• func AllIndex() interface{}
• func DeleteIndex(indexName string) interface{}
• func GroupField(indexName, field string, size, minCount int, excludeValues []string) []byte
• func Init()
• func InsertEsLog(logInfo interface{})
• func TestLog()
• type IndexInfo
• type QueryParams
• type ServerLogModel
  • func QueryLogs(indexName string, params []QueryParams, sortsDesc map[string]bool, ...) (total int64, data []ServerLogModel)

Functions

func AllIndex

func AllIndex() interface{}

func DeleteIndex

func DeleteIndex(indexName string) interface{}

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

type QueryParams

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

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

func QueryLogs

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