Package org.apache.solr.crossdc.common

Interface RequestMirroringSink

All Known Implementing Classes:

KafkaMirroringSink

public interface RequestMirroringSink

Method Summary

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 Details

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