rogue
Loading...
Searching...
No Matches
SplitterV1.h
Go to the documentation of this file.
1
17#ifndef __ROGUE_PROTOCOLS_BATCHER_SPLITTER_V1_H__
18#define __ROGUE_PROTOCOLS_BATCHER_SPLITTER_V1_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::SplitterV1> create();
63
65 static void setup_python();
66
74 SplitterV1();
75
78
83 void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
84};
85
86// Convienence
87typedef std::shared_ptr<rogue::protocols::batcher::SplitterV1> SplitterV1Ptr;
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 v1 super-frame into per-record output frames.
Definition SplitterV1.h:50
~SplitterV1()
Destroys the splitter.
SplitterV1()
Constructs a SplitterV1 instance.
static std::shared_ptr< rogue::protocols::batcher::SplitterV1 > create()
Creates a SplitterV1 instance.
static void setup_python()
Registers Python bindings for this class.
void acceptFrame(std::shared_ptr< rogue::interfaces::stream::Frame > frame)
Accepts one batcher v1 frame and emits parsed records as frames.
std::shared_ptr< rogue::protocols::batcher::SplitterV1 > SplitterV1Ptr
Definition SplitterV1.h:87