Package org.apache.solr.crossdc.common
Interface RequestMirroringSink
-
- All Known Implementing Classes:
KafkaMirroringSink
public interface RequestMirroringSink
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
submit(MirroredSolrRequest<?> request)
Submits a mirrored solr request to the appropriate end-point such that it is eventually received by solr A direct sink may simply use CloudSolrServer to process requests directly.void
submitToDlq(MirroredSolrRequest<?> request)
-
-
-
Method Detail
-
submit
void submit(MirroredSolrRequest<?> request) throws MirroringException
Submits a mirrored solr request to the appropriate end-point such that it is eventually received by solr A direct sink may simply use CloudSolrServer to process requests directly. A queueing sink will serialize the request and submit it to a queue for later consumption- Parameters:
request
- the request that is to be mirrored- Throws:
MirroringException
- Implementations may throw an exception
-
submitToDlq
void submitToDlq(MirroredSolrRequest<?> request) throws MirroringException
- Throws:
MirroringException
-
-