Package com.linkedin.davinci.blobtransfer

Class P2PBlobTransferConfig

java.lang.Object

com.linkedin.davinci.blobtransfer.P2PBlobTransferConfig

public class P2PBlobTransferConfig
extends Object

All configs for P2P blob transfer.

Constructor Summary

Constructors

Constructor	Description
P2PBlobTransferConfig(int p2pTransferServerPort, int p2pTransferClientPort, String baseDir, int maxConcurrentSnapshotUser, int snapshotRetentionTimeInMin, int blobTransferMaxTimeoutInMin, BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat, int peersConnectivityFreshnessInSeconds, long blobTransferClientReadLimitBytesPerSec, long blobTransferServiceWriteLimitBytesPerSec)

Method Summary

Modifier and Type	Method	Description
String	getBaseDir()
long	getBlobTransferClientReadLimitBytesPerSec()
int	getBlobTransferMaxTimeoutInMin()
long	getBlobTransferServiceWriteLimitBytesPerSec()
int	getMaxConcurrentSnapshotUser()
int	getP2pTransferClientPort()
int	getP2pTransferServerPort()
int	getPeersConnectivityFreshnessInSeconds()
int	getSnapshotRetentionTimeInMin()
BlobTransferUtils.BlobTransferTableFormat	getTransferSnapshotTableFormat()

Methods inherited from class java.lang.Object

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

Constructor Details

P2PBlobTransferConfig

public P2PBlobTransferConfig(int p2pTransferServerPort,
 int p2pTransferClientPort,
 String baseDir,
 int maxConcurrentSnapshotUser,
 int snapshotRetentionTimeInMin,
 int blobTransferMaxTimeoutInMin,
 BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat,
 int peersConnectivityFreshnessInSeconds,
 long blobTransferClientReadLimitBytesPerSec,
 long blobTransferServiceWriteLimitBytesPerSec)

Method Details

getP2pTransferServerPort

public int getP2pTransferServerPort()

getP2pTransferClientPort

public int getP2pTransferClientPort()

getBaseDir

public String getBaseDir()

getMaxConcurrentSnapshotUser

public int getMaxConcurrentSnapshotUser()

getSnapshotRetentionTimeInMin

public int getSnapshotRetentionTimeInMin()

getBlobTransferMaxTimeoutInMin

public int getBlobTransferMaxTimeoutInMin()

getTransferSnapshotTableFormat

public BlobTransferUtils.BlobTransferTableFormat getTransferSnapshotTableFormat()

getPeersConnectivityFreshnessInSeconds

public int getPeersConnectivityFreshnessInSeconds()

getBlobTransferClientReadLimitBytesPerSec

public long getBlobTransferClientReadLimitBytesPerSec()

getBlobTransferServiceWriteLimitBytesPerSec

public long getBlobTransferServiceWriteLimitBytesPerSec()