drive

Documentation

Index

• Constants
• func HideKey(key string) string
• type ClientOption
  • func WithAutoCreateTopic(auto bool) ClientOption
  • func WithBrokerAddr(addr []string) ClientOption
  • func WithNameSrvAddr(addr []string) ClientOption
• type MemCacheClient
  • func NewMemCacheClient(host, port string, poolSize int) MemCacheClient
  • func (c *MemCacheClient) Close()
  • func (c *MemCacheClient) Flush() error
  • func (c *MemCacheClient) Get(key string) (string, error)
  • func (c *MemCacheClient) Ping() error
  • func (c *MemCacheClient) Set(key string, value interface{}, exTime int) error
• type MongoClient
  • func NewMongoClient(host, port, user, password, db, collection string) MongoClient
  • func (c *MongoClient) Close()
  • func (c *MongoClient) Get(key string) (string, error)
  • func (c *MongoClient) Ping() error
  • func (c *MongoClient) Set(key string, value interface{}, exTime int) error
• type RabbitMqClient
  • func NewRabbitMqClient(host, port, user, password, vhost string) RabbitMqClient
  • func (c *RabbitMqClient) Close()
  • func (c *RabbitMqClient) Get(queueName string) (string, error)
  • func (c *RabbitMqClient) Ping() error
  • func (c *RabbitMqClient) Publish(queueName string, value interface{}, Priority uint8) error
• type RedisClient
  • func NewRedisClient(host string, port string, password string, db int, poolSize int) RedisClient
  • func (c *RedisClient) BLPop(key string, timeout time.Duration) *redis.StringSliceCmd
  • func (c *RedisClient) Close()
  • func (c *RedisClient) Do(args ...interface{}) *redis.Cmd
  • func (c *RedisClient) Exists(key string) (bool, error)
  • func (c *RedisClient) Flush() error
  • func (c *RedisClient) Get(key string) *redis.StringCmd
  • func (c *RedisClient) LPush(key string, value interface{}) error
  • func (c *RedisClient) Ping() error
  • func (c *RedisClient) RPush(key string, value interface{}) error
  • func (c *RedisClient) Set(key string, value interface{}, exTime time.Duration) error
• type Result
• type RocketMqClient
  • func NewRocketMqClient(opts ...ClientOption) RocketMqClient
  • func (c *RocketMqClient) Publish(topic string, value interface{}, Priority uint8) error
  • func (c *RocketMqClient) Register(topic string) (<-chan string, error)
  • func (c *RocketMqClient) TopicDeleter(topic string)

Constants

const AMQPNil = amqpErr("amqp: nil")

Functions

func HideKey

func HideKey(key string) string

Types

type ClientOption

type ClientOption func(options *clientOptions)

func WithAutoCreateTopic

func WithAutoCreateTopic(auto bool) ClientOption

func WithBrokerAddr

func WithBrokerAddr(addr []string) ClientOption

func WithNameSrvAddr

func WithNameSrvAddr(addr []string) ClientOption

type MemCacheClient

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

func NewMemCacheClient

func NewMemCacheClient(host, port string, poolSize int) MemCacheClient

func (*MemCacheClient) Close

func (c *MemCacheClient) Close()

func (*MemCacheClient) Flush

func (c *MemCacheClient) Flush() error

func (*MemCacheClient) Get

func (c *MemCacheClient) Get(key string) (string, error)

======================= high api =======================

func (*MemCacheClient) Ping

func (c *MemCacheClient) Ping() error

func (*MemCacheClient) Set

func (c *MemCacheClient) Set(key string, value interface{}, exTime int) error

type MongoClient

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

func NewMongoClient

func NewMongoClient(host, port, user, password, db, collection string) MongoClient

func (*MongoClient) Close

func (c *MongoClient) Close()

func (*MongoClient) Get

func (c *MongoClient) Get(key string) (string, error)

======================= high api =======================

func (*MongoClient) Ping

func (c *MongoClient) Ping() error

func (*MongoClient) Set

func (c *MongoClient) Set(key string, value interface{}, exTime int) error

type RabbitMqClient

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

func NewRabbitMqClient

func NewRabbitMqClient(host, port, user, password, vhost string) RabbitMqClient

func (*RabbitMqClient) Close

func (c *RabbitMqClient) Close()

func (*RabbitMqClient) Get

func (c *RabbitMqClient) Get(queueName string) (string, error)

func (*RabbitMqClient) Ping

func (c *RabbitMqClient) Ping() error

func (*RabbitMqClient) Publish

func (c *RabbitMqClient) Publish(queueName string, value interface{}, Priority uint8) error

type RedisClient

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

func NewRedisClient

func NewRedisClient(host string, port string, password string, db int, poolSize int) RedisClient

func (*RedisClient) BLPop

func (c *RedisClient) BLPop(key string, timeout time.Duration) *redis.StringSliceCmd

func (*RedisClient) Close

func (c *RedisClient) Close()

func (*RedisClient) Do

func (c *RedisClient) Do(args ...interface{}) *redis.Cmd

func (*RedisClient) Exists

func (c *RedisClient) Exists(key string) (bool, error)

======================= high api =======================

func (*RedisClient) Flush

func (c *RedisClient) Flush() error

func (*RedisClient) Get

func (c *RedisClient) Get(key string) *redis.StringCmd

func (*RedisClient) LPush

func (c *RedisClient) LPush(key string, value interface{}) error

func (*RedisClient) Ping

func (c *RedisClient) Ping() error

func (*RedisClient) RPush

func (c *RedisClient) RPush(key string, value interface{}) error

func (*RedisClient) Set

func (c *RedisClient) Set(key string, value interface{}, exTime time.Duration) error

type Result

type Result struct {
	Uuid       string    `json:"uuid" bson:"uuid"`
	Res        string    `json:"res" bson:"res"`
	CreateTime time.Time `json:"create_time" bson:"create_time"`
}

type RocketMqClient

type RocketMqClient struct {
	Producer    rocketmq.Producer
	ConsumerMap map[string]rocketmq.PushConsumer
	MsgChanMap  map[string]chan string
	Admin       admin.Admin
	// contains filtered or unexported fields
}

func NewRocketMqClient

func NewRocketMqClient(opts ...ClientOption) RocketMqClient

func (*RocketMqClient) Publish

func (c *RocketMqClient) Publish(topic string, value interface{}, Priority uint8) error

func (*RocketMqClient) Register

func (c *RocketMqClient) Register(topic string) (<-chan string, error)

func (*RocketMqClient) TopicDeleter

func (c *RocketMqClient) TopicDeleter(topic string)