cache

package

v1.0.9 Latest Latest Go to latest Published: Apr 24, 2025 License: MIT Imports: 18 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cgalvisleon/et

Links

Open Source Insights

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 GetRecordId(tag, id string) string
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 RecordId(tag string) string
func Set(key string, val interface{}, second time.Duration) interface{}
func SetCtx(ctx context.Context, key, val string, millisecond time.Duration) string
func SetD(key string, val interface{}, expiration int64) interface{}
func SetDuration(key string, val interface{}, millisecond time.Duration) interface{}
func SetH(key string, val interface{}, expiration int64) interface{}
func SetM(key string, val interface{}, expiration int64) interface{}
func SetVerify(device, key, val string, duration time.Duration) interface{}
func SetW(key string, val interface{}, expiration int64) interface{}
func SetY(key string, val interface{}, expiration int64) interface{}
type Conn
- func ConnectTo(host, password string, db 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 ¶

View Source

const IsNil = redis.Nil

View Source

const PackageName = "cache"

Variables ¶

This section is empty.

Functions ¶

func AllCache ¶

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

* * AllCache * @params search string, page int, rows int * @return error *

func Close ¶

func Close()

* * Close *

func Count ¶

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

* * Count * @params key string, 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, key string * @return int64, error *

func DeleteVerify ¶

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

* * DeleteVerify * @params device string, 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, key string * @return bool *

func FromId ¶

func FromId() string

* * FromId * @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, def string * @return string, error *

func GetCtx ¶

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

* * GetCtx * @params ctx context.Context, key string, 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 GetRecordId ¶

func GetRecordId(tag, id string) string

* * GetRecordId * @param tag string, id string * @return string *

func GetVerify ¶

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

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

func HDelete ¶

func HDelete(key, atr string) error

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

func HDeleteCtx ¶

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

* * HDeleteCtx * @params ctx context.Context, key string, 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, atr string * @return string, error *

func HGetCtx ¶

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

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

func HSet ¶

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

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

func HSetAtrib ¶

func HSetAtrib(key, atr, val string) error

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

func HSetCtx ¶

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

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

func HandlerAll ¶

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

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

func HandlerDelete ¶

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

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

func HandlerGet ¶

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

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

func More ¶

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

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

func RecordId ¶ added in v1.0.8

func RecordId(tag string) string

* * RecordId * @param tag string * @return string *

func Set ¶

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

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

func SetCtx ¶

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

* * SetCtx * @params ctx context.Context, key string, val string, millisecond time.Duration * @return string *

func SetD ¶

func SetD(key string, val interface{}, expiration int64) interface{}

* * SetD * @params key string, val interface{}, expiration int64 * @return interface{} *

func SetDuration ¶

func SetDuration(key string, val interface{}, millisecond time.Duration) interface{}

* * SetDuration * @params key string, val interface{}, millisecond time.Duration * @return interface{} *

func SetH ¶

func SetH(key string, val interface{}, expiration int64) interface{}

* * SetH * @params key string, val interface{}, expiration int64 * @return interface{} *

func SetM ¶

func SetM(key string, val interface{}, expiration int64) interface{}

* * SetM * @params key string, val interface{}, expiration int64 * @return interface{} *

func SetVerify ¶

func SetVerify(device, key, val string, duration time.Duration) interface{}

* * SetVerify * @params device string, key string, val string, duration time.Duration * @return interface{} *

func SetW ¶

func SetW(key string, val interface{}, expiration int64) interface{}

* * SetW * @params key string, val interface{}, expiration int64 * @return interface{} *

func SetY ¶

func SetY(key string, val interface{}, expiration int64) interface{}

* * SetY * @params key string, val interface{}, expiration int64 * @return interface{} *

Types ¶

type Conn ¶

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

func ConnectTo ¶

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

* * Connect to a host * @param host, password string, db int * @return *Conn, error *

func Load ¶

func Load() (*Conn, error)

* * Load * @return *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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL