local loki = require("assay.loki")
local loki_url = env.get("LOKI_URL") or "http://loki-gateway.monitoring:80"
local c = loki.client(loki_url)
assert.eq(c.health:ready(), true, "Loki not ready")
log.info("Loki is ready")
c.logs:push(
{ app = "assay-test", job = "verification" },
{ "assay verification test entry" }
)
log.info("Loki push succeeded")
sleep(5)
local results = c.queries:instant('{app="assay-test"}', { limit = "1" })
assert.gt(#results, 0, "No log entries found in Loki")
log.info("Loki ingestion verified: " .. #results .. " streams found")