com.dynatrace.openkit.core.caching

Class BeaconCacheImpl

java.lang.Object

java.util.Observable

com.dynatrace.openkit.core.caching.BeaconCacheImpl

All Implemented Interfaces:

BeaconCache

public class BeaconCacheImpl
extends java.util.Observable
implements BeaconCache

Class used in OpenKit to cache serialized Beacon data.

This cache needs to deal with high concurrency, since it's possible that a lot of threads insert new data concurrently. Furthermore two OpenKit internal threads are also accessing the cache.

Constructor Summary

Constructors

Constructor and Description
BeaconCacheImpl(Logger logger) Create BeaconCache.

Method Summary

Modifier and Type	Method and Description
void	addActionData(java.lang.Integer beaconID, long timestamp, java.lang.String data) Add action data for a given beaconID to this cache.
void	addEventData(java.lang.Integer beaconID, long timestamp, java.lang.String data) Add event data for a given beaconID to this cache.
void	deleteCacheEntry(java.lang.Integer beaconID) Delete a cache entry for a given beaconID.
int	evictRecordsByAge(java.lang.Integer beaconID, long minTimestamp) Evict beacon cache records by age for a given beacon.
int	evictRecordsByNumber(java.lang.Integer beaconID, int numRecords) Evict beacon cache records by number for given beacon.
java.lang.String[]	getActions(java.lang.Integer beaconID) Get a shallow copy of actions collected so far.
java.util.Set<java.lang.Integer>	getBeaconIDs() Get a Set of currently inserted Beacon ids.
java.lang.String[]	getEvents(java.lang.Integer beaconID) Get a shallow copy of events collected so far.
java.lang.String	getNextBeaconChunk(java.lang.Integer beaconID, java.lang.String chunkPrefix, int maxSize, char delimiter) Get the next chunk for sending to the backend.
long	getNumBytesInCache() Get number of bytes currently stored in cache.
boolean	isEmpty(java.lang.Integer beaconID) Tests if an cached entry for beaconID is empty.
void	removeChunkedData(java.lang.Integer beaconID) Remove all data that was previously included in chunks.
void	resetChunkedData(java.lang.Integer beaconID) Reset all data that was previously included in chunks.

Methods inherited from class java.util.Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.dynatrace.openkit.core.caching.BeaconCache

addObserver

Constructor Detail

BeaconCacheImpl

public BeaconCacheImpl(Logger logger)

Create BeaconCache.

Parameters:

logger -

Method Detail

addEventData

public void addEventData(java.lang.Integer beaconID,
                         long timestamp,
                         java.lang.String data)

Description copied from interface: BeaconCache

Add event data for a given beaconID to this cache.

All registered observers are notified, after the event data has been added.

Specified by:

addEventData in interface BeaconCache

Parameters:

beaconID - The beacon's ID (aka Session ID) for which to add event data.

timestamp - The data's timestamp.

data - serialized event data to add.

addActionData

public void addActionData(java.lang.Integer beaconID,
                          long timestamp,
                          java.lang.String data)

Description copied from interface: BeaconCache

Add action data for a given beaconID to this cache.

Specified by:

addActionData in interface BeaconCache

Parameters:

beaconID - The beacon's ID (aka Session ID) for which to add action data.

timestamp - The data's timestamp.

data - serialized action data to add.

deleteCacheEntry

public void deleteCacheEntry(java.lang.Integer beaconID)

Description copied from interface: BeaconCache

Delete a cache entry for a given beaconID.

Specified by:

deleteCacheEntry in interface BeaconCache

Parameters:

beaconID - The beacon's ID (aka Session ID) which to delete.

getNextBeaconChunk

public java.lang.String getNextBeaconChunk(java.lang.Integer beaconID,
                                           java.lang.String chunkPrefix,
                                           int maxSize,
                                           char delimiter)

Description copied from interface: BeaconCache

Get the next chunk for sending to the backend.

Note: This method must only be invoked from the beacon sending thread.

Specified by:

getNextBeaconChunk in interface BeaconCache

Parameters:

beaconID - The beacon id for which to get the next chunk.

chunkPrefix - Prefix to append to the beginning of the chunk.

maxSize - Maximum chunk size. As soon as chunk's size is greater than or equal to maxSize result is returned.

delimiter - Delimiter between consecutive chunks.

Returns:

null if given beaconID does not exist, an empty string, if there is no more data to send or the next chunk to send.

removeChunkedData

public void removeChunkedData(java.lang.Integer beaconID)

Description copied from interface: BeaconCache

Remove all data that was previously included in chunks.

This method must be called, when data retrieved via BeaconCache.getNextBeaconChunk(Integer, String, int, char) was successfully sent to the backend, otherwise subsequent calls to BeaconCache.getNextBeaconChunk(Integer, String, int, char) will retrieve the same data again and again.

Note: This method must only be invoked from the beacon sending thread.

Specified by:

removeChunkedData in interface BeaconCache

Parameters:

beaconID - The beacon id for which to remove already chunked data.

resetChunkedData

public void resetChunkedData(java.lang.Integer beaconID)

Description copied from interface: BeaconCache

Reset all data that was previously included in chunks.

Note: This method must only be invoked from the beacon sending thread.

Specified by:

resetChunkedData in interface BeaconCache

Parameters:

beaconID - The beacon id for which to remove already chunked data.

getEvents

public java.lang.String[] getEvents(java.lang.Integer beaconID)

Get a shallow copy of events collected so far.

Although this method is intended for debugging purposes only, it still does appropriate locking.

Parameters:

beaconID - The beacon id for which to retrieve the events.

Returns:

List of event data.

getActions

public java.lang.String[] getActions(java.lang.Integer beaconID)

Get a shallow copy of actions collected so far.

Although this method is intended for debugging purposes only, it still does appropriate locking.

Parameters:

beaconID - The beacon id for which to retrieve the events.

Returns:

List of event data.

getBeaconIDs

public java.util.Set<java.lang.Integer> getBeaconIDs()

Description copied from interface: BeaconCache

Get a Set of currently inserted Beacon ids.

The return value is a snapshot of currently inserted beacon ids. All changes made after this call are not reflected in the returned Set.

Specified by:

getBeaconIDs in interface BeaconCache

Returns:

Snapshot of all beacon ids in the cache.

evictRecordsByAge

public int evictRecordsByAge(java.lang.Integer beaconID,
                             long minTimestamp)

Description copied from interface: BeaconCache

Evict beacon cache records by age for a given beacon.

Specified by:

evictRecordsByAge in interface BeaconCache

Parameters:

beaconID - The beacon's identifier.

minTimestamp - The minimum timestamp allowed.

Returns:

Returns the number of evicted cache records.

evictRecordsByNumber

public int evictRecordsByNumber(java.lang.Integer beaconID,
                                int numRecords)

Description copied from interface: BeaconCache

Evict beacon cache records by number for given beacon.

Specified by:

evictRecordsByNumber in interface BeaconCache

Parameters:

beaconID - The beacon's identifier.

numRecords - The maximum number of records to evict.

Returns:

Returns the number of evicted cache records.

getNumBytesInCache

public long getNumBytesInCache()

Description copied from interface: BeaconCache

Get number of bytes currently stored in cache.

Specified by:

getNumBytesInCache in interface BeaconCache

Returns:

Number of bytes currently stored in cache.

isEmpty

public boolean isEmpty(java.lang.Integer beaconID)

Description copied from interface: BeaconCache

Tests if an cached entry for beaconID is empty.

Specified by:

isEmpty in interface BeaconCache

Parameters:

beaconID - beaconID The beacon's identifier.

Returns:

true if the cached entry is empty, false otherwise.