Constructor and Description |
---|
GrpcMessagingClient(AlluxioConfiguration conf,
UserState userState,
ExecutorService executor,
String clientType)
Creates messaging client that can be used to connect to remote messaging servers.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
close()
Closes the client.
|
CompletableFuture<GrpcMessagingConnection> |
connect(InetSocketAddress address)
Creates a client and connects to the given address.
|
public GrpcMessagingClient(AlluxioConfiguration conf, UserState userState, ExecutorService executor, String clientType)
conf
- Alluxio configurationuserState
- authentication userexecutor
- messaging executorclientType
- transport client typepublic CompletableFuture<GrpcMessagingConnection> connect(InetSocketAddress address)
address
- the server addresspublic CompletableFuture<Void> close()
Copyright © 2023. All Rights Reserved.