driver

Documentation

Index

• func CloseMQ(conn *amqp.Connection, channel *amqp.Channel)
• func ConnectMQ(config *configs.Configs, opName string) (*amqp.Connection, *amqp.Channel)
• func Logger(config *configs.Configs) *logrus.Logger
• type RabbitMQ
  • func (r *RabbitMQ) Consume()
  • func (r *RabbitMQ) Publish()
• type RedisClient
  • func NewRedis(redisClient redis.Cmdable) RedisClient
  • func Redis(config *configs.Configs) RedisClient

Functions

func CloseMQ

func CloseMQ(conn *amqp.Connection, channel *amqp.Channel)

func ConnectMQ

func ConnectMQ(config *configs.Configs, opName string) (*amqp.Connection, *amqp.Channel)

func Logger

func Logger(config *configs.Configs) *logrus.Logger

Types

type RabbitMQ

type RabbitMQ struct {
	Body      string
	QueueName string
}

func (*RabbitMQ) Consume

func (r *RabbitMQ) Consume()

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish()

type RedisClient

type RedisClient interface {
	HGet(key, field string) ([]byte, error)
	HSet(key, field string, value interface{}, expDur time.Duration) error
	HDel(key, field string) error
	Del(key string) error
	Set(key string, value interface{}, expDur time.Duration) error
	Get(key string) (string, error)
	SetNX(key string, value string, duration time.Duration) (bool, error)
	Keys(key string) ([]string, error)
}

func NewRedis

func NewRedis(redisClient redis.Cmdable) RedisClient

func Redis

func Redis(config *configs.Configs) RedisClient