curl --request GET \
--url https://api.example.com/v0/admin/stats/connector-pushes \
--header 'Authorization: Bearer <token>'import requests
url = "https://api.example.com/v0/admin/stats/connector-pushes"
headers = {"Authorization": "Bearer <token>"}
response = requests.get(url, headers=headers)
print(response.text)const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};
fetch('https://api.example.com/v0/admin/stats/connector-pushes', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/v0/admin/stats/connector-pushes",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/v0/admin/stats/connector-pushes"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("Authorization", "Bearer <token>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/v0/admin/stats/connector-pushes")
.header("Authorization", "Bearer <token>")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/v0/admin/stats/connector-pushes")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'
response = http.request(request)
puts response.read_body{
"window": "1h",
"resolution_seconds": 2,
"from": "2023-11-07T05:31:56Z",
"to": "2023-11-07T05:31:56Z",
"total": 1,
"items": [
{
"connector_id": "<string>",
"outcome": "received",
"count": 1,
"points": [
{
"start": "2023-11-07T05:31:56Z",
"count": 2
}
]
}
]
}{
"code": "<string>",
"message": "<string>",
"retryable": true,
"field": "<string>",
"resync_url": "<string>"
}Count accepted and refused pushes per source instance
Per-instance attempts to declared source API routes, split into received (2xx, including cached answers and GET challenges) and refused (all other answers). Includes authentication, scope, body, rate and IP refusals for existing instances. No payload, credentials, client IP or raw idempotency key is stored. Audit events and counters commit together. Requires observability:read on all Corpora; returns only the key’s Organization. Uses the Spec 16 rollup windows and retention. By default lists the largest 100 instance/outcome pairs, with a total across every pair. Use connector_id to read both outcomes of one instance; its total then covers that instance only.
curl --request GET \
--url https://api.example.com/v0/admin/stats/connector-pushes \
--header 'Authorization: Bearer <token>'import requests
url = "https://api.example.com/v0/admin/stats/connector-pushes"
headers = {"Authorization": "Bearer <token>"}
response = requests.get(url, headers=headers)
print(response.text)const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};
fetch('https://api.example.com/v0/admin/stats/connector-pushes', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/v0/admin/stats/connector-pushes",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/v0/admin/stats/connector-pushes"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("Authorization", "Bearer <token>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/v0/admin/stats/connector-pushes")
.header("Authorization", "Bearer <token>")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/v0/admin/stats/connector-pushes")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'
response = http.request(request)
puts response.read_body{
"window": "1h",
"resolution_seconds": 2,
"from": "2023-11-07T05:31:56Z",
"to": "2023-11-07T05:31:56Z",
"total": 1,
"items": [
{
"connector_id": "<string>",
"outcome": "received",
"count": 1,
"points": [
{
"start": "2023-11-07T05:31:56Z",
"count": 2
}
]
}
]
}{
"code": "<string>",
"message": "<string>",
"retryable": true,
"field": "<string>",
"resync_url": "<string>"
}Authorizations
API key, not necessarily a JWT. Server derives Organization, permitted actions and Corpus scope; every resource access is authorized.
Query Parameters
1h, 24h, 7d Largest instance/outcome pairs to list; cannot be combined with connector_id.
1 <= x <= 100Read both outcomes of this instance; cannot be combined with limit.
1 - 256Response
Per-instance counters and time buckets.