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

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

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
 
create(GrpcReadStream<I>, StreamObserver<O>) - Static method in interface io.vertx.grpc.GrpcBidiExchange
 
create(StreamObserver<I>, StreamObserver<O>) - Static method in interface io.vertx.grpc.GrpcBidiExchange
 
create(StreamObserver<T>) - Static method in interface io.vertx.grpc.GrpcReadStream
 
create() - Static method in interface io.vertx.grpc.GrpcReadStream
 
create(GrpcReadStream<I>, StreamObserver<O>) - Static method in interface io.vertx.grpc.GrpcUniExchange
 
create(StreamObserver<T>) - Static method in interface io.vertx.grpc.GrpcWriteStream
 

D

decompressorRegistry(DecompressorRegistry) - Method in class io.vertx.grpc.VertxChannelBuilder
 
decompressorRegistry(DecompressorRegistry) - Method in class io.vertx.grpc.VertxServerBuilder
 
directExecutor() - Method in class io.vertx.grpc.VertxChannelBuilder
 
directExecutor() - Method in class io.vertx.grpc.VertxServerBuilder
 
disableRetry() - Method in class io.vertx.grpc.VertxChannelBuilder
 
drainHandler(Handler<Void>) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
drainHandler(Handler<Void>) - Method in interface io.vertx.grpc.GrpcUniExchange
 
drainHandler(Handler<Void>) - Method in interface io.vertx.grpc.GrpcWriteStream
Set a drain handler on the stream.

E

enableFullStreamDecompression() - Method in class io.vertx.grpc.VertxChannelBuilder
 
enableRetry() - Method in class io.vertx.grpc.VertxChannelBuilder
 
endHandler(Handler<Void>) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
endHandler(Handler<Void>) - Method in interface io.vertx.grpc.GrpcReadStream
Set an end handler.
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.grpc.GrpcReadStream
Set an exception handler on the read stream.
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.grpc.GrpcWriteStream
Set an exception handler on the write stream.
executor(Executor) - Method in class io.vertx.grpc.VertxChannelBuilder
 
executor(Executor) - Method in class io.vertx.grpc.VertxServerBuilder
 

F

fail(Throwable) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
fail(Throwable) - Method in interface io.vertx.grpc.GrpcUniExchange
 
fail(Throwable) - Method in interface io.vertx.grpc.GrpcWriteStream
Send an error event into the stream.
fallbackHandlerRegistry(HandlerRegistry) - Method in class io.vertx.grpc.VertxServerBuilder
 
fetch(long) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
fetch(long) - Method in interface io.vertx.grpc.GrpcReadStream
Fetch the specified amount of elements.
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

getPort() - Method in class io.vertx.grpc.VertxServer
 
getRawServer() - Method in class io.vertx.grpc.VertxServer
 
GrpcBidiExchange<I,O> - Interface in io.vertx.grpc
 
GrpcReadStream<T> - Interface in io.vertx.grpc
 
GrpcUniExchange<O,I> - Interface in io.vertx.grpc
 
GrpcWriteStream<T> - Interface in io.vertx.grpc
 

H

handler(Handler<I>) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
handler(Handler<T>) - Method in interface io.vertx.grpc.GrpcReadStream
Set a data handler.
handler(Handler<AsyncResult<I>>) - Method in interface io.vertx.grpc.GrpcUniExchange
 
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
 
io.vertx.grpc - package io.vertx.grpc
 
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

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
 
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
 
nettyBuilder() - Method in class io.vertx.grpc.VertxChannelBuilder
 
nettyBuilder() - Method in class io.vertx.grpc.VertxServerBuilder
 

O

overrideAuthority(String) - Method in class io.vertx.grpc.VertxChannelBuilder
 

P

pause() - Method in interface io.vertx.grpc.GrpcBidiExchange
 
pause() - Method in interface io.vertx.grpc.GrpcReadStream
Pause the ReadSupport.
perRpcBufferLimit(long) - Method in class io.vertx.grpc.VertxChannelBuilder
 

R

readObserver() - Method in interface io.vertx.grpc.GrpcBidiExchange
 
readObserver() - Method in interface io.vertx.grpc.GrpcReadStream
Should not be used by end user, it is a simple accessor the the underlying gRPC StreamObserver.
resume() - Method in interface io.vertx.grpc.GrpcBidiExchange
 
resume() - Method in interface io.vertx.grpc.GrpcReadStream
Resume reading.
retryBufferSize(long) - Method in class io.vertx.grpc.VertxChannelBuilder
 

S

setBinaryLog(BinaryLog) - Method in class io.vertx.grpc.VertxChannelBuilder
 
setBinaryLog(BinaryLog) - Method in class io.vertx.grpc.VertxServerBuilder
 
setReadObserver(StreamObserver<I>) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
setReadObserver(StreamObserver<T>) - Method in interface io.vertx.grpc.GrpcReadStream
 
setWriteQueueMaxSize(int) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
setWriteQueueMaxSize(int) - Method in interface io.vertx.grpc.GrpcUniExchange
 
setWriteQueueMaxSize(int) - Method in interface io.vertx.grpc.GrpcWriteStream
Set the maximum size of the write queue to maxSize.
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
 

U

usePlaintext(boolean) - Method in class io.vertx.grpc.VertxChannelBuilder
 
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(O) - Method in interface io.vertx.grpc.GrpcBidiExchange
 
write(O) - Method in interface io.vertx.grpc.GrpcUniExchange
 
write(T) - Method in interface io.vertx.grpc.GrpcWriteStream
Write some data to the stream.
writeObserver() - Method in interface io.vertx.grpc.GrpcBidiExchange
 
writeObserver() - Method in interface io.vertx.grpc.GrpcUniExchange
 
writeObserver() - Method in interface io.vertx.grpc.GrpcWriteStream
Should not be used by end user, it is a simple accessor the the underlying gRPC StreamObserver.
A B C D E F G H I K M N O P R S U V W 
Skip navigation links

Copyright © 2021 Eclipse. All rights reserved.