Package | Description |
---|---|
org.apache.drill.exec.rpc | |
org.apache.drill.exec.rpc.control | |
org.apache.drill.exec.rpc.data | |
org.apache.drill.exec.rpc.security |
Communication security.
|
org.apache.drill.exec.rpc.user |
Modifier and Type | Class and Description |
---|---|
class |
BasicClient<T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite> |
class |
ConnectionMultiListener<T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite,BC extends BasicClient<T,CC,HS,HR>> |
static class |
ConnectionMultiListener.Builder<T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite,BC extends BasicClient<T,CC,HS,HR>> |
class |
ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>
Manager all connections between two particular bits.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractClientConnection |
Modifier and Type | Field and Description |
---|---|
protected CC |
BasicClient.connection |
Modifier and Type | Method and Description |
---|---|
static <T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite,BC extends BasicClient<T,CC,HS,HR>> |
ConnectionMultiListener.newBuilder(RpcConnectionHandler<CC> connectionListener,
HS handshakeValue,
BC basicClient) |
static <T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite> |
BitRpcUtility.prepareSaslHandshake(RpcConnectionHandler<CC> connectionHandler,
List<String> serverAuthMechanisms,
CC connection,
BitConnectionConfig config,
CoordinationProtos.DrillbitEndpoint endpoint,
BasicClient<T,CC,HS,HR> client,
T saslRpcType)
Creates various instances needed to start the SASL handshake.
|
Modifier and Type | Method and Description |
---|---|
static List<String> |
BitRpcUtility.validateHandshake(int handshakeRpcVersion,
List<String> remoteAuthMechs,
int rpcVersion,
ClientConnection connection,
BitConnectionConfig config,
BasicClient client)
Method to do validation on the handshake message received from server side.
|
Modifier and Type | Class and Description |
---|---|
class |
ControlConnection |
Modifier and Type | Class and Description |
---|---|
class |
DataClientConnection |
Modifier and Type | Class and Description |
---|---|
class |
AuthenticationOutcomeListener<T extends com.google.protobuf.Internal.EnumLite,C extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite>
Handles SASL exchange, on the client-side.
|
Modifier and Type | Class and Description |
---|---|
class |
UserClient.UserToBitConnection |
Copyright © 1970 The Apache Software Foundation. All rights reserved.