org.openkilda.simulator.SimulatorTopology Class Reference

Inheritance diagram for org.openkilda.simulator.SimulatorTopology:

Public Member Functions
	SimulatorTopology (LaunchEnvironment env)
StormTopology	createTopology ()
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)

Static Public Attributes
static final String	SIMULATOR_SPOUT = "simulator-spout"
static final String	COMMAND_SPOUT = "command-spout"
static final String	DEPLOY_TOPOLOGY_BOLT_STREAM = "deploy_topology_stream"
static final String	COMMAND_BOLT_STREAM = "command_bolt_stream"
static final String	COMMAND_BOLT = "command_bolt"
static final String	SWITCH_BOLT = "switch_bolt"
static final String	SWITCH_BOLT_STREAM = "switch_bolt_stream"
static final String	KAFKA_BOLT = "kafka_bolt"
static final String	KAFKA_BOLT_STREAM = "kafka_bolt_stream"
static final String	SIMULATOR_COMMAND_BOLT = "simulator_command_bolt"
static final String	SIMULATOR_COMMAND_STREAM = "simulator_command_stream"
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)

Additional Inherited Members
Public Attributes inherited from org.openkilda.wfm.topology.Topology
String	TOPOLOGY_PROPERTIES = "/topology.properties"
String	TOPOLOGY_PROPERTIES_DEFAULTS_PREFIX = "defaults."
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 15 of file SimulatorTopology.java.

Constructor & Destructor Documentation

SimulatorTopology()

org.openkilda.simulator.SimulatorTopology.SimulatorTopology

(

LaunchEnvironment

env

)

Definition at line 33 of file SimulatorTopology.java.

Member Function Documentation

createTopology()

StormTopology org.openkilda.simulator.SimulatorTopology.createTopology

(

)

Topology creator. Should be implemented.

Returns

StormTopology

Implements org.openkilda.wfm.topology.Topology.

Definition at line 38 of file SimulatorTopology.java.

main()

static void org.openkilda.simulator.SimulatorTopology.main ( String []  args )

static

Definition at line 81 of file SimulatorTopology.java.

Member Data Documentation

COMMAND_BOLT

final String org.openkilda.simulator.SimulatorTopology.COMMAND_BOLT = "command_bolt"

static

Definition at line 23 of file SimulatorTopology.java.

COMMAND_BOLT_STREAM

final String org.openkilda.simulator.SimulatorTopology.COMMAND_BOLT_STREAM = "command_bolt_stream"

static

Definition at line 22 of file SimulatorTopology.java.

COMMAND_SPOUT

final String org.openkilda.simulator.SimulatorTopology.COMMAND_SPOUT = "command-spout"

static

Definition at line 20 of file SimulatorTopology.java.

DEPLOY_TOPOLOGY_BOLT_STREAM

final String org.openkilda.simulator.SimulatorTopology.DEPLOY_TOPOLOGY_BOLT_STREAM = "deploy_topology_stream"

static

Definition at line 21 of file SimulatorTopology.java.

KAFKA_BOLT

final String org.openkilda.simulator.SimulatorTopology.KAFKA_BOLT = "kafka_bolt"

static

Definition at line 26 of file SimulatorTopology.java.

KAFKA_BOLT_STREAM

final String org.openkilda.simulator.SimulatorTopology.KAFKA_BOLT_STREAM = "kafka_bolt_stream"

static

Definition at line 27 of file SimulatorTopology.java.

SIMULATOR_COMMAND_BOLT

final String org.openkilda.simulator.SimulatorTopology.SIMULATOR_COMMAND_BOLT = "simulator_command_bolt"

static

Definition at line 28 of file SimulatorTopology.java.

SIMULATOR_COMMAND_STREAM

final String org.openkilda.simulator.SimulatorTopology.SIMULATOR_COMMAND_STREAM = "simulator_command_stream"

static

Definition at line 29 of file SimulatorTopology.java.

SIMULATOR_SPOUT

final String org.openkilda.simulator.SimulatorTopology.SIMULATOR_SPOUT = "simulator-spout"

static

Definition at line 19 of file SimulatorTopology.java.

SWITCH_BOLT

final String org.openkilda.simulator.SimulatorTopology.SWITCH_BOLT = "switch_bolt"

static

Definition at line 24 of file SimulatorTopology.java.

SWITCH_BOLT_STREAM

final String org.openkilda.simulator.SimulatorTopology.SWITCH_BOLT_STREAM = "switch_bolt_stream"

static

Definition at line 25 of file SimulatorTopology.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/simulator/SimulatorTopology.java