org.kaaproject.kaa.client.logging.strategies

Class RecordCountWithTimeLimitLogUploadStrategy

java.lang.Object

org.kaaproject.kaa.client.logging.DefaultLogUploadStrategy

org.kaaproject.kaa.client.logging.strategies.RecordCountWithTimeLimitLogUploadStrategy

All Implemented Interfaces:

LogUploadStrategy

public class RecordCountWithTimeLimitLogUploadStrategy
extends DefaultLogUploadStrategy

Reference implementation for LogUploadStrategy. Start log upload when there is countThreshold records in storage 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
RecordCountWithTimeLimitLogUploadStrategy(int countThreshold, 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

RecordCountWithTimeLimitLogUploadStrategy

public RecordCountWithTimeLimitLogUploadStrategy(int countThreshold,
                                         long timeLimit,
                                         TimeUnit timeUnit)

Method Detail

checkUploadNeeded

protected LogUploadStrategyDecision checkUploadNeeded(LogStorageStatus status)

Overrides:

checkUploadNeeded in class DefaultLogUploadStrategy