| action_on_receive_notification(NotificationData notif) override | dunedaq::snbmodules::Bookkeeper | virtual |
| add_update_grp_transfer(GroupMetadata grp_transfers) | dunedaq::snbmodules::Bookkeeper | |
| add_update_transfer(const std::string &client_id, const std::string &data) | dunedaq::snbmodules::Bookkeeper | |
| Bookkeeper(const IPFormat &listening_ip, std::string bookkeeper_id, std::string file_log_path="", int refresh_rate=5, std::string connection_prefix="snbmodules", int timeout_send=10, int timeout_receive=100) | dunedaq::snbmodules::Bookkeeper | inline |
| create_new_transfer(const std::string &protocol, const std::string &src, const std::set< std::string > &dests, const std::set< std::filesystem::path > &files, const nlohmann::json &protocol_options=nlohmann::json()) | dunedaq::snbmodules::Bookkeeper | |
| display_information() | dunedaq::snbmodules::Bookkeeper | |
| do_work(std::atomic< bool > &running_flag) | dunedaq::snbmodules::Bookkeeper | |
| get_bookkeeper_id() const | dunedaq::snbmodules::Bookkeeper | inline |
| get_bookkeepers_conn() const | dunedaq::snbmodules::NotificationInterface | inline |
| get_client_name_from_session_name(const std::string &session_name) const | dunedaq::snbmodules::Bookkeeper | inlineprivate |
| get_clients_conn() const | dunedaq::snbmodules::NotificationInterface | inline |
| get_grp_transfers() | dunedaq::snbmodules::Bookkeeper | inline |
| get_grp_transfers() const | dunedaq::snbmodules::Bookkeeper | inline |
| get_ip() const | dunedaq::snbmodules::Bookkeeper | inline |
| get_transfers() | dunedaq::snbmodules::Bookkeeper | inline |
| get_transfers() const | dunedaq::snbmodules::Bookkeeper | inline |
| input_action(char input) | dunedaq::snbmodules::Bookkeeper | |
| listen_for_notification(const std::string &id, const std::string &expected_from="", int timeout=-1, int tries=-1) | dunedaq::snbmodules::NotificationInterface | |
| lookups_connections() | dunedaq::snbmodules::NotificationInterface | inline |
| m_bookkeeper_id | dunedaq::snbmodules::Bookkeeper | private |
| m_bookkeepers_conn | dunedaq::snbmodules::NotificationInterface | private |
| m_clients_conn | dunedaq::snbmodules::NotificationInterface | private |
| m_clients_per_grp_transfer | dunedaq::snbmodules::Bookkeeper | private |
| m_connection_prefix | dunedaq::snbmodules::NotificationInterface | private |
| m_file_log_path | dunedaq::snbmodules::Bookkeeper | private |
| m_grp_transfers | dunedaq::snbmodules::Bookkeeper | private |
| m_ip | dunedaq::snbmodules::Bookkeeper | private |
| m_max_tries | dunedaq::snbmodules::NotificationInterface | private |
| m_refresh_rate | dunedaq::snbmodules::Bookkeeper | private |
| m_timeout_receive | dunedaq::snbmodules::NotificationInterface | private |
| m_timeout_send | dunedaq::snbmodules::NotificationInterface | private |
| m_transfers | dunedaq::snbmodules::Bookkeeper | private |
| NotificationInterface(std::string connection_prefix="snbmodules", int timeout_send=10, int timeout_receive=100) | dunedaq::snbmodules::NotificationInterface | inlineexplicit |
| NotificationInterface(std::vector< std::string > bk_conn, std::set< std::string > client_conn, const std::string &connection_prefix="snbmodules", int timeout_send=10, int timeout_receive=100) | dunedaq::snbmodules::NotificationInterface | inline |
| request_connection_and_available_files(const std::string &client) | dunedaq::snbmodules::Bookkeeper | private |
| request_update_metadata(bool force=false) | dunedaq::snbmodules::Bookkeeper | |
| send_notification(const notification_type::e_notification_type ¬if, const std::string &src, const std::string &dst, const std::string &id_conn, const std::string &data="", int tries=-1) | dunedaq::snbmodules::NotificationInterface | |
| set_bookkeeper_id(std::string bookkeeper_id) | dunedaq::snbmodules::Bookkeeper | inline |
| set_ip(const IPFormat &ip) | dunedaq::snbmodules::Bookkeeper | inline |
| start() | dunedaq::snbmodules::Bookkeeper | |
| start_transfers(const std::string &transfer_id) | dunedaq::snbmodules::Bookkeeper | private |
| ~Bookkeeper() | dunedaq::snbmodules::Bookkeeper | inline |
| ~NotificationInterface()=default | dunedaq::snbmodules::NotificationInterface | virtual |