bumo

Documentation

Index

• Constants
• type Params
• type ParamsData
• type ParamsStream
• type ParamsView
• type QueryAssembly
  • func (q *QueryAssembly) Gen() string

Constants

const (
	ViewTypePrometheusMetric            = 1
	ViewTypePrometheusMetricAggregation = 2
)

const (
	ReplicaStatusYes = iota
	ReplicaStatusNo
)

const (
	DataTypeDistributed = 1
)

const PrometheusMetricName = "clickvisual_alert_metrics"

Types

type Params

type Params struct {
	TableCreateType  int
	Cluster          string
	ReplicaStatus    int
	KafkaJsonMapping string
	LogField         string
	TimeField        string
	Data             ParamsData
	View             ParamsView
	Stream           ParamsStream
}

type ParamsData

type ParamsData struct {
	DataType    int
	TableName   string
	Days        int
	SourceTable string
}

type ParamsStream

type ParamsStream struct {
	TableName               string
	TableTyp                string
	Brokers                 string
	Topic                   string
	Group                   string
	ConsumerNum             int
	KafkaSkipBrokenMessages int
}

type ParamsView

type ParamsView struct {
	WithSQL          string
	ViewType         int
	ViewTable        string
	TargetTable      string
	CommonFields     string
	SourceTable      string
	Where            string
	TimeConvert      string
	IsKafkaTimestamp int
}

type QueryAssembly

type QueryAssembly struct {
	Params Params
	Result string
}

QueryAssembly all in one

func (*QueryAssembly) Gen

func (q *QueryAssembly) Gen() string