mqwork_base

package module
v0.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 27, 2024 License: MIT Imports: 0 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CLICKHOUSE    = "clickhouse"
	STARROCKS     = "starrocks"
	TIDB          = "tidb"
	ELASTICSEARCH = "elasticsearch"
	TDENGINE      = "tdengine"
	GAUSSDB       = "gaussdb"
	MYSQL         = "mysql"
	POSTGRESQL    = "postgresql"
	TBASE         = "tbase"
)
View Source
const (
	NSQ          = "nsq"
	KAFKA        = "kafka"
	RABBITMQ     = "rabbitmq"
	REDIS_STREAM = "redisstream"
	ROCKETMQ     = "rocketmq"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DbConfDto added in v0.0.5

type DbConfDto struct {
	DbType     string
	DbIdentify string
	DbSource   string
}

type MqWorkConfDto added in v0.0.5

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

type WorkConfDto added in v0.0.5

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

type WorkDto added in v0.0.3

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL