Package | Description |
---|---|
alluxio.grpc | |
alluxio.master | |
alluxio.master.journal.raft |
Modifier and Type | Method and Description |
---|---|
static NodeState |
NodeState.forNumber(int value) |
NodeState |
GetNodeStatePResponseOrBuilder.getNodeState()
optional .alluxio.grpc.journal.NodeState node_state = 1; |
NodeState |
GetNodeStatePResponse.getNodeState()
optional .alluxio.grpc.journal.NodeState node_state = 1; |
NodeState |
GetNodeStatePResponse.Builder.getNodeState()
optional .alluxio.grpc.journal.NodeState node_state = 1; |
static NodeState |
NodeState.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static NodeState |
NodeState.valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static NodeState |
NodeState.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static NodeState[] |
NodeState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Internal.EnumLiteMap<NodeState> |
NodeState.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
GetNodeStatePResponse.Builder |
GetNodeStatePResponse.Builder.setNodeState(NodeState value)
optional .alluxio.grpc.journal.NodeState node_state = 1; |
Modifier and Type | Method and Description |
---|---|
GrpcServer |
GrpcServerBuilder.build(java.util.function.Supplier<NodeState> nodeStateSupplier)
Build the server.
|
Constructor and Description |
---|
ServiceVersionClientServiceHandler(Set<ServiceType> services,
java.util.function.Supplier<NodeState> nodeStateSupplier)
Creates service version handler that allows given services.
|
Modifier and Type | Method and Description |
---|---|
NodeState |
AlwaysStandbyPrimarySelector.getState() |
NodeState |
AbstractPrimarySelector.getState() |
NodeState |
PrimarySelector.getState() |
NodeState |
AlwaysStandbyPrimarySelector.getStateUnsafe() |
NodeState |
AbstractPrimarySelector.getStateUnsafe() |
NodeState |
PrimarySelector.getStateUnsafe() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractPrimarySelector.setState(NodeState state) |
void |
AlwaysStandbyPrimarySelector.waitForState(NodeState state) |
void |
AbstractPrimarySelector.waitForState(NodeState state) |
void |
PrimarySelector.waitForState(NodeState state)
Blocks until the primary selector enters the specified state.
|
Modifier and Type | Method and Description |
---|---|
Scoped |
AlwaysStandbyPrimarySelector.onStateChange(java.util.function.Consumer<NodeState> listener) |
Scoped |
AbstractPrimarySelector.onStateChange(java.util.function.Consumer<NodeState> listener) |
Scoped |
PrimarySelector.onStateChange(java.util.function.Consumer<NodeState> listener)
Registers a listener to be executed whenever the selector's state updates.
|
Modifier and Type | Method and Description |
---|---|
void |
RaftPrimarySelector.notifyStateChanged(NodeState state)
Notifies leadership state changed.
|
Copyright © 2023. All Rights Reserved.