Logs, errors and traces. Live, in one place.

npm install @fabbahiense/pulsar-node

import { Pulsar } from '@fabbahiense/pulsar-node'

Pulsar.init({
  url: process.env.PULSAR_URL!,
  apiKey: process.env.PULSAR_API_KEY!,
  serviceName: 'checkout-api',
  interceptConsole: true,
})

app.use(Pulsar.middleware({ autoLog: true })) // one trace per request

console.log('Order received') // sent with the request's trace ID

npm install @fabbahiense/pulsar-next

export async function register() {
  if (process.env.NEXT_RUNTIME === 'nodejs') {
    const { initPulsar } = await import('@fabbahiense/pulsar-next')
    initPulsar({
      url: process.env.PULSAR_URL!,
      apiKey: process.env.PULSAR_API_KEY!,
      serviceName: 'storefront',
    })
  }
}

import { withPulsar } from '@fabbahiense/pulsar-next'

export const POST = withPulsar(async (req: Request) => {
  console.log('Order received') // console capture is on by default
  return Response.json({ ok: true }, { status: 201 })
})

npm install pino pino-abstract-transport @fabbahiense/pulsar-pino-transport

import pino from 'pino'

export const logger = pino({
  transport: {
    target: '@fabbahiense/pulsar-pino-transport',
    options: {
      url: process.env.PULSAR_URL,
      apiKey: process.env.PULSAR_API_KEY,
      source: 'checkout-api',
    },
  },
})

logger.info({ orderId: 'ord_1042' }, 'Order received')

dotnet add package FabBahiense.Pulsar.AspNetCore

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddPulsar(o => o.ServiceName = "checkout-api");

var app = builder.Build();
app.UsePulsarRequestLogging(); // one entry per request, with its trace ID
app.MapGet("/api/orders", (ILogger<Program> log) =>
{
    log.LogInformation("Listing orders");
    return Results.Ok(Array.Empty<object>());
});
app.Run();

{
  "Pulsar": { "Endpoint": "https://pulsar.example.com", "ApiKey": "psk_..." }
}

curl -X POST "$PULSAR_URL/api/ingest" \
  -H "Authorization: Bearer $PULSAR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"level":"info","msg":"Hello, Pulsar","source":"checkout-api"}'