Package com.linkedin.davinci.blobtransfer

Class BlobTransferUtils

java.lang.Object

com.linkedin.davinci.blobtransfer.BlobTransferUtils

public class BlobTransferUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	BlobTransferUtils.BlobTransferTableFormat
static enum	BlobTransferUtils.BlobTransferType

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BLOB_TRANSFER_COMPLETED
static final String	BLOB_TRANSFER_STATUS
static final String	BLOB_TRANSFER_TYPE

Constructor Summary

Constructors

Constructor	Description
BlobTransferUtils()

Method Summary

Modifier and Type	Method	Description
static Optional<BlobTransferAclHandler>	createAclHandler(VeniceConfigLoader configLoader)	Create the acl handler for blob transfer, for both DVC peers and server peers
static io.netty.handler.ssl.SslHandler	createBlobTransferClientSslHandler(Optional<SSLFactory> sslFactory)
static Optional<SSLFactory>	createSSLFactoryForBlobTransferInDVC(VeniceConfigLoader configLoader)	Create an SSLFactory from the Venice config loader
static String	generateFileChecksum(Path filePath)	Generate MD5 checksum for a file
static boolean	isMetadataMessage(io.netty.handler.codec.http.HttpResponse msg)	Check if the HttpResponse message is for metadata.

Methods inherited from class java.lang.Object

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

Field Details

BLOB_TRANSFER_STATUS

public static final String BLOB_TRANSFER_STATUS

See Also:

• Constant Field Values

BLOB_TRANSFER_COMPLETED

public static final String BLOB_TRANSFER_COMPLETED

See Also:

• Constant Field Values

BLOB_TRANSFER_TYPE

public static final String BLOB_TRANSFER_TYPE

See Also:

• Constant Field Values

Constructor Details

BlobTransferUtils

public BlobTransferUtils()

Method Details

isMetadataMessage

public static boolean isMetadataMessage(io.netty.handler.codec.http.HttpResponse msg)

Check if the HttpResponse message is for metadata.

Parameters:

msg - the HttpResponse message

Returns:

true if the message is a metadata message, false otherwise

generateFileChecksum

public static String generateFileChecksum(Path filePath)
                                   throws IOException

Generate MD5 checksum for a file

Parameters:

filePath - the path to the file

Returns:

a hex string

Throws:

IOException - if an I/O error occurs

createSSLFactoryForBlobTransferInDVC

public static Optional<SSLFactory> createSSLFactoryForBlobTransferInDVC(VeniceConfigLoader configLoader)

Create an SSLFactory from the Venice config loader

Parameters:

configLoader - The Venice config loader containing SSL configuration

Returns:

Optional SSLFactory, which will be empty if SSL is not enabled

createBlobTransferClientSslHandler

public static io.netty.handler.ssl.SslHandler createBlobTransferClientSslHandler(Optional<SSLFactory> sslFactory)

createAclHandler

public static Optional<BlobTransferAclHandler> createAclHandler(VeniceConfigLoader configLoader)

Create the acl handler for blob transfer, for both DVC peers and server peers