RPC client for a runtime locking shard cluster.
More...
#include <client.hpp>
|
| client (std::vector< network::endpoint_t > endpoints) |
| Constructor.
|
|
| client ()=delete |
|
| ~client () override=default |
|
| client (const client &)=delete |
|
auto | operator= (const client &) -> client &=delete |
|
| client (client &&)=delete |
|
auto | operator= (client &&) -> client &=delete |
|
auto | init () -> bool |
| Initializes the underlying TCP client.
|
|
auto | try_lock (ticket_number_type ticket_number, broker_id_type broker_id, key_type key, lock_type locktype, bool first_lock, try_lock_callback_type result_callback) -> bool override |
| Requests a try lock operation from the remote shard.
|
|
auto | prepare (ticket_number_type ticket_number, broker_id_type broker_id, state_update_type state_update, prepare_callback_type result_callback) -> bool override |
| Requests a prepare operation from the remote shard.
|
|
auto | commit (ticket_number_type ticket_number, commit_callback_type result_callback) -> bool override |
| Requests a commit operation from the remote shard.
|
|
auto | rollback (ticket_number_type ticket_number, rollback_callback_type result_callback) -> bool override |
| Requests a rollback operation from the remote shard.
|
|
auto | finish (ticket_number_type ticket_number, finish_callback_type result_callback) -> bool override |
| Requests a finish operation from the remote shard.
|
|
auto | get_tickets (broker_id_type broker_id, get_tickets_callback_type result_callback) -> bool override |
| Requests a get tickets operation from the remote shard.
|
|
virtual | ~interface ()=default |
|
| interface ()=default |
|
| interface (const interface &)=delete |
|
auto | operator= (const interface &) -> interface &=delete |
|
| interface (interface &&)=delete |
|
auto | operator= (interface &&) -> interface &=delete |
|
RPC client for a runtime locking shard cluster.
Definition at line 15 of file parsec/runtime_locking_shard/client.hpp.
◆ client() [1/4]
cbdc::parsec::runtime_locking_shard::rpc::client::client |
( |
std::vector< network::endpoint_t > | endpoints | ) |
|
|
explicit |
◆ client() [2/4]
cbdc::parsec::runtime_locking_shard::rpc::client::client |
( |
| ) |
|
|
delete |
◆ ~client()
cbdc::parsec::runtime_locking_shard::rpc::client::~client |
( |
| ) |
|
|
overridedefault |
◆ client() [3/4]
cbdc::parsec::runtime_locking_shard::rpc::client::client |
( |
const client & | | ) |
|
|
delete |
◆ client() [4/4]
cbdc::parsec::runtime_locking_shard::rpc::client::client |
( |
client && | | ) |
|
|
delete |
◆ commit()
◆ finish()
◆ get_tickets()
◆ init()
auto cbdc::parsec::runtime_locking_shard::rpc::client::init |
( |
| ) |
-> bool |
◆ operator=() [1/2]
auto cbdc::parsec::runtime_locking_shard::rpc::client::operator= |
( |
client && | | ) |
-> client &=delete |
|
delete |
◆ operator=() [2/2]
auto cbdc::parsec::runtime_locking_shard::rpc::client::operator= |
( |
const client & | | ) |
-> client &=delete |
|
delete |
◆ prepare()
◆ rollback()
◆ try_lock()
Requests a try lock operation from the remote shard.
- Parameters
-
ticket_number | ticket number. |
broker_id | ID of broker managing ticket. |
key | key to lock. |
locktype | type of lock to acquire. |
first_lock | true if this is the first lock. |
result_callback | function to call with try lock result. |
- Returns
- true if the request was sent successfully.
Implements cbdc::parsec::runtime_locking_shard::interface.
Definition at line 20 of file parsec/runtime_locking_shard/client.cpp.
The documentation for this class was generated from the following files: