goutil

package module

v1.0.0 Latest Latest Go to latest Published: Aug 4, 2020 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitea.huashengtec.com/public/goutil

Links

Open Source Insights

README ¶

goutil

Golang 公共库

Documentation ¶

Index ¶

Variables
func AesDecrypt(cryted string, key string) string
func AesEncrypt(orig string, key string) string
func GetRandomString(length int) string
func InitLog(stdout bool, path string, prefix string, level string)
func PKCS7Padding(ciphertext []byte, blocksize int) []byte
func PKCS7UnPadding(origData []byte) []byte
type AMQPPrx
- func SetupQMAPPrx(uri, tag string) *AMQPPrx
- func (prx *AMQPPrx) Publish(excName, key string, body []byte) error
- func (prx *AMQPPrx) PublishEx(excName, key string, mandatory, immediate bool, mimeType string, body []byte) error
- func (prx *AMQPPrx) SetupConsume(queueName, routeKey, excName string) (<-chan amqp.Delivery, error)
- func (prx *AMQPPrx) SetupConsumeEx(queueName, routeKey, excName string, ...) (<-chan amqp.Delivery, error)
- func (prx *AMQPPrx) SetupPublish(excName, excType string, durable, autoDelete, noWait bool) error
type ConfigPrx
- func SetupConfigPrx(fname string, ftype string) *ConfigPrx
- func (conf *ConfigPrx) GetSection(name string) map[string]interface{}
type MQTTPrx
- func SetupMQTTPrx(uri, user, passwd, cliid string) *MQTTPrx
- func (prx *MQTTPrx) Pub(topic string, qos byte, payload interface{}) error
- func (prx *MQTTPrx) Sub(topic string, qos byte) error
type MongoPrx
- func SetupMongoPrx(connstr string, dbname string) *MongoPrx
type TokenPrx
- func SetupTokenPrx(redisAddr string, redisPasswd string, db int) *TokenPrx
- func (prx *TokenPrx) CheckToken(token string) bool
- func (prx *TokenPrx) DelToken(token string)
- func (prx *TokenPrx) GenToken(data string, seconds int) string
- func (prx *TokenPrx) GetTokenData(token string) string

Constants ¶

This section is empty.

Variables ¶

View Source

var Log = logrus.New()

Log :

Functions ¶

func AesDecrypt ¶

func AesDecrypt(cryted string, key string) string

AesDecrypt :

func AesEncrypt ¶

func AesEncrypt(orig string, key string) string

AesEncrypt :

func GetRandomString ¶

func GetRandomString(length int) string

GetRandomString : 生成随机字符串

func InitLog ¶

func InitLog(stdout bool, path string, prefix string, level string)

InitLog :

func PKCS7Padding ¶

func PKCS7Padding(ciphertext []byte, blocksize int) []byte

PKCS7Padding : 补码,AES加密数据块分组长度必须为128bit(byte[16])，密钥长度可以是128bit(byte[16])、192bit(byte[24])、256bit(byte[32])中的任意一个。

func PKCS7UnPadding ¶

func PKCS7UnPadding(origData []byte) []byte

PKCS7UnPadding :

Types ¶

type AMQPPrx ¶

type AMQPPrx struct {
	// contains filtered or unexported fields
}

AMQPPrx :

func SetupQMAPPrx ¶

func SetupQMAPPrx(uri, tag string) *AMQPPrx

SetupQMAPPrx 创建Rabbitmq链接和通道，并返回操作代理

func (*AMQPPrx) Publish ¶

func (prx *AMQPPrx) Publish(excName, key string, body []byte) error

Publish :

func (*AMQPPrx) PublishEx ¶

func (prx *AMQPPrx) PublishEx(excName, key string, mandatory, immediate bool, mimeType string, body []byte) error

PublishEx :

func (*AMQPPrx) SetupConsume ¶

func (prx *AMQPPrx) SetupConsume(queueName, routeKey, excName string) (<-chan amqp.Delivery, error)

SetupConsume ：

func (*AMQPPrx) SetupConsumeEx ¶

func (prx *AMQPPrx) SetupConsumeEx(queueName, routeKey, excName string, durable, autoDelete, exclusive, noWait bool) (<-chan amqp.Delivery, error)

SetupConsumeEx ：

func (*AMQPPrx) SetupPublish ¶

func (prx *AMQPPrx) SetupPublish(excName, excType string, durable, autoDelete, noWait bool) error

SetupPublish ：

type ConfigPrx ¶

type ConfigPrx struct {
	*viper.Viper
}

ConfigPrx :

func SetupConfigPrx ¶

func SetupConfigPrx(fname string, ftype string) *ConfigPrx

SetupConfigPrx :

func (*ConfigPrx) GetSection ¶

func (conf *ConfigPrx) GetSection(name string) map[string]interface{}

GetSection :

type MQTTPrx ¶

type MQTTPrx struct {
	MQTT.Client
	URI      string
	User     string
	Passwd   string
	ClientID string
	MsgChn   chan MQTT.Message
}

MQTTPrx :

func SetupMQTTPrx ¶

func SetupMQTTPrx(uri, user, passwd, cliid string) *MQTTPrx

SetupMQTTPrx :

func (*MQTTPrx) Pub ¶

func (prx *MQTTPrx) Pub(topic string, qos byte, payload interface{}) error

Pub : topic: "/" - 主题层级分隔符;

"#" - 多层通配符, 须是主题过滤器的最后一个字符;
"+" - 单层通配符
"$" - 通配符,只要不是放在主题的最开头,表示匹配一个字符;放在开头，表示匹配开头

qos: 0-最多一次的传输; 1-至少一次的传输; 2-只有一次的传输

func (*MQTTPrx) Sub ¶

func (prx *MQTTPrx) Sub(topic string, qos byte) error

Sub : topic: "/" - 主题层级分隔符;

"#" - 多层通配符, 须是主题过滤器的最后一个字符;
"+" - 单层通配符
"$" - 通配符,只要不是放在主题的最开头,表示匹配一个字符;放在开头，表示匹配开头

qos: 0-最多一次的传输; 1-至少一次的传输; 2-只有一次的传输

type MongoPrx ¶

type MongoPrx struct {
	*mongo.Client
	DB *mongo.Database
}

MongoPrx :

func SetupMongoPrx ¶

func SetupMongoPrx(connstr string, dbname string) *MongoPrx

SetupMongoPrx :

type TokenPrx ¶

type TokenPrx struct {
	*redis.Client
}

TokenPrx :

func SetupTokenPrx ¶

func SetupTokenPrx(redisAddr string, redisPasswd string, db int) *TokenPrx

SetupTokenPrx :

func (*TokenPrx) CheckToken ¶

func (prx *TokenPrx) CheckToken(token string) bool

CheckToken : 获取Token

func (*TokenPrx) DelToken ¶

func (prx *TokenPrx) DelToken(token string)

DelToken : 获取Token

func (*TokenPrx) GenToken ¶

func (prx *TokenPrx) GenToken(data string, seconds int) string

GenToken : 获取Token

func (*TokenPrx) GetTokenData ¶

func (prx *TokenPrx) GetTokenData(token string) string

GetTokenData : 获取Token

Source Files ¶

View all Source files

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