Constructor and Description |
---|
HttpPostEmitter(HttpEmitterConfig config,
org.asynchttpclient.AsyncHttpClient client) |
HttpPostEmitter(HttpEmitterConfig config,
org.asynchttpclient.AsyncHttpClient client,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
emit(Event event) |
void |
flush() |
ConcurrentTimeCounter |
getBatchFillingTimeCounter() |
int |
getBuffersToEmit() |
int |
getBuffersToReuse() |
int |
getDroppedBuffers() |
long |
getEventsToEmit() |
int |
getFailedBuffers() |
ConcurrentTimeCounter |
getFailedSendingTimeCounter() |
long |
getLargeEventsToEmit() |
ConcurrentTimeCounter |
getSuccessfulSendingTimeCounter() |
int |
getTotalAllocatedBuffers()
This and the following methods are public for external monitoring purposes.
|
long |
getTotalEmittedEvents() |
void |
start() |
String |
toString() |
public HttpPostEmitter(HttpEmitterConfig config, org.asynchttpclient.AsyncHttpClient client)
public HttpPostEmitter(HttpEmitterConfig config, org.asynchttpclient.AsyncHttpClient client, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
public void flush() throws IOException
flush
in interface Emitter
flush
in interface Flushable
IOException
public void close() throws IOException
close
in interface Emitter
close
in interface Closeable
close
in interface AutoCloseable
IOException
public int getTotalAllocatedBuffers()
public int getBuffersToEmit()
public int getBuffersToReuse()
public int getFailedBuffers()
public int getDroppedBuffers()
public long getTotalEmittedEvents()
public long getEventsToEmit()
public long getLargeEventsToEmit()
public ConcurrentTimeCounter getBatchFillingTimeCounter()
public ConcurrentTimeCounter getSuccessfulSendingTimeCounter()
public ConcurrentTimeCounter getFailedSendingTimeCounter()
Copyright © 2011–2018. All rights reserved.