Documentation ¶
Index ¶
Constants ¶
View Source
const ( ActionType_Kafka = 1 ActionType_Bucket = 2 )
ActionType
View Source
const ( Action1Type_Republish = "republish" Action1Type_Kafka = "kafka" Action1Type_Bucket = "bucket" Action1Type_Chronus = "clickhouse" Action1Type_MYSQL = "mysql" Action1Type_POSTGRESQL = "postgresql" Action1Type_REDIS = "redis" Action1Type_INFLUXDB = "influxdb" )
ActionType
View Source
const ( TopicTypeProperty = "property" TopicTypeEvent = "event" TopicTypeAll = "+" TopicTypeRaw = "raw" )
View Source
const ( EventName = "name-event-" EventDefaultName = EventName + "default" EventNameRuleStatus = EventName + "rule-status" EventNameRuleActive = EventName + "rule-active" )
---------event name-----------------------
View Source
const ( //action status ActionStatusBan = "ban" ActionStatusStop = "stop" ActionStatusStating = "stating" ActionStatusStopping = "stopping" ActionStatusRunning = "running" ActionStatusError = "error" ActionStatusException = "exception" //rule在metadata创建, 等待异步消息 RuleStart = "RuleStart" //rule启动失败,rule未启动 RuleStartError = "RuleStartError" RuleActionStart = "RuleActionStart" RuleActionStartError = "RuleActionStartError" RuleStarted = "RuleStarted" RuleStoped = "RuleStoped" RuleActionError = "RuleActionError" RuleActionFail = "RuleActionFail" RuleActionStarted = "RuleActionStarted" )
rule status
View Source
const ( RuleStatusBan = iota + 1 RuleStatusStop RuleStatusRunning RuleStatusException RuleStatusError RuleStatusStating RuleStatusStopping )
View Source
const ( CommandStatusRuleStart = RuleStatusStating CommandStatusRuleStop = RuleStatusStop )
由用户发出的指令状态
View Source
const ErrorPrefix = "RuleErr-"
View Source
const MappingInfoKey = "mapping"
action的configuration里的字段
View Source
const TagsInfoKey = "tags"
Variables ¶
View Source
var Action1Types = []string{ Action1Type_Republish, Action1Type_Kafka, Action1Type_Bucket, Action1Type_Chronus, Action1Type_MYSQL, Action1Type_POSTGRESQL, Action1Type_REDIS, }
View Source
var ActionTypes = []uint8{ ActionType_Kafka, ActionType_Bucket, }
View Source
var TopicTypes = []string{ TopicTypeProperty, TopicTypeEvent, TopicTypeAll, TopicTypeRaw, }
Functions ¶
This section is empty.
Types ¶
Click to show internal directories.
Click to hide internal directories.