logic

Documentation

Index

• type AggregationParser
• type BackendFactory
• type LogParser
• type LuaState
• type QQWry
• type QueryBuilder
• type SLSConfig
• type SLSSearchResult

Types

type AggregationParser

type AggregationParser interface {
	ParseElastic(timeA, timeB, interval int64, m map[string]*elastic.SearchResult) (xAxis []string, yAxis []int64, err error)
	ParseSLS(timeA, timeB, interval int64, m map[string]SLSSearchResult) (xAxis []string, yAxis []int64, err error)
}

type BackendFactory

type BackendFactory interface {
	GetBackendElastic(name string) (cli *elastic.Client, err error)
	GetBackendSLS(name string) (cli sls.ClientInterface, err error)
	GetBackend(name string) (res interface{}, err error)
}

type LogParser

type LogParser interface {
	ParseElastic(backend config.Backend, m map[string]*elastic.SearchResult) (total int, logs service.LogItems, err error)
	ParseSLS(backend config.Backend, m map[string]SLSSearchResult) (total int, logs service.LogItems, err error)
}

type LuaState

type LuaState interface {
	GetLuaState() (L *lua.LState, fn func())
}

type QQWry

type QQWry interface {
	Find(ctx context.Context, ip string) (location fmt.Stringer, err error)
}

type QueryBuilder

type QueryBuilder interface {
	SearchQueryElastic(backend config.Backend, req service.SearchRequest) (
		queries map[string]elastic.Query,
		aggregations map[string]elastic.Aggregation,
		err error,
	)
	SearchQuerySLS(backend config.Backend, req service.SearchRequest) (
		queries map[string]string,
		err error,
	)
}

type SLSConfig

type SLSConfig struct {
	Endpoint        string `json:"endpoint"`
	AccessKeyID     string `json:"access_key_id"`
	AccessKeySecret string `json:"access_key_secret"`
	SecurityToken   string `json:"security_token"`
}

type SLSSearchResult

type SLSSearchResult struct {
	ResponseCountByGetHistograms *sls.GetHistogramsResponse `json:"response_count_by_get_histograms"`
	ResponseCountByGetLogs       *sls.GetLogsV3Response     `json:"response_count_by_get_logs"`
	ResponseLog                  *sls.GetLogsV3Response     `json:"response_log"`
	ResponseAggregation          *sls.GetHistogramsResponse `json:"response_aggregation"`
	ErrorByGetHistograms         error                      `json:"error_by_get_histograms"`
	ErrorByGetLogs               error                      `json:"error_by_get_logs"`
	ErrorResponseLog             error                      `json:"error_response_log"`
	ErrorResponseAggregation     error                      `json:"error_response_aggregation"`
}