code: func (c *Client) EventsPushed() (events []contract.Event, err error) {
  	conn := c.Pool.Get()
  	defer conn.Close()
  
  	objects, err := getObjectsByScore(conn, db.EventsCollection+":pushed", 1, -1, 0)
  	if err != nil {
  		return events, err
  	}
  
  	events = make([]contract.Event, len(objects))
  	err = unmarshalEvents(objects, events)
  	if err != nil {
  		return events, err
  	}
  
  	return events, nil
  }
docs: // Remove all the events that have been pushed
  //func (dbc *DBClient) ScrubEvents()(int, error)
  // Get events that have been pushed (pushed field is not 0)