public abstract class ReplicaClient extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
protected Client |
client |
protected long |
error |
protected Filter |
filter |
protected voldemort.store.cachestore.Value<byte[]> |
index |
protected voldemort.store.cachestore.Key |
indexKey |
protected voldemort.store.cachestore.Value<byte[]> |
lastIndex |
protected voldemort.store.cachestore.Key |
lastIndexKey |
protected voldemort.store.cachestore.Value<byte[]> |
lastRecord |
protected voldemort.store.cachestore.Key |
lastRecordKey |
protected voldemort.store.cachestore.impl.LogChannel |
logChannel |
protected String |
logPath |
static byte |
PARAS_LIST |
static String |
PST |
protected AtomicLong |
seqno |
protected Utils.ServerState |
state |
protected String |
storeName |
protected long |
timeout |
protected voldemort.store.cachestore.impl.CacheStore |
trxStore |
protected String |
url |
Constructor and Description |
---|
ReplicaClient() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
connect() |
Header |
createHeader() |
protected long |
findTimeout() |
int |
getBatchSize() |
String |
getLogPath() |
voldemort.store.cachestore.impl.CacheStore |
getTrxStore() |
String |
getUrl() |
protected void |
init(boolean create) |
void |
resetIndex(int lastInd,
int lastRec) |
boolean |
restart() |
void |
run() |
void |
setBatchSize(int batchSize) |
void |
setFilter(Filter filter) |
protected void |
setKey(int idx) |
void |
setTimeout(long timeout) |
void |
shutdown() |
protected void |
sleep4Time() |
String |
toString() |
protected String storeName
protected String url
protected Client client
protected AtomicLong seqno
protected voldemort.store.cachestore.impl.LogChannel logChannel
protected voldemort.store.cachestore.impl.CacheStore trxStore
protected String logPath
protected voldemort.store.cachestore.Value<byte[]> lastIndex
protected voldemort.store.cachestore.Value<byte[]> lastRecord
protected voldemort.store.cachestore.Value<byte[]> index
protected volatile Utils.ServerState state
protected voldemort.store.cachestore.Key indexKey
protected voldemort.store.cachestore.Key lastIndexKey
protected voldemort.store.cachestore.Key lastRecordKey
protected long error
protected long timeout
protected Filter filter
public static final String PST
public static final byte PARAS_LIST
protected void setKey(int idx)
public void setTimeout(long timeout)
public void setFilter(Filter filter)
protected void init(boolean create)
protected abstract void connect()
protected long findTimeout()
protected void sleep4Time()
public void shutdown()
public boolean restart()
public void resetIndex(int lastInd, int lastRec)
public String getLogPath()
public voldemort.store.cachestore.impl.CacheStore getTrxStore()
public int getBatchSize()
public void setBatchSize(int batchSize)
public String getUrl()
public Header createHeader()
Copyright © 2016. All rights reserved.