Package com.linkedin.davinci.blobtransfer

Class BlobTransferUtils

java.lang.Object
com.linkedin.davinci.blobtransfer.BlobTransferUtils
public class BlobTransferUtils extends Object

  • Field Details

  • 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

    • isBlobTransferManagerEnabled

      public static boolean isBlobTransferManagerEnabled(VeniceServerConfig backendConfig, boolean isIsolatedIngestionEnabled)
      A config check to determine if blob transfer manager is enabled
      Parameters:
      backendConfig - the Venice server config
      isIsolatedIngestionEnabled - whether isolated ingestion is enabled
      Returns:
      true if blob transfer manager is enabled, false otherwise