org.apache.sirona.cube

Class DisruptorPathTrackingDataStore

java.lang.Object

org.apache.sirona.store.tracking.AbstractPathTrackingDataStore

org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore

org.apache.sirona.store.tracking.BatchPathTrackingDataStore

org.apache.sirona.cube.DisruptorPathTrackingDataStore

All Implemented Interfaces:

CollectorPathTrackingDataStore, PathTrackingDataStore

public class DisruptorPathTrackingDataStore
extends BatchPathTrackingDataStore
implements CollectorPathTrackingDataStore

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore

org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore.Pointer

Field Summary

Fields inherited from class org.apache.sirona.store.tracking.BatchPathTrackingDataStore

scheduledTask

Constructor Summary

Constructors

Constructor and Description
DisruptorPathTrackingDataStore()

Method Summary

Modifier and Type	Method and Description
void	destroy()
int	getNumberOfConsumers()
com.lmax.disruptor.RingBuffer<org.apache.sirona.pathtracking.PathTrackingEntry>	getRingBuffer()
int	getRingBufferSize()
void	initialize()
protected void	pushEntriesByBatch(Map<String,List<org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore.Pointer>> pathTrackingEntries)
void	setNumberOfConsumers(int numberOfConsumers)
void	setRingBuffer(com.lmax.disruptor.RingBuffer<org.apache.sirona.pathtracking.PathTrackingEntry> ringBuffer)
void	setRingBufferSize(int ringBufferSize)
void	store(org.apache.sirona.pathtracking.PathTrackingEntry pathTrackingEntry)

Methods inherited from class org.apache.sirona.store.tracking.BatchPathTrackingDataStore

getPeriod, initBatch

Methods inherited from class org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore

clearEntries, getPathTrackingEntries, getPointers, readBytes, retrieve, retrieveTrackingIds, store

Methods inherited from class org.apache.sirona.store.tracking.AbstractPathTrackingDataStore

retrieve, retrieve

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.sirona.store.tracking.PathTrackingDataStore

clearEntries, retrieve, retrieve, retrieve, retrieveTrackingIds, store

Constructor Detail

DisruptorPathTrackingDataStore

public DisruptorPathTrackingDataStore()

Method Detail

initialize

public void initialize()

store

public void store(org.apache.sirona.pathtracking.PathTrackingEntry pathTrackingEntry)

Specified by:

store in interface PathTrackingDataStore

Overrides:

store in class org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore

pushEntriesByBatch

protected void pushEntriesByBatch(Map<String,List<org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore.Pointer>> pathTrackingEntries)

Specified by:

pushEntriesByBatch in class BatchPathTrackingDataStore

getRingBuffer

public com.lmax.disruptor.RingBuffer<org.apache.sirona.pathtracking.PathTrackingEntry> getRingBuffer()

setRingBuffer

public void setRingBuffer(com.lmax.disruptor.RingBuffer<org.apache.sirona.pathtracking.PathTrackingEntry> ringBuffer)

getNumberOfConsumers

public int getNumberOfConsumers()

setNumberOfConsumers

public void setNumberOfConsumers(int numberOfConsumers)

getRingBufferSize

public int getRingBufferSize()

setRingBufferSize

public void setRingBufferSize(int ringBufferSize)

destroy

public void destroy()