Class AltsProtocolNegotiator

java.lang.Object

io.grpc.alts.internal.AltsProtocolNegotiator

public final class AltsProtocolNegotiator
extends 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 final class	AltsProtocolNegotiator.AltsHandshakeValidator
private static final class	AltsProtocolNegotiator.ClientAltsProtocolNegotiator
static final class	AltsProtocolNegotiator.ClientAltsProtocolNegotiatorFactory	ClientAltsProtocolNegotiatorFactory is a factory for doing client side negotiation of an ALTS channel.
private static final class	AltsProtocolNegotiator.ClientTsiHandshakerFactory
private static final class	AltsProtocolNegotiator.GoogleDefaultProtocolNegotiator
static final class	AltsProtocolNegotiator.GoogleDefaultProtocolNegotiatorFactory	A Protocol Negotiator factory which can switch between ALTS and TLS based on EAG Attrs.
(package private) static final class	AltsProtocolNegotiator.LazyChannel	Channel created from a channel pool lazily.
(package private) static final class	AltsProtocolNegotiator.ServerAltsProtocolNegotiator

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	ALTS_MAX_CONCURRENT_HANDSHAKES_ENV_VARIABLE
static final io.grpc.Attributes.Key<Object>	AUTH_CONTEXT_KEY
private static final String	CFE_CLUSTER_AUTHORITY_NAME
private static final String	CFE_CLUSTER_RESOURCE_NAME_PREFIX
(package private) static final int	DEFAULT_ALTS_MAX_CONCURRENT_HANDSHAKES
private static final String	DIRECT_PATH_SERVICE_CFE_CLUSTER_PREFIX
private static final AsyncSemaphore	handshakeSemaphore
private static final Logger	logger
private static final io.netty.util.AsciiString	SCHEME
static final 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(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 Object

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

Field Details

logger

private static final Logger logger

ALTS_MAX_CONCURRENT_HANDSHAKES_ENV_VARIABLE

static final 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<Object> AUTH_CONTEXT_KEY

SCHEME

private static final io.netty.util.AsciiString SCHEME

DIRECT_PATH_SERVICE_CFE_CLUSTER_PREFIX

private static final String DIRECT_PATH_SERVICE_CFE_CLUSTER_PREFIX

See Also:

• Constant Field Values

CFE_CLUSTER_RESOURCE_NAME_PREFIX

private static final String CFE_CLUSTER_RESOURCE_NAME_PREFIX

See Also:

• Constant Field Values

CFE_CLUSTER_AUTHORITY_NAME

private static final String CFE_CLUSTER_AUTHORITY_NAME

See Also:

• Constant Field Values

Constructor Details

AltsProtocolNegotiator

private AltsProtocolNegotiator()

Method Details

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

getAltsMaxConcurrentHandshakes

private static int getAltsMaxConcurrentHandshakes()