UnreachableDestinationsQuarantine::Unreachable_destination_candidate Struct Reference

Class representing a single entry (destination) in quarantined destination set. More...

Public Types
enum class	Function { kInitDestination , kConnectFinish }
using	server_protocol_type = net::ip::tcp

Public Member Functions
	Unreachable_destination_candidate (net::io_context *io_ctx, const mysql_harness::TCPAddress &addr, std::vector< std::string > referencing_instances, std::chrono::seconds quarantine_interval, std::function< void()> on_delete, std::function< void()> on_connect_ok)
	~Unreachable_destination_candidate ()
	Unreachable_destination_candidate (Unreachable_destination_candidate &&)=default
Unreachable_destination_candidate &	operator= (Unreachable_destination_candidate &&)=default
	Unreachable_destination_candidate (const Unreachable_destination_candidate &)=delete
Unreachable_destination_candidate &	operator= (const Unreachable_destination_candidate &)=delete
stdx::expected< void, std::error_code >	connect ()
stdx::expected< void, std::error_code >	resolve ()
stdx::expected< void, std::error_code >	init_endpoint ()
stdx::expected< void, std::error_code >	next_endpoint ()
stdx::expected< void, std::error_code >	connect_init ()
stdx::expected< void, std::error_code >	try_connect ()
stdx::expected< void, std::error_code >	connect_finish ()
stdx::expected< void, std::error_code >	connected ()

Public Attributes
net::io_context *	io_ctx_
mysql_harness::TCPAddress	address_
std::vector< std::string >	referencing_routing_instances_
std::chrono::seconds	quarantine_interval_
net::steady_timer	timer_
net::ip::tcp::resolver::results_type	endpoints_
net::ip::tcp::resolver::results_type::iterator	endpoints_it_
server_protocol_type::socket	server_sock_ {*io_ctx_}
server_protocol_type::endpoint	server_endpoint_
bool	connect_timed_out_ {false}
bool	connected_ {false}
Function	func_ {Function::kInitDestination}
std::error_code	last_ec_
std::function< void()>	on_delete_
std::function< void()>	on_connect_ok_

Detailed Description

Class representing a single entry (destination) in quarantined destination set.

Each destination has its own timer responsible for doing asynchronous availability checks and a list of names of routing instances that currently reference this destination candidate.

Member Typedef Documentation

server_protocol_type

using UnreachableDestinationsQuarantine::Unreachable_destination_candidate::server_protocol_type = net::ip::tcp

Member Enumeration Documentation

Function

enum class UnreachableDestinationsQuarantine::Unreachable_destination_candidate::Function

strong

Enumerator
kInitDestination
kConnectFinish

Constructor & Destructor Documentation

Unreachable_destination_candidate() [1/3]

UnreachableDestinationsQuarantine::Unreachable_destination_candidate::Unreachable_destination_candidate ( net::io_context *  io_ctx, const mysql_harness::TCPAddress &  addr, std::vector< std::string >  referencing_instances, std::chrono::seconds  quarantine_interval, std::function< void()>  on_delete, std::function< void()>  on_connect_ok  )

inline

~Unreachable_destination_candidate()

UnreachableDestinationsQuarantine::Unreachable_destination_candidate::~Unreachable_destination_candidate

(

)

Unreachable_destination_candidate() [2/3]

UnreachableDestinationsQuarantine::Unreachable_destination_candidate::Unreachable_destination_candidate ( Unreachable_destination_candidate &&  )

default

Unreachable_destination_candidate() [3/3]

UnreachableDestinationsQuarantine::Unreachable_destination_candidate::Unreachable_destination_candidate ( const Unreachable_destination_candidate &  )

delete

Member Function Documentation

connect()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::connect

(

)

connect_finish()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::connect_finish

(

)

connect_init()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::connect_init

(

)

connected()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::connected

(

)

init_endpoint()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::init_endpoint

(

)

next_endpoint()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::next_endpoint

(

)

operator=() [1/2]

Unreachable_destination_candidate & UnreachableDestinationsQuarantine::Unreachable_destination_candidate::operator= ( const Unreachable_destination_candidate &  )

delete

operator=() [2/2]

Unreachable_destination_candidate & UnreachableDestinationsQuarantine::Unreachable_destination_candidate::operator= ( Unreachable_destination_candidate &&  )

default

resolve()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::resolve

(

)

try_connect()

stdx::expected< void, std::error_code > UnreachableDestinationsQuarantine::Unreachable_destination_candidate::try_connect

(

)

Member Data Documentation

address_

mysql_harness::TCPAddress UnreachableDestinationsQuarantine::Unreachable_destination_candidate::address_

connect_timed_out_

bool UnreachableDestinationsQuarantine::Unreachable_destination_candidate::connect_timed_out_ {false}

connected_

bool UnreachableDestinationsQuarantine::Unreachable_destination_candidate::connected_ {false}

endpoints_

net::ip::tcp::resolver::results_type UnreachableDestinationsQuarantine::Unreachable_destination_candidate::endpoints_

endpoints_it_

net::ip::tcp::resolver::results_type::iterator UnreachableDestinationsQuarantine::Unreachable_destination_candidate::endpoints_it_

func_

Function UnreachableDestinationsQuarantine::Unreachable_destination_candidate::func_ {Function::kInitDestination}

io_ctx_

net::io_context* UnreachableDestinationsQuarantine::Unreachable_destination_candidate::io_ctx_

last_ec_

std::error_code UnreachableDestinationsQuarantine::Unreachable_destination_candidate::last_ec_

Initial value:

{
        make_error_code(std::errc::no_such_file_or_directory)}

on_connect_ok_

std::function<void()> UnreachableDestinationsQuarantine::Unreachable_destination_candidate::on_connect_ok_

on_delete_

std::function<void()> UnreachableDestinationsQuarantine::Unreachable_destination_candidate::on_delete_

quarantine_interval_

std::chrono::seconds UnreachableDestinationsQuarantine::Unreachable_destination_candidate::quarantine_interval_

referencing_routing_instances_

std::vector<std::string> UnreachableDestinationsQuarantine::Unreachable_destination_candidate::referencing_routing_instances_

server_endpoint_

server_protocol_type::endpoint UnreachableDestinationsQuarantine::Unreachable_destination_candidate::server_endpoint_

server_sock_

server_protocol_type::socket UnreachableDestinationsQuarantine::Unreachable_destination_candidate::server_sock_ {*io_ctx_}

timer_

net::steady_timer UnreachableDestinationsQuarantine::Unreachable_destination_candidate::timer_

---

The documentation for this struct was generated from the following files:

• router/src/destination_status/src/unreachable_destinations_quarantine.h
• router/src/destination_status/src/unreachable_destinations_quarantine.cc