Uses of Class
io.grpc.Attributes
-
Packages that use Attributes Package Description io.grpc The gRPC core public API.io.grpc.grpclb io.grpc.inprocess The in-process transport which is for when a server is in the same process as the client.io.grpc.internal Interfaces and implementations that are internal to gRPC.io.grpc.netty The main transport implementation based on Netty, for both the client and the server.io.grpc.protobuf.services Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.io.grpc.rls io.grpc.servlet API that implements gRPC server as a servlet.io.grpc.servlet.jakarta API that implements gRPC server as a servlet.io.grpc.util Utilities with advanced features in the core layer that user can optionally use. -
-
Uses of Attributes in io.grpc
Fields in io.grpc declared as Attributes Modifier and Type Field Description private AttributesLoadBalancer.ResolvedAddresses. attributesprivate AttributesLoadBalancer.ResolvedAddresses.Builder. attributesprivate AttributesNameResolver.ResolutionResult. attributesprivate AttributesNameResolver.ResolutionResult.Builder. attributesprivate AttributesEquivalentAddressGroup. attrsprivate AttributesLoadBalancer.CreateSubchannelArgs. attrsprivate AttributesLoadBalancer.CreateSubchannelArgs.Builder. attrsprivate AttributesAttributes.Builder. basestatic AttributesAttributes. EMPTYMethods in io.grpc that return Attributes Modifier and Type Method Description AttributesAttributes.Builder. build()Build the attributes.AttributesClientCall. getAttributes()Returns additional properties of the call.AttributesEquivalentAddressGroup. getAttributes()Returns the attributes.AttributesLoadBalancer.CreateSubchannelArgs. getAttributes()Returns the attributes.AttributesLoadBalancer.ResolvedAddresses. getAttributes()Gets the attributes associated with these addresses.abstract AttributesLoadBalancer.Subchannel. getAttributes()The same attributes passed toHelper.createSubchannel().AttributesNameResolver.ResolutionResult. getAttributes()Gets the attributes associated with the addresses resolved by name resolution.AttributesPartialForwardingClientCall. getAttributes()AttributesPartialForwardingServerCall. getAttributes()AttributesServerCall. getAttributes()Returns properties of a single call.AttributesServerStreamTracer.ReadOnlyServerCall. getAttributes()Deprecated.abstract AttributesServerStreamTracer.ServerCallInfo. getAttributes()AttributesInternalSubchannelAddressAttributes. getConnectedAddressAttributes()Return attributes of the server address connected by sub channel.AttributesLoadBalancer.Subchannel. getConnectedAddressAttributes()(Internal use only) returns attributes of the address subchannel is connected to.abstract AttributesCallCredentials.RequestInfo. getTransportAttrs()Returns the transport attributes.AttributesClientTransportFilter. transportReady(Attributes transportAttrs)Called when a transport is ready to accept traffic (when a connection has been established).AttributesServerTransportFilter. transportReady(Attributes transportAttrs)Called when a transport is ready to process streams.Methods in io.grpc with parameters of type Attributes Modifier and Type Method Description static Attributes.BuilderAttributes. newBuilder(Attributes base)Deprecated.UsetoBuilder()on theAttributesinstance instead.voidNameResolver.Listener. onAddresses(java.util.List<EquivalentAddressGroup> servers, Attributes attributes)Handles updates on resolved addresses and attributes.voidNameResolver.Listener2. onAddresses(java.util.List<EquivalentAddressGroup> servers, Attributes attributes)Deprecated.This will be removed in 1.22.0Attributes.BuilderAttributes.Builder. setAll(Attributes other)LoadBalancer.CreateSubchannelArgs.BuilderLoadBalancer.CreateSubchannelArgs.Builder. setAttributes(Attributes attrs)Attributes provided here will be included inLoadBalancer.Subchannel.getAttributes().LoadBalancer.ResolvedAddresses.BuilderLoadBalancer.ResolvedAddresses.Builder. setAttributes(Attributes attributes)Sets the attributes.NameResolver.ResolutionResult.BuilderNameResolver.ResolutionResult.Builder. setAttributes(Attributes attributes)Sets the attributes for the addresses resolved by name resolution.voidClientStreamTracer. streamCreated(Attributes transportAttrs, Metadata headers)The stream is being created on a ready transport.AttributesClientTransportFilter. transportReady(Attributes transportAttrs)Called when a transport is ready to accept traffic (when a connection has been established).AttributesServerTransportFilter. transportReady(Attributes transportAttrs)Called when a transport is ready to process streams.voidClientTransportFilter. transportTerminated(Attributes transportAttrs)Called when a transport completed shutting down.voidServerTransportFilter. transportTerminated(Attributes transportAttrs)Called when a transport is terminated.Constructors in io.grpc with parameters of type Attributes Constructor Description Builder(Attributes base)CreateSubchannelArgs(java.util.List<EquivalentAddressGroup> addrs, Attributes attrs, java.lang.Object[][] customOptions)EquivalentAddressGroup(java.net.SocketAddress addr, Attributes attrs)Singleton constructor with Attributes.EquivalentAddressGroup(java.util.List<java.net.SocketAddress> addrs, Attributes attrs)List constructor withAttributes.ResolutionResult(StatusOr<java.util.List<EquivalentAddressGroup>> addressesOrError, Attributes attributes, NameResolver.ConfigOrError serviceConfig)ResolvedAddresses(java.util.List<EquivalentAddressGroup> addresses, Attributes attributes, java.lang.Object loadBalancingPolicyConfig) -
Uses of Attributes in io.grpc.grpclb
Fields in io.grpc.grpclb declared as Attributes Modifier and Type Field Description private static AttributesGrpclbState. LB_PROVIDED_BACKEND_ATTRSMethods in io.grpc.grpclb that return Attributes Modifier and Type Method Description private static AttributesGrpclbState. createSubchannelAttrs()Methods in io.grpc.grpclb with parameters of type Attributes Modifier and Type Method Description LoadBalancer.SubchannelCachedSubchannelPool. takeOrCreateSubchannel(EquivalentAddressGroup eag, Attributes defaultAttributes)LoadBalancer.SubchannelSubchannelPool. takeOrCreateSubchannel(EquivalentAddressGroup eag, Attributes defaultAttributes)Takes aLoadBalancer.Subchannelfrom the pool for the giveneagif there is one available. -
Uses of Attributes in io.grpc.inprocess
Fields in io.grpc.inprocess declared as Attributes Modifier and Type Field Description private AttributesInProcessTransport. attributesprivate AttributesInProcessTransport. serverStreamAttributesMethods in io.grpc.inprocess that return Attributes Modifier and Type Method Description AttributesInProcessTransport. getAttributes()AttributesInProcessTransport.InProcessStream.InProcessClientStream. getAttributes()AttributesInProcessTransport.InProcessStream.InProcessServerStream. getAttributes()Constructors in io.grpc.inprocess with parameters of type Attributes Constructor Description InProcessTransport(java.net.SocketAddress address, int maxInboundMetadataSize, java.lang.String authority, java.lang.String userAgent, Attributes eagAttrs, boolean includeCauseWithStatus, long assumedMessageSize) -
Uses of Attributes in io.grpc.internal
Fields in io.grpc.internal declared as Attributes Modifier and Type Field Description AttributesDnsNameResolver.InternalResolutionResult. attributesprivate AttributesServerCallInfoImpl. attributesprivate AttributesServerImpl.ServerTransportListenerImpl. attributesprivate AttributesInternalSubchannel. connectedAddressAttributesprivate AttributesClientTransportFactory.ClientTransportOptions. eagAttributesFields in io.grpc.internal with type parameters of type Attributes Modifier and Type Field Description static Attributes.Key<Attributes>GrpcAttributes. ATTR_CLIENT_EAG_ATTRSAttribute key for the attributes of theEquivalentAddressGroup(EquivalentAddressGroup.getAttributes()) that the transport's server address is from.Methods in io.grpc.internal that return Attributes Modifier and Type Method Description AttributesInternalSubchannel.TransportListener. filterTransport(Attributes attributes)AttributesManagedChannelImpl.DelayedTransportListener. filterTransport(Attributes attributes)default AttributesManagedClientTransport.Listener. filterTransport(Attributes attributes)Called just beforeManagedClientTransport.Listener.transportReady()to allow direct modification of transport Attributes.AttributesAbstractServerStream. getAttributes()AttributesClientCallImpl. getAttributes()AttributesClientStream. getAttributes()Attributes that the stream holds at the current moment.AttributesConnectionClientTransport. getAttributes()Returns a set of attributes, which may vary depending on the state of the transport.AttributesDelayedClientCall. getAttributes()AttributesDelayedStream. getAttributes()AttributesForwardingClientStream. getAttributes()AttributesForwardingConnectionClientTransport. getAttributes()AttributesManagedChannelImpl.SubchannelImpl. getAttributes()AttributesNoopClientStream. getAttributes()AttributesRetriableStream. getAttributes()AttributesServerCallImpl. getAttributes()AttributesServerCallInfoImpl. getAttributes()AttributesServerStream. getAttributes()Attributes describing stream.AttributesInternalSubchannel. getConnectedAddressAttributes()Return attributes for server address connected by sub channel.AttributesManagedChannelImpl.SubchannelImpl. getConnectedAddressAttributes()AttributesInternalSubchannel.Index. getCurrentEagAttributes()AttributesPickFirstLeafLoadBalancer.Index. getCurrentEagAttributes()AttributesClientTransportFactory.ClientTransportOptions. getEagAttributes()AttributesServerImpl.ServerTransportListenerImpl. transportReady(Attributes attributes)AttributesServerTransportListener. transportReady(Attributes attributes)The transport has finished all handshakes and is ready to process streams.Methods in io.grpc.internal with parameters of type Attributes Modifier and Type Method Description private PickFirstLeafLoadBalancer.SubchannelDataPickFirstLeafLoadBalancer. createNewSubchannel(java.net.SocketAddress addr, Attributes attrs)AttributesInternalSubchannel.TransportListener. filterTransport(Attributes attributes)AttributesManagedChannelImpl.DelayedTransportListener. filterTransport(Attributes attributes)default AttributesManagedClientTransport.Listener. filterTransport(Attributes attributes)Called just beforeManagedClientTransport.Listener.transportReady()to allow direct modification of transport Attributes.static StatsTraceContextStatsTraceContext. newClientContext(ClientStreamTracer[] tracers, Attributes transportAtts, Metadata headers)Factory method for the client-side.ClientTransportFactory.ClientTransportOptionsClientTransportFactory.ClientTransportOptions. setEagAttributes(Attributes eagAttributes)Sets the non-null EquivalentAddressGroup's attributes.voidForwardingClientStreamTracer. streamCreated(Attributes transportAttrs, Metadata headers)AttributesServerImpl.ServerTransportListenerImpl. transportReady(Attributes attributes)AttributesServerTransportListener. transportReady(Attributes attributes)The transport has finished all handshakes and is ready to process streams.Constructors in io.grpc.internal with parameters of type Attributes Constructor Description ServerCallInfoImpl(MethodDescriptor<ReqT,RespT> methodDescriptor, Attributes attributes, java.lang.String authority) -
Uses of Attributes in io.grpc.netty
Fields in io.grpc.netty declared as Attributes Modifier and Type Field Description private AttributesNettyClientHandler. attributesprivate AttributesNettyServerHandler. attributesCompleted attributes produced by transportReady.private AttributesNettyServerStream. attributesprivate AttributesProtocolNegotiationEvent. attributesprivate AttributesNettyClientHandler. eagAttributesprivate AttributesNettyClientTransport. eagAttributesprivate AttributesNettyServer. eagAttributesprivate AttributesNettyServerBuilder. eagAttributesprivate AttributesNettyServerHandler. eagAttributesprivate AttributesNettyServerTransport. eagAttributesprivate AttributesNettyServerHandler. negotiationAttributesIncomplete attributes produced by negotiator.Methods in io.grpc.netty that return Attributes Modifier and Type Method Description AttributesClientTransportLifecycleManager. filterAttributes(Attributes attributes)static AttributesInternalProtocolNegotiationEvent. getAttributes(ProtocolNegotiationEvent event)(package private) AttributesNettyClientHandler. getAttributes()The protocol negotiation attributes, available once the protocol negotiation completes; otherwise returnsAttributes.EMPTY.AttributesNettyClientStream. getAttributes()AttributesNettyClientTransport. getAttributes()AttributesNettyServerStream. getAttributes()(package private) AttributesProtocolNegotiationEvent. getAttributes()AttributesGrpcHttp2ConnectionHandler. getEagAttributes()Get the attributes of the EquivalentAddressGroup used to create this transport.AttributesNettyClientHandler. getEagAttributes()AttributesNettyServerHandler. getEagAttributes()Methods in io.grpc.netty with parameters of type Attributes Modifier and Type Method Description java.net.SocketAddressNettyChannelBuilder.LocalSocketPicker. createSocketAddress(java.net.SocketAddress remoteAddress, Attributes attrs)Called by gRPC to pick local socket to bind to.static voidInternalNettyServerBuilder. eagAttributes(NettyServerBuilder builder, Attributes eagAttributes)Sets the EAG attributes available to protocol negotiators.(package private) voidNettyServerBuilder. eagAttributes(Attributes eagAttributes)Sets the EAG attributes available to protocol negotiators.AttributesClientTransportLifecycleManager. filterAttributes(Attributes attributes)voidGrpcHttp2ConnectionHandler. handleProtocolNegotiationCompleted(Attributes attrs)Deprecated.Use the two argument method instead.voidGrpcHttp2ConnectionHandler. handleProtocolNegotiationCompleted(Attributes attrs, InternalChannelz.Security securityInfo)Triggered on protocol negotiation completion.voidNettyClientHandler. handleProtocolNegotiationCompleted(Attributes attributes, InternalChannelz.Security securityInfo)voidNettyServerHandler. handleProtocolNegotiationCompleted(Attributes attrs, InternalChannelz.Security securityInfo)(package private) static NettyClientHandlerNettyClientHandler. newHandler(ClientTransportLifecycleManager lifecycleManager, KeepAliveManager keepAliveManager, boolean autoFlowControl, int flowControlWindow, int maxHeaderListSize, com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchFactory, java.lang.Runnable tooManyPingsRunnable, TransportTracer transportTracer, Attributes eagAttributes, java.lang.String authority, ChannelLogger negotiationLogger, com.google.common.base.Ticker ticker)(package private) static NettyClientHandlerNettyClientHandler. newHandler(io.netty.handler.codec.http2.Http2Connection connection, io.netty.handler.codec.http2.Http2FrameReader frameReader, io.netty.handler.codec.http2.Http2FrameWriter frameWriter, ClientTransportLifecycleManager lifecycleManager, KeepAliveManager keepAliveManager, boolean autoFlowControl, int flowControlWindow, int maxHeaderListSize, com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchFactory, java.lang.Runnable tooManyPingsRunnable, TransportTracer transportTracer, Attributes eagAttributes, java.lang.String authority, ChannelLogger negotiationLogger, com.google.common.base.Ticker ticker)(package private) static NettyServerHandlerNettyServerHandler. newHandler(ServerTransportListener transportListener, io.netty.channel.ChannelPromise channelUnused, java.util.List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer transportTracer, int maxStreams, boolean autoFlowControl, int flowControlWindow, int maxHeaderListSize, int maxMessageSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, boolean permitKeepAliveWithoutCalls, long permitKeepAliveTimeInNanos, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes)(package private) static NettyServerHandlerNettyServerHandler. newHandler(io.netty.channel.ChannelPromise channelUnused, io.netty.handler.codec.http2.Http2FrameReader frameReader, io.netty.handler.codec.http2.Http2FrameWriter frameWriter, ServerTransportListener transportListener, java.util.List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer transportTracer, int maxStreams, boolean autoFlowControl, int flowControlWindow, int maxHeaderListSize, int maxMessageSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, boolean permitKeepAliveWithoutCalls, long permitKeepAliveTimeInNanos, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes, com.google.common.base.Ticker ticker)static ProtocolNegotiationEventInternalProtocolNegotiationEvent. withAttributes(ProtocolNegotiationEvent event, Attributes attributes)(package private) ProtocolNegotiationEventProtocolNegotiationEvent. withAttributes(Attributes attributes)Constructors in io.grpc.netty with parameters of type Attributes Constructor Description NettyClientHandler(io.netty.handler.codec.http2.Http2ConnectionDecoder decoder, io.netty.handler.codec.http2.Http2ConnectionEncoder encoder, io.netty.handler.codec.http2.Http2Settings settings, ChannelLogger negotiationLogger, ClientTransportLifecycleManager lifecycleManager, KeepAliveManager keepAliveManager, com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchFactory, java.lang.Runnable tooManyPingsRunnable, TransportTracer transportTracer, Attributes eagAttributes, java.lang.String authority, boolean autoFlowControl, AbstractNettyHandler.PingLimiter pingLimiter, com.google.common.base.Ticker ticker)NettyClientTransport(java.net.SocketAddress address, io.netty.channel.ChannelFactory<? extends io.netty.channel.Channel> channelFactory, java.util.Map<io.netty.channel.ChannelOption<?>,?> channelOptions, io.netty.channel.EventLoopGroup group, ProtocolNegotiator negotiator, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeNanos, long keepAliveTimeoutNanos, boolean keepAliveWithoutCalls, java.lang.String authority, java.lang.String userAgent, java.lang.Runnable tooManyPingsRunnable, TransportTracer transportTracer, Attributes eagAttributes, NettyChannelBuilder.LocalSocketPicker localSocketPicker, ChannelLogger channelLogger, boolean useGetForSafeMethods, com.google.common.base.Ticker ticker)NettyServer(java.util.List<? extends java.net.SocketAddress> addresses, io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> channelFactory, java.util.Map<io.netty.channel.ChannelOption<?>,?> channelOptions, java.util.Map<io.netty.channel.ChannelOption<?>,?> childChannelOptions, ObjectPool<? extends io.netty.channel.EventLoopGroup> bossGroupPool, ObjectPool<? extends io.netty.channel.EventLoopGroup> workerGroupPool, boolean forceHeapBuffer, ProtocolNegotiator protocolNegotiator, java.util.List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer.Factory transportTracerFactory, int maxStreamsPerConnection, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, boolean permitKeepAliveWithoutCalls, long permitKeepAliveTimeInNanos, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes, InternalChannelz channelz)NettyServerHandler(io.netty.channel.ChannelPromise channelUnused, io.netty.handler.codec.http2.Http2Connection connection, ServerTransportListener transportListener, java.util.List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer transportTracer, io.netty.handler.codec.http2.Http2ConnectionDecoder decoder, io.netty.handler.codec.http2.Http2ConnectionEncoder encoder, io.netty.handler.codec.http2.Http2Settings settings, int maxMessageSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, KeepAliveEnforcer keepAliveEnforcer, boolean autoFlowControl, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes, com.google.common.base.Ticker ticker)NettyServerStream(io.netty.channel.Channel channel, NettyServerStream.TransportState state, Attributes transportAttrs, java.lang.String authority, StatsTraceContext statsTraceCtx)NettyServerTransport(io.netty.channel.Channel channel, io.netty.channel.ChannelPromise channelUnused, ProtocolNegotiator protocolNegotiator, java.util.List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer transportTracer, int maxStreams, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, boolean permitKeepAliveWithoutCalls, long permitKeepAliveTimeInNanos, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes)ProtocolNegotiationEvent(Attributes attributes, InternalChannelz.Security security) -
Uses of Attributes in io.grpc.protobuf.services
Methods in io.grpc.protobuf.services with parameters of type Attributes Modifier and Type Method Description (package private) static java.net.SocketAddressBinlogHelper. getPeerSocket(Attributes streamAttributes) -
Uses of Attributes in io.grpc.rls
Fields in io.grpc.rls declared as Attributes Modifier and Type Field Description private AttributesChildLbResolvedAddressFactory. attributesConstructors in io.grpc.rls with parameters of type Attributes Constructor Description ChildLbResolvedAddressFactory(java.util.List<EquivalentAddressGroup> addresses, Attributes attributes) -
Uses of Attributes in io.grpc.servlet
Fields in io.grpc.servlet declared as Attributes Modifier and Type Field Description private AttributesServletAdapter. attributesprivate AttributesServletServerStream. attributesMethods in io.grpc.servlet that return Attributes Modifier and Type Method Description AttributesServletServerStream. getAttributes()Constructors in io.grpc.servlet with parameters of type Attributes Constructor Description ServletServerStream(javax.servlet.AsyncContext asyncCtx, StatsTraceContext statsTraceCtx, int maxInboundMessageSize, Attributes attributes, java.lang.String authority, InternalLogId logId) -
Uses of Attributes in io.grpc.servlet.jakarta
Fields in io.grpc.servlet.jakarta declared as Attributes Modifier and Type Field Description private AttributesServletAdapter. attributesprivate AttributesServletServerStream. attributesMethods in io.grpc.servlet.jakarta that return Attributes Modifier and Type Method Description AttributesServletServerStream. getAttributes()Constructors in io.grpc.servlet.jakarta with parameters of type Attributes Constructor Description ServletServerStream(jakarta.servlet.AsyncContext asyncCtx, StatsTraceContext statsTraceCtx, int maxInboundMessageSize, Attributes attributes, java.lang.String authority, InternalLogId logId) -
Uses of Attributes in io.grpc.util
Methods in io.grpc.util that return Attributes Modifier and Type Method Description AttributesForwardingSubchannel. getAttributes()AttributesHealthProducerHelper.HealthProducerSubchannel. getAttributes()AttributesOutlierDetectionLoadBalancer.OutlierDetectionSubchannel. getAttributes()AttributesTransmitStatusRuntimeExceptionInterceptor.SerializingServerCall. getAttributes()AttributesForwardingSubchannel. getConnectedAddressAttributes()Methods in io.grpc.util with parameters of type Attributes Modifier and Type Method Description voidForwardingClientStreamTracer. streamCreated(Attributes transportAttrs, Metadata headers)
-