mc.go 1.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. package dao
  2. import (
  3. "context"
  4. "fmt"
  5. "github.com/pkg/errors"
  6. )
  7. func userKey(mid int64) (key string) {
  8. key = fmt.Sprintf("u_%d", mid)
  9. return
  10. }
  11. // UserCache .
  12. // func (d *Dao) UserCache(c context.Context, mid int64) (info *model.MCBlockInfo, err error) {
  13. // var (
  14. // key = userKey(mid)
  15. // conn = d.mc.Get(c)
  16. // item *memcache.Item
  17. // )
  18. // defer conn.Close()
  19. // if item, err = conn.Get(key); err != nil {
  20. // if err == memcache.ErrNotFound {
  21. // err = nil
  22. // return
  23. // }
  24. // err = errors.WithStack(err)
  25. // return
  26. // }
  27. // info = &model.MCBlockInfo{}
  28. // if err = conn.Scan(item, info); err != nil {
  29. // if err == memcache.ErrNotFound {
  30. // info = nil
  31. // err = nil
  32. // return
  33. // }
  34. // err = errors.WithStack(err)
  35. // return
  36. // }
  37. // return
  38. // }
  39. // DeleteUserCache .
  40. func (d *Dao) DeleteUserCache(c context.Context, mid int64) (err error) {
  41. var (
  42. key = userKey(mid)
  43. conn = d.mc.Get(c)
  44. )
  45. defer conn.Close()
  46. if err = conn.Delete(key); err != nil {
  47. err = errors.Wrapf(err, "key : %s", key)
  48. return
  49. }
  50. return
  51. }