Package com.linkedin.venice.grpc

Class GrpcUtils

java.lang.Object

com.linkedin.venice.grpc.GrpcUtils

public final class GrpcUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
GrpcUtils()

Method Summary

Modifier and Type	Method	Description
static io.grpc.Status	accessResultToGrpcStatus(AccessResult accessResult)
static io.grpc.ChannelCredentials	buildChannelCredentials(SSLFactory sslFactory)
static X509Certificate	extractGrpcClientCert(io.grpc.ServerCall<?,?> call)
static KeyManager[]	getKeyManagers(SSLFactory sslFactory)
static TrustManager[]	getTrustManagers(SSLFactory sslFactory)
static com.google.protobuf.ByteString	toByteString(io.netty.buffer.ByteBuf buf)	Copies readable bytes from a ByteBuf into a ByteString.
static com.google.protobuf.ByteString	toByteStringNoCopy(byte[] bytes)	Wraps a byte array into a ByteString without copying.

Methods inherited from class java.lang.Object

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

Constructor Details

GrpcUtils

public GrpcUtils()

Method Details

getKeyManagers

public static KeyManager[] getKeyManagers(SSLFactory sslFactory)
                                   throws UnrecoverableKeyException,
CertificateException,
KeyStoreException,
IOException,
NoSuchAlgorithmException

Throws:

UnrecoverableKeyException

CertificateException

KeyStoreException

IOException

NoSuchAlgorithmException

getTrustManagers

public static TrustManager[] getTrustManagers(SSLFactory sslFactory)
                                       throws CertificateException,
KeyStoreException,
IOException,
NoSuchAlgorithmException

Throws:

CertificateException

KeyStoreException

IOException

NoSuchAlgorithmException

accessResultToGrpcStatus

public static io.grpc.Status accessResultToGrpcStatus(AccessResult accessResult)

extractGrpcClientCert

public static X509Certificate extractGrpcClientCert(io.grpc.ServerCall<?,?> call)
                                             throws SSLPeerUnverifiedException

Throws:

SSLPeerUnverifiedException

toByteStringNoCopy

public static com.google.protobuf.ByteString toByteStringNoCopy(byte[] bytes)

Wraps a byte array into a ByteString without copying. The returned ByteString directly aliases the provided array, so the caller must not modify the array after calling this method. Violating this contract can cause silent data corruption in serialized gRPC payloads.

If the caller cannot guarantee immutability of the input array, use ByteString.copyFrom(byte[]) instead.

toByteString

public static com.google.protobuf.ByteString toByteString(io.netty.buffer.ByteBuf buf)

Copies readable bytes from a ByteBuf into a ByteString.

buildChannelCredentials

public static io.grpc.ChannelCredentials buildChannelCredentials(SSLFactory sslFactory)