connect

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const ClientPrefix = "aide-family-"

Variables

This section is empty.

Functions

func GetMysqlConnect 

func GetMysqlConnect(cfg *MysqlConfig) *gorm.DB

GetMysqlConnect 获取新的数据库连接

func GetMysqlConnectSingle 

func GetMysqlConnectSingle(cfg *MysqlConfig) *gorm.DB

GetMysqlConnectSingle 获取同一个数据库连接

func NewRedisDao 

func NewRedisDao(cfg *RedisConfig) *redis.Client

NewRedisDao 连接池

func NewRedisDaoSingleton 

func NewRedisDaoSingleton(cfg *RedisConfig) *redis.Client

NewRedisDaoSingleton 获取同一个redis连接

Types

type MQTTClient added in v1.1.1 

type MQTTClient struct {
	mqtt.Client
	// contains filtered or unexported fields
}

func NewMQTTClient added in v1.1.1 

func NewMQTTClient(cfg *MqttClientConfig, logger *log.Logger) *MQTTClient

NewMQTTClient create mqtt client

func (*MQTTClient) AppendTopic added in v1.1.1 

func (m *MQTTClient) AppendTopic(topic string, config TopicConfig)

AppendTopic append topic

func (*MQTTClient) AppendTopics added in v1.1.1 

func (m *MQTTClient) AppendTopics(topics map[string]TopicConfig)

AppendTopics append topic

func (*MQTTClient) ClearTopicSet added in v1.1.1 

func (m *MQTTClient) ClearTopicSet()

ClearTopicSet clear topic set

func (*MQTTClient) Publish added in v1.1.1 

func (m *MQTTClient) Publish(msg PublishMessage)

Publish message

func (*MQTTClient) RemoveTopic added in v1.1.1 

func (m *MQTTClient) RemoveTopic(topic string)

RemoveTopic remove topic

func (*MQTTClient) Subscribe added in v1.1.1 

func (m *MQTTClient) Subscribe()

Subscribe subscribe topic

func (*MQTTClient) Unsubscribe added in v1.1.1 

func (m *MQTTClient) Unsubscribe(topic string)

Unsubscribe 关闭主题监听

type MqttClientConfig added in v1.1.1 

type MqttClientConfig struct {
	Broker    string
	Port      int
	Username  string
	Password  string
	ClientId  string
	Keepalive time.Duration
}

MqttClientConfig mqtt client

func NewDefaultMqttClientConfig added in v1.1.1 

func NewDefaultMqttClientConfig() *MqttClientConfig

NewDefaultMqttClientConfig new default mqtt client config

func NewMqttClientConfig added in v1.1.1 

func NewMqttClientConfig(opts ...MqttClientConfigOption) *MqttClientConfig

NewMqttClientConfig new mqtt client config

type MqttClientConfigOption added in v1.1.1 

type MqttClientConfigOption func(*MqttClientConfig)

MqttClientConfigOption mqtt client config option

func WithBroker added in v1.1.1 

func WithBroker(broker string) MqttClientConfigOption

WithBroker set broker

func WithClientId added in v1.1.1 

func WithClientId(clientId string) MqttClientConfigOption

WithClientId set keepalive

func WithKeepalive added in v1.1.1 

func WithKeepalive(keepalive time.Duration) MqttClientConfigOption

WithKeepalive set keepalive

func WithPassword added in v1.1.1 

func WithPassword(password string) MqttClientConfigOption

WithPassword set password

func WithPort added in v1.1.1 

func WithPort(port int) MqttClientConfigOption

WithPort set port

func WithUsername added in v1.1.1 

func WithUsername(username string) MqttClientConfigOption

WithUsername set username

type MysqlConfig 

type MysqlConfig struct {
	User     string
	Password string
	Addr     string
	Port     uint
	DBName   string
	Charset  string
	Debug    bool
}

MysqlConfig 数据库配置类型

func NewMysqlConfig added in v1.1.0 

func NewMysqlConfig(opts ...MysqlConfigOption) *MysqlConfig

NewMysqlConfig 创建数据库配置

type MysqlConfigOption added in v1.1.0 

type MysqlConfigOption func(*MysqlConfig)

func WithMysqlAddr added in v1.1.0 

func WithMysqlAddr(addr string) MysqlConfigOption

WithMysqlAddr 设置数据库地址

func WithMysqlCharset added in v1.1.0 

func WithMysqlCharset(charset string) MysqlConfigOption

WithMysqlCharset 设置数据库字符集

func WithMysqlDBName added in v1.1.0 

func WithMysqlDBName(dbName string) MysqlConfigOption

WithMysqlDBName 设置数据库名

func WithMysqlDebug added in v1.1.0 

func WithMysqlDebug(debug bool) MysqlConfigOption

WithMysqlDebug 设置数据库调试模式

func WithMysqlPassword added in v1.1.0 

func WithMysqlPassword(password string) MysqlConfigOption

WithMysqlPassword 设置数据库密码

func WithMysqlPort added in v1.1.0 

func WithMysqlPort(port uint) MysqlConfigOption

WithMysqlPort 设置数据库端口

func WithMysqlUser added in v1.1.0 

func WithMysqlUser(user string) MysqlConfigOption

WithMysqlUser 设置数据库用户名

type PublishMessage added in v1.1.1 

type PublishMessage struct {
	Topic    string // 主题
	Payload  string // 消息内容
	Qos      byte   // 服务质量
	Retained bool   // 是否保留消息
}

type RedisConfig added in v1.1.0 

type RedisConfig struct {
	redis.Options
}

RedisConfig redis connect

func NewRedisConfig added in v1.1.0 

func NewRedisConfig(options ...RedisConfigOption) *RedisConfig

NewRedisConfig 创建redis配置

type RedisConfigOption added in v1.1.0 

type RedisConfigOption func(*RedisConfig)

func WithRedisAddr added in v1.1.0 

func WithRedisAddr(addr string, port int) RedisConfigOption

WithRedisAddr redis地址

func WithRedisDB added in v1.1.0 

func WithRedisDB(db int) RedisConfigOption

WithRedisDB redis数据库

func WithRedisDialTimeout added in v1.1.0 

func WithRedisDialTimeout(dialTimeout time.Duration) RedisConfigOption

WithRedisDialTimeout redis连接超时时间

func WithRedisDialer added in v1.1.0 

func WithRedisDialer(dialer func() (net.Conn, error)) RedisConfigOption

WithRedisDialer redis连接

func WithRedisIdleCheckFrequency added in v1.1.0 

func WithRedisIdleCheckFrequency(idleCheckFrequency time.Duration) RedisConfigOption

WithRedisIdleCheckFrequency redis空闲检查频率

func WithRedisIdleTimeout added in v1.1.0 

func WithRedisIdleTimeout(idleTimeout time.Duration) RedisConfigOption

WithRedisIdleTimeout redis空闲超时时间

func WithRedisMaxConnAge added in v1.1.0 

func WithRedisMaxConnAge(maxConnAge time.Duration) RedisConfigOption

WithRedisMaxConnAge redis最大连接时间

func WithRedisMaxRetries added in v1.1.0 

func WithRedisMaxRetries(maxRetries int) RedisConfigOption

WithRedisMaxRetries redis最大重试次数

func WithRedisMaxRetryBackoff added in v1.1.0 

func WithRedisMaxRetryBackoff(maxRetryBackoff time.Duration) RedisConfigOption

WithRedisMaxRetryBackoff redis最大重试间隔

func WithRedisMinIdleConns added in v1.1.0 

func WithRedisMinIdleConns(minIdleConns int) RedisConfigOption

WithRedisMinIdleConns redis最小空闲连接数

func WithRedisMinRetryBackoff added in v1.1.0 

func WithRedisMinRetryBackoff(minRetryBackoff time.Duration) RedisConfigOption

WithRedisMinRetryBackoff redis最小重试间隔

func WithRedisNetwork added in v1.1.0 

func WithRedisNetwork(network string) RedisConfigOption

WithRedisNetwork redis网络类型

func WithRedisOnConnect added in v1.1.0 

func WithRedisOnConnect(onConnect func(*redis.Conn) error) RedisConfigOption

WithRedisOnConnect redis 连接成功后的回调

func WithRedisPassword added in v1.1.0 

func WithRedisPassword(password string) RedisConfigOption

WithRedisPassword redis密码

func WithRedisPoolSize added in v1.1.0 

func WithRedisPoolSize(poolSize int) RedisConfigOption

WithRedisPoolSize redis连接池大小

func WithRedisPoolTimeout added in v1.1.0 

func WithRedisPoolTimeout(poolTimeout time.Duration) RedisConfigOption

WithRedisPoolTimeout redis连接池超时时间

func WithRedisReadTimeout added in v1.1.0 

func WithRedisReadTimeout(readTimeout time.Duration) RedisConfigOption

WithRedisReadTimeout redis读超时时间

func WithRedisTLSConfig added in v1.1.0 

func WithRedisTLSConfig(tlsConfig *tls.Config) RedisConfigOption

WithRedisTLSConfig redis tls配置

func WithRedisWriteTimeout added in v1.1.0 

func WithRedisWriteTimeout(writeTimeout time.Duration) RedisConfigOption

WithRedisWriteTimeout redis写超时时间

type TopicConfig added in v1.1.1 

type TopicConfig struct {
	Qos     byte
	Handler mqtt.MessageHandler
}

func NewTopicConfig added in v1.1.1 

func NewTopicConfig(qos byte, Handler mqtt.MessageHandler) TopicConfig

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.