26#ifndef ROUTER_SRC_REST_MRS_SRC_MRS_MONITOR_H_
27#define ROUTER_SRC_REST_MRS_SRC_MRS_MONITOR_H_
74 const bool is_dynamic)
77 std::optional<collector::MysqlCacheManager::CachedObject>
get_rw_session();
84 DestinationState::k_read_only};
99 using Parent::WaitableMonitor;
Monitor can be waited for.
Definition: monitor.h:62
Definition: wait_variable.h:34
Definition: mysql_cache_manager.h:87
Definition: configuration.h:49
Definition: endpoint_manager.h:55
Definition: gtid_manager.h:50
Definition: response_cache.h:66
Definition: authorize_manager.h:52
Definition: query_factory_proxy.h:38
Definition: schema_monitor.h:96
Definition: schema_monitor.h:51
collector::MysqlCacheManager * cache_
Definition: schema_monitor.h:106
mrs::GtidManager * gtid_manager_
Definition: schema_monitor.h:110
void stop()
Definition: schema_monitor.cc:170
void run()
Definition: schema_monitor.cc:201
mrs::EndpointManager * dbobject_manager_
Definition: schema_monitor.h:107
~SchemaMonitor()
Definition: schema_monitor.cc:161
std::pair< std::string, std::string > get_router_name_and_address()
Definition: schema_monitor.cc:410
mrs::observability::EntitiesManager * entities_manager_
Definition: schema_monitor.h:109
mrs::ResponseCache * response_cache_
Definition: schema_monitor.h:114
SchemaMonitor(const mrs::Configuration &configuration, collector::MysqlCacheManager *cache, mrs::EndpointManager *dbobject_manager, authentication::AuthorizeManager *auth_manager, mrs::observability::EntitiesManager *entities_manager, mrs::GtidManager *gtid_manager, mrs::database::QueryFactoryProxy *query_factory, mrs::ResponseCache *response_cache, mrs::ResponseCache *file_cache, SlowQueryMonitor *slow_query_monitor, MetadataLogger *metadata_logger)
Definition: schema_monitor.cc:137
MetadataSourceDestination md_source_destination_
Definition: schema_monitor.h:118
const mrs::Configuration configuration_
Definition: schema_monitor.h:104
SlowQueryMonitor * slow_query_monitor_
Definition: schema_monitor.h:116
std::optional< std::string > router_name_
Definition: schema_monitor.h:105
void start()
Definition: schema_monitor.cc:163
void reset()
Definition: schema_monitor.cc:179
bool wait_until_next_refresh()
Definition: schema_monitor.cc:402
mrs::ResponseCache * file_cache_
Definition: schema_monitor.h:115
WaitableVariable< State > state_
Definition: schema_monitor.h:111
MetadataLogger * metadata_logger_
Definition: schema_monitor.h:117
State
Definition: schema_monitor.h:102
@ k_running
Definition: schema_monitor.h:102
@ k_stopped
Definition: schema_monitor.h:102
@ k_initializing
Definition: schema_monitor.h:102
mrs::authentication::AuthorizeManager * auth_manager_
Definition: schema_monitor.h:108
mrs::database::QueryFactoryProxy * proxy_query_factory_
Definition: schema_monitor.h:113
Waitable waitable_
Definition: schema_monitor.h:112
Definition: slow_query_monitor.h:47
Definition: entities_manager.h:40
Definition: authorize_manager.h:48
required string configuration
Definition: replication_asynchronous_connection_failover.proto:49