code: func (s *messageStoreImpl) Get() []interface{} {
  	res := make([]interface{}, 0)
  
  	s.lock.RLock()
  	defer s.lock.RUnlock()
  
  	for _, msg := range s.messages {
  		if !msg.expired {
  			res = append(res, msg.data)
  		}
  	}
  	return res
  }
docs: // get returns all messages in the store