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 Attributes
LoadBalancer.ResolvedAddresses. attributes
private Attributes
LoadBalancer.ResolvedAddresses.Builder. attributes
private Attributes
NameResolver.ResolutionResult. attributes
private Attributes
NameResolver.ResolutionResult.Builder. attributes
private Attributes
EquivalentAddressGroup. attrs
private Attributes
LoadBalancer.CreateSubchannelArgs. attrs
private Attributes
LoadBalancer.CreateSubchannelArgs.Builder. attrs
private Attributes
Attributes.Builder. base
static Attributes
Attributes. EMPTY
Methods in io.grpc that return Attributes Modifier and Type Method Description Attributes
Attributes.Builder. build()
Build the attributes.Attributes
ClientCall. getAttributes()
Returns additional properties of the call.Attributes
EquivalentAddressGroup. getAttributes()
Returns the attributes.Attributes
LoadBalancer.CreateSubchannelArgs. getAttributes()
Returns the attributes.Attributes
LoadBalancer.ResolvedAddresses. getAttributes()
Gets the attributes associated with these addresses.abstract Attributes
LoadBalancer.Subchannel. getAttributes()
The same attributes passed toHelper.createSubchannel()
.Attributes
NameResolver.ResolutionResult. getAttributes()
Gets the attributes associated with the addresses resolved by name resolution.Attributes
PartialForwardingClientCall. getAttributes()
Attributes
PartialForwardingServerCall. getAttributes()
Attributes
ServerCall. getAttributes()
Returns properties of a single call.Attributes
ServerStreamTracer.ReadOnlyServerCall. getAttributes()
Deprecated.abstract Attributes
ServerStreamTracer.ServerCallInfo. getAttributes()
Attributes
InternalSubchannelAddressAttributes. getConnectedAddressAttributes()
Return attributes of the server address connected by sub channel.Attributes
LoadBalancer.Subchannel. getConnectedAddressAttributes()
(Internal use only) returns attributes of the address subchannel is connected to.abstract Attributes
CallCredentials.RequestInfo. getTransportAttrs()
Returns the transport attributes.Attributes
ClientTransportFilter. transportReady(Attributes transportAttrs)
Called when a transport is ready to accept traffic (when a connection has been established).Attributes
ServerTransportFilter. 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.Builder
Attributes. newBuilder(Attributes base)
Deprecated.UsetoBuilder()
on theAttributes
instance instead.void
NameResolver.Listener. onAddresses(java.util.List<EquivalentAddressGroup> servers, Attributes attributes)
Handles updates on resolved addresses and attributes.void
NameResolver.Listener2. onAddresses(java.util.List<EquivalentAddressGroup> servers, Attributes attributes)
Deprecated.This will be removed in 1.22.0Attributes.Builder
Attributes.Builder. setAll(Attributes other)
LoadBalancer.CreateSubchannelArgs.Builder
LoadBalancer.CreateSubchannelArgs.Builder. setAttributes(Attributes attrs)
Attributes provided here will be included inLoadBalancer.Subchannel.getAttributes()
.LoadBalancer.ResolvedAddresses.Builder
LoadBalancer.ResolvedAddresses.Builder. setAttributes(Attributes attributes)
Sets the attributes.NameResolver.ResolutionResult.Builder
NameResolver.ResolutionResult.Builder. setAttributes(Attributes attributes)
Sets the attributes for the addresses resolved by name resolution.void
ClientStreamTracer. streamCreated(Attributes transportAttrs, Metadata headers)
The stream is being created on a ready transport.Attributes
ClientTransportFilter. transportReady(Attributes transportAttrs)
Called when a transport is ready to accept traffic (when a connection has been established).Attributes
ServerTransportFilter. transportReady(Attributes transportAttrs)
Called when a transport is ready to process streams.void
ClientTransportFilter. transportTerminated(Attributes transportAttrs)
Called when a transport completed shutting down.void
ServerTransportFilter. 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 Attributes
GrpclbState. LB_PROVIDED_BACKEND_ATTRS
Methods in io.grpc.grpclb that return Attributes Modifier and Type Method Description private static Attributes
GrpclbState. createSubchannelAttrs()
Methods in io.grpc.grpclb with parameters of type Attributes Modifier and Type Method Description LoadBalancer.Subchannel
CachedSubchannelPool. takeOrCreateSubchannel(EquivalentAddressGroup eag, Attributes defaultAttributes)
LoadBalancer.Subchannel
SubchannelPool. takeOrCreateSubchannel(EquivalentAddressGroup eag, Attributes defaultAttributes)
Takes aLoadBalancer.Subchannel
from the pool for the giveneag
if 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 Attributes
InProcessTransport. attributes
private Attributes
InProcessTransport. serverStreamAttributes
Methods in io.grpc.inprocess that return Attributes Modifier and Type Method Description Attributes
InProcessTransport. getAttributes()
Attributes
InProcessTransport.InProcessStream.InProcessClientStream. getAttributes()
Attributes
InProcessTransport.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 Attributes
DnsNameResolver.InternalResolutionResult. attributes
private Attributes
ServerCallInfoImpl. attributes
private Attributes
ServerImpl.ServerTransportListenerImpl. attributes
private Attributes
InternalSubchannel. connectedAddressAttributes
private Attributes
ClientTransportFactory.ClientTransportOptions. eagAttributes
Fields in io.grpc.internal with type parameters of type Attributes Modifier and Type Field Description static Attributes.Key<Attributes>
GrpcAttributes. ATTR_CLIENT_EAG_ATTRS
Attribute 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 Attributes
InternalSubchannel.TransportListener. filterTransport(Attributes attributes)
Attributes
ManagedChannelImpl.DelayedTransportListener. filterTransport(Attributes attributes)
default Attributes
ManagedClientTransport.Listener. filterTransport(Attributes attributes)
Called just beforeManagedClientTransport.Listener.transportReady()
to allow direct modification of transport Attributes.Attributes
AbstractServerStream. getAttributes()
Attributes
ClientCallImpl. getAttributes()
Attributes
ClientStream. getAttributes()
Attributes that the stream holds at the current moment.Attributes
ConnectionClientTransport. getAttributes()
Returns a set of attributes, which may vary depending on the state of the transport.Attributes
DelayedClientCall. getAttributes()
Attributes
DelayedStream. getAttributes()
Attributes
ForwardingClientStream. getAttributes()
Attributes
ForwardingConnectionClientTransport. getAttributes()
Attributes
ManagedChannelImpl.SubchannelImpl. getAttributes()
Attributes
NoopClientStream. getAttributes()
Attributes
RetriableStream. getAttributes()
Attributes
ServerCallImpl. getAttributes()
Attributes
ServerCallInfoImpl. getAttributes()
Attributes
ServerStream. getAttributes()
Attributes describing stream.Attributes
InternalSubchannel. getConnectedAddressAttributes()
Return attributes for server address connected by sub channel.Attributes
ManagedChannelImpl.SubchannelImpl. getConnectedAddressAttributes()
Attributes
InternalSubchannel.Index. getCurrentEagAttributes()
Attributes
PickFirstLeafLoadBalancer.Index. getCurrentEagAttributes()
Attributes
ClientTransportFactory.ClientTransportOptions. getEagAttributes()
Attributes
ServerImpl.ServerTransportListenerImpl. transportReady(Attributes attributes)
Attributes
ServerTransportListener. 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.SubchannelData
PickFirstLeafLoadBalancer. createNewSubchannel(java.net.SocketAddress addr, Attributes attrs)
Attributes
InternalSubchannel.TransportListener. filterTransport(Attributes attributes)
Attributes
ManagedChannelImpl.DelayedTransportListener. filterTransport(Attributes attributes)
default Attributes
ManagedClientTransport.Listener. filterTransport(Attributes attributes)
Called just beforeManagedClientTransport.Listener.transportReady()
to allow direct modification of transport Attributes.static StatsTraceContext
StatsTraceContext. newClientContext(ClientStreamTracer[] tracers, Attributes transportAtts, Metadata headers)
Factory method for the client-side.ClientTransportFactory.ClientTransportOptions
ClientTransportFactory.ClientTransportOptions. setEagAttributes(Attributes eagAttributes)
Sets the non-null EquivalentAddressGroup's attributes.void
ForwardingClientStreamTracer. streamCreated(Attributes transportAttrs, Metadata headers)
Attributes
ServerImpl.ServerTransportListenerImpl. transportReady(Attributes attributes)
Attributes
ServerTransportListener. 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 Attributes
NettyClientHandler. attributes
private Attributes
NettyServerHandler. attributes
Completed attributes produced by transportReady.private Attributes
NettyServerStream. attributes
private Attributes
ProtocolNegotiationEvent. attributes
private Attributes
NettyClientHandler. eagAttributes
private Attributes
NettyClientTransport. eagAttributes
private Attributes
NettyServer. eagAttributes
private Attributes
NettyServerBuilder. eagAttributes
private Attributes
NettyServerHandler. eagAttributes
private Attributes
NettyServerTransport. eagAttributes
private Attributes
NettyServerHandler. negotiationAttributes
Incomplete attributes produced by negotiator.Methods in io.grpc.netty that return Attributes Modifier and Type Method Description Attributes
ClientTransportLifecycleManager. filterAttributes(Attributes attributes)
static Attributes
InternalProtocolNegotiationEvent. getAttributes(ProtocolNegotiationEvent event)
(package private) Attributes
NettyClientHandler. getAttributes()
The protocol negotiation attributes, available once the protocol negotiation completes; otherwise returnsAttributes.EMPTY
.Attributes
NettyClientStream. getAttributes()
Attributes
NettyClientTransport. getAttributes()
Attributes
NettyServerStream. getAttributes()
(package private) Attributes
ProtocolNegotiationEvent. getAttributes()
Attributes
GrpcHttp2ConnectionHandler. getEagAttributes()
Get the attributes of the EquivalentAddressGroup used to create this transport.Attributes
NettyClientHandler. getEagAttributes()
Attributes
NettyServerHandler. getEagAttributes()
Methods in io.grpc.netty with parameters of type Attributes Modifier and Type Method Description java.net.SocketAddress
NettyChannelBuilder.LocalSocketPicker. createSocketAddress(java.net.SocketAddress remoteAddress, Attributes attrs)
Called by gRPC to pick local socket to bind to.static void
InternalNettyServerBuilder. eagAttributes(NettyServerBuilder builder, Attributes eagAttributes)
Sets the EAG attributes available to protocol negotiators.(package private) void
NettyServerBuilder. eagAttributes(Attributes eagAttributes)
Sets the EAG attributes available to protocol negotiators.Attributes
ClientTransportLifecycleManager. filterAttributes(Attributes attributes)
void
GrpcHttp2ConnectionHandler. handleProtocolNegotiationCompleted(Attributes attrs)
Deprecated.Use the two argument method instead.void
GrpcHttp2ConnectionHandler. handleProtocolNegotiationCompleted(Attributes attrs, InternalChannelz.Security securityInfo)
Triggered on protocol negotiation completion.void
NettyClientHandler. handleProtocolNegotiationCompleted(Attributes attributes, InternalChannelz.Security securityInfo)
void
NettyServerHandler. handleProtocolNegotiationCompleted(Attributes attrs, InternalChannelz.Security securityInfo)
(package private) static NettyClientHandler
NettyClientHandler. 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 NettyClientHandler
NettyClientHandler. 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 NettyServerHandler
NettyServerHandler. 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 NettyServerHandler
NettyServerHandler. 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 ProtocolNegotiationEvent
InternalProtocolNegotiationEvent. withAttributes(ProtocolNegotiationEvent event, Attributes attributes)
(package private) ProtocolNegotiationEvent
ProtocolNegotiationEvent. 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.SocketAddress
BinlogHelper. getPeerSocket(Attributes streamAttributes)
-
Uses of Attributes in io.grpc.rls
Fields in io.grpc.rls declared as Attributes Modifier and Type Field Description private Attributes
ChildLbResolvedAddressFactory. attributes
Constructors 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 Attributes
ServletAdapter. attributes
private Attributes
ServletServerStream. attributes
Methods in io.grpc.servlet that return Attributes Modifier and Type Method Description Attributes
ServletServerStream. 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 Attributes
ServletAdapter. attributes
private Attributes
ServletServerStream. attributes
Methods in io.grpc.servlet.jakarta that return Attributes Modifier and Type Method Description Attributes
ServletServerStream. 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 Attributes
ForwardingSubchannel. getAttributes()
Attributes
HealthProducerHelper.HealthProducerSubchannel. getAttributes()
Attributes
OutlierDetectionLoadBalancer.OutlierDetectionSubchannel. getAttributes()
Attributes
TransmitStatusRuntimeExceptionInterceptor.SerializingServerCall. getAttributes()
Attributes
ForwardingSubchannel. getConnectedAddressAttributes()
Methods in io.grpc.util with parameters of type Attributes Modifier and Type Method Description void
ForwardingClientStreamTracer. streamCreated(Attributes transportAttrs, Metadata headers)
-