org.opennms.netmgt.newts

Class NewtsWriter

java.lang.Object

org.opennms.netmgt.newts.NewtsWriter

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<SampleBatchEvent>

public class NewtsWriter
extends Object
implements com.lmax.disruptor.EventHandler<SampleBatchEvent>

Used to write samples to the SampleRepository. Calls to #insert() publish the samples to a ring buffer so that they don't block while the data is being persisted.

Author:

jwhite

Constructor Summary

Constructors

Constructor and Description
NewtsWriter(Integer maxBatchSize, Integer ringBufferSize, com.codahale.metrics.MetricRegistry registry)

Method Summary

Modifier and Type	Method and Description
void	insert(List<org.opennms.newts.api.Sample> samples)
void	onEvent(SampleBatchEvent event, long sequence, boolean endOfBatch)

Methods inherited from class java.lang.Object

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

Constructor Detail

NewtsWriter

@Inject
public NewtsWriter(@Named(value="newts.max_batch_size")
                           Integer maxBatchSize,
                           @Named(value="newts.ring_buffer_size")
                           Integer ringBufferSize,
                           com.codahale.metrics.MetricRegistry registry)

Method Detail

insert

public void insert(List<org.opennms.newts.api.Sample> samples)

onEvent

public void onEvent(SampleBatchEvent event,
                    long sequence,
                    boolean endOfBatch)

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<SampleBatchEvent>