Package org.apache.solr.handler.admin.api

Class ReplicationAPIBase

java.lang.Object

org.apache.solr.api.JerseyResource

org.apache.solr.handler.admin.api.ReplicationAPIBase

Direct Known Subclasses:

CoreReplication

public abstract class ReplicationAPIBase
extends JerseyResource

A common parent for "replication" (i.e. replication-level) APIs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ReplicationAPIBase.DirectoryFileStream	This class is used to read and send files in the lucene index
protected class	ReplicationAPIBase.LocalFsConfFileStream
protected class	ReplicationAPIBase.LocalFsFileStream	This is used to write files in the conf directory.
protected class	ReplicationAPIBase.LocalFsTlogFileStream

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHECKSUM
static final String	COMPRESSION
static final String	CONF_FILE_SHORT
static final String	FILE
static final String	FILE_STREAM
static final String	GENERATION
static final String	INTERVAL_ERR_MSG
static final Pattern	INTERVAL_PATTERN
static final String	LEN
static final String	MAX_WRITE_PER_SECOND
static final String	OFFSET
static final int	PACKET_SZ
static final String	POLL_INTERVAL
protected final SolrCore	solrCore
protected final SolrQueryRequest	solrQueryRequest
protected final SolrQueryResponse	solrQueryResponse
static final String	STATUS
static final String	TLOG_FILE

Fields inherited from class org.apache.solr.api.JerseyResource

containerRequestContext

Constructor Summary

Constructors

Constructor	Description
ReplicationAPIBase(SolrCore solrCore, SolrQueryRequest solrQueryRequest, SolrQueryResponse solrQueryResponse)

Method Summary

Modifier and Type	Method	Description
protected ReplicationAPIBase.DirectoryFileStream	doFetchFile(String filePath, String dirType, String offset, String len, boolean compression, boolean checksum, double maxWriteMBPerSec, Long gen)
protected FileListResponse	doFetchFileList(long generation)
protected IndexVersionResponse	doFetchIndexVersion()
protected FileListResponse	getFileList(long generation, ReplicationHandler replicationHandler)

Methods inherited from class org.apache.solr.api.JerseyResource

ensureRequiredParameterProvided, ensureRequiredRequestBodyProvided, instantiateJerseyResponse, instantiateJerseyResponse

Methods inherited from class java.lang.Object

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

Field Details

CONF_FILE_SHORT

public static final String CONF_FILE_SHORT

See Also:

• Constant Field Values

TLOG_FILE

public static final String TLOG_FILE

See Also:

• Constant Field Values

FILE_STREAM

public static final String FILE_STREAM

See Also:

• Constant Field Values

STATUS

public static final String STATUS

See Also:

• Constant Field Values

PACKET_SZ

public static final int PACKET_SZ

See Also:

• Constant Field Values

GENERATION

public static final String GENERATION

See Also:

• Constant Field Values

OFFSET

public static final String OFFSET

See Also:

• Constant Field Values

LEN

public static final String LEN

See Also:

• Constant Field Values

FILE

public static final String FILE

See Also:

• Constant Field Values

MAX_WRITE_PER_SECOND

public static final String MAX_WRITE_PER_SECOND

See Also:

• Constant Field Values

CHECKSUM

public static final String CHECKSUM

See Also:

• Constant Field Values

COMPRESSION

public static final String COMPRESSION

See Also:

• Constant Field Values

POLL_INTERVAL

public static final String POLL_INTERVAL

See Also:

• Constant Field Values

INTERVAL_ERR_MSG

public static final String INTERVAL_ERR_MSG

See Also:

• Constant Field Values

INTERVAL_PATTERN

public static final Pattern INTERVAL_PATTERN

solrCore

protected final SolrCore solrCore

solrQueryRequest

protected final SolrQueryRequest solrQueryRequest

solrQueryResponse

protected final SolrQueryResponse solrQueryResponse

Constructor Details

ReplicationAPIBase

public ReplicationAPIBase(SolrCore solrCore,
 SolrQueryRequest solrQueryRequest,
 SolrQueryResponse solrQueryResponse)

Method Details

doFetchIndexVersion

protected IndexVersionResponse doFetchIndexVersion()
                                            throws IOException

Throws:

IOException

doFetchFileList

protected FileListResponse doFetchFileList(long generation)

doFetchFile

protected ReplicationAPIBase.DirectoryFileStream doFetchFile(String filePath,
 String dirType,
 String offset,
 String len,
 boolean compression,
 boolean checksum,
 double maxWriteMBPerSec,
 Long gen)

getFileList

protected FileListResponse getFileList(long generation,
 ReplicationHandler replicationHandler)