'curl the Elasticsearch pod and look for a unique uuid in its logs.'

def query_es_from_es(self, es_pod, uuid):

    pod_name = es_pod['metadata']['name']
    exec_cmd = 'exec    {pod_name}    --    curl    --max-time    30    -s    -f    --cacert    /etc/elasticsearch/secret/admin-ca    --cert    /etc/elasticsearch/secret/admin-cert    --key    /etc/elasticsearch/secret/admin-key    https://logging-es:9200/project.{namespace}*/_count?q=message:{uuid}'
    exec_cmd = exec_cmd.format(pod_name=pod_name, namespace=self.logging_namespace(), uuid=uuid)
    result = self.exec_oc(exec_cmd, [])
    try:
        count = json.loads(result)['count']
    except (KeyError, ValueError):
        raise OpenShiftCheckException('esInvalidResponse', 'Invalid    response    from    Elasticsearch    query:\n        {}\nResponse    was:\n{}'.format(exec_cmd, result))
    return count
