Modifier and Type | Method and Description |
---|---|
protected abstract ServiceType |
AbstractClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
Server.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingBlockMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingFileSystemMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingJobMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingJournalMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingMetaMasterClient.getRemoteServiceType() |
protected ServiceType |
RetryHandlingMetaMasterConfigClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingMetricsMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingTableMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RpcPortHealthCheckClient.getServiceType() |
Constructor and Description |
---|
RpcPortHealthCheckClient(InetSocketAddress nodeAddress,
ServiceType serviceType,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a worker health check client.
|
Modifier and Type | Method and Description |
---|---|
static ServiceType |
ServiceType.forNumber(int value) |
ServiceType |
GetServiceVersionPRequestOrBuilder.getServiceType()
The purpose of this field is to make grpc service on standby masters work without
making client changes and keeps backwards compatibility.
|
ServiceType |
GetServiceVersionPRequest.getServiceType()
The purpose of this field is to make grpc service on standby masters work without
making client changes and keeps backwards compatibility.
|
ServiceType |
GetServiceVersionPRequest.Builder.getServiceType()
The purpose of this field is to make grpc service on standby masters work without
making client changes and keeps backwards compatibility.
|
static ServiceType |
ServiceType.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static ServiceType |
ServiceType.valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static ServiceType |
ServiceType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ServiceType[] |
ServiceType.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<ServiceType> |
ServiceType.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
GrpcServerBuilder |
GrpcServerBuilder.addService(ServiceType serviceType,
GrpcService serviceDefinition)
Add a service to this server.
|
GetServiceVersionPRequest.Builder |
GetServiceVersionPRequest.Builder.setServiceType(ServiceType value)
The purpose of this field is to make grpc service on standby masters work without
making client changes and keeps backwards compatibility.
|
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 |
---|---|
Map<ServiceType,GrpcService> |
NoopMaster.getServices() |
default Map<ServiceType,GrpcService> |
Master.getStandbyServices() |
Constructor and Description |
---|
MasterServingHealthCheck(InetSocketAddress nodeAddress,
ServiceType serviceType,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a new instance of
MasterHealthCheckClient.MasterServingHealthCheck to check for an open RPC port
for the given service. |
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
AlluxioConfiguration alluxioConf,
UserState userState,
ServiceType serviceType) |
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf,
ServiceType serviceType) |
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf,
UserState userState,
ServiceType serviceType) |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
BackupWorkerRole.getRoleServices() |
Map<ServiceType,GrpcService> |
BackupLeaderRole.getRoleServices() |
Map<ServiceType,GrpcService> |
BackupRole.getRoleServices() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultBlockMaster.getServices() |
Map<ServiceType,GrpcService> |
DefaultBlockMaster.getStandbyServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
FileSystemMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultFileSystemMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
JobMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
default Map<ServiceType,GrpcService> |
JournalSystem.getJournalServices() |
Map<ServiceType,GrpcService> |
DefaultJournalMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RaftJournalServiceClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
RaftJournalSystem.getJournalServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingJobMasterMasterClient.getRemoteServiceType() |
protected ServiceType |
RetryHandlingMetaMasterMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultMetaMaster.getServices() |
Map<ServiceType,GrpcService> |
DefaultMetaMaster.getStandbyServices() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultMetricsMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
protected void |
RpcServerService.startGrpcServer(java.util.function.Function<Master,Map<ServiceType,GrpcService>> serviceProvider) |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingMetaMasterProxyClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
static void |
NetworkAddressUtils.pingService(InetSocketAddress address,
ServiceType serviceType,
AlluxioConfiguration conf,
UserState userState)
Test if the input address is serving an Alluxio service.
|
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
JobWorker.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
BlockMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
PagedDoraWorker.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
FileSystemMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingJobMasterClient.getRemoteServiceType() |
Copyright © 2023. All Rights Reserved.