Skip navigation links
A B C D E F G H I K M N O P R S U V W 

A

addService(ServerServiceDefinition) - Method in class io.vertx.grpc.VertxServerBuilder
 
addService(BindableService) - Method in class io.vertx.grpc.VertxServerBuilder
 
addStreamTracerFactory(ServerStreamTracer.Factory) - Method in class io.vertx.grpc.VertxServerBuilder
 
addTransportFilter(ServerTransportFilter) - Method in class io.vertx.grpc.VertxServerBuilder
 
awaitTermination(long, TimeUnit) - Method in class io.vertx.grpc.VertxServer
 
awaitTermination() - Method in class io.vertx.grpc.VertxServer
 

B

bind(Metadata) - Method in class io.vertx.grpc.ContextServerInterceptor
This method is called before the ContextServerInterceptor.interceptCall(ServerCall, Metadata, ServerCallHandler) call happens and allows extracting data from the metadata to the vert.x context.
BlockingServerInterceptor - Class in io.vertx.grpc
Wraps the ServerInterceptor and executes it on worker thread.
build() - Method in class io.vertx.grpc.VertxChannelBuilder
 
build() - Method in class io.vertx.grpc.VertxServerBuilder
 

C

ClientCalls - Class in io.vertx.grpc.stub
 
commandDecorator(Consumer<Runnable>) - Method in class io.vertx.grpc.VertxServerBuilder
Add a command decorator for the grpc calls.
compressorRegistry(CompressorRegistry) - Method in class io.vertx.grpc.VertxChannelBuilder
 
compressorRegistry(CompressorRegistry) - Method in class io.vertx.grpc.VertxServerBuilder
 
ContextServerInterceptor - Class in io.vertx.grpc
An abstract interceptor that allows capturing data from the metadata to the vertx context so it can be used later on the asynchronous APIs.
ContextServerInterceptor() - Constructor for class io.vertx.grpc.ContextServerInterceptor
 

D

decompressorRegistry(DecompressorRegistry) - Method in class io.vertx.grpc.VertxChannelBuilder
 
decompressorRegistry(DecompressorRegistry) - Method in class io.vertx.grpc.VertxServerBuilder
 
defaultLoadBalancingPolicy(String) - Method in class io.vertx.grpc.VertxChannelBuilder
 
defaultServiceConfig(Map<String, ?>) - Method in class io.vertx.grpc.VertxChannelBuilder
 
directExecutor() - Method in class io.vertx.grpc.VertxChannelBuilder
 
directExecutor() - Method in class io.vertx.grpc.VertxServerBuilder
 
disableRetry() - Method in class io.vertx.grpc.VertxChannelBuilder
 
disableServiceConfigLookUp() - Method in class io.vertx.grpc.VertxChannelBuilder
 
drainHandler(Handler<Void>) - Method in class io.vertx.grpc.stub.GrpcWriteStream
 

E

enableFullStreamDecompression() - Method in class io.vertx.grpc.VertxChannelBuilder
 
enableRetry() - Method in class io.vertx.grpc.VertxChannelBuilder
 
end(Handler<AsyncResult<Void>>) - Method in class io.vertx.grpc.stub.GrpcWriteStream
 
exceptionHandler(Handler<Throwable>) - Method in class io.vertx.grpc.stub.GrpcWriteStream
 
executor(Executor) - Method in class io.vertx.grpc.VertxChannelBuilder
 
executor(Executor) - Method in class io.vertx.grpc.VertxServerBuilder
 

F

fallbackHandlerRegistry(HandlerRegistry) - Method in class io.vertx.grpc.VertxServerBuilder
 
forAddress(Vertx, String, int) - Static method in class io.vertx.grpc.VertxChannelBuilder
 
forAddress(Vertx, SocketAddress) - Static method in class io.vertx.grpc.VertxChannelBuilder
 
forAddress(Vertx, SocketAddress) - Static method in class io.vertx.grpc.VertxServerBuilder
 
forAddress(Vertx, String, int) - Static method in class io.vertx.grpc.VertxServerBuilder
 
forPort(Vertx, int) - Static method in class io.vertx.grpc.VertxServerBuilder
 
forTarget(Vertx, String) - Static method in class io.vertx.grpc.VertxChannelBuilder
 

G

get(String) - Static method in class io.vertx.grpc.ContextServerInterceptor
 
getOrDefault(String, T) - Static method in class io.vertx.grpc.ContextServerInterceptor
 
getPort() - Method in class io.vertx.grpc.VertxServer
 
getRawServer() - Method in class io.vertx.grpc.VertxServer
 
GrpcWriteStream<T> - Class in io.vertx.grpc.stub
 
GrpcWriteStream(StreamObserver<T>) - Constructor for class io.vertx.grpc.stub.GrpcWriteStream
 

H

handshakeTimeout(long, TimeUnit) - Method in class io.vertx.grpc.VertxServerBuilder
 

I

idleTimeout(long, TimeUnit) - Method in class io.vertx.grpc.VertxChannelBuilder
 
intercept(List<ClientInterceptor>) - Method in class io.vertx.grpc.VertxChannelBuilder
 
intercept(ClientInterceptor...) - Method in class io.vertx.grpc.VertxChannelBuilder
 
intercept(ServerInterceptor) - Method in class io.vertx.grpc.VertxServerBuilder
 
interceptCall(ServerCall<ReqT, RespT>, Metadata, ServerCallHandler<ReqT, RespT>) - Method in class io.vertx.grpc.BlockingServerInterceptor
 
interceptCall(ServerCall<ReqT, RespT>, Metadata, ServerCallHandler<ReqT, RespT>) - Method in class io.vertx.grpc.ContextServerInterceptor
 
io.vertx.grpc - package io.vertx.grpc
 
io.vertx.grpc.stub - package io.vertx.grpc.stub
 
isShutdown() - Method in class io.vertx.grpc.VertxServer
 
isTerminated() - Method in class io.vertx.grpc.VertxServer
 

K

keepAliveTime(long, TimeUnit) - Method in class io.vertx.grpc.VertxChannelBuilder
 
keepAliveTimeout(long, TimeUnit) - Method in class io.vertx.grpc.VertxChannelBuilder
 
keepAliveWithoutCalls(boolean) - Method in class io.vertx.grpc.VertxChannelBuilder
 

M

manyToMany(ContextInternal, Handler<WriteStream<I>>, Function<StreamObserver<O>, StreamObserver<I>>) - Static method in class io.vertx.grpc.stub.ClientCalls
 
manyToMany(StreamObserver<O>, String, BiConsumer<ReadStream<I>, WriteStream<O>>) - Static method in class io.vertx.grpc.stub.ServerCalls
 
manyToOne(ContextInternal, Handler<WriteStream<I>>, Function<StreamObserver<O>, StreamObserver<I>>) - Static method in class io.vertx.grpc.stub.ClientCalls
 
manyToOne(StreamObserver<O>, String, Function<ReadStream<I>, Future<O>>) - Static method in class io.vertx.grpc.stub.ServerCalls
 
maxHedgedAttempts(int) - Method in class io.vertx.grpc.VertxChannelBuilder
 
maxInboundMessageSize(int) - Method in class io.vertx.grpc.VertxChannelBuilder
 
maxInboundMessageSize(int) - Method in class io.vertx.grpc.VertxServerBuilder
 
maxInboundMetadataSize(int) - Method in class io.vertx.grpc.VertxChannelBuilder
 
maxInboundMetadataSize(int) - Method in class io.vertx.grpc.VertxServerBuilder
 
maxRetryAttempts(int) - Method in class io.vertx.grpc.VertxChannelBuilder
 
maxTraceEvents(int) - Method in class io.vertx.grpc.VertxChannelBuilder
 

N

nameResolverFactory(NameResolver.Factory) - Method in class io.vertx.grpc.VertxChannelBuilder
Deprecated.
nettyBuilder() - Method in class io.vertx.grpc.VertxChannelBuilder
 
nettyBuilder() - Method in class io.vertx.grpc.VertxServerBuilder
 

O

offloadExecutor(Executor) - Method in class io.vertx.grpc.VertxChannelBuilder
 
oneToMany(ContextInternal, I, BiConsumer<I, StreamObserver<O>>) - Static method in class io.vertx.grpc.stub.ClientCalls
 
oneToMany(I, StreamObserver<O>, String, BiConsumer<I, WriteStream<O>>) - Static method in class io.vertx.grpc.stub.ServerCalls
 
oneToOne(ContextInternal, I, BiConsumer<I, StreamObserver<O>>) - Static method in class io.vertx.grpc.stub.ClientCalls
 
oneToOne(I, StreamObserver<O>, String, Function<I, Future<O>>) - Static method in class io.vertx.grpc.stub.ServerCalls
 
overrideAuthority(String) - Method in class io.vertx.grpc.VertxChannelBuilder
 

P

perRpcBufferLimit(long) - Method in class io.vertx.grpc.VertxChannelBuilder
 
proxyDetector(ProxyDetector) - Method in class io.vertx.grpc.VertxChannelBuilder
 
put(String, T) - Static method in class io.vertx.grpc.ContextServerInterceptor
 

R

retryBufferSize(long) - Method in class io.vertx.grpc.VertxChannelBuilder
 

S

ServerCalls - Class in io.vertx.grpc.stub
 
setBinaryLog(BinaryLog) - Method in class io.vertx.grpc.VertxChannelBuilder
 
setBinaryLog(BinaryLog) - Method in class io.vertx.grpc.VertxServerBuilder
 
setWriteQueueMaxSize(int) - Method in class io.vertx.grpc.stub.GrpcWriteStream
 
shutdown() - Method in class io.vertx.grpc.VertxServer
 
shutdown(Handler<AsyncResult<Void>>) - Method in class io.vertx.grpc.VertxServer
 
shutdownNow() - Method in class io.vertx.grpc.VertxServer
 
start() - Method in class io.vertx.grpc.VertxServer
 
start(Handler<AsyncResult<Void>>) - Method in class io.vertx.grpc.VertxServer
 
streamObserver() - Method in class io.vertx.grpc.stub.GrpcWriteStream
Low level control of the observer for advanced use cases.

U

usePlaintext() - Method in class io.vertx.grpc.VertxChannelBuilder
 
userAgent(String) - Method in class io.vertx.grpc.VertxChannelBuilder
 
useSsl(Handler<ClientOptionsBase>) - Method in class io.vertx.grpc.VertxChannelBuilder
 
useSsl(Handler<HttpServerOptions>) - Method in class io.vertx.grpc.VertxServerBuilder
 
useTransportSecurity() - Method in class io.vertx.grpc.VertxChannelBuilder
 
useTransportSecurity(File, File) - Method in class io.vertx.grpc.VertxServerBuilder
 
useTransportSecurity(InputStream, InputStream) - Method in class io.vertx.grpc.VertxServerBuilder
 

V

VertxChannelBuilder - Class in io.vertx.grpc
 
VertxServer - Class in io.vertx.grpc
 
VertxServerBuilder - Class in io.vertx.grpc
 

W

wrap(Vertx, ServerInterceptor) - Static method in class io.vertx.grpc.BlockingServerInterceptor
 
write(T) - Method in class io.vertx.grpc.stub.GrpcWriteStream
 
write(T, Handler<AsyncResult<Void>>) - Method in class io.vertx.grpc.stub.GrpcWriteStream
 
writeQueueFull() - Method in class io.vertx.grpc.stub.GrpcWriteStream
 
A B C D E F G H I K M N O P R S U V W 
Skip navigation links

Copyright © 2022 Eclipse. All rights reserved.