org.openkilda.wfm.topology.cache.CacheTopology Class Reference

Inheritance diagram for org.openkilda.wfm.topology.cache.CacheTopology:

Public Member Functions
	CacheTopology (LaunchEnvironment env)
StormTopology	createTopology () throws NameCollisionException
Public Member Functions inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
final String	getTopologyName ()
final T	getConfig ()

Static Public Member Functions
static void	main (String[] args)

Additional Inherited Members
Public Attributes inherited from org.openkilda.wfm.topology.Topology
String	TOPOLOGY_PROPERTIES = "/topology.properties"
String	TOPOLOGY_PROPERTIES_DEFAULTS_PREFIX = "defaults."
Static Public Attributes inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
static final String	SPOUT_ID_CTRL = "ctrl.in"
static final String	BOLT_ID_CTRL_ROUTE = "ctrl.route"
static final String	BOLT_ID_CTRL_OUTPUT = "ctrl.out"
static final String	MESSAGE_FIELD = "message"
static final Fields	fieldMessage = new Fields(MESSAGE_FIELD)
Protected Member Functions inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
	AbstractTopology (LaunchEnvironment env, Class< T > topologyConfigClass)
String	getDefaultTopologyName ()
void	setup () throws TException, NameCollisionException
Config	makeStormConfig ()
void	localExecutionMainLoop ()
void	checkAndCreateTopic (final String topic)
KafkaSpout< String, String >	createKafkaSpout (String topic, String spoutId)
KafkaBolt	createKafkaBolt (final String topic)
void	createCtrlBranch (TopologyBuilder builder, List< CtrlBoltRef > targets) throws StreamNameCollisionException
void	createHealthCheckHandler (TopologyBuilder builder, String prefix)
KafkaSpoutConfig.Builder< String, String >	makeKafkaSpoutConfigBuilder (String spoutId, String topic)
Static Protected Member Functions inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
static int	handleLaunchException (Exception error)
Protected Attributes inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
final String	topologyName
final KafkaNamingStrategy	kafkaNamingStrategy
final TopologyNamingStrategy	topoNamingStrategy
final ConfigurationProvider	configurationProvider
final T	topologyConfig

Detailed Description

Definition at line 39 of file CacheTopology.java.

Constructor & Destructor Documentation

CacheTopology()

org.openkilda.wfm.topology.cache.CacheTopology.CacheTopology

(

LaunchEnvironment

env

)

Definition at line 49 of file CacheTopology.java.

Member Function Documentation

createTopology()

StormTopology org.openkilda.wfm.topology.cache.CacheTopology.createTopology

(

)

throws NameCollisionException

Topology creator. Should be implemented.

Returns

StormTopology

Implements org.openkilda.wfm.topology.Topology.

Definition at line 57 of file CacheTopology.java.

main()

static void org.openkilda.wfm.topology.cache.CacheTopology.main ( String []  args )

static

Definition at line 129 of file CacheTopology.java.

---

The documentation for this class was generated from the following file:

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/wfm/src/main/java/org/openkilda/wfm/topology/cache/CacheTopology.java