code: func (c *ShardedClient) Flush(expiration uint32) Response {
  	var err error
  	for shard, conn := range c.manager.GetAllShards() {
  		response := c.flushHelper(shard, conn, expiration)
  		if response.Error() != nil {
  			if err == nil {
  				err = response.Error()
  			} else {
  				err = errors.Wrap(response.Error(), err.Error())
  			}
  		}
  	}
  
  	if err != nil {
  		return NewErrorResponse(err)
  	}
  
  	return NewResponse(StatusNoError)
  }
docs: // See Client interface for documentation.