VPJSSLUtils (venice API)

java.lang.Object

com.linkedin.venice.hadoop.utils.VPJSSLUtils

public class VPJSSLUtils extends Object

This class contains some utils methods for VPJ jobs to obtain SSL-related configs.

Constructor Summary

Constructors

Constructor

Description

VPJSSLUtils()
Method Summary

Modifier and Type

Method

Description

static Optional<SSLFactory>

createSSLFactory(boolean enableSsl, String sslFactoryClassName, Lazy<Properties> sslProps)

static Properties

getSslProperties(VeniceProperties allProperties)

Build a ssl properties based on the hadoop token file.

static void

resetExecutorSslPropsCacheForTests()

Test-only hook to reset the per-JVM SSL properties cache between test cases.

static VeniceProperties

setupSSLForExecutor(VeniceProperties config)

Sets up SSL on the executor side before creating a PubSub consumer, by materializing SSL properties from the Hadoop token file.

static void

validateSslProperties(VeniceProperties props)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- VPJSSLUtils
  
  public VPJSSLUtils()
Method Details
- getSslProperties
  
  public static Properties getSslProperties(VeniceProperties allProperties) throws IOException
  
  Build a ssl properties based on the hadoop token file.
  
  Throws:
  
  IOException
- setupSSLForExecutor
  
  public static VeniceProperties setupSSLForExecutor(VeniceProperties config)
  
  Sets up SSL on the executor side before creating a PubSub consumer, by materializing SSL properties from the Hadoop token file. This is a no-op when no SSL configurator class is configured. The materialized SSL properties are cached per-JVM (see cachedExecutorSslProps) so repeated calls on the same executor don't re-read the token file or re-write temp certificate files.
- resetExecutorSslPropsCacheForTests
  
  public static void resetExecutorSslPropsCacheForTests()
  
  Test-only hook to reset the per-JVM SSL properties cache between test cases.
- validateSslProperties
  
  public static void validateSslProperties(VeniceProperties props)
- createSSLFactory
  
  public static Optional<SSLFactory> createSSLFactory(boolean enableSsl, String sslFactoryClassName, Lazy<Properties> sslProps)