black.go 599 B

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