A B C D E F H I J M O P R S W

A

address(String) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

This is a optional parameter.

B

BasicAuthHttpSolrServer - Class in com.englishtown.vertx.solr.impl

Extension of HttpSolrServer which can add the basic authorization http header

BasicAuthHttpSolrServer(String) - Constructor for class com.englishtown.vertx.solr.impl.BasicAuthHttpSolrServer

BasicAuthHttpSolrServer(String, HttpClient) - Constructor for class com.englishtown.vertx.solr.impl.BasicAuthHttpSolrServer

BasicAuthHttpSolrServer(String, HttpClient, ResponseParser) - Constructor for class com.englishtown.vertx.solr.impl.BasicAuthHttpSolrServer

BasicAuthLBHttpSolrServer - Class in com.englishtown.vertx.solr.impl

Extension of LBHttpSolrServer with wrapped BasicAuthHttpSolrServer

BasicAuthLBHttpSolrServer(String...) - Constructor for class com.englishtown.vertx.solr.impl.BasicAuthLBHttpSolrServer

BasicAuthLBHttpSolrServer(HttpClient, String...) - Constructor for class com.englishtown.vertx.solr.impl.BasicAuthLBHttpSolrServer

The provided httpClient should use a multi-threaded connection manager

BasicAuthLBHttpSolrServer(HttpClient, ResponseParser, String...) - Constructor for class com.englishtown.vertx.solr.impl.BasicAuthLBHttpSolrServer

The provided httpClient should use a multi-threaded connection manager

C

com.englishtown.vertx.solr - package com.englishtown.vertx.solr

com.englishtown.vertx.solr.hk2 - package com.englishtown.vertx.solr.hk2

com.englishtown.vertx.solr.impl - package com.englishtown.vertx.solr.impl

com.englishtown.vertx.solr.streams - package com.englishtown.vertx.solr.streams

com.englishtown.vertx.solr.streams.impl - package com.englishtown.vertx.solr.streams.impl

CONFIG_SERVER_TYPE - Static variable in class com.englishtown.vertx.solr.impl.JsonConfigSolrConfigurator

CONFIG_SERVER_URL - Static variable in class com.englishtown.vertx.solr.impl.JsonConfigSolrConfigurator

CONFIG_SERVER_URLS - Static variable in class com.englishtown.vertx.solr.impl.JsonConfigSolrConfigurator

configure() - Method in class com.englishtown.vertx.solr.hk2.SolrBinder

Implement to provide binding definitions using the exposed binding methods.

createMethod(SolrRequest) - Method in class com.englishtown.vertx.solr.impl.BasicAuthHttpSolrServer

createPump(ReadJsonStream<?>, WriteJsonStream<?>) - Static method in class com.englishtown.vertx.solr.streams.impl.SolrPump

Pumps data from a ReadJsonStream to a WriteJsonStream and performs flow control where necessary to prevent the write stream buffer from getting overfull.

createPump(ReadJsonStream<?>, WriteJsonStream<?>, int) - Static method in class com.englishtown.vertx.solr.streams.impl.SolrPump

Create a new SolrDataPump with the given ReadJsonStream and WriteJsonStream and writeQueueMaxSize

createSolrServer() - Method in class com.englishtown.vertx.solr.impl.JsonConfigSolrConfigurator

createSolrServer() - Method in interface com.englishtown.vertx.solr.SolrConfigurator

CursorMarkReadJsonStream - Class in com.englishtown.vertx.solr.streams.impl

CursorMark implementation of ReadJsonStreamBase using CursorMark to paginate json Solr results

CursorMarkReadJsonStream() - Constructor for class com.englishtown.vertx.solr.streams.impl.CursorMarkReadJsonStream

D

dataHandler(Handler<JsonObject>) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

This method starts the SolrPump.

DEFAULT_ADDRESS - Static variable in class com.englishtown.vertx.solr.SolrVerticle

DEFAULT_SERVER_TYPE - Static variable in class com.englishtown.vertx.solr.impl.JsonConfigSolrConfigurator

DefaultSolrQuerySerializer - Class in com.englishtown.vertx.solr.impl

Default implementation of SolrQuerySerializer

DefaultSolrQuerySerializer() - Constructor for class com.englishtown.vertx.solr.impl.DefaultSolrQuerySerializer

deserialize(JsonObject) - Method in class com.englishtown.vertx.solr.impl.DefaultSolrQuerySerializer

deserialize(JsonObject) - Method in interface com.englishtown.vertx.solr.SolrQuerySerializer

doQuery(Message<JsonObject>) - Method in class com.englishtown.vertx.solr.SolrVerticle

drainHandler - Variable in class com.englishtown.vertx.solr.streams.impl.WriteJsonStreamBase

drainHandler(Handler<Void>) - Method in class com.englishtown.vertx.solr.streams.impl.WriteJsonStreamBase

E

endHandler(Handler<Void>) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

endHandler(Handler<Void>) - Method in interface com.englishtown.vertx.solr.streams.ReadJsonStream

Set an end handler.

eventBus(EventBus) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

This is a required parameter.

exceptionHandler(Handler<Throwable>) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

exceptionHandler - Variable in class com.englishtown.vertx.solr.streams.impl.WriteJsonStreamBase

exceptionHandler(Handler<Throwable>) - Method in class com.englishtown.vertx.solr.streams.impl.WriteJsonStreamBase

F

FIELD_ACTION - Static variable in class com.englishtown.vertx.solr.SolrVerticle

FIELD_QUERY - Static variable in class com.englishtown.vertx.solr.SolrVerticle

H

handle(Message<JsonObject>) - Method in class com.englishtown.vertx.solr.SolrVerticle

Event bus json message handler

handleEnd() - Method in class com.englishtown.vertx.solr.streams.impl.WriteJsonStreamBase

handleReply(JsonObject) - Method in class com.englishtown.vertx.solr.streams.impl.CursorMarkReadJsonStream

handleReply(JsonObject) - Method in class com.englishtown.vertx.solr.streams.impl.OffsetReadJsonStream

handleReply(JsonObject) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

Pagination looping logic - continuously runs through a doQuery loop until all results have been streamed

I

init(Container) - Method in class com.englishtown.vertx.solr.impl.JsonConfigSolrConfigurator

isComplete(JsonObject) - Method in class com.englishtown.vertx.solr.streams.impl.CursorMarkReadJsonStream

isComplete(JsonObject) - Method in class com.englishtown.vertx.solr.streams.impl.OffsetReadJsonStream

isComplete(JsonObject) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

J

JsonConfigSolrConfigurator - Class in com.englishtown.vertx.solr.impl

Vert.x json configuration implementation

JsonConfigSolrConfigurator(Container) - Constructor for class com.englishtown.vertx.solr.impl.JsonConfigSolrConfigurator

M

makeServer(String) - Method in class com.englishtown.vertx.solr.impl.BasicAuthLBHttpSolrServer

O

objectsPumped() - Method in class com.englishtown.vertx.solr.streams.impl.SolrPump

Return the total number of Json objects pumped by this pump.

OffsetReadJsonStream - Class in com.englishtown.vertx.solr.streams.impl

Implementation of ReadJsonStreamBase using an integer offset to paginate json Solr results

OffsetReadJsonStream() - Constructor for class com.englishtown.vertx.solr.streams.impl.OffsetReadJsonStream

P

pause() - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

R

ReadJsonStream<T> - Interface in com.englishtown.vertx.solr.streams

Represents a stream of Json data that can be read from.

ReadJsonStreamBase<T extends ReadJsonStreamBase<T>> - Class in com.englishtown.vertx.solr.streams.impl

Base implementation of ReadJsonStream

ReadJsonStreamBase() - Constructor for class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

resume() - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

S

serialize(SolrQuery) - Method in class com.englishtown.vertx.solr.impl.DefaultSolrQuerySerializer

serialize(SolrQuery) - Method in interface com.englishtown.vertx.solr.SolrQuerySerializer

serializer(SolrQuerySerializer) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

This is a required parameter.

setQueryStart(SolrQuery) - Method in class com.englishtown.vertx.solr.streams.impl.CursorMarkReadJsonStream

setQueryStart(SolrQuery) - Method in class com.englishtown.vertx.solr.streams.impl.OffsetReadJsonStream

setQueryStart(SolrQuery) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

Set the query start point for pagination.

setWriteQueueMaxSize(int) - Method in class com.englishtown.vertx.solr.streams.impl.SolrPump

Set the write queue max size to writeQueueMaxSize

SolrBinder - Class in com.englishtown.vertx.solr.hk2

HK2 binder for solr

SolrBinder() - Constructor for class com.englishtown.vertx.solr.hk2.SolrBinder

SolrConfigurator - Interface in com.englishtown.vertx.solr

Provides solr configuration

SolrPump - Class in com.englishtown.vertx.solr.streams.impl

A Solr implementation of the vertx Pump using JsonObjects instead of Buffers

solrQuery(SolrQuery) - Method in class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

This is a required parameter.

SolrQuerySerializer - Interface in com.englishtown.vertx.solr

Serialize/deserialize solr queries to json

SolrVerticle - Class in com.englishtown.vertx.solr

Solr client worker verticle

SolrVerticle(SolrConfigurator, SolrQuerySerializer) - Constructor for class com.englishtown.vertx.solr.SolrVerticle

start() - Method in class com.englishtown.vertx.solr.SolrVerticle

start() - Method in class com.englishtown.vertx.solr.streams.impl.SolrPump

Start the Pump.

stop() - Method in class com.englishtown.vertx.solr.SolrVerticle

stop() - Method in class com.englishtown.vertx.solr.streams.impl.SolrPump

Stop the SolrDataPump.

W

write(JsonObject) - Method in interface com.englishtown.vertx.solr.streams.WriteJsonStream

Write some data to the stream.

WriteJsonStream<T> - Interface in com.englishtown.vertx.solr.streams

Represents a stream of Json data that can be written to

WriteJsonStreamBase<T extends WriteJsonStreamBase> - Class in com.englishtown.vertx.solr.streams.impl

Abstract default implementation of WriteJsonStream

WriteJsonStreamBase() - Constructor for class com.englishtown.vertx.solr.streams.impl.WriteJsonStreamBase

A B C D E F H I J M O P R S W