Package com.linkedin.venice.client.store

Class RouterBasedStoreMetadataFetcher

java.lang.Object

com.linkedin.venice.client.store.RouterBasedStoreMetadataFetcher

All Implemented Interfaces:

StoreMetadataFetcher, Closeable, AutoCloseable

public class RouterBasedStoreMetadataFetcher
extends Object
implements StoreMetadataFetcher

Router-based implementation for fetching store metadata that is not cluster-specific. Unlike RouterBasedStoreSchemaFetcher, this class is not tied to a specific store and operates on metadata available globally across clusters. This class uses a TransportClient directly (rather than AbstractAvroStoreClient) because AbstractAvroStoreClient is store-scoped, whereas /stores is a cluster-agnostic router endpoint. The underlying transport may be D2-, HTTPS-, or HTTP-backed depending on how the caller configured the ClientConfig passed to ClientFactory.createStoreMetadataFetcher(ClientConfig).

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE_STORES

Constructor Summary

Constructors

Constructor	Description
RouterBasedStoreMetadataFetcher(ClientConfig clientConfig)	Constructs a fetcher that owns the underlying TransportClient built from clientConfig; closing this fetcher closes the transport.

Method Summary

Modifier and Type	Method	Description
void	close()
Set<String>	getAllStoreNames()	Returns all store names available across all clusters, as seen by the router's non-cluster-specific HelixReadOnlyStoreConfigRepository.

Methods inherited from class java.lang.Object

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

Field Details

TYPE_STORES

public static final String TYPE_STORES

See Also:

• Constant Field Values

Constructor Details

RouterBasedStoreMetadataFetcher

public RouterBasedStoreMetadataFetcher(ClientConfig clientConfig)

Constructs a fetcher that owns the underlying TransportClient built from clientConfig; closing this fetcher closes the transport.

Method Details

getAllStoreNames

public Set<String> getAllStoreNames()

Returns all store names available across all clusters, as seen by the router's non-cluster-specific HelixReadOnlyStoreConfigRepository.

Specified by:

getAllStoreNames in interface StoreMetadataFetcher

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException