public class LlapFixedRegistryImpl extends Object implements ServiceRegistry
Modifier and Type | Field and Description |
---|---|
static String |
FIXED_REGISTRY_RESOLVE_HOST_NAMES |
Constructor and Description |
---|
LlapFixedRegistryImpl(String hosts,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
ServiceInstanceSet |
getInstances(String component)
Client API to get the list of instances registered via the current registry key.
|
static String |
getWorkerIdentity(String host) |
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
|
String |
toString() |
void |
unregister()
Remove the current registration cleanly (implementation defined cleanup)
|
@InterfaceAudience.Private public static final String FIXED_REGISTRY_RESOLVE_HOST_NAMES
public LlapFixedRegistryImpl(String hosts, org.apache.hadoop.conf.Configuration conf)
public void start() throws IOException
ServiceRegistry
start
in interface ServiceRegistry
IOException
public void stop() throws IOException
ServiceRegistry
stop
in interface ServiceRegistry
IOException
public String register() throws IOException
ServiceRegistry
register
in interface ServiceRegistry
IOException
public void unregister() throws IOException
ServiceRegistry
unregister
in interface ServiceRegistry
IOException
public ServiceInstanceSet getInstances(String component) throws IOException
ServiceRegistry
getInstances
in interface ServiceRegistry
IOException
public void registerStateChangeListener(ServiceInstanceStateChangeListener listener)
ServiceRegistry
registerStateChangeListener
in interface ServiceRegistry
listener
- - state change listenerCopyright © 2016 The Apache Software Foundation. All rights reserved.