Get the distribution state
curl --request GET \
--url https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/stateimport requests
url = "https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state', 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://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$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://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state")
.asString();require 'uri'
require 'net/http'
url = URI("https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_body""""Get the distribution state
Returns the distribution state of the given query cube, as the messages received from its data cubes and the JGroups membership notifications left it. The state is reported for the query cube itself, for every data cube it knows and for every branch of those data cubes. It reflects what the query cube has received, not what it has already applied onto the cube.
GET
/
activeviam
/
distribution-observability
/
rest
/
v1
/
{queryCubeName}
/
state
Get the distribution state
curl --request GET \
--url https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/stateimport requests
url = "https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state', 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://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$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://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state")
.asString();require 'uri'
require 'net/http'
url = URI("https://{host}/activeviam/distribution-observability/rest/v1/{queryCubeName}/state")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_body""""Was this page helpful?