File tree Expand file tree Collapse file tree 1 file changed +25
-0
lines changed
Expand file tree Collapse file tree 1 file changed +25
-0
lines changed Original file line number Diff line number Diff line change 1+ /*
2+
3+ The interface and struct hierarchies:
4+
5+ Consumer [interface]
6+ └── KafkaConsumer [struct]
7+ ├── OCPRulesConsumer [value]
8+ └── DVOConsumer [value]
9+
10+ MessageProcessor [interface]
11+ ├── OCPRulesProcessor [struct]
12+ └── DVOProcessor [struct]
13+
14+ OCPRulesProcessor satisfies MessageProcessor
15+ DVOProcessor satisfies MessageProcessor
16+ ProcessMessage(consumer *KafkaConsumer, msg *sarama.ConsumerMessage)
17+ - please see that all required info is passed to this method
18+ - and it does not need the "true" OOP-like hierarchy of Consumers
19+
20+ OCPRulesConsumer is instance of KafkaConsumer
21+ - owns OCPRulesProcessor
22+ DVOConsumer is instance of KafkaConsumer
23+ - owns DVOProcessor
24+ */
25+
126package main
227
328import (
You can’t perform that action at this time.
0 commit comments