service

Documentation

Index

• type Message
• type Redis
  • func GetDefaultRedisDriver() *Redis
  • func NewRedisDriver(addr, password string, db int) *Redis
  • func (r *Redis) Connect() error
  • func (r *Redis) Del(key string) (int64, error)
  • func (r *Redis) Exists(key string) (bool, error)
  • func (r *Redis) Get(key string) (string, error)
  • func (r *Redis) HDel(key, field string) (int64, error)
  • func (r *Redis) HExists(key, field string) (bool, error)
  • func (r *Redis) HGet(key, field string) (string, error)
  • func (r *Redis) HLen(key string) (int64, error)
  • func (r *Redis) HScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd
  • func (r *Redis) HSet(key, field, value string) (bool, error)
  • func (r *Redis) HTruncate(key string) (int64, error)
  • func (r *Redis) Ping() error
  • func (r *Redis) Publish(channel string, message string) error
  • func (r *Redis) Set(key, value string, expiration time.Duration) (bool, error)
  • func (r *Redis) Subscribe(channel string, callback func(message Message) error) error

Types

type Message

type Message struct {
	Channel string
	Payload string
}

Message item

type Redis

type Redis struct {
	Client   *redis.Client
	Addr     string
	Password string
	DB       int
}

Redis driver

func GetDefaultRedisDriver

func GetDefaultRedisDriver() *Redis

GetDefaultRedisDriver create a new instance

func NewRedisDriver

func NewRedisDriver(addr, password string, db int) *Redis

NewRedisDriver create a new instance

func (*Redis) Connect

func (r *Redis) Connect() error

Connect establish a redis connection

func (*Redis) Del

func (r *Redis) Del(key string) (int64, error)

Del deletes a record

func (*Redis) Exists

func (r *Redis) Exists(key string) (bool, error)

Exists deletes a record

func (*Redis) Get

func (r *Redis) Get(key string) (string, error)

Get gets a record value

func (*Redis) HDel

func (r *Redis) HDel(key, field string) (int64, error)

HDel deletes a hash record

func (*Redis) HExists

func (r *Redis) HExists(key, field string) (bool, error)

HExists checks if key exists on a hash

func (*Redis) HGet

func (r *Redis) HGet(key, field string) (string, error)

HGet gets a record from hash

func (*Redis) HLen

func (r *Redis) HLen(key string) (int64, error)

HLen count hash records

func (*Redis) HScan

func (r *Redis) HScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd

HScan return an iterative obj for a hash

func (*Redis) HSet

func (r *Redis) HSet(key, field, value string) (bool, error)

HSet sets a record in hash

func (*Redis) HTruncate

func (r *Redis) HTruncate(key string) (int64, error)

HTruncate deletes a hash

func (*Redis) Ping

func (r *Redis) Ping() error

Ping checks the redis connection

func (*Redis) Publish

func (r *Redis) Publish(channel string, message string) error

Publish sends a message to channel

func (*Redis) Set

func (r *Redis) Set(key, value string, expiration time.Duration) (bool, error)

Set sets a record

func (*Redis) Subscribe

func (r *Redis) Subscribe(channel string, callback func(message Message) error) error

Subscribe listens to a channel