org.kaaproject.kaa.client.logging.strategies

Class StorageSizeWithTimeLimitLogUploadStrategy

java.lang.Object

org.kaaproject.kaa.client.logging.DefaultLogUploadStrategy

org.kaaproject.kaa.client.logging.strategies.StorageSizeWithTimeLimitLogUploadStrategy

All Implemented Interfaces:

LogUploadStrategy

public class StorageSizeWithTimeLimitLogUploadStrategy
extends DefaultLogUploadStrategy

Reference implementation for LogUploadStrategy. Start log upload when there storage size is >= volumeThreshold bytes or records are stored for more then timeLimit TimeUnit units.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	lastUploadTime

Fields inherited from class org.kaaproject.kaa.client.logging.DefaultLogUploadStrategy

batchCount, batchSize, countThreshold, isUploadLocked, maxParallelUploads, retryPeriod, timeout, uploadCheckPeriod, volumeThreshold

Constructor Summary

Constructors

Constructor and Description
StorageSizeWithTimeLimitLogUploadStrategy(int volumeThreshold, long timeLimit, TimeUnit timeUnit)

Method Summary

Methods

Modifier and Type	Method and Description
protected LogUploadStrategyDecision	checkUploadNeeded(LogStorageStatus status)

Methods inherited from class org.kaaproject.kaa.client.logging.DefaultLogUploadStrategy

getBatchCount, getBatchSize, getCountThreshold, getMaxParallelUploads, getTimeout, getUploadCheckPeriod, getVolumeThreshold, isUploadLocked, isUploadNeeded, lockUpload, onFailure, onTimeout, setBatch, setBatchCount, setCountThreshold, setMaxParallelUploads, setRetryPeriod, setTimeout, setUploadCheckPeriod, setVolumeThreshold, unlockUpload

Methods inherited from class java.lang.Object

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

Field Detail

lastUploadTime

protected long lastUploadTime

Constructor Detail

StorageSizeWithTimeLimitLogUploadStrategy

public StorageSizeWithTimeLimitLogUploadStrategy(int volumeThreshold,
                                         long timeLimit,
                                         TimeUnit timeUnit)

Method Detail

checkUploadNeeded

protected LogUploadStrategyDecision checkUploadNeeded(LogStorageStatus status)

Overrides:

checkUploadNeeded in class DefaultLogUploadStrategy