rogue
Loading...
Searching...
No Matches
SplitterV2.h
Go to the documentation of this file.
1
17#ifndef __ROGUE_PROTOCOLS_BATCHER_SPLITTER_V2_H__
18#define __ROGUE_PROTOCOLS_BATCHER_SPLITTER_V2_H__
19#include "rogue/Directives.h"
20
21#include <stdint.h>
22
23#include <memory>
24#include <thread>
25
26#include "rogue/Logging.h"
29
30namespace rogue {
31namespace protocols {
32namespace batcher {
33
51 public:
62 static std::shared_ptr<rogue::protocols::batcher::SplitterV2> create();
63
65 static void setup_python();
66
74 SplitterV2();
75
78
83 void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
84};
85
86// Convienence
87typedef std::shared_ptr<rogue::protocols::batcher::SplitterV2> SplitterV2Ptr;
88} // namespace batcher
89} // namespace protocols
90} // namespace rogue
91#endif
Stream master endpoint.
Definition Master.h:65
Stream slave endpoint and default frame pool.
Definition Slave.h:72
Splits one batcher v2 super-frame into per-record output frames.
Definition SplitterV2.h:50
static void setup_python()
Registers Python bindings for this class.
SplitterV2()
Constructs a SplitterV2 instance.
~SplitterV2()
Destroys the splitter.
static std::shared_ptr< rogue::protocols::batcher::SplitterV2 > create()
Creates a SplitterV2 instance.
void acceptFrame(std::shared_ptr< rogue::interfaces::stream::Frame > frame)
Accepts one batcher v2 frame and emits parsed records as frames.
std::shared_ptr< rogue::protocols::batcher::SplitterV2 > SplitterV2Ptr
Definition SplitterV2.h:87