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, int blobReceiveMaxTimeoutInMin, int blobReceiveReaderIdleTimeInSeconds, BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat, int peersConnectivityFreshnessInSeconds, long blobTransferClientReadLimitBytesPerSec, long blobTransferServiceWriteLimitBytesPerSec, int snapshotCleanupIntervalInMins, int maxConcurrentBlobReceiveReplicas, int p2pTransferClientNettyWorkerThreadCount)

Method Summary

Modifier and Type	Method	Description
String	getBaseDir()
int	getBlobReceiveReaderIdleTimeInSeconds()
int	getBlobReceiveTimeoutInMin()
long	getBlobTransferClientReadLimitBytesPerSec()
int	getBlobTransferMaxTimeoutInMin()
long	getBlobTransferServiceWriteLimitBytesPerSec()
int	getMaxConcurrentBlobReceiveReplicas()
int	getMaxConcurrentSnapshotUser()
int	getP2pTransferClientNettyWorkerThreadCount()
int	getP2pTransferClientPort()
int	getP2pTransferServerPort()
int	getPeersConnectivityFreshnessInSeconds()
int	getSnapshotCleanupIntervalInMins()
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,
 int blobReceiveMaxTimeoutInMin,
 int blobReceiveReaderIdleTimeInSeconds,
 BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat,
 int peersConnectivityFreshnessInSeconds,
 long blobTransferClientReadLimitBytesPerSec,
 long blobTransferServiceWriteLimitBytesPerSec,
 int snapshotCleanupIntervalInMins,
 int maxConcurrentBlobReceiveReplicas,
 int p2pTransferClientNettyWorkerThreadCount)

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()

getBlobReceiveTimeoutInMin

public int getBlobReceiveTimeoutInMin()

getBlobReceiveReaderIdleTimeInSeconds

public int getBlobReceiveReaderIdleTimeInSeconds()

getTransferSnapshotTableFormat

public BlobTransferUtils.BlobTransferTableFormat getTransferSnapshotTableFormat()

getPeersConnectivityFreshnessInSeconds

public int getPeersConnectivityFreshnessInSeconds()

getBlobTransferClientReadLimitBytesPerSec

public long getBlobTransferClientReadLimitBytesPerSec()

getBlobTransferServiceWriteLimitBytesPerSec

public long getBlobTransferServiceWriteLimitBytesPerSec()

getSnapshotCleanupIntervalInMins

public int getSnapshotCleanupIntervalInMins()

getMaxConcurrentBlobReceiveReplicas

public int getMaxConcurrentBlobReceiveReplicas()

getP2pTransferClientNettyWorkerThreadCount

public int getP2pTransferClientNettyWorkerThreadCount()