mqwork_base

Documentation

Index

• Constants
• type DbConfDto
• type MqWorkConfDto
• type WorkConfDto
• type WorkDto

Constants

const (
	CLICKHOUSE    = "clickhouse"
	STARROCKS     = "starrocks"
	TIDB          = "tidb"
	ELASTICSEARCH = "elasticsearch"
	TDENGINE      = "tdengine"
	GAUSSDB       = "gaussdb"
	MYSQL         = "mysql"
	POSTGRESQL    = "postgresql"
	TBASE         = "tbase"
)

const (
	NSQ          = "nsq"
	KAFKA        = "kafka"
	RABBITMQ     = "rabbitmq"
	REDIS_STREAM = "redisstream"
	ROCKETMQ     = "rocketmq"
)

Types

type DbConfDto

type DbConfDto struct {
	DbType     string
	DbIdentify string
	DbSource   string
}

type MqWorkConfDto

type MqWorkConfDto struct {
	DbConf    []DbConfDto
	WorkConf  []WorkConfDto
	DebugConf []string
}

type WorkConfDto

type WorkConfDto struct {
	MqType       string
	MqIdentify   string
	Addr         string
	ProducerAddr string
	Channel      string
	LogLevel     string
	TopicHandler interface{}
}

type WorkDto

type WorkDto struct {
	Conf           map[string]string
	MqName         string
	MqAddr         []string
	MqChannel      string
	MqTopic        string
	MqProducerAddr string
	Handler        interface{}
	HandlerName    string
}