org.opennms.netmgt.collection.test.api

Class CollectorTestUtils

java.lang.Object

org.opennms.netmgt.collection.test.api.CollectorTestUtils

public abstract class CollectorTestUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
CollectorTestUtils()

Method Summary

Modifier and Type	Method and Description
static File	anticipatePath(FileAnticipator fa, File rootDir, String... pathElements)
static void	collectNTimes(RrdStrategy<?,?> rrdStrategy, ResourceStorageDao resourceStorageDao, CollectionSpecification spec, CollectionAgent agent, int numUpdates)
static CollectionSpecification	createCollectionSpec(String svcName, ServiceCollector svcCollector, String collectionName, ReadablePollOutagesDao pollOutagesDao)
static LocationAwareCollectorClient	createLocationAwareCollectorClient()
static void	failToCollectNTimes(RrdStrategy<?,?> rrdStrategy, ResourceStorageDao resourceStorageDao, CollectionSpecification spec, CollectionAgent agent, int numUpdates)
static void	persistCollectionSet(RrdStrategy<?,?> rrdStrategy, ResourceStorageDao resourceStorageDao, CollectionSpecification spec, CollectionSet collectionSet)
static String	rrd(RrdStrategy<Object,Object> rrdStrategy, String file)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectorTestUtils

public CollectorTestUtils()

Method Detail

createLocationAwareCollectorClient

public static LocationAwareCollectorClient createLocationAwareCollectorClient()

createCollectionSpec

public static CollectionSpecification createCollectionSpec(String svcName,
                                                           ServiceCollector svcCollector,
                                                           String collectionName,
                                                           ReadablePollOutagesDao pollOutagesDao)

persistCollectionSet

public static void persistCollectionSet(RrdStrategy<?,?> rrdStrategy,
                                        ResourceStorageDao resourceStorageDao,
                                        CollectionSpecification spec,
                                        CollectionSet collectionSet)

collectNTimes

public static void collectNTimes(RrdStrategy<?,?> rrdStrategy,
                                 ResourceStorageDao resourceStorageDao,
                                 CollectionSpecification spec,
                                 CollectionAgent agent,
                                 int numUpdates)
                          throws InterruptedException,
                                 CollectionException

Throws:

InterruptedException

CollectionException

failToCollectNTimes

public static void failToCollectNTimes(RrdStrategy<?,?> rrdStrategy,
                                       ResourceStorageDao resourceStorageDao,
                                       CollectionSpecification spec,
                                       CollectionAgent agent,
                                       int numUpdates)
                                throws InterruptedException,
                                       CollectionException

Throws:

InterruptedException

CollectionException

anticipatePath

public static File anticipatePath(FileAnticipator fa,
                                  File rootDir,
                                  String... pathElements)

rrd

public static String rrd(RrdStrategy<Object,Object> rrdStrategy,
                         String file)