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 D2TransportClient directly (rather than AbstractAvroStoreClient) to avoid store-level D2 service discovery, which requires a store name and is unnecessary for cluster-agnostic endpoints like /stores.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE_STORES

Constructor Summary

Constructors

Constructor	Description
RouterBasedStoreMetadataFetcher(com.linkedin.d2.balancer.D2Client d2Client, String d2ServiceName)

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(com.linkedin.d2.balancer.D2Client d2Client,
 String d2ServiceName)

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