C D E F G H I M P Q R S T

C

close() - Method in class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceClient

close() - Method in interface info.pascalkrause.vertx.datacollector.service.DataCollectorService

Is needed for the proxy generation

close() - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceImpl

close() - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxEBProxy

close() - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxProxyHandler

collect(String, JsonObject, Handler<AsyncResult<Void>>) - Method in class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceClient

collect(String, JsonObject) - Method in interface info.pascalkrause.vertx.datacollector.job.CollectorJob

This method should be used to create a Future that contains the collection logic.

collect(String, JsonObject, Handler<AsyncResult<Void>>) - Method in interface info.pascalkrause.vertx.datacollector.service.DataCollectorService

This method is doing the same as DataCollectorService.collectAndReceive(String, JsonObject, Handler), but will not send back the result.

collect(String, JsonObject, Handler<AsyncResult<Void>>) - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceImpl

collect(String, JsonObject, Handler<AsyncResult<Void>>) - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxEBProxy

collectAndReceive(String, JsonObject, Handler<AsyncResult<CollectorJobResult>>) - Method in class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceClient

collectAndReceive(String, JsonObject, Handler<AsyncResult<CollectorJobResult>>) - Method in interface info.pascalkrause.vertx.datacollector.service.DataCollectorService

This method triggers a CollectorJob and receives the CollectorJobResult in the passed result handler.

collectAndReceive(String, JsonObject, Handler<AsyncResult<CollectorJobResult>>) - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceImpl

collectAndReceive(String, JsonObject, Handler<AsyncResult<CollectorJobResult>>) - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxEBProxy

CollectorJob - Interface in info.pascalkrause.vertx.datacollector.job

A generic interface which must be implemented to run the collection job inside the CollectorJobExecutor worker pool.

CollectorJobResult - Class in info.pascalkrause.vertx.datacollector.job

CollectorJobResult(JsonObject) - Constructor for class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

Is used by the generated DataCollectorService proxy.

CollectorJobResult(String, String, String, String, JsonObject, CollectorJobResult.Error) - Constructor for class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

This class stores the information which will be collected in the CollectorJob implementation.

CollectorJobResult.Error - Class in info.pascalkrause.vertx.datacollector.job

The class CollectorJobResult.Error can be used to store all error related information which occur during the processing of the CollectorJob implementation.

create() - Method in class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceFactory

create(DeliveryOptions) - Method in class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceFactory

D

DataCollectorError - Class in info.pascalkrause.vertx.datacollector.client.error

DataCollectorError() - Constructor for class info.pascalkrause.vertx.datacollector.client.error.DataCollectorError

DataCollectorService - Interface in info.pascalkrause.vertx.datacollector.service

DataCollectorServiceClient - Class in info.pascalkrause.vertx.datacollector.client

DataCollectorServiceClient(DataCollectorService) - Constructor for class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceClient

DataCollectorServiceFactory - Class in info.pascalkrause.vertx.datacollector.client

DataCollectorServiceFactory(Vertx, String) - Constructor for class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceFactory

DataCollectorServiceImpl - Class in info.pascalkrause.vertx.datacollector.service

DataCollectorServiceImpl(Vertx, CollectorJob, int, int, boolean, long, String) - Constructor for class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceImpl

DataCollectorServiceVerticle - Class in info.pascalkrause.vertx.datacollector

DataCollectorServiceVerticle(String, CollectorJob, int, int, boolean) - Constructor for class info.pascalkrause.vertx.datacollector.DataCollectorServiceVerticle

DataCollectorServiceVerticle(String, CollectorJob, int, int, boolean, long) - Constructor for class info.pascalkrause.vertx.datacollector.DataCollectorServiceVerticle

DataCollectorServiceVertxEBProxy - Class in info.pascalkrause.vertx.datacollector.service

DataCollectorServiceVertxEBProxy(Vertx, String) - Constructor for class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxEBProxy

DataCollectorServiceVertxEBProxy(Vertx, String, DeliveryOptions) - Constructor for class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxEBProxy

DataCollectorServiceVertxProxyHandler - Class in info.pascalkrause.vertx.datacollector.service

DataCollectorServiceVertxProxyHandler(Vertx, DataCollectorService) - Constructor for class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxProxyHandler

DataCollectorServiceVertxProxyHandler(Vertx, DataCollectorService, long) - Constructor for class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxProxyHandler

DataCollectorServiceVertxProxyHandler(Vertx, DataCollectorService, boolean, long) - Constructor for class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxProxyHandler

DEFAULT_CONNECTION_TIMEOUT - Static variable in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxProxyHandler

E

equals(Object) - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

Error(String) - Constructor for class info.pascalkrause.vertx.datacollector.job.CollectorJobResult.Error

ERROR_QUEUE_LIMIT_REACHED - Static variable in interface info.pascalkrause.vertx.datacollector.service.DataCollectorService

F

fromJson(JsonObject) - Static method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult.Error

G

getCreated() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

getError() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

getMetricsSnapshot(Handler<AsyncResult<JsonObject>>) - Method in class info.pascalkrause.vertx.datacollector.client.DataCollectorServiceClient

getMetricsSnapshot() - Method in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

getMetricsSnapshot(Handler<AsyncResult<JsonObject>>) - Method in interface info.pascalkrause.vertx.datacollector.service.DataCollectorService

Returns a JsonObject which contains a current snapshot of the metrics.

getMetricsSnapshot() - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceImpl

Visible for Testing

getMetricsSnapshot(Handler<AsyncResult<JsonObject>>) - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceImpl

getMetricsSnapshot(Handler<AsyncResult<JsonObject>>) - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxEBProxy

getName() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult.Error

getQuality() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

getRequestId() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

getResult() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

getServiceAddress() - Method in class info.pascalkrause.vertx.datacollector.DataCollectorServiceVerticle

getSource() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

H

handle(Message<JsonObject>) - Method in class info.pascalkrause.vertx.datacollector.service.DataCollectorServiceVertxProxyHandler

hashCode() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

I

info.pascalkrause.vertx.datacollector - package info.pascalkrause.vertx.datacollector

info.pascalkrause.vertx.datacollector.client - package info.pascalkrause.vertx.datacollector.client

info.pascalkrause.vertx.datacollector.client.error - package info.pascalkrause.vertx.datacollector.client.error

info.pascalkrause.vertx.datacollector.job - package info.pascalkrause.vertx.datacollector.job

info.pascalkrause.vertx.datacollector.metrics - package info.pascalkrause.vertx.datacollector.metrics

info.pascalkrause.vertx.datacollector.service - package info.pascalkrause.vertx.datacollector.service

init(Vertx, Context) - Method in class info.pascalkrause.vertx.datacollector.DataCollectorServiceVerticle

M

METRIC_QUEUE_FREE - Static variable in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

METRIC_QUEUE_MAX_SIZE - Static variable in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

METRIC_QUEUE_OCCUPIED - Static variable in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

METRIC_TOTAL_JOBS_COUNT - Static variable in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

METRIC_TOTAL_JOBS_EXCEPTION - Static variable in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

METRIC_TOTAL_JOBS_FAILED - Static variable in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

METRIC_TOTAL_JOBS_SUCCEEDED - Static variable in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

MetricSnapshotFactory - Class in info.pascalkrause.vertx.datacollector.metrics

MetricSnapshotFactory(MetricRegistry) - Constructor for class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

P

postCollectAction(AsyncResult<CollectorJobResult>) - Method in interface info.pascalkrause.vertx.datacollector.job.CollectorJob

This method will be called after the CollectorJob.collect(String, JsonObject) method and returns a Future which can be used to do some post-collect stuff like rough parsing or saving the result into a database.

Q

QueueLimitReached - Class in info.pascalkrause.vertx.datacollector.client.error

QueueLimitReached() - Constructor for class info.pascalkrause.vertx.datacollector.client.error.QueueLimitReached

R

registerQueueMetrics(AtomicInteger, int) - Method in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

registerTotalMetrics(AsyncResult<CollectorJobResult>) - Method in class info.pascalkrause.vertx.datacollector.metrics.MetricSnapshotFactory

S

start(Future<Void>) - Method in class info.pascalkrause.vertx.datacollector.DataCollectorServiceVerticle

stop(Future<Void>) - Method in class info.pascalkrause.vertx.datacollector.DataCollectorServiceVerticle

T

toJson() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

toString() - Method in class info.pascalkrause.vertx.datacollector.job.CollectorJobResult

C D E F G H I M P Q R S T