cache

Documentation

Index

• Constants
• func AllCache(search string, page, rows int) (et.List, error)
• func Close()
• func Count(key string, expiration time.Duration) int
• func Delete(key string) (int64, error)
• func DeleteCtx(ctx context.Context, key string) (int64, error)
• func DeleteVerify(device string, key string) (int64, error)
• func Empty(match string) error
• func Exists(key string) bool
• func ExistsCtx(ctx context.Context, key string) bool
• func FromId() string
• func GenId(args ...interface{}) string
• func GenKey(args ...interface{}) string
• func Get(key, def string) (string, error)
• func GetCtx(ctx context.Context, key, def string) (string, error)
• func GetItem(key string) (et.Item, error)
• func GetItems(key string) (et.Items, error)
• func GetJson(key string) (et.Json, error)
• func GetVerify(device string, key string) (string, error)
• func HDelete(key, atr string) error
• func HDeleteCtx(ctx context.Context, key, atr string) error
• func HGet(key string) (map[string]string, error)
• func HGetAtrib(key, atr string) (string, error)
• func HGetCtx(ctx context.Context, key string) (map[string]string, error)
• func HSet(key string, val map[string]string) error
• func HSetAtrib(key, atr, val string) error
• func HSetCtx(ctx context.Context, key string, val map[string]string) error
• func HandlerAll(w http.ResponseWriter, r *http.Request)
• func HandlerDelete(w http.ResponseWriter, r *http.Request)
• func HandlerGet(w http.ResponseWriter, r *http.Request)
• func More(key string, second time.Duration) int
• func Set(key string, val interface{}, second time.Duration) error
• func SetCtx(ctx context.Context, key, val string, second time.Duration) error
• func SetD(key string, val interface{}) error
• func SetH(key string, val interface{}) error
• func SetM(key string, val interface{}) error
• func SetVerify(device, key, val string, duration time.Duration) error
• func SetW(key string, val interface{}) error
• func SetY(key string, val interface{}) error
• type Conn
  • func ConnectTo(host, password string, dbname int) (*Conn, error)
  • func Load() (*Conn, error)
  • func (s *Conn) Pub(channel string, message []byte) error
  • func (s *Conn) Sub(channel string, f func(*redis.Message))
  • func (s *Conn) Unsub(channel string) error
• type Message
  • func (s Message) ToJson() (et.Json, error)

Constants

const IsNil = redis.Nil

const PackageName = "cache"

Functions

func AllCache

func AllCache(search string, page, rows int) (et.List, error)

* * AllCache * @params device string * @params key string * @params val string * @return error *

func Close

func Close()

func Count

func Count(key string, expiration time.Duration) int

* * Count * @params key string * @params expiration time.Duration (second) * @return int64 *

func Delete

func Delete(key string) (int64, error)

* * Delete * @params key string * @return int64, error *

func DeleteCtx

func DeleteCtx(ctx context.Context, key string) (int64, error)

* * DeleteCtx * @params ctx context.Context * @params key string * @return int64, error *

func DeleteVerify

func DeleteVerify(device string, key string) (int64, error)

* * DeleteVerify * @params device string * @params key string * @return int64, error *

func Empty

func Empty(match string) error

* * Empty * @return error *

func Exists

func Exists(key string) bool

* * Exists * @params key string * @return bool *

func ExistsCtx

func ExistsCtx(ctx context.Context, key string) bool

* * ExistsCtx * @params ctx context.Context * @params key string * @return bool *

func FromId

func FromId() string

* * FromId return the id of the connection * @return string *

func GenId

func GenId(args ...interface{}) string

* * GenId * @params args ...interface{} * @return string *

func GenKey

func GenKey(args ...interface{}) string

* * GenKey * @params args ...interface{} * @return string *

func Get

func Get(key, def string) (string, error)

* * Get * @params key string * @params def string * @return string, error *

func GetCtx

func GetCtx(ctx context.Context, key, def string) (string, error)

* * GetCtx * @params ctx context.Context * @params key string * @params def string * @return string, error *

func GetItem

func GetItem(key string) (et.Item, error)

* * GetItem * @params key string * @return Item, error *

func GetItems

func GetItems(key string) (et.Items, error)

* * GetItems * @params key string * @return Items, error *

func GetJson

func GetJson(key string) (et.Json, error)

* * GetJson * @params key string * @return Json, error *

func GetVerify

func GetVerify(device string, key string) (string, error)

* * GetVerify * @params device string * @params key string * @return string, error *

func HDelete

func HDelete(key, atr string) error

* * HDelete * @params key string * @params atr string * @return error *

func HDeleteCtx

func HDeleteCtx(ctx context.Context, key, atr string) error

* * HDeleteCtx * @params ctx context.Context * @params key string * @params atr string * @return error *

func HGet

func HGet(key string) (map[string]string, error)

* * HGet * @params key string * @return map[string]string, error *

func HGetAtrib

func HGetAtrib(key, atr string) (string, error)

* * HGetAtrib * @params key string * @params atr string * @return string, error *

func HGetCtx

func HGetCtx(ctx context.Context, key string) (map[string]string, error)

* * HGetCtx * @params ctx context.Context * @params key string * @return map[string]string, error *

func HSet

func HSet(key string, val map[string]string) error

* * HSet * @params key string * @params val map[string]string * @return error *

func HSetAtrib

func HSetAtrib(key, atr, val string) error

* * HSetAtrib * @params key string * @params atr string * @params val string * @return error *

func HSetCtx

func HSetCtx(ctx context.Context, key string, val map[string]string) error

* * HSetCtx * @params ctx context.Context * @params key string * @params val map[string]string * @return error *

func HandlerAll

func HandlerAll(w http.ResponseWriter, r *http.Request)

* * HandlerAll * @params w http.ResponseWriter * @params r *http.Request *

func HandlerDelete

func HandlerDelete(w http.ResponseWriter, r *http.Request)

* * HandlerDelete * @params w http.ResponseWriter * @params r *http.Request *

func HandlerGet

func HandlerGet(w http.ResponseWriter, r *http.Request)

* * HandlerGet * @params w http.ResponseWriter * @params r *http.Request *

func More

func More(key string, second time.Duration) int

* * More * @params key string * @params second time.Duration * @return int *

func Set

func Set(key string, val interface{}, second time.Duration) error

* * Set * @params key string * @params val interface{} * @params second time.Duration * @return error *

func SetCtx

func SetCtx(ctx context.Context, key, val string, second time.Duration) error

* * SetCtx * @params ctx context.Context * @params key string * @params val string * @params second time.Duration * @return error *

func SetD

func SetD(key string, val interface{}) error

* * SetD * @params key string * @params val interface{} * @return error *

func SetH

func SetH(key string, val interface{}) error

* * SetH * @params key string * @params val interface{} * @return error *

func SetM

func SetM(key string, val interface{}) error

* * SetM * @params key string * @params val interface{} * @return error *

func SetVerify

func SetVerify(device, key, val string, duration time.Duration) error

* * SetVerify * @params device string * @params key string * @params val string * @params duration time.Duration * @return error *

func SetW

func SetW(key string, val interface{}) error

* * SetW * @params key string * @params val interface{} * @return error *

func SetY

func SetY(key string, val interface{}) error

* * SetY * @params key string * @params val interface{} * @return error *

Types

type Conn

type Conn struct {
	*redis.Client
	// contains filtered or unexported fields
}

func ConnectTo

func ConnectTo(host, password string, dbname int) (*Conn, error)

func Load

func Load() (*Conn, error)

func (*Conn) Pub

func (s *Conn) Pub(channel string, message []byte) error

* * Pub * @param channel string * @param message interface{} * @return error *

func (*Conn) Sub

func (s *Conn) Sub(channel string, f func(*redis.Message))

* * Sub * @param channel string * @param f func(interface{}) *

func (*Conn) Unsub

func (s *Conn) Unsub(channel string) error

* * Unsub * @param channel string * @return error *

type Message

type Message struct {
	ID      string `json:"id"`
	Content string `json:"content"`
}

func (Message) ToJson

func (s Message) ToJson() (et.Json, error)