cls

Documentation

Index

• Constants
• Variables
• func GetFieldTypeByPrestoType(prestoType string) data.FieldType
• func GetLog(logInfos []*clsAPI.LogInfo, refId string) []*data.Frame
• func GetRequestClient() string
• func Query(ctx context.Context, logServiceParams pluginCommon.LogServiceParams, ...) backend.DataResponse
• func QueryLog(ctx context.Context, logServiceParams pluginCommon.LogServiceParams, ...) backend.DataResponse
• func SearchLog(ctx context.Context, param *clsAPI.SearchLogRequest, region string, ...) (response *clsAPI.SearchLogResponse, err error)
• func Stringify(v interface{}) string
• func StringifyAll(args ...interface{}) []string
• func TransferAnalysisRecordsToFrame(list []map[string]interface{}, Columns []clsAPI.Column, framaName string, ...) []*data.Frame
• type PrestoAndFieldType

Constants

const (
	MaxQueryDataConcurrentGoroutines = 20 // 每个TopicId拥有一个容量为20的并发池
)

Variables

var PrestoAndFieldTypeMap = []PrestoAndFieldType{

	{
		// contains filtered or unexported fields
	},

	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},

	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},

	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},

	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
}

* Presto类型与FieldType转化表

• @doc https://iwiki.woa.com/pages/viewpage.action?pageId=905584985

Functions

func GetFieldTypeByPrestoType

func GetFieldTypeByPrestoType(prestoType string) data.FieldType

func GetLog

func GetLog(logInfos []*clsAPI.LogInfo, refId string) []*data.Frame

func GetRequestClient

func GetRequestClient() string

func Query

func Query(ctx context.Context, logServiceParams pluginCommon.LogServiceParams, query backend.DataQuery, opts pluginCommon.ApiOpts) backend.DataResponse

func QueryLog

func QueryLog(ctx context.Context, logServiceParams pluginCommon.LogServiceParams, query backend.DataQuery, opts pluginCommon.ApiOpts) backend.DataResponse

func SearchLog

func SearchLog(ctx context.Context, param *clsAPI.SearchLogRequest, region string, opts pluginCommon.ApiOpts) (response *clsAPI.SearchLogResponse, err error)

func Stringify

func Stringify(v interface{}) string

func StringifyAll

func StringifyAll(args ...interface{}) []string

func TransferAnalysisRecordsToFrame

func TransferAnalysisRecordsToFrame(list []map[string]interface{}, Columns []clsAPI.Column, framaName string, fieldName string) []*data.Frame

Types

type PrestoAndFieldType

type PrestoAndFieldType struct {
	// contains filtered or unexported fields
}