Uses of Class
io.grpc.Metadata
Packages that use Metadata
Package
Description
The gRPC core public API.
Interfaces and implementations that are internal to gRPC.
API for gRPC over Protocol Buffers, including tools for serializing and de-serializing protobuf
messages.
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 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.Status.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().abstract 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.voidThe response headers have been received.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.voidClientStreamTracer.streamCreated(Attributes transportAttrs, Metadata headers) The stream is being created on a ready transport.ModifierConstructorDescriptionStatusException(Status status, Metadata trailers) Constructs an exception with both a status and trailers.StatusRuntimeException(Status status, Metadata trailers) Constructs the exception with both a status and trailers. -
Uses of Metadata in io.grpc.internal
Methods in io.grpc.internal that return MetadataMethods in io.grpc.internal with parameters of type MetadataModifier and TypeMethodDescriptionvoidStatsTraceContext.clientInboundHeaders(Metadata headers) voidStatsTraceContext.clientInboundTrailers(Metadata trailers) final voidvoidCloses the stream for both reading and writing.voidClientStreamListener.closed(Status status, ClientStreamListener.RpcProgress rpcProgress, Metadata trailers) Called when the stream is fully closed.static ClientStreamTracer[]GrpcUtil.getClientStreamTracers(CallOptions callOptions, Metadata headers, int previousAttempts, boolean isTransparentRetry) Gets stream tracers based on CallOptions.voidClientStreamListener.headersRead(Metadata headers) Called upon receiving all header information from the remote end-point.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.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.ClientTransport.newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) Creates a new stream for sending messages to a remote end-point.final voidDelayedClientCall.start(ClientCall.Listener<RespT> listener, Metadata headers) voidForwardingClientStreamTracer.streamCreated(Attributes transportAttrs, Metadata headers) voidServerTransportListener.streamCreated(ServerStream stream, String method, Metadata headers) Called when a new stream was created by the remote client.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.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) PickSubchannelArgsImpl(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, LoadBalancer.PickDetailsConsumer pickDetailsConsumer) Creates call args object for given method with its call options, metadata. -
Uses of Metadata in io.grpc.protobuf
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.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.stub
Methods in io.grpc.stub with parameters of type MetadataModifier and TypeMethodDescriptionstatic 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.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. -
Uses of Metadata in io.grpc.util
Methods in io.grpc.util with parameters of type MetadataModifier and TypeMethodDescriptionvoidForwardingClientStreamTracer.inboundHeaders(Metadata headers) voidForwardingClientStreamTracer.inboundTrailers(Metadata trailers) <ReqT,RespT>
ServerCall.Listener<ReqT> TransmitStatusRuntimeExceptionInterceptor.interceptCall(ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) voidForwardingClientStreamTracer.streamCreated(Attributes transportAttrs, Metadata headers)