PullSession Class

Declaration

class simaai::neat::graph::GraphRun::PullSession { ... }

Included Headers

#include <GraphRun.h>

Friends Index

class	GraphRun

Private Constructors Index

	PullSession (GraphRun *run, const std::vector< Output > *outputs, std::vector< NodeId > output_nodes, GraphRunStats *stats)

Public Member Functions Index

PullSession &	per_stream_target (int n)
PullSession &	stall_after_ms (int ms)
PullSession &	timeout_ms (int ms)
PullSession &	max_runtime_ms (int ms)
PullSession &	expect_streams (std::vector< std::string > ids)
PullSession &	on_sample (std::function< void(const Sample &, NodeId)> cb)
GraphRunStats &	stats ()
void	run ()

Private Member Attributes Index

GraphRun *	run_ = nullptr
const std::vector< Output > *	outputs_ = nullptr
std::vector< NodeId >	output_nodes_
GraphRunStats *	stats_ = nullptr
GraphRunPullOptions	opt_
std::unordered_set< std::string >	expected_
std::unordered_set< std::string >	unknown_
bool	saw_empty_stream_id_ = false
std::function< void(const Sample &, NodeId)>	on_sample_

Definition at line 144 of file GraphRun.h.

Friends

GraphRun

friend class GraphRun

Definition at line 156 of file GraphRun.h.

156 friend class GraphRun;

Private Constructors

PullSession()

simaai::neat::graph::GraphRun::PullSession::PullSession (GraphRun * run, const std::vector< Output > * outputs, std::vector< NodeId > output_nodes, GraphRunStats * stats)

Definition at line 157 of file GraphRun.h.

Public Member Functions

expect_streams()

PullSession& simaai::neat::graph::GraphRun::PullSession::expect_streams (std::vector< std::string > ids)

Definition at line 150 of file GraphRun.h.

max_runtime_ms()

PullSession& simaai::neat::graph::GraphRun::PullSession::max_runtime_ms (int ms)

Definition at line 149 of file GraphRun.h.

on_sample()

PullSession& simaai::neat::graph::GraphRun::PullSession::on_sample (std::function< void(const Sample &, NodeId)> cb)

Definition at line 151 of file GraphRun.h.

per_stream_target()

PullSession& simaai::neat::graph::GraphRun::PullSession::per_stream_target (int n)

Definition at line 146 of file GraphRun.h.

run()

void simaai::neat::graph::GraphRun::PullSession::run ()

Definition at line 153 of file GraphRun.h.

stall_after_ms()

PullSession& simaai::neat::graph::GraphRun::PullSession::stall_after_ms (int ms)

Definition at line 147 of file GraphRun.h.

stats()

GraphRunStats& simaai::neat::graph::GraphRun::PullSession::stats ()

Definition at line 152 of file GraphRun.h.

timeout_ms()

PullSession& simaai::neat::graph::GraphRun::PullSession::timeout_ms (int ms)

Definition at line 148 of file GraphRun.h.

Private Member Attributes

expected_

std::unordered_set<std::string> simaai::neat::graph::GraphRun::PullSession::expected_

Definition at line 165 of file GraphRun.h.

165 std::unordered_set<std::string> expected_;

on_sample_

std::function<void(const Sample&, NodeId)> simaai::neat::graph::GraphRun::PullSession::on_sample_

Definition at line 168 of file GraphRun.h.

168 std::function<void(const Sample&, NodeId)> on_sample_;

opt_

GraphRunPullOptions simaai::neat::graph::GraphRun::PullSession::opt_

Definition at line 164 of file GraphRun.h.

164 GraphRunPullOptions opt_;

output_nodes_

std::vector<NodeId> simaai::neat::graph::GraphRun::PullSession::output_nodes_

Definition at line 162 of file GraphRun.h.

162 std::vector<NodeId> output_nodes_;

outputs_

const std::vector<Output>* simaai::neat::graph::GraphRun::PullSession::outputs_ = nullptr

Definition at line 161 of file GraphRun.h.

161 const std::vector<Output>* outputs_ = nullptr;

run_

GraphRun* simaai::neat::graph::GraphRun::PullSession::run_ = nullptr

Definition at line 160 of file GraphRun.h.

160 GraphRun* run_ = nullptr;

saw_empty_stream_id_

bool simaai::neat::graph::GraphRun::PullSession::saw_empty_stream_id_ = false

Definition at line 167 of file GraphRun.h.

167 bool saw_empty_stream_id_ = false;

stats_

GraphRunStats* simaai::neat::graph::GraphRun::PullSession::stats_ = nullptr

Definition at line 163 of file GraphRun.h.

163 GraphRunStats* stats_ = nullptr;

unknown_

std::unordered_set<std::string> simaai::neat::graph::GraphRun::PullSession::unknown_

Definition at line 166 of file GraphRun.h.

166 std::unordered_set<std::string> unknown_;

---

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

• GraphRun.h

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.1.