org.kaaproject.kaa.client.logging.memory

Class MemLogStorage

java.lang.Object

org.kaaproject.kaa.client.logging.memory.MemLogStorage

All Implemented Interfaces:

LogStorage, LogStorageStatus

public class MemLogStorage
extends Object
implements LogStorage, LogStorageStatus

Constructor Summary

Constructors

Constructor and Description
MemLogStorage()
MemLogStorage(long bucketSize, int bucketRecordCount)
MemLogStorage(long maxStorageSize, long bucketSize, int bucketRecordCount)

Method Summary

Methods

Modifier and Type	Method and Description
void	addLogRecord(LogRecord record) Persists new log record.
void	close() Closes log storage and releases all used resources (if any)
long	getConsumedVolume() Retrieves current log storage size used by added records.
LogBlock	getRecordBlock(long blockSize, int batchCount) Retrieves new log block of specified size or null if there is no logs.
long	getRecordCount() Retrieves current number of added records.
LogStorageStatus	getStatus() Gets log storage status.
void	notifyUploadFailed(int id) Notifies if sending of a log block with a specified id was failed.
void	removeRecordBlock(int id) Removes already sent log records by its block id.

Methods inherited from class java.lang.Object

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

Constructor Detail

MemLogStorage

public MemLogStorage()

MemLogStorage

public MemLogStorage(long bucketSize,
             int bucketRecordCount)

MemLogStorage

public MemLogStorage(long maxStorageSize,
             long bucketSize,
             int bucketRecordCount)

Method Detail

getConsumedVolume

public long getConsumedVolume()

Description copied from interface: LogStorageStatus

Retrieves current log storage size used by added records.

Specified by:

getConsumedVolume in interface LogStorageStatus

Returns:

Amount of bytes consumed by added records

getRecordCount

public long getRecordCount()

Description copied from interface: LogStorageStatus

Retrieves current number of added records.

Specified by:

getRecordCount in interface LogStorageStatus

Returns:

Number of records in a local storage

addLogRecord

public void addLogRecord(LogRecord record)

Description copied from interface: LogStorage

Persists new log record.

Specified by:

addLogRecord in interface LogStorage

Parameters:

record - New record (LogRecord)

getRecordBlock

public LogBlock getRecordBlock(long blockSize,
                      int batchCount)

Description copied from interface: LogStorage

Retrieves new log block of specified size or null if there is no logs.

The size of retrieved log records should NOT be greater than specified block size.

Specified by:

getRecordBlock in interface LogStorage

Parameters:

blockSize - Maximum size of sending log block

Returns:

New log block (LogBlock)

removeRecordBlock

public void removeRecordBlock(int id)

Description copied from interface: LogStorage

Removes already sent log records by its block id.

Use in case of a successful upload.

Specified by:

removeRecordBlock in interface LogStorage

Parameters:

id - Unique id of sent log block

notifyUploadFailed

public void notifyUploadFailed(int id)

Description copied from interface: LogStorage

Notifies if sending of a log block with a specified id was failed.

Specified by:

notifyUploadFailed in interface LogStorage

Parameters:

id - Unique id of log block.

close

public void close()

Description copied from interface: LogStorage

Closes log storage and releases all used resources (if any)

Specified by:

close in interface LogStorage

getStatus

public LogStorageStatus getStatus()

Description copied from interface: LogStorage

Gets log storage status.

Specified by:

getStatus in interface LogStorage

Returns:

current status of log storage