Uses of Class
io.grpc.Metadata
Packages that use Metadata
Package
Description
The gRPC core public API.
The in-process transport which is for when a server is in the same process as the client.
Interfaces and implementations that are internal to gRPC.
The main transport implementation based on Netty,
for both the client and the server.
API for gRPC over Protocol Buffers, including tools for serializing and de-serializing protobuf
messages.
Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.
API that implements gRPC server as a servlet.
API that implements gRPC server as a servlet.
API for the Stub layer.
Utilities with advanced features in the core layer that user can optionally use.
-
Uses of Metadata in io.grpc
Modifier and TypeFieldDescriptionprivate final MetadataCompositeCallCredentials.CombiningMetadataApplier.firstHeadersprivate final MetadataStatusException.trailersprivate final MetadataStatusRuntimeException.trailersModifier and TypeMethodDescriptionabstract MetadataLoadBalancer.PickSubchannelArgs.getHeaders()Headers of the call.final MetadataStatusException.getTrailers()Returns the received trailers.final MetadataStatusRuntimeException.getTrailers()Returns the received trailers.static MetadataInternalMetadata.newMetadata(byte[]... binaryValues) static MetadataInternalMetadata.newMetadata(int usedNames, byte[]... binaryValues) static MetadataInternalMetadata.newMetadataWithParsedValues(int usedNames, Object[] namesAndValues) Creates a newMetadatainstance from serialized data, with some values pre-parsed.static MetadataStatus.trailersFromThrowable(Throwable t) Extract an error trailers from the causal chain of aThrowable.Modifier and TypeMethodDescriptionabstract voidCalled when headers are successfully generated.voidvoidStatus.asException(Metadata trailers) Same asStatus.asException()but includes the provided trailers in the returned exception.static final StatusRuntimeExceptionInternalStatus.asRuntimeException(Status status, Metadata trailers, boolean fillInStackTrace) Create a newStatusRuntimeExceptionwith the internal option of skipping the filling of the stack trace.Status.asRuntimeException(Metadata trailers) Same asStatus.asRuntimeException()but includes the provided trailers in the returned exception.protected abstract voidClientInterceptors.CheckedForwardingClientCall.checkedStart(ClientCall.Listener<RespT> responseListener, Metadata headers) Subclasses implement the start logic here that would normally belong tostart().voidabstract voidClose the call with the provided status.<ReqT,RespT>
ExecutorServerCallExecutorSupplier.getExecutor(ServerCall<ReqT, RespT> call, Metadata metadata) Returns an executor to handle the server call.static intInternalMetadata.headerCount(Metadata md) voidClientStreamTracer.inboundHeaders(Metadata headers) Headers has been received from the server.voidClientStreamTracer.inboundTrailers(Metadata trailers) Trailing metadata has been received from the server.static <ReqT,RespT>
ServerCall.Listener<ReqT> Contexts.interceptCall(Context context, ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) Make the providedContextContext.current()for the creation of a listener to a received call and for all events received by that listener.<ReqT,RespT>
ServerCall.Listener<ReqT> ServerInterceptor.interceptCall(ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) voidPerform a simple merge of two sets of metadata.voidMetadata.merge(Metadata other, Set<Metadata.Key<?>> keys) Merge values from the given set of keys into this set of metadata.ClientStreamTracer.Factory.newClientStreamTracer(ClientStreamTracer.StreamInfo info, Metadata headers) Creates aClientStreamTracerfor a new client stream.abstract ServerStreamTracerServerStreamTracer.Factory.newServerStreamTracer(String fullMethodName, Metadata headers) Creates aServerStreamTracerfor a new server stream.voidThe ClientCall has been closed.voidvoidThe response headers have been received.voidvoidPartialForwardingServerCall.sendHeaders(Metadata headers) abstract voidServerCall.sendHeaders(Metadata headers) Send response header metadata prior to sending a response message.static byte[][]static Object[]InternalMetadata.serializePartial(Metadata md) Serializes all metadata entries, leaving some values asInputStreams.abstract voidClientCall.start(ClientCall.Listener<RespT> responseListener, Metadata headers) Start a call, usingresponseListenerfor processing response messages.final voidClientInterceptors.CheckedForwardingClientCall.start(ClientCall.Listener<RespT> responseListener, Metadata headers) voidForwardingClientCall.start(ClientCall.Listener<RespT> responseListener, Metadata headers) ServerCallHandler.startCall(ServerCall<RequestT, ResponseT> call, Metadata headers) Starts asynchronous processing of an incoming call.ServerInterceptors.InterceptCallHandler.startCall(ServerCall<ReqT, RespT> call, Metadata headers) voidClientStreamTracer.streamCreated(Attributes transportAttrs, Metadata headers) The stream is being created on a ready transport.ModifierConstructorDescriptionCombiningMetadataApplier(CallCredentials.MetadataApplier delegate, Metadata firstHeaders) StatusException(Status status, Metadata trailers) Constructs an exception with both a status and trailers.(package private)StatusException(Status status, Metadata trailers, boolean fillInStackTrace) StatusRuntimeException(Status status, Metadata trailers) Constructs the exception with both a status and trailers.(package private)StatusRuntimeException(Status status, Metadata trailers, boolean fillInStackTrace) -
Uses of Metadata in io.grpc.grpclb
Methods in io.grpc.grpclb with parameters of type MetadataModifier and TypeMethodDescriptionGrpclbClientLoadRecorder.newClientStreamTracer(ClientStreamTracer.StreamInfo info, Metadata headers) TokenAttachingTracerFactory.newClientStreamTracer(ClientStreamTracer.StreamInfo info, Metadata headers) -
Uses of Metadata in io.grpc.inprocess
Fields in io.grpc.inprocess declared as MetadataModifier and TypeFieldDescriptionprivate MetadataInProcessTransport.InProcessStream.InProcessServerStream.clientNotifyTrailersprivate final MetadataInProcessTransport.InProcessStream.headersMethods in io.grpc.inprocess with parameters of type MetadataModifier and TypeMethodDescriptionvoidprivate static intInProcessTransport.metadataSize(Metadata metadata) InProcessTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) private voidInProcessTransport.InProcessStream.InProcessServerStream.notifyClientClose(Status status, Metadata trailers) clientStream.serverClosed() must be called before this methodvoidInProcessTransport.InProcessStream.InProcessServerStream.writeHeaders(Metadata headers, boolean flush) Constructors in io.grpc.inprocess with parameters of type MetadataModifierConstructorDescription(package private)InProcessServerStream(MethodDescriptor<?, ?> method, Metadata headers) privateInProcessStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, String authority, StatsTraceContext statsTraceContext) -
Uses of Metadata in io.grpc.internal
Fields in io.grpc.internal declared as MetadataModifier and TypeFieldDescriptionprivate MetadataAbstractClientStream.GetFramer.headersprivate MetadataAbstractClientStream.headersprivate final MetadataPickSubchannelArgsImpl.headersprivate final MetadataRetriableStream.headersprivate final MetadataRetriableStream.SavedCloseMasterListenerReason.metadataprivate final MetadataMetadataApplierImpl.origHeadersprivate MetadataHttp2ClientStreamTransportState.transportErrorMetadataMethods in io.grpc.internal that return MetadataModifier and TypeMethodDescriptionPickSubchannelArgsImpl.getHeaders()(package private) final MetadataRetriableStream.updateHeaders(Metadata originalHeaders, int previousAttemptCount) Adds grpc-previous-rpc-attempts in the headers of a retry/hedging RPC.Methods in io.grpc.internal with parameters of type MetadataModifier and TypeMethodDescriptionprivate voidAbstractServerStream.addStatusToTrailers(Metadata trailers, Status status) voidvoidStatsTraceContext.clientInboundHeaders(Metadata headers) voidStatsTraceContext.clientInboundTrailers(Metadata trailers) final voidvoidvoidCloses the stream for both reading and writing.voidClientCallImpl.ClientStreamListenerImpl.closed(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) voidClientStreamListener.closed(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) Called when the stream is fully closed.voidDelayedStream.DelayedStreamListener.closed(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) voidForwardingClientStreamListener.closed(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) voidRetriableStream.Sublistener.closed(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) private voidClientCallImpl.ClientStreamListenerImpl.closedInternal(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) private voidServerCallImpl.closeInternal(Status status, Metadata trailers) private voidAbstractClientStream.TransportState.closeListener(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) Closes the listener if not previously closed.private voidClientCallImpl.closeObserver(ClientCall.Listener<RespT> observer, Status status, Metadata trailers) private Context.CancellableContextServerImpl.ServerTransportListenerImpl.createContext(Metadata headers, StatsTraceContext statsTraceCtx) private static CharsetHttp2ClientStreamTransportState.extractCharset(Metadata headers) Inspect the raw metadata and figure out what charset is being used.static ClientStreamTracer[]GrpcUtil.getClientStreamTracers(CallOptions callOptions, Metadata headers, int previousAttempts, boolean isTransparentRetry) Gets stream tracers based on CallOptions.private IntegerRetriableStream.Sublistener.getPushbackMills(Metadata trailer) voidClientCallImpl.ClientStreamListenerImpl.headersRead(Metadata headers) voidClientStreamListener.headersRead(Metadata headers) Called upon receiving all header information from the remote end-point.voidDelayedStream.DelayedStreamListener.headersRead(Metadata headers) voidForwardingClientStreamListener.headersRead(Metadata headers) voidRetriableStream.Sublistener.headersRead(Metadata headers) protected abstract voidHttp2ClientStreamTransportState.http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers) Called to process a failure in HTTP/2 processing.voidForwardingClientStreamTracer.inboundHeaders(Metadata headers) protected voidAbstractClientStream.TransportState.inboundHeadersReceived(Metadata headers) Called by transport implementations when they receive headers.voidForwardingClientStreamTracer.inboundTrailers(Metadata trailers) protected voidAbstractClientStream.TransportState.inboundTrailersReceived(Metadata trailers, Status status) Processes the trailers and status from the server.private RetriableStream.HedgingPlanRetriableStream.Sublistener.makeHedgingDecision(Status status, Metadata trailer) private RetriableStream.RetryPlanRetriableStream.Sublistener.makeRetryDecision(Status status, Metadata trailer) Decides in current situation whether or not the RPC should retry and if it should retry how long the backoff should be.static StatsTraceContextStatsTraceContext.newClientContext(ClientStreamTracer[] tracers, Attributes transportAtts, Metadata headers) Factory method for the client-side.static StatsTraceContextStatsTraceContext.newServerContext(List<? extends ServerStreamTracer.Factory> factories, String fullMethodName, Metadata headers) Factory method for the server-side.CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) ClientCallImpl.ClientStreamProvider.newStream(MethodDescriptor<?, ?> method, CallOptions callOptions, Metadata headers, Context context) ClientTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) Creates a new stream for sending messages to a remote end-point.final ClientStreamDelayedClientTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) If aLoadBalancer.SubchannelPickeris being, or has been provided viaDelayedClientTransport.reprocess(io.grpc.LoadBalancer.SubchannelPicker), the last picker will be consulted.FailingClientTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) ForwardingConnectionClientTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) InternalSubchannel.CallTracingTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) ManagedChannelImpl.ChannelStreamProvider.newStream(MethodDescriptor<?, ?> method, CallOptions callOptions, Metadata headers, Context context) (package private) abstract ClientStreamRetriableStream.newSubstream(Metadata headers, ClientStreamTracer.Factory tracerFactory, int previousAttempts, boolean isTransparentRetry) Creates a new physical ClientStream that represents a retry/hedging attempt.voidvoid(package private) static voidClientCallImpl.prepareHeaders(Metadata headers, DecompressorRegistry decompressorRegistry, Compressor compressor, boolean fullStreamDecompression) private voidRetriableStream.safeCloseMasterListener(Status status, ClientStreamListener.RpcProgress progress, Metadata metadata) voidServerCallImpl.sendHeaders(Metadata headers) private voidServerCallImpl.sendHeadersInternal(Metadata headers) voidClientCallImpl.start(ClientCall.Listener<RespT> observer, Metadata headers) final voidDelayedClientCall.start(ClientCall.Listener<RespT> listener, Metadata headers) voidManagedChannelImpl.ConfigSelectingClientCall.start(ClientCall.Listener<RespT> observer, Metadata headers) private voidClientCallImpl.startInternal(ClientCall.Listener<RespT> observer, Metadata headers) private <WReqT,WRespT>
ServerStreamListenerServerImpl.ServerTransportListenerImpl.startWrappedCall(String fullMethodName, ServerImpl.ServerTransportListenerImpl.ServerCallParameters<WReqT, WRespT> params, Metadata headers) private StatusHttp2ClientStreamTransportState.statusFromTrailers(Metadata trailers) Extract the response status from trailers.voidForwardingClientStreamTracer.streamCreated(Attributes transportAttrs, Metadata headers) voidServerImpl.ServerTransportListenerImpl.streamCreated(ServerStream stream, String methodName, Metadata headers) voidServerTransportListener.streamCreated(ServerStream stream, String method, Metadata headers) Called when a new stream was created by the remote client.private voidServerImpl.ServerTransportListenerImpl.streamCreatedInternal(ServerStream stream, String methodName, Metadata headers, io.perfmark.Tag tag) private static voidHttp2ClientStreamTransportState.stripTransportDetails(Metadata metadata) Strip HTTP transport implementation details so they don't leak via metadata into the application layer.static byte[][]TransportFrameUtil.toHttp2Headers(Metadata headers) Transform the given headers to a format where only spec-compliant ASCII characters are allowed.protected voidHttp2ClientStreamTransportState.transportHeadersReceived(Metadata headers) Called by subclasses wheneverHeadersare received from the transport.final voidAbstractClientStream.TransportState.transportReportStatus(Status status, boolean stopDelivery, Metadata trailers) Report stream closure with status to the application layer if not already reported.final voidAbstractClientStream.TransportState.transportReportStatus(Status status, ClientStreamListener.RpcProgress rpcProgress, boolean stopDelivery, Metadata trailers) Report stream closure with status to the application layer if not already reported.protected voidHttp2ClientStreamTransportState.transportTrailersReceived(Metadata trailers) Called by subclasses for the terminal trailer metadata on a stream.(package private) final MetadataRetriableStream.updateHeaders(Metadata originalHeaders, int previousAttemptCount) Adds grpc-previous-rpc-attempts in the headers of a retry/hedging RPC.private StatusHttp2ClientStreamTransportState.validateInitialMetadata(Metadata headers) Inspect initial headers to make sure they conform to HTTP and gRPC, returning aStatuson failure.voidAbstractClientStream.Sink.writeHeaders(Metadata metadata, byte[] payload) Sends the request headers to the remote end point.voidAbstractServerStream.Sink.writeHeaders(Metadata headers, boolean flush) Sends response headers to the remote end point.final voidAbstractServerStream.writeHeaders(Metadata headers, boolean flush) voidServerStream.writeHeaders(Metadata headers, boolean flush) Writes custom metadata as headers on the response stream sent to the client.voidAbstractServerStream.Sink.writeTrailers(Metadata trailers, boolean headersSent, Status status) Sends trailers to the remote end point.Constructors in io.grpc.internal with parameters of type MetadataModifierConstructorDescriptionprotectedAbstractClientStream(WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, Metadata headers, CallOptions callOptions, boolean useGet) GetFramer(Metadata headers, StatsTraceContext statsTraceCtx) (package private)MetadataApplierImpl(ClientTransport transport, MethodDescriptor<?, ?> method, Metadata origHeaders, CallOptions callOptions, MetadataApplierImpl.MetadataApplierListener listener, ClientStreamTracer[] tracers) PickSubchannelArgsImpl(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, LoadBalancer.PickDetailsConsumer pickDetailsConsumer) Creates call args object for given method with its call options, metadata.(package private)RetriableStream(MethodDescriptor<ReqT, ?> method, Metadata headers, RetriableStream.ChannelBufferMeter channelBufferUsed, long perRpcBufferLimit, long channelBufferLimit, Executor callExecutor, ScheduledExecutorService scheduledExecutorService, RetryPolicy retryPolicy, HedgingPolicy hedgingPolicy, RetriableStream.Throttle throttle) (package private)SavedCloseMasterListenerReason(Status status, ClientStreamListener.RpcProgress progress, Metadata metadata) (package private)ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method, Metadata inboundHeaders, Context.CancellableContext context, DecompressorRegistry decompressorRegistry, CompressorRegistry compressorRegistry, CallTracer serverCallTracer, io.perfmark.Tag tag) -
Uses of Metadata in io.grpc.netty
Methods in io.grpc.netty that return MetadataModifier and TypeMethodDescriptionstatic MetadataUtils.convertHeaders(io.netty.handler.codec.http2.Http2Headers http2Headers) static MetadataUtils.convertTrailers(io.netty.handler.codec.http2.Http2Headers http2Headers) Methods in io.grpc.netty with parameters of type MetadataModifier and TypeMethodDescriptionstatic io.netty.handler.codec.http2.Http2HeadersUtils.convertClientHeaders(Metadata headers, io.netty.util.AsciiString scheme, io.netty.util.AsciiString defaultPath, io.netty.util.AsciiString authority, io.netty.util.AsciiString method, io.netty.util.AsciiString userAgent) static io.netty.handler.codec.http2.Http2HeadersUtils.convertServerHeaders(Metadata headers) static io.netty.handler.codec.http2.Http2HeadersUtils.convertTrailers(Metadata trailers, boolean headersSent) protected voidNettyClientStream.TransportState.http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers) NettyClientTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) voidNettyClientStream.Sink.writeHeaders(Metadata headers, byte[] requestPayload) voidNettyServerStream.Sink.writeHeaders(Metadata headers, boolean flush) private voidNettyClientStream.Sink.writeHeadersInternal(Metadata headers, byte[] requestPayload) voidNettyServerStream.Sink.writeTrailers(Metadata trailers, boolean headersSent, Status status) Constructors in io.grpc.netty with parameters of type MetadataModifierConstructorDescription(package private)NettyClientStream(NettyClientStream.TransportState state, MethodDescriptor<?, ?> method, Metadata headers, io.netty.channel.Channel channel, io.netty.util.AsciiString authority, io.netty.util.AsciiString scheme, io.netty.util.AsciiString userAgent, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions callOptions, boolean useGetForSafeMethods) -
Uses of Metadata in io.grpc.protobuf
Methods in io.grpc.protobuf that return MetadataModifier and TypeMethodDescriptionprivate static MetadataStatusProto.toMetadata(com.google.rpc.Status statusProto) private static MetadataStatusProto.toMetadata(com.google.rpc.Status statusProto, Metadata metadata) Methods in io.grpc.protobuf with parameters of type MetadataModifier and TypeMethodDescriptionstatic com.google.rpc.StatusStatusProto.fromStatusAndTrailers(Status status, Metadata trailers) Extracts thegoogle.rpc.Statusfrom trailers, and makes sure they match the gRPCstatus.private static MetadataStatusProto.toMetadata(com.google.rpc.Status statusProto, Metadata metadata) static StatusExceptionStatusProto.toStatusException(com.google.rpc.Status statusProto, Metadata metadata) Convert aStatusinstance to aStatusExceptionwith additional metadata.static StatusExceptionStatusProto.toStatusException(com.google.rpc.Status statusProto, Metadata metadata, Throwable cause) Convert aStatusinstance to aStatusExceptionwith additional metadata and the root exception thrown.static StatusRuntimeExceptionStatusProto.toStatusRuntimeException(com.google.rpc.Status statusProto, Metadata metadata) Convert aStatusinstance to aStatusRuntimeExceptionwith additional metadata. -
Uses of Metadata in io.grpc.protobuf.services
Methods in io.grpc.protobuf.services with parameters of type MetadataModifier and TypeMethodDescription(package private) static BinlogHelper.MaybeTruncated<Metadata.Builder> BinlogHelper.createMetadataProto(Metadata metadata, int maxHeaderBytes) (package private) abstract voidBinlogHelper.SinkWriter.logClientHeader(long seq, String methodName, String authority, com.google.protobuf.Duration timeout, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress) Logs the client header.(package private) voidBinlogHelper.SinkWriterImpl.logClientHeader(long seq, String methodName, String authority, com.google.protobuf.Duration timeout, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress) (package private) abstract voidBinlogHelper.SinkWriter.logServerHeader(long seq, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress) Logs the server header.(package private) voidBinlogHelper.SinkWriterImpl.logServerHeader(long seq, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress) (package private) abstract voidBinlogHelper.SinkWriter.logTrailer(long seq, Status status, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress) Logs the server trailer.(package private) voidBinlogHelper.SinkWriterImpl.logTrailer(long seq, Status status, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress) voidHealthCheckingLoadBalancerFactory.HealthCheckState.HcStream.onClose(Status status, Metadata trailers) -
Uses of Metadata in io.grpc.rls
Methods in io.grpc.rls with parameters of type MetadataModifier and TypeMethodDescription(package private) RlsProtoData.RouteLookupRequestCreates aRlsProtoData.RouteLookupRequestfor given request's metadata.RlsRequestFactory.createRequestHeaders(Metadata metadata, List<RlsProtoData.NameMatcher> keyBuilder) -
Uses of Metadata in io.grpc.servlet
Methods in io.grpc.servlet that return MetadataModifier and TypeMethodDescriptionprivate static MetadataServletAdapter.getHeaders(javax.servlet.http.HttpServletRequest req) Methods in io.grpc.servlet with parameters of type MetadataModifier and TypeMethodDescriptionvoidServletServerStream.Sink.writeHeaders(Metadata headers, boolean flush) private voidServletServerStream.writeHeadersToServletResponse(Metadata metadata) voidServletServerStream.Sink.writeTrailers(Metadata trailers, boolean headersSent, Status status) -
Uses of Metadata in io.grpc.servlet.jakarta
Methods in io.grpc.servlet.jakarta that return MetadataModifier and TypeMethodDescriptionprivate static MetadataServletAdapter.getHeaders(jakarta.servlet.http.HttpServletRequest req) Methods in io.grpc.servlet.jakarta with parameters of type MetadataModifier and TypeMethodDescriptionvoidServletServerStream.Sink.writeHeaders(Metadata headers, boolean flush) private voidServletServerStream.writeHeadersToServletResponse(Metadata metadata) voidServletServerStream.Sink.writeTrailers(Metadata trailers, boolean headersSent, Status status) -
Uses of Metadata in io.grpc.stub
Fields in io.grpc.stub declared as MetadataModifier and TypeFieldDescriptionprivate final MetadataMetadataUtils.HeaderAttachingClientInterceptor.extraHeadersprivate final MetadataMetadataUtils.MetadataAttachingServerInterceptor.extrasFields in io.grpc.stub with type parameters of type MetadataModifier and TypeFieldDescription(package private) final AtomicReference<Metadata> MetadataUtils.MetadataCapturingClientInterceptor.headersCapture(package private) final AtomicReference<Metadata> MetadataUtils.MetadataCapturingClientInterceptor.trailersCaptureMethods in io.grpc.stub with parameters of type MetadataModifier and TypeMethodDescriptionvoidMetadataUtils.MetadataAttachingServerInterceptor.MetadataAttachingServerCall.close(Status status, Metadata trailers) <ReqT,RespT>
ServerCall.Listener<ReqT> MetadataUtils.MetadataAttachingServerInterceptor.interceptCall(ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) static ClientInterceptorMetadataUtils.newAttachHeadersInterceptor(Metadata extraHeaders) Returns a client interceptor that attaches a set of headers to requests.static ServerInterceptorMetadataUtils.newAttachMetadataServerInterceptor(Metadata extras) Returns a ServerInterceptor that adds the specified Metadata to every response stream, one way or another.voidvoidvoidvoidMetadataUtils.MetadataCapturingClientInterceptor.MetadataCapturingClientCall.MetadataCapturingClientCallListener.onClose(Status status, Metadata trailers) voidvoidvoidvoidMetadataUtils.MetadataCapturingClientInterceptor.MetadataCapturingClientCall.MetadataCapturingClientCallListener.onHeaders(Metadata headers) voidMetadataUtils.MetadataAttachingServerInterceptor.MetadataAttachingServerCall.sendHeaders(Metadata headers) voidMetadataUtils.HeaderAttachingClientInterceptor.HeaderAttachingClientCall.start(ClientCall.Listener<RespT> responseListener, Metadata headers) voidMetadataUtils.MetadataCapturingClientInterceptor.MetadataCapturingClientCall.start(ClientCall.Listener<RespT> responseListener, Metadata headers) ServerCalls.StreamingServerCallHandler.startCall(ServerCall<ReqT, RespT> call, Metadata headers) ServerCalls.UnaryServerCallHandler.startCall(ServerCall<ReqT, RespT> call, Metadata headers) Method parameters in io.grpc.stub with type arguments of type MetadataModifier and TypeMethodDescriptionstatic ClientInterceptorMetadataUtils.newCaptureMetadataInterceptor(AtomicReference<Metadata> headersCapture, AtomicReference<Metadata> trailersCapture) Captures the last received metadata on a channel.Constructors in io.grpc.stub with parameters of type MetadataModifierConstructorDescription(package private)HeaderAttachingClientInterceptor(Metadata extraHeaders) (package private)Constructor parameters in io.grpc.stub with type arguments of type MetadataModifierConstructorDescription(package private)MetadataCapturingClientInterceptor(AtomicReference<Metadata> headersCapture, AtomicReference<Metadata> trailersCapture) -
Uses of Metadata in io.grpc.util
Methods in io.grpc.util with parameters of type MetadataModifier and TypeMethodDescriptionvoidTransmitStatusRuntimeExceptionInterceptor.SerializingServerCall.close(Status status, Metadata trailers) voidForwardingClientStreamTracer.inboundHeaders(Metadata headers) voidForwardingClientStreamTracer.inboundTrailers(Metadata trailers) <ReqT,RespT>
ServerCall.Listener<ReqT> TransmitStatusRuntimeExceptionInterceptor.interceptCall(ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) OutlierDetectionLoadBalancer.OutlierDetectionPicker.ResultCountingClientStreamTracerFactory.newClientStreamTracer(ClientStreamTracer.StreamInfo info, Metadata headers) voidTransmitStatusRuntimeExceptionInterceptor.SerializingServerCall.sendHeaders(Metadata headers) voidForwardingClientStreamTracer.streamCreated(Attributes transportAttrs, Metadata headers)