Package io.grpc.alts.internal

Class AltsProtocolNegotiator

java.lang.Object

io.grpc.alts.internal.AltsProtocolNegotiator

public final class AltsProtocolNegotiator
extends java.lang.Object

A gRPC InternalProtocolNegotiator.ProtocolNegotiator for ALTS. This class creates a Netty handler that provides ALTS security on the wire, similar to Netty's SslHandler.

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

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.

Methods inherited from class java.lang.Object

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

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

Constructor Detail

AltsProtocolNegotiator

private AltsProtocolNegotiator()

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()