mirror of
https://github.com/scylladb/scylladb.git
synced 2026-04-20 00:20:47 +00:00
70 lines
2.3 KiB
C++
70 lines
2.3 KiB
C++
/*
|
|
* Copyright (C) 2019-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.1
|
|
*/
|
|
#pragma once
|
|
|
|
#include <seastar/net/inet_address.hh>
|
|
#include <seastar/core/sstring.hh>
|
|
#include "seastarx.hh"
|
|
#include "utils/loading_shared_values.hh"
|
|
|
|
#include <list>
|
|
#include <optional>
|
|
|
|
enum class client_type {
|
|
cql = 0,
|
|
thrift,
|
|
alternator,
|
|
};
|
|
|
|
sstring to_string(client_type ct);
|
|
|
|
enum class client_connection_stage {
|
|
established = 0,
|
|
authenticating,
|
|
ready,
|
|
};
|
|
|
|
// We implement a keys cache using a map-like utils::loading_shared_values container by storing empty values.
|
|
struct options_cache_value_type {};
|
|
using client_options_cache_type = utils::loading_shared_values<sstring, options_cache_value_type>;
|
|
using client_options_cache_entry_type = client_options_cache_type::entry_ptr;
|
|
using client_options_cache_key_type = client_options_cache_type::key_type;
|
|
|
|
// This struct represents a single OPTION key-value pair from the client's connection options.
|
|
// Both key and value are represented by corresponding "references" to their cached values.
|
|
// Each "reference" is effectively a lw_shared_ptr value.
|
|
struct client_option_key_value_cached_entry {
|
|
client_options_cache_entry_type key;
|
|
client_options_cache_entry_type value;
|
|
};
|
|
|
|
sstring to_string(client_connection_stage ct);
|
|
|
|
// Representation of a row in `system.clients'. std::optionals are for nullable cells.
|
|
struct client_data {
|
|
net::inet_address ip;
|
|
int32_t port;
|
|
client_type ct = client_type::cql;
|
|
client_connection_stage connection_stage = client_connection_stage::established;
|
|
int32_t shard_id; /// ID of server-side shard which is processing the connection.
|
|
|
|
std::optional<client_options_cache_entry_type> driver_name;
|
|
std::optional<client_options_cache_entry_type> driver_version;
|
|
std::optional<sstring> hostname;
|
|
std::optional<int32_t> protocol_version;
|
|
std::optional<sstring> ssl_cipher_suite;
|
|
std::optional<bool> ssl_enabled;
|
|
std::optional<sstring> ssl_protocol;
|
|
std::optional<sstring> username;
|
|
std::optional<sstring> scheduling_group_name;
|
|
std::list<client_option_key_value_cached_entry> client_options;
|
|
|
|
sstring stage_str() const { return to_string(connection_stage); }
|
|
sstring client_type_str() const { return to_string(ct); }
|
|
};
|