public abstract class ErrorStore extends Object
Constructor and Description |
---|
ErrorStore() |
Modifier and Type | Method and Description |
---|---|
protected ErrorEntry |
constructErrorEntry(int id,
long timestamp,
String siddhiAppName,
String streamName,
byte[] eventAsBytes,
String cause,
byte[] stackTraceAsBytes,
byte[] originalPayloadAsBytes,
ErrorOccurrence errorOccurrence,
ErroneousEventType erroneousEventType,
ErrorType errorType) |
abstract void |
discardErrorEntries(String siddhiAppName) |
abstract void |
discardErrorEntry(int id) |
abstract int |
getErrorEntriesCount(String siddhiAppName) |
protected com.lmax.disruptor.EventHandler<PublishableErrorEntry>[] |
getEventHandler() |
abstract int |
getTotalErrorEntriesCount() |
abstract List<ErrorEntry> |
loadErrorEntries(String siddhiAppName,
Map<String,String> queryParams) |
abstract ErrorEntry |
loadErrorEntry(int id) |
protected void |
produce(long timestamp,
String siddhiAppName,
String streamName,
byte[] eventAsBytes,
String cause,
byte[] stackTraceAsBytes,
byte[] originalPayloadAsBytes,
String errorOccurrence,
String eventType,
String errorType) |
abstract void |
purge(Map retentionPolicyParams) |
protected void |
save(String siddhiAppName,
String streamName,
ErroneousEvent erroneousEvent,
ErroneousEventType eventType,
ErrorOccurrence errorOccurrence,
ErrorType errorType) |
protected abstract void |
saveEntry(long timestamp,
String siddhiAppName,
String streamName,
byte[] eventAsBytes,
String cause,
byte[] stackTraceAsBytes,
byte[] originalPayloadAsBytes,
String errorOccurrence,
String eventType,
String errorType) |
void |
saveMappingError(String siddhiAppName,
List<ErroneousEvent> erroneousEvents,
String streamName) |
void |
saveTransportError(String siddhiAppName,
ErroneousEvent erroneousEvent,
ErroneousEventType eventType,
String streamName,
ErrorOccurrence errorOccurrence) |
void |
setBufferSize(int bufferSize) |
void |
setDropWhenBufferFull(boolean dropWhenBufferFull) |
abstract void |
setProperties(Map properties) |
protected void produce(long timestamp, String siddhiAppName, String streamName, byte[] eventAsBytes, String cause, byte[] stackTraceAsBytes, byte[] originalPayloadAsBytes, String errorOccurrence, String eventType, String errorType)
protected com.lmax.disruptor.EventHandler<PublishableErrorEntry>[] getEventHandler()
public abstract void setProperties(Map properties)
public void setBufferSize(int bufferSize)
public void setDropWhenBufferFull(boolean dropWhenBufferFull)
public void saveMappingError(String siddhiAppName, List<ErroneousEvent> erroneousEvents, String streamName)
public void saveTransportError(String siddhiAppName, ErroneousEvent erroneousEvent, ErroneousEventType eventType, String streamName, ErrorOccurrence errorOccurrence)
protected void save(String siddhiAppName, String streamName, ErroneousEvent erroneousEvent, ErroneousEventType eventType, ErrorOccurrence errorOccurrence, ErrorType errorType) throws ErrorStoreException
ErrorStoreException
protected abstract void saveEntry(long timestamp, String siddhiAppName, String streamName, byte[] eventAsBytes, String cause, byte[] stackTraceAsBytes, byte[] originalPayloadAsBytes, String errorOccurrence, String eventType, String errorType) throws ErrorStoreException
ErrorStoreException
public abstract List<ErrorEntry> loadErrorEntries(String siddhiAppName, Map<String,String> queryParams)
public abstract ErrorEntry loadErrorEntry(int id)
protected ErrorEntry constructErrorEntry(int id, long timestamp, String siddhiAppName, String streamName, byte[] eventAsBytes, String cause, byte[] stackTraceAsBytes, byte[] originalPayloadAsBytes, ErrorOccurrence errorOccurrence, ErroneousEventType erroneousEventType, ErrorType errorType) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public abstract void discardErrorEntry(int id)
public abstract void discardErrorEntries(String siddhiAppName)
public abstract int getTotalErrorEntriesCount()
public abstract int getErrorEntriesCount(String siddhiAppName)
public abstract void purge(Map retentionPolicyParams)
Copyright © 2021. All rights reserved.