HTTP API

{
  "event": "User login successful",
  "level": "info",
  "timestamp": "2026-03-21T10:30:00.000Z",
  "index": "production",
  "source": "auth-service",
  "sourcetype": "application",
  "host": "web-01",
  "attributes": {
    "user_id": "usr_abc123",
    "ip_address": "192.168.1.100",
    "method": "POST",
    "path": "/api/auth/login"
  }
}

{
  "data": {
    "accepted": 1,
    "rejected": 0,
    "timestamp": "2026-03-21T10:30:00.000Z",
    "quotaStatus": {
      "plan": "starter",
      "limitMB": 1024,
      "usedMB": 42.5,
      "percent": 4.15,
      "blocked": false
    }
  }
}

[
  {
    "event": "GET /api/users 200 12ms",
    "level": "info",
    "source": "nginx",
    "sourcetype": "access_log",
    "attributes": { "status": "200", "duration_ms": "12" }
  },
  {
    "event": "Database connection timeout",
    "level": "error",
    "source": "api-server",
    "sourcetype": "application",
    "attributes": { "db": "postgres", "timeout_ms": "5000" }
  }
]

curl -X POST https://api.logpulse.io/api/v1/logs \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -d '{
    "event": "Payment processed successfully",
    "level": "info",
    "source": "payment-service",
    "attributes": {
      "amount": "49.99",
      "currency": "EUR",
      "order_id": "ord_xyz789"
    }
  }'

import requests

API_KEY = "YOUR_API_KEY"
BASE_URL = "https://api.logpulse.io"

# Send a batch of logs
logs = [
    {
        "event": "User signed up",
        "level": "info",
        "source": "auth-service",
        "attributes": {"user_id": "usr_001", "plan": "growth"}
    },
    {
        "event": "Welcome email sent",
        "level": "info",
        "source": "email-service",
        "attributes": {"user_id": "usr_001", "template": "welcome"}
    }
]

response = requests.post(
    f"{BASE_URL}/api/v1/logs",
    json=logs,
    headers={"Authorization": f"Bearer {API_KEY}"}
)

print(response.json())
# {"data": {"accepted": 2, "rejected": 0, "timestamp": "...", "quotaStatus": {...}}}

const API_KEY = process.env.LOGPULSE_API_KEY;

async function sendLog(event, level = 'info', attributes = {}) {
  const response = await fetch('https://api.logpulse.io/api/v1/logs', {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'Authorization': `Bearer ${API_KEY}`,
    },
    body: JSON.stringify({
      event,
      level,
      source: 'my-node-app',
      sourcetype: 'application',
      attributes,
    }),
  });

  if (!response.ok) {
    throw new Error(`LogPulse API error: ${response.status}`);
  }

  return response.json();
}

// Usage
await sendLog('Order created', 'info', { order_id: 'ord_123' }); // attributes

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "net/http"
    "os"
)

type LogEntry struct {
    Event      string            `json:"event"`
    Level      string            `json:"level,omitempty"`
    Source     string            `json:"source,omitempty"`
    Sourcetype string           `json:"sourcetype,omitempty"`
    Attributes map[string]string `json:"attributes,omitempty"`
}

func SendLog(entry LogEntry) error {
    body, err := json.Marshal(entry)
    if err != nil {
        return err
    }

    req, err := http.NewRequest("POST",
        "https://api.logpulse.io/api/v1/logs",
        bytes.NewBuffer(body))
    if err != nil {
        return err
    }

    req.Header.Set("Content-Type", "application/json")
    req.Header.Set("Authorization",
        "Bearer "+os.Getenv("LOGPULSE_API_KEY"))

    resp, err := http.DefaultClient.Do(req)
    if err != nil {
        return err
    }
    defer resp.Body.Close()

    if resp.StatusCode != http.StatusOK {
        return fmt.Errorf("unexpected status: %d", resp.StatusCode)
    }
    return nil
}