org.opennms.features.kafka.producer.collection

Class KafkaPersisterFactory

java.lang.Object

org.opennms.features.kafka.producer.collection.KafkaPersisterFactory

All Implemented Interfaces:

PersisterFactory

public class KafkaPersisterFactory
extends Object
implements PersisterFactory

Constructor Summary

Constructors

Constructor and Description
KafkaPersisterFactory()

Method Summary

Modifier and Type	Method and Description
Persister	createPersister(ServiceParameters params, RrdRepository repository) Creates a visitor that is used to persist attributes in a CollectionSet.
Persister	createPersister(ServiceParameters params, RrdRepository repository, boolean dontPersistCounters, boolean forceStoreByGroup, boolean dontReorderAttributes) Creates a visitor that is used to persist attributes in a CollectionSet.
void	destroy()
void	init()
void	setCollectionSetMapper(CollectionSetMapper collectionSetMapper)
void	setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin configAdmin)
void	setTopicName(String topicName)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaPersisterFactory

public KafkaPersisterFactory()

Method Detail

createPersister

public Persister createPersister(ServiceParameters params,
                                 RrdRepository repository,
                                 boolean dontPersistCounters,
                                 boolean forceStoreByGroup,
                                 boolean dontReorderAttributes)

Description copied from interface: PersisterFactory

Creates a visitor that is used to persist attributes in a CollectionSet.

Specified by:

createPersister in interface PersisterFactory

Parameters:

params - used to determine if individual groups or resources in the collection set should be persisted

repository - used to the RRD persisters to build the appropriate RRD structures

dontPersistCounters - used to disable persistence for counters in order to try and avoid spikes

forceStoreByGroup - forces the given CollectionSet to be persisted as a group

dontReorderAttributes - store attributes in the order they are visited

Returns:

a Persister that persists the attributes

createPersister

public Persister createPersister(ServiceParameters params,
                                 RrdRepository repository)

Description copied from interface: PersisterFactory

Creates a visitor that is used to persist attributes in a CollectionSet.

Specified by:

createPersister in interface PersisterFactory

Parameters:

params - used to determine if individual groups or resources in the collection set should be persisted

repository - used to the RRD persisters to build the appropriate RRD structures

Returns:

a Persister that persists the attributes

init

public void init()
          throws IOException

Throws:

IOException

destroy

public void destroy()

setConfigAdmin

public void setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin configAdmin)

setCollectionSetMapper

public void setCollectionSetMapper(CollectionSetMapper collectionSetMapper)

setTopicName

public void setTopicName(String topicName)