action

Documentation

Index

• Constants
• Variables
• func AddMetaEvent(kafkaData model.KafkaData) (err error)
• func AddTableColumn(kafkaData model.KafkaData, ...) (err error)
• func MysqlConsumer()

Constants

const (
	PresetAttribute  = 1
	CustomAttribute  = 2
	IsUserAttribute  = 1
	IsEventAttribute = 2
)

Variables

var AttributeMap sync.Map

var MetaAttrRelationSet sync.Map

var MetaEventMap sync.Map

Functions

func AddMetaEvent

func AddMetaEvent(kafkaData model.KafkaData) (err error)

func AddTableColumn

func AddTableColumn(kafkaData model.KafkaData, failFunc func(data consumer_data.ReportAcceptStatusData), tableName string, ReqDataObject *parser.FastjsonMetric) (err error)

func MysqlConsumer

func MysqlConsumer()