public class GrpcMessagingServer extends Object implements io.atomix.catalyst.transport.Server
Server
implementation based on Alluxio gRPC messaging.
Each server should listen only one address.
Outstanding listen futures should be completed before calling close()
.Constructor and Description |
---|
GrpcMessagingServer(AlluxioConfiguration conf,
UserState userState,
ExecutorService executor,
GrpcMessagingProxy proxy)
Creates a transport server that can be used to accept connections from remote clients.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
close() |
CompletableFuture<Void> |
listen(io.atomix.catalyst.transport.Address address,
java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener) |
public GrpcMessagingServer(AlluxioConfiguration conf, UserState userState, ExecutorService executor, GrpcMessagingProxy proxy)
conf
- Alluxio configurationuserState
- authentication userexecutor
- transport executorproxy
- external proxy configurationpublic CompletableFuture<Void> listen(io.atomix.catalyst.transport.Address address, java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener)
listen
in interface io.atomix.catalyst.transport.Server
public CompletableFuture<Void> close()
close
in interface io.atomix.catalyst.transport.Server
Copyright © 2023. All Rights Reserved.