Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- func (s *Server) cacheRefresh(ctx context.Context,) error {
- fmt.Println("refreshing cache")
- s.cache.mu.Lock()
- defer s.cache.mu.Unlock()
- _, err := s.clicks.SetClicks(ctx, &pb.SetRequest{
- counts: &pb.counts{
- right: s.cache.values.right,
- left: a.cache.values.left,
- center: a.cache.values.center,
- },
- })
- s.cache.mu.Unlock()
- if err != nil {
- return err
- }
- gets, err := s.clicks.GetClicks(ctx, &pb.GetRequest{})
- if err != nil {
- return err
- }
- s.cache.values.right = gets.counts.right
- a.cache.values.left = gets.counts.left
- a.cache.values.center = gets.counts.center
- return nil
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement