Package com.linkedin.venice.fastclient.meta

Interface StoreMetadata

All Superinterfaces:

AutoCloseable, Closeable, SchemaReader

All Known Implementing Classes:

AbstractStoreMetadata, RequestBasedMetadata

public interface StoreMetadata
extends SchemaReader

This interface defines the APIs to retrieve store metadata and routing data, and it also includes the feedback APIs: trackHealthBasedOnRequestToInstance(java.lang.String, int, int, java.util.concurrent.CompletableFuture<com.linkedin.venice.client.store.transport.TransportClientResponse>) to decide the healthiness of each replica.

Method Summary

Modifier and Type	Method	Description
int	getBatchGetLimit()
String	getClusterName()
VeniceCompressor	getCompressor(CompressionStrategy compressionStrategy, int version)
int	getCurrentStoreVersion()
InstanceHealthMonitor	getInstanceHealthMonitor()
int	getPartitionId(int version, byte[] key)
int	getPartitionId(int version, ByteBuffer key)
List<String>	getReplicas(int version, int partitionId)
default List<String>	getReplicas(long requestId, int version, int partitionId, int requiredReplicaCount)	This function is expected to return fully qualified URI, such as: "https://fake.host:8888".
List<String>	getReplicas(long requestId, int version, int partitionId, int requiredReplicaCount, Set<String> excludedInstances)
String	getStoreName()
default boolean	isReady()
void	start()
ChainedCompletableFuture<Integer,Integer>	trackHealthBasedOnRequestToInstance(String instance, int version, int partitionId, CompletableFuture<TransportClientResponse> transportFuture)

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface com.linkedin.venice.schema.SchemaReader

getKeySchema, getLatestUpdateSchema, getLatestValueSchema, getLatestValueSchemaId, getUpdateSchema, getValueSchema, getValueSchemaId

Method Details

getClusterName

String getClusterName()

getStoreName

String getStoreName()

getCurrentStoreVersion

int getCurrentStoreVersion()

getPartitionId

int getPartitionId(int version,
 ByteBuffer key)

getPartitionId

int getPartitionId(int version,
 byte[] key)

getReplicas

List<String> getReplicas(int version,
 int partitionId)

getReplicas

default List<String> getReplicas(long requestId,
 int version,
 int partitionId,
 int requiredReplicaCount)

This function is expected to return fully qualified URI, such as: "https://fake.host:8888".

Parameters:

version -

partitionId -

Returns:

getReplicas

List<String> getReplicas(long requestId,
 int version,
 int partitionId,
 int requiredReplicaCount,
 Set<String> excludedInstances)

trackHealthBasedOnRequestToInstance

ChainedCompletableFuture<Integer,Integer> trackHealthBasedOnRequestToInstance(String instance,
 int version,
 int partitionId,
 CompletableFuture<TransportClientResponse> transportFuture)

getInstanceHealthMonitor

InstanceHealthMonitor getInstanceHealthMonitor()

getCompressor

VeniceCompressor getCompressor(CompressionStrategy compressionStrategy,
 int version)

getBatchGetLimit

int getBatchGetLimit()

start

void start()

isReady

default boolean isReady()