JoinBundle Class

Declaration

class simaai::neat::graph::nodes::JoinBundle { ... }

Included Headers

#include <JoinBundle.h>

Base class

class	StageExecutor

Public Constructors Index

	JoinBundle (JoinBundleOptions opt)

Public Member Functions Index

void	set_ports (const StagePorts &ports) override
void	on_input (StageMsg &&msg, std::vector< StageOutMsg > &out) override
void	on_tick (std::int64_t now_ns, std::vector< StageOutMsg > &out) override

Private Member Functions Index

std::string	make_key_ (const Sample &sample) const
void	touch_key_ (const std::string &key)
void	evict_expired_ (std::int64_t now_ns)
void	evict_oldest_ ()
bool	ready_ (const Pending &pending) const
void	erase_key_ (const std::string &key)

Private Member Attributes Index

JoinBundleOptions	opt_
std::vector< std::string >	input_names_
std::unordered_map< PortId, std::string >	port_names_
std::unordered_map< std::string, PortId >	name_to_port_
std::unordered_set< PortId >	required_ports_
std::unordered_map< std::string, Pending >	pending_
std::deque< std::string >	order_
PortId	out_port_ = kInvalidPort

Definition at line 37 of file JoinBundle.h.

Public Constructors

JoinBundle()

simaai::neat::graph::nodes::JoinBundle::JoinBundle (JoinBundleOptions opt)

explicit

Definition at line 39 of file JoinBundle.h.

Public Member Functions

on_input()

void simaai::neat::graph::nodes::JoinBundle::on_input (StageMsg && msg, std::vector< StageOutMsg > & out)

virtual

Definition at line 42 of file JoinBundle.h.

on_tick()

void simaai::neat::graph::nodes::JoinBundle::on_tick (std::int64_t now_ns, std::vector< StageOutMsg > & out)

virtual

Definition at line 43 of file JoinBundle.h.

set_ports()

void simaai::neat::graph::nodes::JoinBundle::set_ports (const StagePorts & ports)

virtual

Definition at line 41 of file JoinBundle.h.

Private Member Functions

erase_key_()

void simaai::neat::graph::nodes::JoinBundle::erase_key_ (const std::string & key)

Definition at line 56 of file JoinBundle.h.

evict_expired_()

void simaai::neat::graph::nodes::JoinBundle::evict_expired_ (std::int64_t now_ns)

Definition at line 53 of file JoinBundle.h.

evict_oldest_()

void simaai::neat::graph::nodes::JoinBundle::evict_oldest_ ()

Definition at line 54 of file JoinBundle.h.

make_key_()

std::string simaai::neat::graph::nodes::JoinBundle::make_key_ (const Sample & sample)

Definition at line 51 of file JoinBundle.h.

ready_()

bool simaai::neat::graph::nodes::JoinBundle::ready_ (const Pending & pending)

Definition at line 55 of file JoinBundle.h.

touch_key_()

void simaai::neat::graph::nodes::JoinBundle::touch_key_ (const std::string & key)

Definition at line 52 of file JoinBundle.h.

Private Member Attributes

input_names_

std::vector<std::string> simaai::neat::graph::nodes::JoinBundle::input_names_

Definition at line 59 of file JoinBundle.h.

59 std::vector<std::string> input_names_;

name_to_port_

std::unordered_map<std::string, PortId> simaai::neat::graph::nodes::JoinBundle::name_to_port_

Definition at line 61 of file JoinBundle.h.

61 std::unordered_map<std::string, PortId> name_to_port_;

opt_

JoinBundleOptions simaai::neat::graph::nodes::JoinBundle::opt_

Definition at line 58 of file JoinBundle.h.

58 JoinBundleOptions opt_;

order_

std::deque<std::string> simaai::neat::graph::nodes::JoinBundle::order_

Definition at line 64 of file JoinBundle.h.

64 std::deque<std::string> order_;

out_port_

PortId simaai::neat::graph::nodes::JoinBundle::out_port_ = kInvalidPort

Definition at line 65 of file JoinBundle.h.

65 PortId out_port_ = kInvalidPort;

pending_

std::unordered_map<std::string, Pending> simaai::neat::graph::nodes::JoinBundle::pending_

Definition at line 63 of file JoinBundle.h.

63 std::unordered_map<std::string, Pending> pending_;

port_names_

std::unordered_map<PortId, std::string> simaai::neat::graph::nodes::JoinBundle::port_names_

Definition at line 60 of file JoinBundle.h.

60 std::unordered_map<PortId, std::string> port_names_;

required_ports_

std::unordered_set<PortId> simaai::neat::graph::nodes::JoinBundle::required_ports_

Definition at line 62 of file JoinBundle.h.

62 std::unordered_set<PortId> required_ports_;

---

The documentation for this class was generated from the following file:

• JoinBundle.h

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.1.