nodes Namespace

Definition

namespace simaai::neat::graph::nodes { ... }

Classes Index

struct	FanOutOptions
class	FanOut
struct	JoinBundleOptions
class	JoinBundle
struct	JoinEncodedWithMetaOptions
class	JoinEncodedWithMeta
class	LambdaStage
class	PipelineNode
struct	StageModelExecutorOptions
class	StageModelExecutor
struct	StageNodeOptions
class	StageNode
class	StampFrameId
class	StreamMetadata
struct	StreamSchedulerOptions
class	StreamScheduler

Typedefs Index

using	LambdaOnInput = std::function< void(StageMsg &&, std::vector< StageOutMsg > &, const StagePorts &)>
using	LambdaOnTick = std::function< void(std::int64_t, std::vector< StageOutMsg > &, const StagePorts &)>
using	SampleMapFn = std::function< void(Sample &)>
using	TensorMapFn = std::function< void(Sample &, simaai::neat::Tensor &)>
using	SampleMapTransformFn = std::function< Sample(Sample)>

Enumerations Index

enum class	JoinKeyPolicy { ... }
enum class	StageKeyBy { ... }
enum class	StreamDropPolicy { ... }

Functions Index

std::shared_ptr< simaai::neat::graph::Node >	Pipeline (const simaai::neat::NodeGroup &group, std::string label={})
std::shared_ptr< simaai::neat::graph::Node >	Pipeline (simaai::neat::NodeGroup &&group, std::string label={})
std::shared_ptr< simaai::neat::graph::Node >	Pipeline (std::shared_ptr< simaai::neat::Node > node, std::string label={})
std::shared_ptr< simaai::neat::graph::Node >	Stage (std::string kind, StageNode::StageExecutorFactory factory, std::vector< PortDesc > inputs, std::vector< PortDesc > outputs, std::string label={}, StageNode::OutputSpecFn out_fn={}, StageNodeOptions options={})
std::shared_ptr< simaai::neat::graph::Node >	FanOutNode (std::vector< std::string > outputs, std::string label={}, std::string input="in")
std::shared_ptr< simaai::neat::graph::Node >	JoinBundleNode (std::vector< std::string > inputs, std::string label={}, std::string output="bundle", JoinBundleOptions opt={})
std::shared_ptr< simaai::neat::graph::Node >	JoinEncodedWithMetaNode (std::vector< std::string > inputs, std::string label={}, std::string output="bundle")
std::shared_ptr< simaai::neat::graph::Node >	LambdaStageNode (std::string kind, std::vector< std::string > inputs, std::vector< std::string > outputs, LambdaOnInput on_input, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={}, LambdaOnTick on_tick={})
std::shared_ptr< simaai::neat::graph::Node >	Map (SampleMapFn fn, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={})
std::shared_ptr< simaai::neat::graph::Node >	TensorMap (TensorMapFn fn, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={})
std::shared_ptr< simaai::neat::graph::Node >	Map (SampleMapTransformFn fn, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={})
std::shared_ptr< simaai::neat::graph::Node >	StageModelExecutorNode (const StageModelExecutorOptions &opt, std::string label={}, StageNodeOptions node_opt={})
std::shared_ptr< simaai::neat::graph::Node >	StampFrameIdNode (std::string label={})
std::shared_ptr< simaai::neat::graph::Node >	StreamMetadataNode (StreamMetadataDefaults defaults={}, std::string label={})
std::shared_ptr< simaai::neat::graph::Node >	StreamSchedulerNode (StreamSchedulerOptions opt={}, std::string label={}, std::string input="in", std::string output="out")

Typedefs

LambdaOnInput

using simaai::neat::graph::nodes::LambdaOnInput = typedef std::function<void(StageMsg&&, std::vector<StageOutMsg>&, const StagePorts&)>

Definition at line 19 of file LambdaStage.h.

19using LambdaOnInput = std::function<void(StageMsg&&, std::vector<StageOutMsg>&, const StagePorts&)>;

LambdaOnTick

using simaai::neat::graph::nodes::LambdaOnTick = typedef std::function<void(std::int64_t, std::vector<StageOutMsg>&, const StagePorts&)>

Definition at line 20 of file LambdaStage.h.

21 std::function<void(std::int64_t, std::vector<StageOutMsg>&, const StagePorts&)>;

SampleMapFn

using simaai::neat::graph::nodes::SampleMapFn = typedef std::function<void(Sample&)>

Definition at line 23 of file Map.h.

23using SampleMapFn = std::function<void(Sample&)>;

SampleMapTransformFn

using simaai::neat::graph::nodes::SampleMapTransformFn = typedef std::function<Sample(Sample)>

Definition at line 25 of file Map.h.

25using SampleMapTransformFn = std::function<Sample(Sample)>;

TensorMapFn

using simaai::neat::graph::nodes::TensorMapFn = typedef std::function<void(Sample&, simaai::neat::Tensor&)>

Definition at line 24 of file Map.h.

24using TensorMapFn = std::function<void(Sample&, simaai::neat::Tensor&)>;

Enumerations

JoinKeyPolicy

enum class JoinKeyPolicy

strong

Enumeration values

StreamFrame	(= 0)
StreamPts

Definition at line 23 of file JoinBundle.h.

23enum class JoinKeyPolicy {

24 StreamFrame = 0,

25 StreamPts,

26};

StageKeyBy

enum class StageKeyBy

strong

Enumeration values

None	(= 0)
StreamId

Definition at line 24 of file StageNode.h.

24enum class StageKeyBy {

25 None = 0,

26 StreamId,

27};

StreamDropPolicy

enum class StreamDropPolicy

strong

Enumeration values

DropOldest	(= 0)
DropNewest

Definition at line 23 of file StreamScheduler.h.

23enum class StreamDropPolicy {

24 DropOldest = 0,

25 DropNewest,

26};

Functions

FanOutNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::FanOutNode (std::vector< std::string > outputs, std::string label={}, std::string input="in")

Definition at line 39 of file FanOut.h.

JoinBundleNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::JoinBundleNode (std::vector< std::string > inputs, std::string label={}, std::string output="bundle", JoinBundleOptions opt={})

Definition at line 69 of file JoinBundle.h.

JoinEncodedWithMetaNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::JoinEncodedWithMetaNode (std::vector< std::string > inputs, std::string label={}, std::string output="bundle")

Definition at line 56 of file JoinEncodedWithMeta.h.

LambdaStageNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::LambdaStageNode (std::string kind, std::vector< std::string > inputs, std::vector< std::string > outputs, LambdaOnInput on_input, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={}, LambdaOnTick on_tick={})

inline

Definition at line 53 of file LambdaStage.h.

53LambdaStageNode(std::string kind, std::vector<std::string> inputs, std::vector<std::string> outputs,

54 LambdaOnInput on_input, std::string label = {}, StageNodeOptions options = {},

55 StageNode::OutputSpecFn out_fn = {}, LambdaOnTick on_tick = {}) {

56 LambdaOnInput fn = std::move(on_input);

57 LambdaOnTick tick = std::move(on_tick);

58 StageNode::StageExecutorFactory factory = [fn, tick]() mutable {

59 return std::make_unique<LambdaStage>(fn, tick);

60 };

61

62 std::vector<PortDesc> in_ports;

63 in_ports.reserve(inputs.size());

64 for (auto& name : inputs) {

65 in_ports.push_back(PortDesc{.name = std::move(name), .spec = OutputSpec{}});

66 }

67

68 std::vector<PortDesc> out_ports;

69 out_ports.reserve(outputs.size());

70 for (auto& name : outputs) {

71 out_ports.push_back(PortDesc{.name = std::move(name), .spec = OutputSpec{}});

72 }

73

74 return std::make_shared<StageNode>(std::move(kind), std::move(factory), std::move(in_ports),

75 std::move(out_ports), std::move(label), std::move(out_fn),

76 std::move(options));

77}

Map()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::Map (SampleMapFn fn, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={})

Definition at line 27 of file Map.h.

Map()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::Map (SampleMapTransformFn fn, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={})

Definition at line 35 of file Map.h.

Pipeline()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::Pipeline (const simaai::neat::NodeGroup & group, std::string label={})

inline

Definition at line 18 of file Adapters.h.

18inline std::shared_ptr<simaai::neat::graph::Node> Pipeline(const simaai::neat::NodeGroup& group,

19 std::string label = {}) {

20 return std::make_shared<PipelineNode>(group, std::move(label));

21}

Pipeline()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::Pipeline (simaai::neat::NodeGroup && group, std::string label={})

inline

Definition at line 23 of file Adapters.h.

23inline std::shared_ptr<simaai::neat::graph::Node> Pipeline(simaai::neat::NodeGroup&& group,

24 std::string label = {}) {

25 return std::make_shared<PipelineNode>(std::move(group), std::move(label));

26}

Pipeline()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::Pipeline (std::shared_ptr< simaai::neat::Node > node, std::string label={})

inline

Definition at line 28 of file Adapters.h.

28inline std::shared_ptr<simaai::neat::graph::Node> Pipeline(std::shared_ptr<simaai::neat::Node> node,

29 std::string label = {}) {

30 return std::make_shared<PipelineNode>(std::move(node), std::move(label));

31}

Stage()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::Stage (std::string kind, StageNode::StageExecutorFactory factory, std::vector< PortDesc > inputs, std::vector< PortDesc > outputs, std::string label={}, StageNode::OutputSpecFn out_fn={}, StageNodeOptions options={})

inline

Definition at line 34 of file Adapters.h.

34Stage(std::string kind, StageNode::StageExecutorFactory factory, std::vector<PortDesc> inputs,

35 std::vector<PortDesc> outputs, std::string label = {}, StageNode::OutputSpecFn out_fn = {},

36 StageNodeOptions options = {}) {

37 return std::make_shared<StageNode>(std::move(kind), std::move(factory), std::move(inputs),

38 std::move(outputs), std::move(label), std::move(out_fn),

39 std::move(options));

40}

StageModelExecutorNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::StageModelExecutorNode (const StageModelExecutorOptions & opt, std::string label={}, StageNodeOptions node_opt={})

Definition at line 45 of file StageModelExecutor.h.

StampFrameIdNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::StampFrameIdNode (std::string label={})

Definition at line 31 of file StampFrameId.h.

StreamMetadataNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::StreamMetadataNode (StreamMetadataDefaults defaults={}, std::string label={})

Definition at line 33 of file StreamMetadata.h.

StreamSchedulerNode()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::StreamSchedulerNode (StreamSchedulerOptions opt={}, std::string label={}, std::string input="in", std::string output="out")

Definition at line 53 of file StreamScheduler.h.

TensorMap()

std::shared_ptr<simaai::neat::graph::Node> simaai::neat::graph::nodes::TensorMap (TensorMapFn fn, std::string label={}, StageNodeOptions options={}, StageNode::OutputSpecFn out_fn={})

Definition at line 31 of file Map.h.

---

The documentation for this namespace was generated from the following files:

• Adapters.h
• FanOut.h
• JoinBundle.h
• JoinEncodedWithMeta.h
• LambdaStage.h
• Map.h
• StageModelExecutor.h
• StageNode.h
• StampFrameId.h
• StreamMetadata.h
• StreamScheduler.h

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.1.