RegistryCenterNode { public String getDataSourcePath(final String schemaName, final String dataSourceName) { return Joiner.on("/").join("", ROOT, DATA_NODES_NAME, schemaName, dataSourceName); }  String getProxyNodePath(final String instanceId); String getDataNodesPath(); String getSchemaPath(final String schemaName); String getDataSourcePath(final String schemaName, final String dataSourceName); Optional<GovernanceSchema> getGovernanceSchema(final String dataSourceNodeFullPath); Collection<String> getAllSchemaPaths(final Collection<String> schemaNames);  }
@Test public void assertGetDataSourcePath() { assertThat(registryCenterNode.getDataSourcePath("primary_replica_db", "replica_ds_0"), is("/states/datanodes/primary_replica_db/replica_ds_0")); }