Package com.agido.logback.elasticsearch.writer

Class ElasticsearchWriter

java.lang.Object

com.agido.logback.elasticsearch.writer.ElasticsearchWriter

All Implemented Interfaces:

SafeWriter

public class ElasticsearchWriter
extends Object
implements SafeWriter

Constructor Summary

Constructors

Constructor	Description
ElasticsearchWriter(ErrorReporter errorReporter, Settings settings, HttpRequestHeaders headers)

Method Summary

Modifier and Type	Method	Description
ErrorReporter	getErrorReporter()
Collection<HttpRequestHeader>	getHeaderList()
StringBuilder	getSendBuffer()
Settings	getSettings()
boolean	hasPendingData()
boolean	isBufferExceeded()
void	sendData()
void	setBufferExceeded(boolean bufferExceeded)
protected String	slurpErrors(HttpURLConnection urlConnection)
void	write(char[] cbuf, int off, int len)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ElasticsearchWriter

public ElasticsearchWriter(ErrorReporter errorReporter,
 Settings settings,
 HttpRequestHeaders headers)

Method Details

write

public void write(char[] cbuf,
 int off,
 int len)

Specified by:

write in interface SafeWriter

sendData

public void sendData()
              throws IOException

Specified by:

sendData in interface SafeWriter

Throws:

IOException

hasPendingData

public boolean hasPendingData()

Specified by:

hasPendingData in interface SafeWriter

slurpErrors

protected String slurpErrors(HttpURLConnection urlConnection)

getSendBuffer

public StringBuilder getSendBuffer()

getSettings

public Settings getSettings()

getHeaderList

public Collection<HttpRequestHeader> getHeaderList()

getErrorReporter

public ErrorReporter getErrorReporter()

isBufferExceeded

public boolean isBufferExceeded()

setBufferExceeded

public void setBufferExceeded(boolean bufferExceeded)