![]() |
Open Kilda Java Documentation
|
Public Member Functions | |
void | initState (InMemoryKeyValueState< String, Cache > state) |
void | prepare (Map map, TopologyContext topologyContext, OutputCollector outputCollector) |
void | execute (Tuple tuple) |
void | declareOutputFields (OutputFieldsDeclarer output) |
AbstractDumpState | dumpState () |
void | clearState () |
AbstractDumpState | dumpStateBySwitchId (SwitchId switchId) |
String | getCtrlStreamId () |
TopologyContext | getContext () |
OutputCollector | getOutput () |
Optional< AbstractDumpState > | dumpResorceCacheState () |
Static Public Attributes | |
static final String | STREAM_ID_CTRL = "ctrl" |
Definition at line 75 of file CacheBolt.java.
void org.openkilda.wfm.topology.cache.CacheBolt.clearState | ( | ) |
Implements org.openkilda.wfm.ctrl.ICtrlBolt.
Definition at line 540 of file CacheBolt.java.
void org.openkilda.wfm.topology.cache.CacheBolt.declareOutputFields | ( | OutputFieldsDeclarer | output | ) |
Definition at line 223 of file CacheBolt.java.
Optional<AbstractDumpState> org.openkilda.wfm.topology.cache.CacheBolt.dumpResorceCacheState | ( | ) |
Implements org.openkilda.wfm.ctrl.ICtrlBolt.
Definition at line 571 of file CacheBolt.java.
AbstractDumpState org.openkilda.wfm.topology.cache.CacheBolt.dumpState | ( | ) |
Implements org.openkilda.wfm.ctrl.ICtrlBolt.
Definition at line 531 of file CacheBolt.java.
AbstractDumpState org.openkilda.wfm.topology.cache.CacheBolt.dumpStateBySwitchId | ( | SwitchId | switchId | ) |
Implements org.openkilda.wfm.ctrl.ICtrlBolt.
Definition at line 546 of file CacheBolt.java.
void org.openkilda.wfm.topology.cache.CacheBolt.execute | ( | Tuple | tuple | ) |
Definition at line 158 of file CacheBolt.java.
TopologyContext org.openkilda.wfm.topology.cache.CacheBolt.getContext | ( | ) |
Implements org.openkilda.wfm.IKildaBolt.
Definition at line 561 of file CacheBolt.java.
String org.openkilda.wfm.topology.cache.CacheBolt.getCtrlStreamId | ( | ) |
Implements org.openkilda.wfm.ctrl.ICtrlBolt.
Definition at line 556 of file CacheBolt.java.
OutputCollector org.openkilda.wfm.topology.cache.CacheBolt.getOutput | ( | ) |
Implements org.openkilda.wfm.IKildaBolt.
Definition at line 566 of file CacheBolt.java.
void org.openkilda.wfm.topology.cache.CacheBolt.initState | ( | InMemoryKeyValueState< String, Cache > | state | ) |
Definition at line 123 of file CacheBolt.java.
void org.openkilda.wfm.topology.cache.CacheBolt.prepare | ( | Map | map, |
TopologyContext | topologyContext, | ||
OutputCollector | outputCollector | ||
) |
Definition at line 149 of file CacheBolt.java.
|
static |
Definition at line 78 of file CacheBolt.java.