Home
last modified time | relevance | path

Searched refs:metadata_cache (Results 1 – 25 of 112) sorted by relevance

12345

/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/tests/
H A Dtest_metadata_cache_group.cc32 using metadata_cache::InstanceStatus;
33 using metadata_cache::LookupResult;
34 using metadata_cache::ServerMode;
35 using InstanceVector = std::vector<metadata_cache::ManagedInstance>;
41 class MetadataCacheAPIStub : public metadata_cache::MetadataCacheAPIBase {
51 metadata_cache::ReplicasetStateListenerInterface *listener) override { in add_listener()
57 metadata_cache::ReplicasetStateListenerInterface *) override { in remove_listener()
118 std::vector<metadata_cache::ManagedInstance> instance_vector_;
155 {kReplicasetName, "uuid1", metadata_cache::ServerMode::ReadOnly, "3308", in TEST_F()
174 {kReplicasetName, "uuid1", metadata_cache::ServerMode::ReadOnly, "3307", in TEST_F()
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/metadata_cache/tests/helper/
H A Dmock_metadata.h58 metadata_cache::ManagedInstance ms1;
59 metadata_cache::ManagedInstance ms2;
60 metadata_cache::ManagedInstance ms3;
61 metadata_cache::ManagedInstance ms4;
62 metadata_cache::ManagedInstance ms5;
63 metadata_cache::ManagedInstance ms6;
64 metadata_cache::ManagedInstance ms7;
65 metadata_cache::ManagedInstance ms8;
66 metadata_cache::ManagedInstance ms9;
73 std::vector<metadata_cache::ManagedInstance> replicaset_1_vector;
[all …]
H A Dmock_metadata.cc47 ms1.mode = metadata_cache::ServerMode::ReadWrite; in MockNG()
54 ms2.mode = metadata_cache::ServerMode::ReadOnly; in MockNG()
61 ms3.mode = metadata_cache::ServerMode::ReadOnly; in MockNG()
68 ms4.mode = metadata_cache::ServerMode::ReadWrite; in MockNG()
75 ms5.mode = metadata_cache::ServerMode::ReadOnly; in MockNG()
82 ms6.mode = metadata_cache::ServerMode::ReadOnly; in MockNG()
89 ms7.mode = metadata_cache::ServerMode::ReadWrite; in MockNG()
96 ms8.mode = metadata_cache::ServerMode::ReadWrite; in MockNG()
103 ms9.mode = metadata_cache::ServerMode::ReadWrite; in MockNG()
150 const std::vector<metadata_cache::ManagedInstance> & /*instances*/, in fetch_instances()
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/metadata_cache/src/
H A Dmetadata_cache.cc72 metadata_cache->refresh_thread(); in run_thread()
251 bool metadata_cache::ManagedInstance::operator==( in operator ==()
261 metadata_cache::ManagedInstance::ManagedInstance( in ManagedInstance()
313 case metadata_cache::ServerMode::ReadWrite: in to_string()
315 case metadata_cache::ServerMode::ReadOnly: in to_string()
317 case metadata_cache::ServerMode::Unavailable: in to_string()
410 metadata_cache::ManagedInstance *instance = nullptr; in mark_instance_reachability()
428 case metadata_cache::InstanceStatus::Reachable: in mark_instance_reachability()
430 case metadata_cache::InstanceStatus::InvalidHost: in mark_instance_reachability()
438 case metadata_cache::InstanceStatus::Unreachable: in mark_instance_reachability()
[all …]
H A Dcluster_metadata_gr.cc121 metadata_cache::ManagedReplicaSet in update_replicaset_status()
195 case metadata_cache::ReplicasetStatus:: in update_replicaset_status()
268 using MI = metadata_cache::ManagedInstance; in check_replicaset_status()
284 using metadata_cache::ReplicasetStatus; in check_replicaset_status()
285 using metadata_cache::ServerMode; in check_replicaset_status()
527 throw metadata_cache::metadata_error( in fetch_instances_from_metadata_server()
533 metadata_cache::ManagedInstance s; in fetch_instances_from_metadata_server()
554 throw metadata_cache::metadata_error(e.what()); in fetch_instances_from_metadata_server()
612 throw metadata_cache::metadata_error( in fetch_instances_from_metadata_server()
618 metadata_cache::ManagedInstance instance; in fetch_instances_from_metadata_server()
[all …]
H A Dmetadata_cache.h55 : public metadata_cache::ReplicasetStateNotifierInterface {
99 using metadata_servers_list_t = std::vector<metadata_cache::ManagedInstance>;
123 metadata_cache::InstanceStatus status);
152 metadata_cache::ReplicasetStateListenerInterface *listener) override;
162 metadata_cache::ReplicasetStateListenerInterface *listener) override;
164 metadata_cache::MetadataCacheAPIBase::RefreshStatus refresh_status() { in refresh_status()
200 const metadata_cache::ManagedInstance &metadata_server);
215 std::map<std::string, metadata_cache::ManagedReplicaSet> replicaset_data_;
290 std::set<metadata_cache::ReplicasetStateListenerInterface *>>
312 std::string to_string(metadata_cache::ServerMode mode);
[all …]
H A Dcluster_metadata_ar.cc41 const std::vector<metadata_cache::ManagedInstance> &instances, in fetch_instances()
43 std::vector<metadata_cache::ManagedInstance> new_instances; in fetch_instances()
111 metadata_cache::ManagedReplicaSet replicaset; in fetch_instances()
146 std::vector<metadata_cache::ManagedInstance>
149 std::vector<metadata_cache::ManagedInstance> result; in fetch_instances_from_member()
179 throw metadata_cache::metadata_error( in fetch_instances_from_member()
185 metadata_cache::ManagedInstance instance; in fetch_instances_from_member()
193 ? metadata_cache::ServerMode::ReadWrite in fetch_instances_from_member()
194 : metadata_cache::ServerMode::ReadOnly; in fetch_instances_from_member()
211 throw metadata_cache::metadata_error(e.what()); in fetch_instances_from_member()
H A Dcluster_metadata.h52 const metadata_cache::ManagedInstance &mi)>;
102 const metadata_cache::ManagedInstance &metadata_server) noexcept override;
117 bool update_router_version(const metadata_cache::ManagedInstance &rw_instance,
121 const metadata_cache::ManagedInstance &rw_instance,
131 const metadata_cache::ManagedInstance &mi);
171 bool set_instance_ports(metadata_cache::ManagedInstance &instance,
176 void set_instance_attributes(metadata_cache::ManagedInstance &instance,
H A Dmetadata.h47 std::map<std::string, metadata_cache::ManagedReplicaSet>;
60 const std::vector<metadata_cache::ManagedInstance> &instances,
65 const metadata_cache::ManagedInstance &rw_instance,
69 const metadata_cache::ManagedInstance &rw_instance,
73 const metadata_cache::ManagedInstance &metadata_server) = 0;
78 const std::vector<metadata_cache::ManagedInstance> &instances,
H A Dgroup_replication_metadata.cc64 throw metadata_cache::metadata_error( in IMPORT_LOG_FUNCTIONS()
83 throw metadata_cache::metadata_error(e.what()); in IMPORT_LOG_FUNCTIONS()
84 } catch (const metadata_cache::metadata_error &) { in IMPORT_LOG_FUNCTIONS()
124 throw metadata_cache::metadata_error( in fetch_group_replication_members()
145 throw metadata_cache::metadata_error( in fetch_group_replication_members()
200 throw metadata_cache::metadata_error(e.what()); in fetch_group_replication_members()
201 } catch (const metadata_cache::metadata_error &) { in fetch_group_replication_members()
H A Dcluster_metadata.cc87 throw metadata_cache::metadata_error( in ClusterMetadata()
104 const metadata_cache::ManagedInstance &mi) { in do_connect()
121 const metadata_cache::ManagedInstance &metadata_server) noexcept { in connect_and_setup_session()
167 throw metadata_cache::metadata_error(mysqlrouter::string_format( in get_and_check_metadata_schema_version()
178 bool set_instance_ports(metadata_cache::ManagedInstance &instance, in set_instance_ports()
221 const metadata_cache::ManagedInstance &rw_instance, in update_router_version()
281 const metadata_cache::ManagedInstance &rw_instance, in update_router_last_check_in()
415 return get_bool_tag(attributes, metadata_cache::kNodeTagHidden, in get_hidden()
416 metadata_cache::kNodeTagHiddenDefault, out_warning); in get_hidden()
422 metadata_cache::kNodeTagDisconnectWhenHiddenDefault, in get_disconnect_existing_sessions_when_hidden()
[all …]
H A Dplugin_config.cc50 {"address", metadata_cache::kDefaultMetadataAddress}, in get_default()
51 {"ttl", ms_to_seconds_string(metadata_cache::kDefaultMetadataTTL)}, in get_default()
53 ms_to_seconds_string(metadata_cache::kDefaultAuthCacheTTL)}, in get_default()
55 ms_to_seconds_string(metadata_cache::kDefaultAuthCacheRefreshInterval)}, in get_default()
56 {"connect_timeout", to_string(metadata_cache::kDefaultConnectTimeout)}, in get_default()
57 {"read_timeout", to_string(metadata_cache::kDefaultReadTimeout)}, in get_default()
H A Dcluster_metadata_gr.h89 const std::vector<metadata_cache::ManagedInstance> & /*instances*/, in fetch_instances()
103 const std::vector<metadata_cache::ManagedInstance> &instances, in setup_notifications_listener()
152 metadata_cache::ManagedReplicaSet &replicaset);
154 metadata_cache::ReplicasetStatus check_replicaset_status(
155 std::vector<metadata_cache::ManagedInstance> &instances,
H A Dmetadata_cache_plugin.cc47 using metadata_cache::LookupResult;
93 : public metadata_cache::ReplicasetStateListenerInterface {
100 metadata_cache::MetadataCacheAPI::instance()->remove_listener( in ~MetadataServersStateListener()
179 ? metadata_cache::kDefaultMetadataCluster in start()
197 auto md_cache = metadata_cache::MetadataCacheAPI::instance(); in start()
239 metadata_cache::MetadataCacheAPI::instance()->cache_stop(); in start()
H A Dcluster_metadata_ar.h94 const std::vector<metadata_cache::ManagedInstance> &instances,
105 const std::vector<metadata_cache::ManagedInstance> & /*instances*/, in setup_notifications_listener()
121 std::vector<metadata_cache::ManagedInstance> fetch_instances_from_member(
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/src/
H A Ddest_metadata_cache.h45 public metadata_cache::ReplicasetStateListenerInterface {
51 const std::string &metadata_cache, const std::string &replicaset,
55 metadata_cache::MetadataCacheAPIBase *cache_api =
56 metadata_cache::MetadataCacheAPI::instance(),
156 const metadata_cache::LookupResult &managed_servers,
160 const metadata_cache::LookupResult &managed_servers) const;
172 metadata_cache::MetadataCacheAPIBase *cache_api_;
179 void on_instances_change(const metadata_cache::LookupResult &instances,
183 void notify(const metadata_cache::LookupResult &instances,
H A Ddest_metadata_cache.cc54 using metadata_cache::ManagedInstance;
198 metadata_cache::MetadataCacheAPIBase *cache_api, in DestMetadataCacheGroup()
201 cache_name_(metadata_cache), in DestMetadataCacheGroup()
218 const metadata_cache::LookupResult &managed_servers, in get_available()
257 (it.mode == metadata_cache::ServerMode::ReadWrite || in get_available()
266 it.mode == metadata_cache::ServerMode::ReadOnly) { in get_available()
274 it.mode == metadata_cache::ServerMode::ReadWrite) { in get_available()
293 if (it.mode == metadata_cache::ServerMode::ReadWrite) { in get_available_primaries()
461 metadata_cache::InstanceStatus::Unreachable); in get_server_socket_gr()
574 const metadata_cache::LookupResult &instances, in on_instances_change()
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/rest_metadata_cache/src/
H A Drest_clusters_nodes.cc41 static const char *server_mode_to_string(metadata_cache::ServerMode mode) { in server_mode_to_string()
43 case metadata_cache::ServerMode::ReadOnly: in server_mode_to_string()
45 case metadata_cache::ServerMode::ReadWrite: in server_mode_to_string()
47 case metadata_cache::ServerMode::Unavailable: in server_mode_to_string()
65 metadata_cache::LookupResult res = in on_handle_request()
66 metadata_cache::MetadataCacheAPI::instance()->lookup_replicaset( in on_handle_request()
H A Drest_metadata_cache_status.cc53 metadata_cache::MetadataCacheAPI::instance()->instance_name()) { in on_handle_request()
66 metadata_cache::MetadataCacheAPI::RefreshStatus refresh_status; in on_handle_request()
69 metadata_cache::MetadataCacheAPI::instance()->get_refresh_status(); in on_handle_request()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/metadata_cache/tests/
H A Dtest_cache_plugin.cc65 using metadata_cache::ManagedInstance;
77 metadata_cache::MetadataCacheAPI::instance()->cache_init( in SetUp()
83 metadata_cache::MetadataCacheAPI::instance()->cache_start(); in SetUp()
110 metadata_cache::MetadataCacheAPI::instance()->cache_stop(); in TearDown()
113 metadata_cache::MetadataCacheAPIBase *cache_api_{
114 metadata_cache::MetadataCacheAPI::instance()};
H A Dtest_plugin_config.cc125 {"foo", metadata_cache::kDefaultMetadataTTL, "",
184 TCPAddress("foobar", metadata_cache::kDefaultMetadataPort),
187 TCPAddress("fuzzbozz", metadata_cache::kDefaultMetadataPort),
202 {"foo", metadata_cache::kDefaultMetadataTTL, "",
205 TCPAddress("foobar", metadata_cache::kDefaultMetadataPort),
231 TCPAddress("foobar", metadata_cache::kDefaultMetadataPort),
234 TCPAddress("fuzzbozz", metadata_cache::kDefaultMetadataPort),
/dports/sysutils/py-ranger/ranger-1.9.3/ranger/core/
H A Dmetadata.py29 self.metadata_cache = dict()
35 self.metadata_cache.clear()
40 return ostruct(copy.deepcopy(self.metadata_cache[filename]))
84 self.metadata_cache[filename] = entry
91 if filename in self.metadata_cache:
92 return self.metadata_cache[filename]
108 self.metadata_cache[filename] = entry
/dports/www/elgg/elgg-3.3.23/vendor/elgg/elgg/engine/classes/Elgg/Database/
H A DMetadataTable.php27 protected $metadata_cache; variable in Elgg\\Database\\MetadataTable
49 * @param MetadataCache $metadata_cache A cache for this table
54 MetadataCache $metadata_cache, argument
58 $this->metadata_cache = $metadata_cache;
245 $this->metadata_cache->clear($metadata->entity_guid);
328 $this->metadata_cache->clear($metadata->entity_guid);
370 $this->metadata_cache->clear($metadata->entity_guid);
441 $this->metadata_cache->invalidateByOptions($options);
474 if ($this->metadata_cache->isLoaded($entity_guid)) {
475 $ids = $this->metadata_cache->getSingleId($entity_guid, $name);
/dports/devel/mercurial/mercurial-6.0/mercurial/revlogutils/
H A Drewrite.py579 metadata_cache=None, argument
595 if metadata_cache is not None:
596 metadata_cache[filerev] = has_meta
618 metadata_cache,
629 metadata_cache, argument
641 metadata_cache[filerev] = False
655 metadata_cache,
676 metadata_cache,
728 metadata_cache = {}
792 metadata_cache,
[all …]
/dports/textproc/py-isbnlib/isbnlib-3.10.9/isbnlib/
H A Dregistry.py115 metadata_cache = IMCache() # should be an instance variable
120 global metadata_cache
121 metadata_cache = cache

12345