f3eade2f62
Drop the AGPL license in favor of a source-available license. See the blog post [1] for details. [1] https://www.scylladb.com/2024/12/18/why-were-moving-to-a-source-available-license/
41 lines
1.3 KiB
Python
41 lines
1.3 KiB
Python
# Copyright 2023-present ScyllaDB
|
|
#
|
|
# SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
|
|
import pytest
|
|
import sys
|
|
import requests
|
|
import threading
|
|
import time
|
|
|
|
|
|
def test_gossiper_live_endpoints(cql, rest_api):
|
|
resp = rest_api.send("GET", f"gossiper/endpoint/live")
|
|
resp.raise_for_status()
|
|
live_endpoints = set(resp.json())
|
|
all_hosts_endpoints = set([host.address for host in cql.cluster.metadata.all_hosts()])
|
|
assert live_endpoints == all_hosts_endpoints
|
|
|
|
def test_gossiper_unreachable_endpoints(cql, rest_api):
|
|
resp = rest_api.send("GET", f"gossiper/endpoint/down")
|
|
resp.raise_for_status()
|
|
unreachable_endpoints = set(resp.json())
|
|
assert not unreachable_endpoints
|
|
|
|
def test_gossiper_unreachable_endpoints(cql, rest_api):
|
|
resp = rest_api.send("GET", f"gossiper/endpoint/down")
|
|
resp.raise_for_status()
|
|
unreachable_endpoints = set(resp.json())
|
|
for ep in unreachable_endpoints:
|
|
resp = rest_api.send("GET", f"gossiper/downtime/{ep}")
|
|
resp.raise_for_status()
|
|
assert int(resp.json()) > 0
|
|
|
|
resp = rest_api.send("GET", f"gossiper/endpoint/live")
|
|
resp.raise_for_status()
|
|
live_endpoints = set(resp.json())
|
|
for ep in live_endpoints:
|
|
resp = rest_api.send("GET", f"gossiper/downtime/{ep}")
|
|
resp.raise_for_status()
|
|
assert int(resp.json()) == 0
|