Package io.grpc.alts.internal
Class AltsProtocolNegotiator
- java.lang.Object
-
- io.grpc.alts.internal.AltsProtocolNegotiator
-
public final class AltsProtocolNegotiator extends java.lang.Object
A gRPCInternalProtocolNegotiator.ProtocolNegotiator
for ALTS. This class creates a Netty handler that provides ALTS security on the wire, similar to Netty'sSslHandler
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
AltsProtocolNegotiator.AltsHandshakeValidator
private static class
AltsProtocolNegotiator.ClientAltsProtocolNegotiator
static class
AltsProtocolNegotiator.ClientAltsProtocolNegotiatorFactory
ClientAltsProtocolNegotiatorFactory is a factory for doing client side negotiation of an ALTS channel.private static class
AltsProtocolNegotiator.ClientTsiHandshakerFactory
private static class
AltsProtocolNegotiator.GoogleDefaultProtocolNegotiator
static class
AltsProtocolNegotiator.GoogleDefaultProtocolNegotiatorFactory
A Protocol Negotiator factory which can switch between ALTS and TLS based on EAG Attrs.(package private) static class
AltsProtocolNegotiator.LazyChannel
Channel created from a channel pool lazily.(package private) static class
AltsProtocolNegotiator.ServerAltsProtocolNegotiator
-
Field Summary
Fields Modifier and Type Field Description (package private) static java.lang.String
ALTS_MAX_CONCURRENT_HANDSHAKES_ENV_VARIABLE
static io.grpc.Attributes.Key<java.lang.Object>
AUTH_CONTEXT_KEY
private static java.lang.String
CFE_CLUSTER_AUTHORITY_NAME
private static java.lang.String
CFE_CLUSTER_RESOURCE_NAME_PREFIX
(package private) static int
DEFAULT_ALTS_MAX_CONCURRENT_HANDSHAKES
private static java.lang.String
DIRECT_PATH_SERVICE_CFE_CLUSTER_PREFIX
private static AsyncSemaphore
handshakeSemaphore
private static java.util.logging.Logger
logger
private static io.netty.util.AsciiString
SCHEME
static io.grpc.Attributes.Key<TsiPeer>
TSI_PEER_KEY
-
Constructor Summary
Constructors Modifier Constructor Description private
AltsProtocolNegotiator()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description private static int
getAltsMaxConcurrentHandshakes()
(package private) static int
getAltsMaxConcurrentHandshakes(java.lang.String altsMaxConcurrentHandshakes)
static io.grpc.netty.InternalProtocolNegotiator.ProtocolNegotiator
serverAltsProtocolNegotiator(io.grpc.internal.ObjectPool<io.grpc.Channel> handshakerChannelPool)
Creates a protocol negotiator for ALTS on the server side.
-
-
-
Field Detail
-
logger
private static final java.util.logging.Logger logger
-
ALTS_MAX_CONCURRENT_HANDSHAKES_ENV_VARIABLE
static final java.lang.String ALTS_MAX_CONCURRENT_HANDSHAKES_ENV_VARIABLE
- See Also:
- Constant Field Values
-
DEFAULT_ALTS_MAX_CONCURRENT_HANDSHAKES
static final int DEFAULT_ALTS_MAX_CONCURRENT_HANDSHAKES
- See Also:
- Constant Field Values
-
handshakeSemaphore
private static final AsyncSemaphore handshakeSemaphore
-
TSI_PEER_KEY
@TransportAttr public static final io.grpc.Attributes.Key<TsiPeer> TSI_PEER_KEY
-
AUTH_CONTEXT_KEY
@TransportAttr public static final io.grpc.Attributes.Key<java.lang.Object> AUTH_CONTEXT_KEY
-
SCHEME
private static final io.netty.util.AsciiString SCHEME
-
DIRECT_PATH_SERVICE_CFE_CLUSTER_PREFIX
private static final java.lang.String DIRECT_PATH_SERVICE_CFE_CLUSTER_PREFIX
- See Also:
- Constant Field Values
-
CFE_CLUSTER_RESOURCE_NAME_PREFIX
private static final java.lang.String CFE_CLUSTER_RESOURCE_NAME_PREFIX
- See Also:
- Constant Field Values
-
CFE_CLUSTER_AUTHORITY_NAME
private static final java.lang.String CFE_CLUSTER_AUTHORITY_NAME
- See Also:
- Constant Field Values
-
-
Method Detail
-
serverAltsProtocolNegotiator
public static io.grpc.netty.InternalProtocolNegotiator.ProtocolNegotiator serverAltsProtocolNegotiator(io.grpc.internal.ObjectPool<io.grpc.Channel> handshakerChannelPool)
Creates a protocol negotiator for ALTS on the server side.
-
getAltsMaxConcurrentHandshakes
static int getAltsMaxConcurrentHandshakes(java.lang.String altsMaxConcurrentHandshakes)
-
getAltsMaxConcurrentHandshakes
private static int getAltsMaxConcurrentHandshakes()
-
-