Package com.linkedin.venice.listener

Class ServerReadMetadataRepository

java.lang.Object

com.linkedin.venice.listener.ServerReadMetadataRepository

All Implemented Interfaces:

ReadMetadataRetriever

public class ServerReadMetadataRepository
extends Object
implements ReadMetadataRetriever

A wrapper that holds reference for various repositories responsible for constructing metadata responses upon request.

Constructor Summary

Constructors

Constructor

Description

ServerReadMetadataRepository(String serverCluster, io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository storeRepository, ReadOnlySchemaRepository schemaRepository, HelixReadOnlyStoreConfigRepository storeConfigRepository, Optional<CompletableFuture<HelixCustomizedViewOfflinePushRepository>> customizedViewFuture, Optional<CompletableFuture<HelixInstanceConfigRepository>> helixInstanceFuture)

Method Summary

Modifier and Type	Method	Description
ServerCurrentVersionResponse	getCurrentVersionResponse(String storeName)
MetadataResponse	getMetadata(String storeName)	Return the metadata information for the given store.
StorePropertiesResponse	getStoreProperties(String storeName, Optional<Integer> largestKnownSchemaId)	Return the store properties for the given store.

Methods inherited from class java.lang.Object

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

Constructor Details

ServerReadMetadataRepository

public ServerReadMetadataRepository(String serverCluster,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 ReadOnlyStoreRepository storeRepository,
 ReadOnlySchemaRepository schemaRepository,
 HelixReadOnlyStoreConfigRepository storeConfigRepository,
 Optional<CompletableFuture<HelixCustomizedViewOfflinePushRepository>> customizedViewFuture,
 Optional<CompletableFuture<HelixInstanceConfigRepository>> helixInstanceFuture)

Method Details

getMetadata

public MetadataResponse getMetadata(String storeName)

Return the metadata information for the given store. The data is retrieved from its respective repositories which originate from the VeniceServer.

Specified by:

getMetadata in interface ReadMetadataRetriever

Parameters:

storeName -

Returns:

MetadataResponse object that holds all the information required for answering a server metadata fetch request.

getStoreProperties

public StorePropertiesResponse getStoreProperties(String storeName,
 Optional<Integer> largestKnownSchemaId)

Return the store properties for the given store. The data is retrieved from its respective repositories which originate from the VeniceServer.

Specified by:

getStoreProperties in interface ReadMetadataRetriever

Parameters:

storeName -

Returns:

StorePropertiesResponse object that holds all the information required for answering a server metadata fetch request.

getCurrentVersionResponse

public ServerCurrentVersionResponse getCurrentVersionResponse(String storeName)

Specified by:

getCurrentVersionResponse in interface ReadMetadataRetriever