alluxio.membership

Class DefaultServiceEntity

java.lang.Object

alluxio.membership.DefaultServiceEntity

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

WorkerServiceEntity

public abstract class DefaultServiceEntity
extends Object
implements Closeable

Base Entity class including information to register to Etcd when using EtcdMembershipManager. It will be serialized to JSON format to store on etcd, including only those fields with marked @Expose annotation.

Field Summary

Fields

Modifier and Type	Field and Description
ReentrantLock	mLock
AtomicBoolean	mNeedReconnect
protected long	mRevision
protected String	mServiceEntityName

Constructor Summary

Constructors

Constructor and Description
DefaultServiceEntity() CTOR for DefaultServiceEntity.
DefaultServiceEntity(String serviceEntityName) CTOR for ServiceEntity with given ServiceEntity name.

Method Summary

Modifier and Type	Method and Description
void	close()
void	deserialize(byte[] buf) Deserialize the ServiceEntity from bytes.
io.etcd.jetcd.support.CloseableClient	getKeepAliveClient() Get the keepalive client instance.
AlluxioEtcdClient.Lease	getLease()
long	getLeaseTimeoutInSec() Get the timeout for lease in seconds.
long	getLeaseTTLInSec() Get the TTL for lease in seconds.
long	getRevisionNumber() Get the revision number of currently registered DefaultServiceEntity on ETCD.
String	getServiceEntityName() Get service entity name.
byte[]	serialize() Serialize the ServiceEntity to bytes.
void	setKeepAliveClient(io.etcd.jetcd.support.CloseableClient keepAliveClient) Set keep alive client.
void	setLease(AlluxioEtcdClient.Lease lease) Set lease.
void	setLeaseTimeoutInSec(long timeout) Set the timeout for lease in seconds.
void	setLeaseTTLInSec(long ttl) Set the TTL for lease in seconds.
void	setRevisionNumber(long revisionNumber) Set revision number.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

mServiceEntityName

@Expose
 @SerializedName(value="ServiceEntityName")
protected String mServiceEntityName

mRevision

protected long mRevision

mLock

public final ReentrantLock mLock

mNeedReconnect

public AtomicBoolean mNeedReconnect

Constructor Detail

DefaultServiceEntity

public DefaultServiceEntity()

CTOR for DefaultServiceEntity.

DefaultServiceEntity

public DefaultServiceEntity(String serviceEntityName)

CTOR for ServiceEntity with given ServiceEntity name.

Parameters:

serviceEntityName -

Method Detail

getServiceEntityName

public String getServiceEntityName()

Get service entity name.

Returns:

service entity name

setKeepAliveClient

public void setKeepAliveClient(io.etcd.jetcd.support.CloseableClient keepAliveClient)

Set keep alive client.

Parameters:

keepAliveClient -

getKeepAliveClient

public io.etcd.jetcd.support.CloseableClient getKeepAliveClient()

Get the keepalive client instance.

Returns:

jetcd keepalive client

getLease

public AlluxioEtcdClient.Lease getLease()

Returns:

lease

setLease

public void setLease(AlluxioEtcdClient.Lease lease)

Set lease.

Parameters:

lease -

getRevisionNumber

public long getRevisionNumber()

Get the revision number of currently registered DefaultServiceEntity on ETCD.

Returns:

revision number

setRevisionNumber

public void setRevisionNumber(long revisionNumber)

Set revision number.

Parameters:

revisionNumber -

getLeaseTTLInSec

public long getLeaseTTLInSec()

Get the TTL for lease in seconds.

Returns:

TTL

setLeaseTTLInSec

public void setLeaseTTLInSec(long ttl)

Set the TTL for lease in seconds.

Parameters:

ttl -

getLeaseTimeoutInSec

public long getLeaseTimeoutInSec()

Get the timeout for lease in seconds.

Returns:

timeout

setLeaseTimeoutInSec

public void setLeaseTimeoutInSec(long timeout)

Set the timeout for lease in seconds.

Parameters:

timeout -

serialize

public byte[] serialize()

Serialize the ServiceEntity to bytes.

Returns:

serialized data

deserialize

public void deserialize(byte[] buf)

Deserialize the ServiceEntity from bytes.

Parameters:

buf -

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException