Class DefaultConfigService
java.lang.Object
com.here.platform.data.client.service.config.DefaultConfigService
- All Implemented Interfaces:
ConfigService
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classNested classes/interfaces inherited from interface com.here.platform.data.client.service.config.ConfigService
ConfigService.Operation, ConfigService.Operation$, ConfigService.StatusResponse, ConfigService.StatusResponse$, ConfigService.SubscriptionStatusResponse, ConfigService.SubscriptionStatusResponse$, ConfigService.SubscriptionStatusToken, ConfigService.SubscriptionStatusToken$ -
Constructor Summary
ConstructorsConstructorDescriptionDefaultConfigService(HttpHandler httpHandler, ClientExecutionContext clientExecutionContext) -
Method Summary
Modifier and TypeMethodDescriptionscala.concurrent.Future<Object>checkSubscriptionExists(HRN hrn, InternalSettings settings) scala.concurrent.Future<ConfigService.Operation>createCatalog(WritableCatalogConfiguration configuration, InternalSettings settings) scala.concurrent.Future<ConfigService.Operation>deleteCatalog(HRN hrn, InternalSettings settings) scala.concurrent.Future<ConfigService.Operation>deleteLayer(HRN hrn, String layer, InternalSettings settings) scala.concurrent.Future<Object>exists(HRN hrn, InternalSettings settings) scala.concurrent.Future<CatalogConfiguration>getConfig(HRN hrn, InternalSettings settings) scala.concurrent.Future<CatalogConfiguration>getConfigFromHref(InternalSettings settings, String href) scala.concurrent.Future<SubscriptionConfiguration>getSubscriptionConfig(HRN hrn, InternalSettings settings) scala.concurrent.Future<CatalogSubset>getSubset(HRN hrn, String subsetId, InternalSettings settings) scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<CatalogSubset,org.apache.pekko.NotUsed>> getSubsets(HRN hrn, scala.Option<Object> limit, scala.Option<scala.collection.immutable.Seq<String>> areas, InternalSettings settings) scala.concurrent.Future<CatalogSubsetsFingerprint>getSubsetsFingerprint(HRN hrn, InternalSettings settings) scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<CatalogConfiguration,org.apache.pekko.NotUsed>> listCatalogs(ListCatalogsParams params, InternalSettings settings) scala.concurrent.Future<scala.collection.immutable.Seq<HRN>>listCatalogs(InternalSettings settings) scala.concurrent.Future<scala.collection.immutable.Seq<SubscriptionConfiguration>>listSubscriptions(scala.Option<Object> limit, InternalSettings settings) scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<SubscriptionConfiguration,org.apache.pekko.NotUsed>> listSubscriptionsAsSource(scala.Option<Object> limit, InternalSettings settings) static StringmarshalUpdatableLayer(UpdatableLayer updatableLayer) static Stringscala.concurrent.Future<ConfigService.Operation>removeAutomaticVersionDeletion(HRN hrn, InternalSettings settings) scala.concurrent.Future<ConfigService.StatusResponse>status(InternalSettings settings, String url) scala.concurrent.Future<ConfigService.SubscriptionStatusToken>subscribe(WritableSubscriptionConfiguration configuration, InternalSettings settings) scala.concurrent.Future<ConfigService.SubscriptionStatusResponse>subscriptionStatus(String statusToken, InternalSettings settings) static scala.collection.immutable.Seq<HRN>unmarshalCatalogs(String json) static CatalogConfigurationunmarshalConfig(String json, org.apache.pekko.event.LoggingAdapter log) static CatalogConfigurationunmarshalConfig(org.json4s.JValue ast, org.apache.pekko.event.LoggingAdapter log) static scala.collection.immutable.Seq<CatalogConfiguration>unmarshalConfigs(String json, org.apache.pekko.event.LoggingAdapter log) static ConfigService.StatusResponsescala.concurrent.Future<ConfigService.SubscriptionStatusToken>unsubscribe(HRN hrn, InternalSettings settings) scala.concurrent.Future<ConfigService.Operation>updateCatalog(HRN hrn, WritableCatalogConfiguration configuration, InternalSettings settings) scala.concurrent.Future<ConfigService.Operation>updateLayer(HRN hrn, String layerId, InternalSettings settings, UpdatableLayer layer)
-
Constructor Details
-
DefaultConfigService
-
-
Method Details
-
unmarshalConfigs
public static scala.collection.immutable.Seq<CatalogConfiguration> unmarshalConfigs(String json, org.apache.pekko.event.LoggingAdapter log) -
unmarshalConfig
public static CatalogConfiguration unmarshalConfig(String json, org.apache.pekko.event.LoggingAdapter log) -
unmarshalConfig
public static CatalogConfiguration unmarshalConfig(org.json4s.JValue ast, org.apache.pekko.event.LoggingAdapter log) -
marshalWritableConfig
-
marshalUpdatableLayer
-
unmarshalStatusResponse
-
unmarshalCatalogs
-
unmarshalSubscriptionStatusResponse
public static ConfigService.SubscriptionStatusResponse unmarshalSubscriptionStatusResponse(String json) -
getConfig
- Specified by:
getConfigin interfaceConfigService
-
createCatalog
public scala.concurrent.Future<ConfigService.Operation> createCatalog(WritableCatalogConfiguration configuration, InternalSettings settings) - Specified by:
createCatalogin interfaceConfigService
-
status
public scala.concurrent.Future<ConfigService.StatusResponse> status(InternalSettings settings, String url) - Specified by:
statusin interfaceConfigService
-
listCatalogs
public scala.concurrent.Future<scala.collection.immutable.Seq<HRN>> listCatalogs(InternalSettings settings) - Specified by:
listCatalogsin interfaceConfigService
-
listCatalogs
public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<CatalogConfiguration,org.apache.pekko.NotUsed>> listCatalogs(ListCatalogsParams params, InternalSettings settings) - Specified by:
listCatalogsin interfaceConfigService
-
exists
- Specified by:
existsin interfaceConfigService
-
deleteCatalog
public scala.concurrent.Future<ConfigService.Operation> deleteCatalog(HRN hrn, InternalSettings settings) - Specified by:
deleteCatalogin interfaceConfigService
-
deleteLayer
public scala.concurrent.Future<ConfigService.Operation> deleteLayer(HRN hrn, String layer, InternalSettings settings) - Specified by:
deleteLayerin interfaceConfigService
-
updateCatalog
public scala.concurrent.Future<ConfigService.Operation> updateCatalog(HRN hrn, WritableCatalogConfiguration configuration, InternalSettings settings) - Specified by:
updateCatalogin interfaceConfigService
-
getConfigFromHref
public scala.concurrent.Future<CatalogConfiguration> getConfigFromHref(InternalSettings settings, String href) - Specified by:
getConfigFromHrefin interfaceConfigService
-
removeAutomaticVersionDeletion
public scala.concurrent.Future<ConfigService.Operation> removeAutomaticVersionDeletion(HRN hrn, InternalSettings settings) - Specified by:
removeAutomaticVersionDeletionin interfaceConfigService
-
updateLayer
public scala.concurrent.Future<ConfigService.Operation> updateLayer(HRN hrn, String layerId, InternalSettings settings, UpdatableLayer layer) - Specified by:
updateLayerin interfaceConfigService
-
subscriptionStatus
public scala.concurrent.Future<ConfigService.SubscriptionStatusResponse> subscriptionStatus(String statusToken, InternalSettings settings) - Specified by:
subscriptionStatusin interfaceConfigService
-
subscribe
public scala.concurrent.Future<ConfigService.SubscriptionStatusToken> subscribe(WritableSubscriptionConfiguration configuration, InternalSettings settings) - Specified by:
subscribein interfaceConfigService
-
unsubscribe
public scala.concurrent.Future<ConfigService.SubscriptionStatusToken> unsubscribe(HRN hrn, InternalSettings settings) - Specified by:
unsubscribein interfaceConfigService
-
checkSubscriptionExists
- Specified by:
checkSubscriptionExistsin interfaceConfigService
-
getSubscriptionConfig
public scala.concurrent.Future<SubscriptionConfiguration> getSubscriptionConfig(HRN hrn, InternalSettings settings) - Specified by:
getSubscriptionConfigin interfaceConfigService
-
listSubscriptions
public scala.concurrent.Future<scala.collection.immutable.Seq<SubscriptionConfiguration>> listSubscriptions(scala.Option<Object> limit, InternalSettings settings) - Specified by:
listSubscriptionsin interfaceConfigService
-
listSubscriptionsAsSource
public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<SubscriptionConfiguration,org.apache.pekko.NotUsed>> listSubscriptionsAsSource(scala.Option<Object> limit, InternalSettings settings) - Specified by:
listSubscriptionsAsSourcein interfaceConfigService
-
getSubsets
public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<CatalogSubset,org.apache.pekko.NotUsed>> getSubsets(HRN hrn, scala.Option<Object> limit, scala.Option<scala.collection.immutable.Seq<String>> areas, InternalSettings settings) - Specified by:
getSubsetsin interfaceConfigService
-
getSubset
public scala.concurrent.Future<CatalogSubset> getSubset(HRN hrn, String subsetId, InternalSettings settings) - Specified by:
getSubsetin interfaceConfigService
-
getSubsetsFingerprint
public scala.concurrent.Future<CatalogSubsetsFingerprint> getSubsetsFingerprint(HRN hrn, InternalSettings settings) - Specified by:
getSubsetsFingerprintin interfaceConfigService
-