public class

ZkHelixRoleDefaultImpl

extends Object
implements HelixConnectionStateListener HelixRole HelixService
java.lang.Object
   ↳ org.apache.helix.manager.zk.ZkHelixRoleDefaultImpl

Summary

Public Constructors
ZkHelixRoleDefaultImpl(ZkHelixConnection connection, ClusterId clusterId, Id instanceId)
Public Methods
HelixDataAccessor getAccessor()
get data accessor
ClusterId getClusterId()
get cluster id to which this role belongs
HelixConnection getConnection()
get the underlying connection
Id getId()
get id of this helix-role
ClusterMessagingService getMessagingService()
get the messaging-service
InstanceType getType()
helix-role type
boolean isStarted()
is service started
void onConnected()
called after connection is established
void onDisconnecting()
called before disconnect
void start()
start helix service
void stop()
stop helix service
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.apache.helix.HelixConnectionStateListener
From interface org.apache.helix.HelixRole
From interface org.apache.helix.HelixService

Public Constructors

public ZkHelixRoleDefaultImpl (ZkHelixConnection connection, ClusterId clusterId, Id instanceId)

Public Methods

public HelixDataAccessor getAccessor ()

get data accessor

public ClusterId getClusterId ()

get cluster id to which this role belongs

Returns
  • cluster id

public HelixConnection getConnection ()

get the underlying connection

Returns
  • helix-connection

public Id getId ()

get id of this helix-role

Returns
  • id

public ClusterMessagingService getMessagingService ()

get the messaging-service

Returns
  • messaging-service

public InstanceType getType ()

helix-role type

public boolean isStarted ()

is service started

public void onConnected ()

called after connection is established

public void onDisconnecting ()

called before disconnect

public void start ()

start helix service

public void stop ()

stop helix service