dbg::GraphEmitterClient Struct Reference

GRPC client that checks for server health and make graph creation and update calls. More...

#include <client.hpp>

Collaboration diagram for dbg::GraphEmitterClient:

Public Member Functions
	GraphEmitterClient (std::shared_ptr< grpc::ChannelInterface > channel, ClientConfig cfg)
void	create_graph (tenncor::CreateGraphRequest &request)
	Add job that pass CreateGraphRequest. More...
void	update_graph (tenncor::UpdateGraphRequest &request)
	Add job that pass UpdateGraphRequest. More...
void	update_node_data (std::vector< tenncor::UpdateNodeDataRequest > &requests, size_t update_it)
	Add job that streams UpdateNodeDataRequest. More...
bool	is_connected (void)
	Return true if the client is connected to the server. More...
void	join (void)
	Wait until all request jobs are complete. More...
void	clear (void)
	Kill all request jobs. More...

Private Attributes
std::unique_ptr< tenncor::GraphEmitter::Stub >	stub_
ClientConfig	cfg_
jobs::Sequence	sequential_jobs_
std::atomic< bool >	connected_
jobs::ManagedJob	health_checker_

Detailed Description

GRPC client that checks for server health and make graph creation and update calls.

Constructor & Destructor Documentation

GraphEmitterClient()

dbg::GraphEmitterClient::GraphEmitterClient ( std::shared_ptr< grpc::ChannelInterface >  channel, ClientConfig  cfg  )

inline

Member Function Documentation

clear()

void dbg::GraphEmitterClient::clear ( void  )

inline

Kill all request jobs.

create_graph()

void dbg::GraphEmitterClient::create_graph ( tenncor::CreateGraphRequest &  request )

inline

Add job that pass CreateGraphRequest.

is_connected()

bool dbg::GraphEmitterClient::is_connected ( void  )

inline

Return true if the client is connected to the server.

join()

void dbg::GraphEmitterClient::join ( void  )

inline

Wait until all request jobs are complete.

update_graph()

void dbg::GraphEmitterClient::update_graph ( tenncor::UpdateGraphRequest &  request )

inline

Add job that pass UpdateGraphRequest.

update_node_data()

void dbg::GraphEmitterClient::update_node_data ( std::vector< tenncor::UpdateNodeDataRequest > &  requests, size_t  update_it  )

inline

Add job that streams UpdateNodeDataRequest.

Member Data Documentation

cfg_

ClientConfig dbg::GraphEmitterClient::cfg_

private

connected_

std::atomic<bool> dbg::GraphEmitterClient::connected_

private

health_checker_

jobs::ManagedJob dbg::GraphEmitterClient::health_checker_

private

sequential_jobs_

jobs::Sequence dbg::GraphEmitterClient::sequential_jobs_

private

stub_

std::unique_ptr<tenncor::GraphEmitter::Stub> dbg::GraphEmitterClient::stub_

private

---

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

• dbg/grpc/client.hpp