Package | Description |
---|---|
alluxio.cli.fsadmin.journal | |
alluxio.client.journal | |
alluxio.grpc | |
alluxio.master.journal | |
alluxio.master.journal.raft | |
alluxio.wire |
Modifier and Type | Method and Description |
---|---|
static NetAddress |
QuorumCommand.stringToAddress(String serverAddress) |
Modifier and Type | Method and Description |
---|---|
void |
JournalMasterClient.removeQuorumServer(NetAddress serverAddress)
Removes a server from journal quorum.
|
void |
RetryHandlingJournalMasterClient.removeQuorumServer(NetAddress serverAddress) |
String |
JournalMasterClient.transferLeadership(NetAddress newLeaderNetAddress)
Initiates changing the leading master of the quorum.
|
String |
RetryHandlingJournalMasterClient.transferLeadership(NetAddress newLeaderNetAddress) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<NetAddress> |
NetAddress.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
NetAddress |
NetAddress.Builder.build() |
NetAddress |
NetAddress.Builder.buildPartial() |
static NetAddress |
NetAddress.getDefaultInstance() |
NetAddress |
NetAddress.getDefaultInstanceForType() |
NetAddress |
NetAddress.Builder.getDefaultInstanceForType() |
NetAddress |
GetMasterIdPRequest.getMasterAddress()
optional .alluxio.grpc.NetAddress masterAddress = 1; |
NetAddress |
GetMasterIdPRequest.Builder.getMasterAddress()
optional .alluxio.grpc.NetAddress masterAddress = 1; |
NetAddress |
GetMasterIdPRequestOrBuilder.getMasterAddress()
optional .alluxio.grpc.NetAddress masterAddress = 1; |
NetAddress |
MasterInfo.getMasterAddresses(int index)
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
NetAddress |
MasterInfo.Builder.getMasterAddresses(int index)
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
NetAddress |
MasterInfoOrBuilder.getMasterAddresses(int index)
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
NetAddress |
TransferLeadershipPRequestOrBuilder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 2; |
NetAddress |
TransferLeadershipPRequest.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 2; |
NetAddress |
TransferLeadershipPRequest.Builder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 2; |
NetAddress |
RemoveQuorumServerPRequestOrBuilder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 2; |
NetAddress |
RemoveQuorumServerPRequest.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 2; |
NetAddress |
RemoveQuorumServerPRequest.Builder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 2; |
NetAddress |
AddQuorumServerRequestOrBuilder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 1; |
NetAddress |
AddQuorumServerRequest.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 1; |
NetAddress |
AddQuorumServerRequest.Builder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 1; |
NetAddress |
QuorumServerInfoOrBuilder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 1; |
NetAddress |
QuorumServerInfo.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 1; |
NetAddress |
QuorumServerInfo.Builder.getServerAddress()
optional .alluxio.grpc.NetAddress serverAddress = 1; |
NetAddress |
MasterInfo.getWorkerAddresses(int index)
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
NetAddress |
MasterInfo.Builder.getWorkerAddresses(int index)
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
NetAddress |
MasterInfoOrBuilder.getWorkerAddresses(int index)
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
static NetAddress |
NetAddress.parseDelimitedFrom(InputStream input) |
static NetAddress |
NetAddress.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NetAddress |
NetAddress.parseFrom(byte[] data) |
static NetAddress |
NetAddress.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NetAddress |
NetAddress.parseFrom(ByteBuffer data) |
static NetAddress |
NetAddress.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NetAddress |
NetAddress.parseFrom(com.google.protobuf.ByteString data) |
static NetAddress |
NetAddress.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NetAddress |
NetAddress.parseFrom(com.google.protobuf.CodedInputStream input) |
static NetAddress |
NetAddress.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NetAddress |
NetAddress.parseFrom(InputStream input) |
static NetAddress |
NetAddress.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<NetAddress> |
MasterInfo.getMasterAddressesList()
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
List<NetAddress> |
MasterInfo.Builder.getMasterAddressesList()
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
List<NetAddress> |
MasterInfoOrBuilder.getMasterAddressesList()
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
com.google.protobuf.Parser<NetAddress> |
NetAddress.getParserForType() |
List<NetAddress> |
MasterInfo.getWorkerAddressesList()
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
List<NetAddress> |
MasterInfo.Builder.getWorkerAddressesList()
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
List<NetAddress> |
MasterInfoOrBuilder.getWorkerAddressesList()
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
static com.google.protobuf.Parser<NetAddress> |
NetAddress.parser() |
Modifier and Type | Method and Description |
---|---|
MasterInfo.Builder |
MasterInfo.Builder.addMasterAddresses(int index,
NetAddress value)
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
MasterInfo.Builder |
MasterInfo.Builder.addMasterAddresses(NetAddress value)
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
MasterInfo.Builder |
MasterInfo.Builder.addWorkerAddresses(int index,
NetAddress value)
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
MasterInfo.Builder |
MasterInfo.Builder.addWorkerAddresses(NetAddress value)
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
NetAddress.Builder |
NetAddress.Builder.mergeFrom(NetAddress other) |
GetMasterIdPRequest.Builder |
GetMasterIdPRequest.Builder.mergeMasterAddress(NetAddress value)
optional .alluxio.grpc.NetAddress masterAddress = 1; |
TransferLeadershipPRequest.Builder |
TransferLeadershipPRequest.Builder.mergeServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 2; |
RemoveQuorumServerPRequest.Builder |
RemoveQuorumServerPRequest.Builder.mergeServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 2; |
AddQuorumServerRequest.Builder |
AddQuorumServerRequest.Builder.mergeServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 1; |
QuorumServerInfo.Builder |
QuorumServerInfo.Builder.mergeServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 1; |
static NetAddress.Builder |
NetAddress.newBuilder(NetAddress prototype) |
GetMasterIdPRequest.Builder |
GetMasterIdPRequest.Builder.setMasterAddress(NetAddress value)
optional .alluxio.grpc.NetAddress masterAddress = 1; |
MasterInfo.Builder |
MasterInfo.Builder.setMasterAddresses(int index,
NetAddress value)
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
TransferLeadershipPRequest.Builder |
TransferLeadershipPRequest.Builder.setServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 2; |
RemoveQuorumServerPRequest.Builder |
RemoveQuorumServerPRequest.Builder.setServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 2; |
AddQuorumServerRequest.Builder |
AddQuorumServerRequest.Builder.setServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 1; |
QuorumServerInfo.Builder |
QuorumServerInfo.Builder.setServerAddress(NetAddress value)
optional .alluxio.grpc.NetAddress serverAddress = 1; |
MasterInfo.Builder |
MasterInfo.Builder.setWorkerAddresses(int index,
NetAddress value)
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
Modifier and Type | Method and Description |
---|---|
MasterInfo.Builder |
MasterInfo.Builder.addAllMasterAddresses(Iterable<? extends NetAddress> values)
repeated .alluxio.grpc.NetAddress masterAddresses = 2; |
MasterInfo.Builder |
MasterInfo.Builder.addAllWorkerAddresses(Iterable<? extends NetAddress> values)
repeated .alluxio.grpc.NetAddress workerAddresses = 9; |
static InetSocketAddress[] |
GrpcUtils.netAddressToSocketAddress(List<NetAddress> request)
Convert a list of
NetAddress to InetSocketAddress . |
Modifier and Type | Method and Description |
---|---|
void |
DefaultJournalMaster.removeQuorumServer(NetAddress serverAddress) |
void |
JournalMaster.removeQuorumServer(NetAddress serverAddress)
Removes a server from journal quorum.
|
String |
DefaultJournalMaster.transferLeadership(NetAddress newLeaderAddress) |
String |
JournalMaster.transferLeadership(NetAddress newLeaderAddress)
Changes the leading master of the journal quorum.
|
Modifier and Type | Method and Description |
---|---|
void |
RaftJournalSystem.addQuorumServer(NetAddress serverNetAddress)
Adds a server to the quorum.
|
void |
RaftJournalSystem.removeQuorumServer(NetAddress serverNetAddress)
Removes from RAFT quorum, a server with given address.
|
String |
RaftJournalSystem.transferLeadership(NetAddress newLeaderNetAddress)
Transfers the leadership of the quorum to another server.
|
Modifier and Type | Method and Description |
---|---|
NetAddress |
Address.toProto() |
Modifier and Type | Method and Description |
---|---|
static Address |
Address.fromProto(NetAddress address)
Creates a new instance of
Address from proto representation. |
Constructor and Description |
---|
Address(NetAddress netAddress)
Creates a new instance of
Address from proto representation. |
Copyright © 2023. All Rights Reserved.