public interface ServiceRegistry
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.records.ApplicationId |
getApplicationId() |
ServiceInstanceSet |
getInstances(String component,
long clusterReadyTimeoutMs)
Client API to get the list of instances registered via the current registry key.
|
String |
register()
Register the current instance - the implementation takes care of the endpoints to register.
|
void |
registerStateChangeListener(ServiceInstanceStateChangeListener listener)
Adds state change listeners for service instances.
|
void |
start()
Start the service registry
|
void |
stop()
Stop the service registry
|
void |
unregister()
Remove the current registration cleanly (implementation defined cleanup)
|
void start() throws IOException
IOException
void stop() throws IOException
IOException
String register() throws IOException
IOException
void unregister() throws IOException
IOException
ServiceInstanceSet getInstances(String component, long clusterReadyTimeoutMs) throws IOException
component
- clusterReadyTimeoutMs
- The time to wait for the cluster to be ready, if it's not
started yet. 0 means do not wait.IOException
void registerStateChangeListener(ServiceInstanceStateChangeListener listener) throws IOException
listener
- - state change listenerIOException
org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId() throws IOException
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.