conn

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

func (*EtcdClient) Close ¶

func (e *EtcdClient) Close()

Close 关闭etcd的连接

func (*EtcdClient) NewEtcdClient ¶

func (e *EtcdClient) NewEtcdClient()

NewEtcdClient 创建etcd的客户端

func (*EtcdClient) Parse ¶

func (e *EtcdClient) Parse(key string, v interface{}) error

Parse 解析etcd内的value

func (*EtcdClient) Put ¶ added in v1.0.1

func (e *EtcdClient) Put(key string, data interface{}) error

etcd 键入key value 创建你的数据

data := YourData{
	Field1: "Value1",
	Field2: 42,
	// Initialize other fields as needed
}

func (*MinioClient) NewMinioClient ¶

func (mn *MinioClient) NewMinioClient()

func (*MinioClient) SetBucketLifecycle ¶

func (mn *MinioClient) SetBucketLifecycle(bucketName string, expirationDays int)

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) NewNatsClient ¶

func (nc *NatsClient) NewNatsClient()

NewNatsClient 创建nats的客户端

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 所以错误日志内部处理

func (*SqlClient) NewSqlDB ¶

func (s *SqlClient) NewSqlDB()