Package | Description |
---|---|
alluxio.grpc | |
alluxio.master | |
alluxio.worker.grpc |
Modifier and Type | Method and Description |
---|---|
GrpcServerBuilder |
GrpcServerBuilder.addService(GrpcService serviceDefinition)
Add a service to this server.
|
GrpcServerBuilder |
GrpcServerBuilder.addService(ServiceType serviceType,
GrpcService serviceDefinition)
Add a service to this server.
|
GrpcServerBuilder |
GrpcServerBuilder.bossEventLoopGroup(io.netty.channel.EventLoopGroup bossGroup)
Sets the boss
EventLoopGroup . |
GrpcServerBuilder |
GrpcServerBuilder.channelType(Class<? extends io.netty.channel.ServerChannel> channelType)
Sets the netty channel type.
|
GrpcServerBuilder |
GrpcServerBuilder.executor(Executor executor)
Set the executor for this server.
|
GrpcServerBuilder |
GrpcServerBuilder.flowControlWindow(int flowControlWindow)
Sets flow control window.
|
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AlluxioConfiguration conf)
Create an new instance of
GrpcServerBuilder with authentication support. |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AuthenticationServer authenticationServer,
AlluxioConfiguration conf)
Create a new instance of
GrpcServerBuilder with authentication support. |
GrpcServerBuilder |
GrpcServerBuilder.intercept(io.grpc.ServerInterceptor interceptor)
Adds an interceptor for this server.
|
GrpcServerBuilder |
GrpcServerBuilder.keepAliveTime(long keepAliveTime,
TimeUnit timeUnit)
Sets the server keep-alive time.
|
GrpcServerBuilder |
GrpcServerBuilder.keepAliveTimeout(long keepAliveTimeout,
TimeUnit timeUnit)
Sets the server keep-alive timeout.
|
GrpcServerBuilder |
GrpcServerBuilder.maxInboundMessageSize(int messageSize)
Sets the maximum size of inbound messages.
|
GrpcServerBuilder |
GrpcServerBuilder.permitKeepAlive(long permitKeepAlive,
TimeUnit timeUnit)
Sets the high-bar for client-side keep-alive frequency.
|
GrpcServerBuilder |
GrpcServerBuilder.sslContext(io.netty.handler.ssl.SslContext sslContext)
Sets TLS context.
|
<T> GrpcServerBuilder |
GrpcServerBuilder.withChildOption(io.netty.channel.ChannelOption<T> option,
T value)
Sets a netty channel option.
|
GrpcServerBuilder |
GrpcServerBuilder.workerEventLoopGroup(io.netty.channel.EventLoopGroup workerGroup)
Sets the worker
EventLoopGroup . |
Modifier and Type | Method and Description |
---|---|
GrpcServerBuilder |
AlluxioJobMasterProcess.createBaseRpcServer() |
GrpcServerBuilder |
AlluxioMasterProcess.createBaseRpcServer() |
abstract GrpcServerBuilder |
MasterProcess.createBaseRpcServer() |
Modifier and Type | Method and Description |
---|---|
protected GrpcServerBuilder |
GrpcDataServer.createServerBuilder(String hostName,
SocketAddress bindAddress,
ChannelType type) |
Copyright © 2023. All Rights Reserved.