Set Replica Identity Decisions Endpoint
curl --request PUT \
--url https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"decisions": {}
}
'import requests
url = "https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions"
payload = { "decisions": {} }
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.put(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'PUT',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({decisions: {}})
};
fetch('https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions', 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.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "PUT",
CURLOPT_POSTFIELDS => json_encode([
'decisions' => [
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions"
payload := strings.NewReader("{\n \"decisions\": {}\n}")
req, _ := http.NewRequest("PUT", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.put("https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"decisions\": {}\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Put.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"decisions\": {}\n}"
response = http.request(request)
puts response.read_body{
"id": "<string>",
"name": "<string>",
"org_id": "<string>",
"service_name": "<string>",
"can_delete": true,
"can_update": true,
"created_at": "<string>",
"project_id": "<string>",
"status": "<string>"
}{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>",
"ctx": {},
"input": "<unknown>"
}
]
}Connectors
Submit replica identity decisions
Resolve tables that need an identity decision
PUT
/
v1
/
connectors
/
{connector_id}
/
replica-identity-decisions
Set Replica Identity Decisions Endpoint
curl --request PUT \
--url https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"decisions": {}
}
'import requests
url = "https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions"
payload = { "decisions": {} }
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.put(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'PUT',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({decisions: {}})
};
fetch('https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions', 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.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "PUT",
CURLOPT_POSTFIELDS => json_encode([
'decisions' => [
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions"
payload := strings.NewReader("{\n \"decisions\": {}\n}")
req, _ := http.NewRequest("PUT", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.put("https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"decisions\": {}\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.tryardent.com/v1/connectors/{connector_id}/replica-identity-decisions")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Put.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"decisions\": {}\n}"
response = http.request(request)
puts response.read_body{
"id": "<string>",
"name": "<string>",
"org_id": "<string>",
"service_name": "<string>",
"can_delete": true,
"can_update": true,
"created_at": "<string>",
"project_id": "<string>",
"status": "<string>"
}{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>",
"ctx": {},
"input": "<unknown>"
}
]
}If Ardent reports tables that need a decision, submit a table-to-decision map:
Decision values:
The map is a full replace: tables you omit revert to
{
"decisions": {
"public.audit_events": "exclude",
"public.invoice_line_items": "replica_identity_full"
}
}
| Value | Meaning |
|---|---|
exclude | Do not replicate this table yet |
add_pk | You will add a primary key or valid unique key on source before retrying |
replica_identity_full | Opt into REPLICA IDENTITY FULL for this table |
exclude.Authorizations
Ardent API key (sk-ard_live_… / sk-ard_test_…) or a dashboard session token.
Path Parameters
Body
application/json
Per-table decision: exclude, add_pk, or replica_identity_full.
Show child attributes
Show child attributes
Response
The refreshed connector row, including replica_identity_preflight.
Connector ID.
Connector name.
Organization the connector belongs to.
Service type. postgresql today.
Whether the caller may delete this connector.
Whether the caller may update this connector.
When the connector was created.
Project the connector belongs to.
Current connector status.