Fleet Management

BASE=https://fleet-management-prod-us-east-0.grafana.net
TOKEN=<STACK_ID>:<API_TOKEN>

# List all collectors + health
curl -s -X POST "$BASE/collector.v1.CollectorService/ListCollectors" \
  -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" \
  -d '{}' | jq '.collectors[] | {id, name, remoteConfigStatus}'

# Update collector attributes (matchers target these)
curl -s -X POST "$BASE/collector.v1.CollectorService/UpdateCollector" \
  -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" \
  -d '{
    "id": "<COLLECTOR_ID>",
    "attributes": [
      {"name":"env",   "value":"production"},
      {"name":"team",  "value":"platform"},
      {"name":"region","value":"us-east-1"}
    ]
  }'

# List
curl -s -X POST "$BASE/pipeline.v1.PipelineService/ListPipelines" \
  -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" -d '{}'

# Create (plain-text Alloy config, not base64)
curl -s -X POST "$BASE/pipeline.v1.PipelineService/CreatePipeline" \
  -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" \
  -d '{
    "name": "k8s-metrics",
    "contents": "prometheus.scrape \"default\" {\n  targets = []\n  forward_to = []\n}",
    "matchers": [{"name":"env","value":"production","type":"EQUAL"}]
  }'

# Update — set matchers
curl -s -X POST "$BASE/pipeline.v1.PipelineService/UpdatePipeline" \
  -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" \
  -d '{
    "id":"<PIPELINE_ID>",
    "matchers": [
      {"name":"env","value":"production","type":"EQUAL"},
      {"name":"team","value":"platform","type":"EQUAL"}
    ]
  }'

# List revisions
curl -X POST $BASE/pipeline.v1.PipelineService/ListPipelineRevisions \
  -H "Authorization: Bearer $TOKEN" -d '{"pipelineId": "pipeline-id"}'

# Roll back to a previous revision
curl -X POST $BASE/pipeline.v1.PipelineService/RollbackPipeline \
  -H "Authorization: Bearer $TOKEN" \
  -d '{"pipelineId": "pipeline-id", "revisionId": "revision-id"}'

curl -X POST $BASE/tenant.v1.TenantService/GetLimits \
  -H "Authorization: Bearer $TOKEN" -d '{}'

# Response:
# {
#   "maxCollectors": 1000,
#   "maxPipelines": 100,
#   "maxPipelineSizeBytes": 1048576,
#   "maxMatchersPerPipeline": 10
# }

remotecfg {
  url = "https://fleet-management-prod-us-east-0.grafana.net"

  basic_auth {
    username = sys.env("FM_INSTANCE_ID")   // Stack ID / instance ID
    password = sys.env("FM_API_KEY")
  }

  // Attributes used to match pipeline matchers
  attributes = {
    "env"    = "production",
    "region" = "us-east-1",
    "team"   = "platform",
  }

  poll_interval = "1m"   // How often to check for config updates
  id            = ""     // Auto-generated; persist across restarts for stable ID
}

# 1. Create canary pipeline targeting one collector by attribute
POST .../CreatePipeline
{ "name": "canary-v2",
  "matchers": [{"name": "canary", "value": "true", "type": "EQUAL"}],
  "contents": "# New config v2..." }

# 2. Add canary=true attribute to test collector
POST .../UpdateCollector
{ "id": "collector-id", "attributes": [{"name": "canary", "value": "true"}] }

# 3. Validate metrics; expand to more collectors
# 4. Update main pipeline, remove canary pipeline

# Temporarily boost log verbosity for one collector
POST .../CreatePipeline
{ "name": "debug-001",
  "matchers": [{"name": "id", "value": "collector-001", "type": "EQUAL"}],
  "contents": "logging { level = \"debug\" }" }
# Delete when done

# Pass K8s metadata as env vars to Alloy
env:
  - name: K8S_NODE_NAME
    valueFrom: { fieldRef: { fieldPath: spec.nodeName } }
  - name: K8S_NAMESPACE
    valueFrom: { fieldRef: { fieldPath: metadata.namespace } }

remotecfg {
  url = sys.env("FM_URL")
  basic_auth {
    username = sys.env("FM_INSTANCE_ID")
    password = sys.env("FM_API_KEY")
  }
  attributes = {
    "k8s.node.name" = sys.env("K8S_NODE_NAME"),
    "k8s.namespace" = sys.env("K8S_NAMESPACE"),
    "env"           = "production",
  }
}