public class GrpcMessagingTransport extends Object implements io.atomix.catalyst.transport.Transport
Transport
implementation based on Alluxio gRPC messaging.Constructor and Description |
---|
GrpcMessagingTransport(AlluxioConfiguration clientConf,
AlluxioConfiguration serverConf,
UserState clientUser,
UserState serverUser,
String clientType)
Creates
Transport based on Alluxio gRPC messaging. |
GrpcMessagingTransport(AlluxioConfiguration conf,
UserState user,
String clientType)
Creates
Transport based on Alluxio gRPC messaging. |
Modifier and Type | Method and Description |
---|---|
io.atomix.catalyst.transport.Client |
client() |
void |
close() |
io.atomix.catalyst.transport.Server |
server() |
GrpcMessagingTransport |
withServerProxy(GrpcMessagingProxy proxy)
Sets external proxy configuration for servers.
|
public GrpcMessagingTransport(AlluxioConfiguration conf, UserState user, String clientType)
Transport
based on Alluxio gRPC messaging.conf
- Alluxio configurationuser
- Alluxio userclientType
- Transport client typepublic GrpcMessagingTransport(AlluxioConfiguration clientConf, AlluxioConfiguration serverConf, UserState clientUser, UserState serverUser, String clientType)
Transport
based on Alluxio gRPC messaging.clientConf
- Alluxio configuration for clientsserverConf
- Alluxio configuration for serversclientUser
- User for clientsserverUser
- User for serversclientType
- Transport client typepublic GrpcMessagingTransport withServerProxy(GrpcMessagingProxy proxy)
proxy
- external proxy configurationpublic io.atomix.catalyst.transport.Client client()
client
in interface io.atomix.catalyst.transport.Transport
public io.atomix.catalyst.transport.Server server()
server
in interface io.atomix.catalyst.transport.Transport
public void close()
close
in interface io.atomix.catalyst.transport.Transport
close
in interface AutoCloseable
Copyright © 2023. All Rights Reserved.