black.go 560 B

123456789101112131415161718192021222324252627282930313233
  1. package feed
  2. import (
  3. "context"
  4. "time"
  5. "go-common/library/log"
  6. )
  7. func (s *Service) loadBlackCache() {
  8. bs, err := s.blk.Black(context.Background())
  9. if err != nil {
  10. log.Error("s.blk.Black error(%v)", err)
  11. return
  12. }
  13. s.blackCache = bs
  14. log.Info("reBlackList success")
  15. }
  16. // blackproc load blacklist cache.
  17. func (s *Service) blackproc() {
  18. for {
  19. time.Sleep(s.tick)
  20. s.loadBlackCache()
  21. }
  22. }
  23. func (s *Service) BlackList(c context.Context, mid int64) (aidm map[int64]struct{}, err error) {
  24. if mid == 0 {
  25. return
  26. }
  27. return s.blk.BlackList(c, mid)
  28. }