'Clear all the primed queries from a particular cluster
:param cluster_name: cluster to clear queries from'

def clear_all_queries(self, cluster_name=DEFAULT_CLUSTER):

    opener = build_opener(HTTPHandler)
    request = Request('http://{0}/{1}/{2}'.format(self.admin_addr, 'prime', cluster_name))
    request.get_method = (lambda : 'DELETE')
    connection = opener.open(request)
    return connection.read()
