Documentation ¶
Index ¶
- type CustomDMText
- type EtcdClient
- type MinioClient
- type NatsClient
- func (n *NatsClient) ChanQueueSubscribe(subj, queue string, msgHandle func(data []byte))
- func (n *NatsClient) ChanSubscribe(subj string, msgHandle func(data []byte))
- func (n *NatsClient) Close()
- func (nc *NatsClient) NewNatsClient()
- func (n *NatsClient) Publish(subj, queue string, msg interface{})
- func (n *NatsClient) QueueSubscribe(subj, queue string, msgHandle func(data []byte))
- func (n *NatsClient) Subscribe(subj string, msgHandle func(data []byte))
- type SqlClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CustomDMText ¶
type CustomDMText struct{}
CustomDMText 实现ICustomDriverValueConver接口,扩展自定义类型,例如 达梦数据库TEXT类型,映射出来的是dm.DmClob类型,无法使用string类型直接接收
func (CustomDMText) ConverDriverValue ¶
func (dmtext CustomDMText) ConverDriverValue(ctx context.Context, columnType *sql.ColumnType, tempDriverValue driver.Value, structFieldType *reflect.Type) (interface{}, error)
ConverDriverValue 数据库列类型,GetDriverValue返回的driver.Value的临时接收值,struct属性类型 map接收或者字段不存在,无法获取到structFieldType,会传入nil 返回符合接收类型值的指针,指针,指针!!!!
func (CustomDMText) GetDriverValue ¶
func (dmtext CustomDMText) GetDriverValue(ctx context.Context, columnType *sql.ColumnType, structFieldType *reflect.Type) (driver.Value, error)
GetDriverValue 根据数据库列类型,返回driver.Value的实例,struct属性类型 map接收或者字段不存在,无法获取到structFieldType,会传入nil
type EtcdClient ¶
func (*EtcdClient) Parse ¶
func (e *EtcdClient) Parse(key string, v interface{}) error
Parse 解析etcd内的value
type MinioClient ¶
func (*MinioClient) NewMinioClient ¶
func (mn *MinioClient) NewMinioClient()
func (*MinioClient) SetBucketLifecycle ¶
func (mn *MinioClient) SetBucketLifecycle(bucketName string, expirationDays int)
type NatsClient ¶
func (*NatsClient) ChanQueueSubscribe ¶
func (n *NatsClient) ChanQueueSubscribe(subj, queue string, msgHandle func(data []byte))
ChanQueueSubscribe 通道订阅模式,用于排序处理消息,单次订阅
func (*NatsClient) ChanSubscribe ¶
func (n *NatsClient) ChanSubscribe(subj string, msgHandle func(data []byte))
ChanSubscribe 通道订阅模式,用于排序处理消息,多次订阅
func (*NatsClient) Close ¶
func (n *NatsClient) Close()
func (*NatsClient) Publish ¶
func (n *NatsClient) Publish(subj, queue string, msg interface{})
Publish 发布消息到nats
func (*NatsClient) QueueSubscribe ¶
func (n *NatsClient) QueueSubscribe(subj, queue string, msgHandle func(data []byte))
QueueSubscribe 队列形式的订阅,只消费一次,多服务时使用,多用于goroutine 所以错误日志内部处理
func (*NatsClient) Subscribe ¶
func (n *NatsClient) Subscribe(subj string, msgHandle func(data []byte))
Subscribe 普通订阅,可多次消费,单节点时使用,多用于goroutine 所以错误日志内部处理
Click to show internal directories.
Click to hide internal directories.