Refactor flow

[localvar]

No description provided.

[codecov-commenter]

Codecov Report

Merging #631 (1b29687) into pipeline (5596d7c) will increase coverage by 0.15%.
The diff coverage is 75.53%.

@@             Coverage Diff              @@
##           pipeline     #631      +/-   ##
============================================
+ Coverage     72.14%   72.29%   +0.15%     
============================================
  Files            96       96              
  Lines         10822    10810      -12     
============================================
+ Hits           7807     7815       +8     
+ Misses         2535     2511      -24     
- Partials        480      484       +4     

Impacted Files	Coverage Δ
pkg/filters/fallback/fallback.go	67.50% <0.00%> (-0.80%)	⬇️
pkg/filters/responseadaptor/responseadaptor.go	32.43% <0.00%> (-1.50%)	⬇️
pkg/object/meshcontroller/spec/spec.go	0.00% <0.00%> (ø)
pkg/filters/topicmapper/topicmapper.go	39.47% <50.00%> (+1.01%)	⬆️
pkg/filters/connectcontrol/connectcontrol.go	90.90% <66.66%> (-0.12%)	⬇️
pkg/filters/kafkabackend/kafka.go	72.00% <66.66%> (+11.47%)	⬆️
pkg/filters/mqttclientauth/mqttauth.go	82.14% <66.66%> (-0.32%)	⬇️
pkg/object/pipeline/pipeline.go	77.13% <68.42%> (+0.46%)	⬆️
pkg/filters/certextractor/certextractor.go	85.91% <100.00%> (-1.59%)	⬇️
pkg/filters/corsadaptor/corsadaptor.go	90.62% <100.00%> (-0.15%)	⬇️
... and 33 more

---

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 5596d7c...1b29687. Read the comment docs.