Package com.linkedin.venice.blobtransfer

Class ServerAndDaVinciBlobFinder

java.lang.Object

com.linkedin.venice.blobtransfer.ServerAndDaVinciBlobFinder

All Implemented Interfaces:

BlobFinder, AutoCloseable

public class ServerAndDaVinciBlobFinder
extends Object
implements BlobFinder

Discovers Da Vinci peers first and Venice servers second for client cold-start blob transfer.

Constructor Summary

Constructors

Constructor	Description
ServerAndDaVinciBlobFinder(ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
BlobPeersDiscoveryResponse	discoverBlobPeers(String storeName, int version, int partitionId)	This method will look through the partitions for the store and version provided until it finds the partition requested, it will then return the URL of the instances that are ready to serve in the partition.
boolean	shouldPreservePeerOrder()

Methods inherited from class java.lang.Object

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

Constructor Details

ServerAndDaVinciBlobFinder

public ServerAndDaVinciBlobFinder(ClientConfig clientConfig)

Method Details

discoverBlobPeers

public BlobPeersDiscoveryResponse discoverBlobPeers(String storeName,
 int version,
 int partitionId)

Description copied from interface: BlobFinder

This method will look through the partitions for the store and version provided until it finds the partition requested, it will then return the URL of the instances that are ready to serve in the partition.

Specified by:

discoverBlobPeers in interface BlobFinder

shouldPreservePeerOrder

public boolean shouldPreservePeerOrder()

Specified by:

shouldPreservePeerOrder in interface BlobFinder

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception