mirror of https://github.com/apache/cassandra
Merge 37695b35c0 into 209ef2b6c4
This commit is contained in:
Nivy Kani
GitHub
commit
a3b9fd47a1
|
|
@ -116,7 +116,7 @@ We shall discuss some of the virtual tables in more detail next.
|
|||
|
||||
The `clients` virtual table lists all active connections (connected
|
||||
clients) including their ip address, port, client_options, connection stage, driver
|
||||
name, driver version, hostname, protocol version, request count, ssl
|
||||
name, driver version, protocol version, request count, ssl
|
||||
enabled, ssl protocol and user name:
|
||||
|
||||
[source, console]
|
||||
|
|
@ -131,7 +131,6 @@ cqlsh> SELECT * FROM system_views.clients;
|
|||
connection_stage | ready
|
||||
driver_name | DataStax Python Driver
|
||||
driver_version | 3.25.0
|
||||
hostname | localhost
|
||||
protocol_version | 5
|
||||
request_count | 16
|
||||
ssl_cipher_suite | null
|
||||
|
|
@ -147,7 +146,6 @@ cqlsh> SELECT * FROM system_views.clients;
|
|||
connection_stage | ready
|
||||
driver_name | DataStax Python Driver
|
||||
driver_version | 3.25.0
|
||||
hostname | localhost
|
||||
protocol_version | 5
|
||||
request_count | 4
|
||||
ssl_cipher_suite | null
|
||||
|
|
@ -163,7 +161,6 @@ cqlsh> SELECT * FROM system_views.clients;
|
|||
connection_stage | ready
|
||||
driver_name | DataStax Java driver for Apache Cassandra(R)
|
||||
driver_version | 4.13.0
|
||||
hostname | localhost
|
||||
protocol_version | 5
|
||||
request_count | 18
|
||||
ssl_cipher_suite | null
|
||||
|
|
@ -179,7 +176,6 @@ cqlsh> SELECT * FROM system_views.clients;
|
|||
connection_stage | ready
|
||||
driver_name | DataStax Java driver for Apache Cassandra(R)
|
||||
driver_version | 4.13.0
|
||||
hostname | localhost
|
||||
protocol_version | 5
|
||||
request_count | 7
|
||||
ssl_cipher_suite | null
|
||||
|
|
@ -216,7 +212,6 @@ VIRTUAL TABLE system_views.clients (
|
|||
connection_stage text,
|
||||
driver_name text,
|
||||
driver_version text,
|
||||
hostname text,
|
||||
protocol_version int,
|
||||
request_count bigint,
|
||||
ssl_cipher_suite text,
|
||||
|
|
@ -564,10 +559,10 @@ results in:
|
|||
+
|
||||
[source, cql]
|
||||
----
|
||||
address | port | connection_stage | driver_name | driver_version | hostname | protocol_version | request_count | ssl_cipher_suite | ssl_enabled | ssl_protocol | username
|
||||
-----------+-------+------------------+------------------------+----------------+-----------|||+------------------+---------------+------------------+-------------+--------------+-----------
|
||||
127.0.0.1 | 37308 | ready | DataStax Python Driver | 3.21.0.post0 | localhost | 4 | 17 | null | False | null | anonymous
|
||||
127.0.0.1 | 37310 | ready | DataStax Python Driver | 3.21.0.post0 | localhost | 4 | 8 | null | False | null | anonymous
|
||||
address | port | connection_stage | driver_name | driver_version | protocol_version | request_count | ssl_cipher_suite | ssl_enabled | ssl_protocol | username
|
||||
-----------+-------+------------------+------------------------+----------------+------------------+---------------+------------------+-------------+--------------+-----------
|
||||
127.0.0.1 | 37308 | ready | DataStax Python Driver | 3.21.0.post0 | 4 | 17 | null | False | null | anonymous
|
||||
127.0.0.1 | 37310 | ready | DataStax Python Driver | 3.21.0.post0 | 4 | 8 | null | False | null | anonymous
|
||||
|
||||
(2 rows)
|
||||
----
|
||||
|
|
@ -29,7 +29,6 @@ final class ClientsTable extends AbstractVirtualTable
|
|||
{
|
||||
private static final String ADDRESS = "address";
|
||||
private static final String PORT = "port";
|
||||
private static final String HOSTNAME = "hostname";
|
||||
private static final String USERNAME = "username";
|
||||
private static final String CONNECTION_STAGE = "connection_stage";
|
||||
private static final String PROTOCOL_VERSION = "protocol_version";
|
||||
|
|
@ -50,7 +49,6 @@ final class ClientsTable extends AbstractVirtualTable
|
|||
.partitioner(new LocalPartitioner(InetAddressType.instance))
|
||||
.addPartitionKeyColumn(ADDRESS, InetAddressType.instance)
|
||||
.addClusteringColumn(PORT, Int32Type.instance)
|
||||
.addRegularColumn(HOSTNAME, UTF8Type.instance)
|
||||
.addRegularColumn(USERNAME, UTF8Type.instance)
|
||||
.addRegularColumn(CONNECTION_STAGE, UTF8Type.instance)
|
||||
.addRegularColumn(PROTOCOL_VERSION, Int32Type.instance)
|
||||
|
|
@ -75,7 +73,6 @@ final class ClientsTable extends AbstractVirtualTable
|
|||
InetSocketAddress remoteAddress = client.remoteAddress();
|
||||
|
||||
result.row(remoteAddress.getAddress(), remoteAddress.getPort())
|
||||
.column(HOSTNAME, remoteAddress.getHostName())
|
||||
.column(USERNAME, client.username().orElse(null))
|
||||
.column(CONNECTION_STAGE, client.stage().toString().toLowerCase())
|
||||
.column(PROTOCOL_VERSION, client.protocolVersion())
|
||||
|
|
|
|||
|
|
@ -46,7 +46,6 @@ final class GossipInfoTable extends AbstractVirtualTable
|
|||
|
||||
static final String ADDRESS = "address";
|
||||
static final String PORT = "port";
|
||||
static final String HOSTNAME = "hostname";
|
||||
static final String GENERATION = "generation";
|
||||
static final String HEARTBEAT = "heartbeat";
|
||||
|
||||
|
|
@ -96,7 +95,6 @@ final class GossipInfoTable extends AbstractVirtualTable
|
|||
EndpointState localState = new EndpointState(entry.getValue());
|
||||
|
||||
SimpleDataSet dataSet = result.row(endpoint.getAddress(), endpoint.getPort())
|
||||
.column(HOSTNAME, endpoint.getHostName())
|
||||
.column(GENERATION, getGeneration(localState))
|
||||
.column(HEARTBEAT, getHeartBeat(localState));
|
||||
|
||||
|
|
@ -173,7 +171,6 @@ final class GossipInfoTable extends AbstractVirtualTable
|
|||
.partitioner(new LocalPartitioner(InetAddressType.instance))
|
||||
.addPartitionKeyColumn(ADDRESS, InetAddressType.instance)
|
||||
.addClusteringColumn(PORT, Int32Type.instance)
|
||||
.addRegularColumn(HOSTNAME, UTF8Type.instance)
|
||||
.addRegularColumn(GENERATION, Int32Type.instance)
|
||||
.addRegularColumn(HEARTBEAT, Int32Type.instance);
|
||||
|
||||
|
|
|
|||
|
|
@ -56,6 +56,7 @@ public class ClientsTableTest extends CQLTester
|
|||
public void testSelectAll() throws Throwable
|
||||
{
|
||||
ResultSet result = executeNet("SELECT * FROM vts.clients");
|
||||
assertThat(result.getColumnDefinitions().size()).isEqualTo(13);
|
||||
|
||||
for (Row r : result)
|
||||
{
|
||||
|
|
@ -65,7 +66,6 @@ public class ClientsTableTest extends CQLTester
|
|||
Assert.assertNotNull(r.getMap("client_options", String.class, String.class));
|
||||
Assert.assertTrue(r.getLong("request_count") > 0 );
|
||||
// the following are questionable if they belong here
|
||||
Assert.assertEquals("localhost", r.getString("hostname"));
|
||||
Assertions.assertThat(r.getMap("client_options", String.class, String.class))
|
||||
.hasEntrySatisfying("DRIVER_VERSION", value -> assertThat(value.contains(r.getString("driver_name"))))
|
||||
.hasEntrySatisfying("DRIVER_VERSION", value -> assertThat(value.contains(r.getString("driver_version"))));
|
||||
|
|
|
|||
|
|
@ -77,13 +77,12 @@ public class GossipInfoTableTest extends CQLTester
|
|||
|
||||
assertThat(resultSet.size()).isEqualTo(1);
|
||||
UntypedResultSet.Row row = resultSet.one();
|
||||
assertThat(row.getColumns().size()).isEqualTo(66);
|
||||
assertThat(row.getColumns().size()).isEqualTo(65);
|
||||
|
||||
assertThat(endpoint).isNotNull();
|
||||
assertThat(localState).isNotNull();
|
||||
assertThat(row.getInetAddress("address")).isEqualTo(endpoint.getAddress());
|
||||
assertThat(row.getInt("port")).isEqualTo(endpoint.getPort());
|
||||
assertThat(row.getString("hostname")).isEqualTo(endpoint.getHostName());
|
||||
assertThat(row.getInt("generation")).isEqualTo(localState.getHeartBeatState().getGeneration());
|
||||
assertThat(row.getInt("heartbeat")).isNotNull();
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue