Package com.here.platform.data.client.service.config

Class DefaultConfigService

java.lang.Object

com.here.platform.data.client.service.config.DefaultConfigService

All Implemented Interfaces:

ConfigService

public class DefaultConfigService
extends Object
implements ConfigService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultConfigService.RawIndexProperties
static class	DefaultConfigService.RawIndexProperties$
static class	DefaultConfigService.RawInteractiveMapProperties
static class	DefaultConfigService.RawInteractiveMapProperties$
static class	DefaultConfigService.RawObjectStoreProperties
static class	DefaultConfigService.RawObjectStoreProperties$
static class	DefaultConfigService.RawStreamProperties
static class	DefaultConfigService.RawStreamProperties$
static class	DefaultConfigService.RawUpdatableLayer
static class	DefaultConfigService.RawUpdatableLayer$

Nested 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

Constructors

Constructor	Description
DefaultConfigService(HttpHandler httpHandler, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
scala.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 String	marshalUpdatableLayer(UpdatableLayer updatableLayer)
static String	marshalWritableConfig(WritableCatalogConfiguration config)
scala.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 CatalogConfiguration	unmarshalConfig(String json, org.apache.pekko.event.LoggingAdapter log)
static CatalogConfiguration	unmarshalConfig(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.StatusResponse	unmarshalStatusResponse(String json)
static ConfigService.SubscriptionStatusResponse	unmarshalSubscriptionStatusResponse(String json)
scala.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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultConfigService

public DefaultConfigService(HttpHandler httpHandler,
 ClientExecutionContext clientExecutionContext)

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

public static String marshalWritableConfig(WritableCatalogConfiguration config)

marshalUpdatableLayer

public static String marshalUpdatableLayer(UpdatableLayer updatableLayer)

unmarshalStatusResponse

public static ConfigService.StatusResponse unmarshalStatusResponse(String json)

unmarshalCatalogs

public static scala.collection.immutable.Seq<HRN> unmarshalCatalogs(String json)

unmarshalSubscriptionStatusResponse

public static ConfigService.SubscriptionStatusResponse unmarshalSubscriptionStatusResponse(String json)

getConfig

public scala.concurrent.Future<CatalogConfiguration> getConfig(HRN hrn,
 InternalSettings settings)

Specified by:

getConfig in interface ConfigService

createCatalog

public scala.concurrent.Future<ConfigService.Operation> createCatalog(WritableCatalogConfiguration configuration,
 InternalSettings settings)

Specified by:

createCatalog in interface ConfigService

status

public scala.concurrent.Future<ConfigService.StatusResponse> status(InternalSettings settings,
 String url)

Specified by:

status in interface ConfigService

listCatalogs

public scala.concurrent.Future<scala.collection.immutable.Seq<HRN>> listCatalogs(InternalSettings settings)

Specified by:

listCatalogs in interface ConfigService

listCatalogs

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<CatalogConfiguration,org.apache.pekko.NotUsed>> listCatalogs(ListCatalogsParams params,
 InternalSettings settings)

Specified by:

listCatalogs in interface ConfigService

exists

public scala.concurrent.Future<Object> exists(HRN hrn,
 InternalSettings settings)

Specified by:

exists in interface ConfigService

deleteCatalog

public scala.concurrent.Future<ConfigService.Operation> deleteCatalog(HRN hrn,
 InternalSettings settings)

Specified by:

deleteCatalog in interface ConfigService

deleteLayer

public scala.concurrent.Future<ConfigService.Operation> deleteLayer(HRN hrn,
 String layer,
 InternalSettings settings)

Specified by:

deleteLayer in interface ConfigService

updateCatalog

public scala.concurrent.Future<ConfigService.Operation> updateCatalog(HRN hrn,
 WritableCatalogConfiguration configuration,
 InternalSettings settings)

Specified by:

updateCatalog in interface ConfigService

getConfigFromHref

public scala.concurrent.Future<CatalogConfiguration> getConfigFromHref(InternalSettings settings,
 String href)

Specified by:

getConfigFromHref in interface ConfigService

removeAutomaticVersionDeletion

public scala.concurrent.Future<ConfigService.Operation> removeAutomaticVersionDeletion(HRN hrn,
 InternalSettings settings)

Specified by:

removeAutomaticVersionDeletion in interface ConfigService

updateLayer

public scala.concurrent.Future<ConfigService.Operation> updateLayer(HRN hrn,
 String layerId,
 InternalSettings settings,
 UpdatableLayer layer)

Specified by:

updateLayer in interface ConfigService

subscriptionStatus

public scala.concurrent.Future<ConfigService.SubscriptionStatusResponse> subscriptionStatus(String statusToken,
 InternalSettings settings)

Specified by:

subscriptionStatus in interface ConfigService

subscribe

public scala.concurrent.Future<ConfigService.SubscriptionStatusToken> subscribe(WritableSubscriptionConfiguration configuration,
 InternalSettings settings)

Specified by:

subscribe in interface ConfigService

unsubscribe

public scala.concurrent.Future<ConfigService.SubscriptionStatusToken> unsubscribe(HRN hrn,
 InternalSettings settings)

Specified by:

unsubscribe in interface ConfigService

checkSubscriptionExists

public scala.concurrent.Future<Object> checkSubscriptionExists(HRN hrn,
 InternalSettings settings)

Specified by:

checkSubscriptionExists in interface ConfigService

getSubscriptionConfig

public scala.concurrent.Future<SubscriptionConfiguration> getSubscriptionConfig(HRN hrn,
 InternalSettings settings)

Specified by:

getSubscriptionConfig in interface ConfigService

listSubscriptions

public scala.concurrent.Future<scala.collection.immutable.Seq<SubscriptionConfiguration>> listSubscriptions(scala.Option<Object> limit,
 InternalSettings settings)

Specified by:

listSubscriptions in interface ConfigService

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:

listSubscriptionsAsSource in interface ConfigService

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:

getSubsets in interface ConfigService

getSubset

public scala.concurrent.Future<CatalogSubset> getSubset(HRN hrn,
 String subsetId,
 InternalSettings settings)

Specified by:

getSubset in interface ConfigService

getSubsetsFingerprint

public scala.concurrent.Future<CatalogSubsetsFingerprint> getSubsetsFingerprint(HRN hrn,
 InternalSettings settings)

Specified by:

getSubsetsFingerprint in interface ConfigService