Pull the next leased batch of events
curl --request POST \
--url https://api.occtoo.com/v1/event-destinations/{id}/pull \
--header 'Authorization: Bearer <token>'import requests
url = "https://api.occtoo.com/v1/event-destinations/{id}/pull"
headers = {"Authorization": "Bearer <token>"}
response = requests.post(url, headers=headers)
print(response.text)const options = {method: 'POST', headers: {Authorization: 'Bearer <token>'}};
fetch('https://api.occtoo.com/v1/event-destinations/{id}/pull', 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.occtoo.com/v1/event-destinations/{id}/pull",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
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.occtoo.com/v1/event-destinations/{id}/pull"
req, _ := http.NewRequest("POST", 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.post("https://api.occtoo.com/v1/event-destinations/{id}/pull")
.header("Authorization", "Bearer <token>")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.occtoo.com/v1/event-destinations/{id}/pull")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
response = http.request(request)
puts response.read_body{
"leaseId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"generation": 123,
"attempt": 123,
"events": "<array>"
}{
"message": "<string>"
}{
"message": "<string>"
}{
"message": "<string>"
}Events API
Pull the next leased batch of events
Leases the next batch of events after the durable consumer’s server-tracked position. Only durable consumer destinations can be pulled; other destination types return 400. A pull immediately resumes the calling worker’s own outstanding lease (pulling before acknowledging means the previous handout was abandoned). The workerId identifies the individual worker and must be unique per worker instance; omitting it makes all anonymous pulls share one identity. Expired leases are redelivered before new work is handed out. Returns 204 when the durable consumer is caught up, 409 while it is paused and 429 when the in-flight window is full.
POST
/
v1
/
event-destinations
/
{id}
/
pull
Pull the next leased batch of events
curl --request POST \
--url https://api.occtoo.com/v1/event-destinations/{id}/pull \
--header 'Authorization: Bearer <token>'import requests
url = "https://api.occtoo.com/v1/event-destinations/{id}/pull"
headers = {"Authorization": "Bearer <token>"}
response = requests.post(url, headers=headers)
print(response.text)const options = {method: 'POST', headers: {Authorization: 'Bearer <token>'}};
fetch('https://api.occtoo.com/v1/event-destinations/{id}/pull', 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.occtoo.com/v1/event-destinations/{id}/pull",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
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.occtoo.com/v1/event-destinations/{id}/pull"
req, _ := http.NewRequest("POST", 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.post("https://api.occtoo.com/v1/event-destinations/{id}/pull")
.header("Authorization", "Bearer <token>")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.occtoo.com/v1/event-destinations/{id}/pull")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
response = http.request(request)
puts response.read_body{
"leaseId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"generation": 123,
"attempt": 123,
"events": "<array>"
}{
"message": "<string>"
}{
"message": "<string>"
}{
"message": "<string>"
}Authorizations
kindeOAuthbearerAuthapiKey
Sign in with the existing Occtoo Studio identity and selected organization.
FlowAuthorization Code
- Authorization URL
- https://auth.occtoo.com/oauth2/auth?audience=https%3A%2F%2Fapi-weu.occtoo.com
- Token URL
- https://auth.occtoo.com/oauth2/token
Path Parameters
Query Parameters
Was this page helpful?