Class 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.
    • 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()