org.openkilda.wfm.topology.flow.FlowTopology Class Reference

Inheritance diagram for org.openkilda.wfm.topology.flow.FlowTopology:

Public Member Functions
	FlowTopology (LaunchEnvironment env)
	FlowTopology (LaunchEnvironment env, PathComputerAuth pathComputerAuth)
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)

Static Public Attributes
static final String	SWITCH_ID_FIELD = "switch-id"
static final String	STATUS_FIELD = "status"
static final String	ERROR_TYPE_FIELD = "error-type"
static final Fields	fieldFlowId = new Fields(Utils.FLOW_ID)
static final Fields	fieldSwitchId = new Fields(SWITCH_ID_FIELD)
static final Fields	fieldsFlowIdStatus = new Fields(Utils.FLOW_ID, STATUS_FIELD)
static final Fields	fieldsMessageFlowId = new Fields(MESSAGE_FIELD, Utils.FLOW_ID)
static final Fields	fieldsMessageErrorType = new Fields(MESSAGE_FIELD, ERROR_TYPE_FIELD)
static final Fields	fieldsMessageSwitchIdFlowIdTransactionId
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

Flow topology.

Definition at line 53 of file FlowTopology.java.

Constructor & Destructor Documentation

FlowTopology() [1/2]

org.openkilda.wfm.topology.flow.FlowTopology.FlowTopology

(

LaunchEnvironment

env

)

Definition at line 69 of file FlowTopology.java.

FlowTopology() [2/2]

org.openkilda.wfm.topology.flow.FlowTopology.FlowTopology	(	LaunchEnvironment	env,
		PathComputerAuth	pathComputerAuth
	)

Definition at line 77 of file FlowTopology.java.

Member Function Documentation

createTopology()

StormTopology org.openkilda.wfm.topology.flow.FlowTopology.createTopology

(

)

throws NameCollisionException

Topology creator. Should be implemented.

Returns

StormTopology

Implements org.openkilda.wfm.topology.Topology.

Definition at line 84 of file FlowTopology.java.

main()

static void org.openkilda.wfm.topology.flow.FlowTopology.main ( String []  args )

static

Topology entry point.

Definition at line 265 of file FlowTopology.java.

Member Data Documentation

ERROR_TYPE_FIELD

final String org.openkilda.wfm.topology.flow.FlowTopology.ERROR_TYPE_FIELD = "error-type"

static

Definition at line 56 of file FlowTopology.java.

fieldFlowId

final Fields org.openkilda.wfm.topology.flow.FlowTopology.fieldFlowId = new Fields(Utils.FLOW_ID)

static

Definition at line 57 of file FlowTopology.java.

fieldsFlowIdStatus

final Fields org.openkilda.wfm.topology.flow.FlowTopology.fieldsFlowIdStatus = new Fields(Utils.FLOW_ID, STATUS_FIELD)

static

Definition at line 59 of file FlowTopology.java.

fieldsMessageErrorType

final Fields org.openkilda.wfm.topology.flow.FlowTopology.fieldsMessageErrorType = new Fields(MESSAGE_FIELD, ERROR_TYPE_FIELD)

static

Definition at line 61 of file FlowTopology.java.

fieldsMessageFlowId

final Fields org.openkilda.wfm.topology.flow.FlowTopology.fieldsMessageFlowId = new Fields(MESSAGE_FIELD, Utils.FLOW_ID)

static

Definition at line 60 of file FlowTopology.java.

fieldsMessageSwitchIdFlowIdTransactionId

final Fields org.openkilda.wfm.topology.flow.FlowTopology.fieldsMessageSwitchIdFlowIdTransactionId

static

Initial value:

=
            new Fields(MESSAGE_FIELD, SWITCH_ID_FIELD, Utils.FLOW_ID, Utils.TRANSACTION_ID)

Definition at line 62 of file FlowTopology.java.

fieldSwitchId

final Fields org.openkilda.wfm.topology.flow.FlowTopology.fieldSwitchId = new Fields(SWITCH_ID_FIELD)

static

Definition at line 58 of file FlowTopology.java.

STATUS_FIELD

final String org.openkilda.wfm.topology.flow.FlowTopology.STATUS_FIELD = "status"

static

Definition at line 55 of file FlowTopology.java.

SWITCH_ID_FIELD

final String org.openkilda.wfm.topology.flow.FlowTopology.SWITCH_ID_FIELD = "switch-id"

static

Definition at line 54 of file FlowTopology.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/flow/FlowTopology.java