summaryrefslogtreecommitdiffstats
path: root/aclk/schema-wrappers/node_info.cc
diff options
context:
space:
mode:
Diffstat (limited to 'aclk/schema-wrappers/node_info.cc')
-rw-r--r--aclk/schema-wrappers/node_info.cc136
1 files changed, 0 insertions, 136 deletions
diff --git a/aclk/schema-wrappers/node_info.cc b/aclk/schema-wrappers/node_info.cc
deleted file mode 100644
index 5e321f688..000000000
--- a/aclk/schema-wrappers/node_info.cc
+++ /dev/null
@@ -1,136 +0,0 @@
-#include "node_info.h"
-
-#include "proto/nodeinstance/info/v1/info.pb.h"
-
-#include "schema_wrapper_utils.h"
-
-static int generate_node_info(nodeinstance::info::v1::NodeInfo *info, struct aclk_node_info *data)
-{
- google::protobuf::Map<std::string, std::string> *map;
-
- if (data->name)
- info->set_name(data->name);
-
- if (data->os)
- info->set_os(data->os);
- if (data->os_name)
- info->set_os_name(data->os_name);
- if (data->os_version)
- info->set_os_version(data->os_version);
-
- if (data->kernel_name)
- info->set_kernel_name(data->kernel_name);
- if (data->kernel_version)
- info->set_kernel_version(data->kernel_version);
-
- if (data->architecture)
- info->set_architecture(data->architecture);
-
- info->set_cpus(data->cpus);
-
- if (data->cpu_frequency)
- info->set_cpu_frequency(data->cpu_frequency);
-
- if (data->memory)
- info->set_memory(data->memory);
-
- if (data->disk_space)
- info->set_disk_space(data->disk_space);
-
- if (data->version)
- info->set_version(data->version);
-
- if (data->release_channel)
- info->set_release_channel(data->release_channel);
-
- if (data->timezone)
- info->set_timezone(data->timezone);
-
- if (data->virtualization_type)
- info->set_virtualization_type(data->virtualization_type);
-
- if (data->container_type)
- info->set_container_type(data->container_type);
-
- if (data->custom_info)
- info->set_custom_info(data->custom_info);
-
- if (data->machine_guid)
- info->set_machine_guid(data->machine_guid);
-
- nodeinstance::info::v1::MachineLearningInfo *ml_info = info->mutable_ml_info();
- ml_info->set_ml_capable(data->ml_info.ml_capable);
- ml_info->set_ml_enabled(data->ml_info.ml_enabled);
-
- map = info->mutable_host_labels();
- rrdlabels_walkthrough_read(data->host_labels_ptr, label_add_to_map_callback, map);
- return 0;
-}
-
-char *generate_update_node_info_message(size_t *len, struct update_node_info *info)
-{
- nodeinstance::info::v1::UpdateNodeInfo msg;
-
- msg.set_node_id(info->node_id);
- msg.set_claim_id(info->claim_id);
-
- if (generate_node_info(msg.mutable_data(), &info->data))
- return NULL;
-
- set_google_timestamp_from_timeval(info->updated_at, msg.mutable_updated_at());
- msg.set_machine_guid(info->machine_guid);
- msg.set_child(info->child);
-
- nodeinstance::info::v1::MachineLearningInfo *ml_info = msg.mutable_ml_info();
- ml_info->set_ml_capable(info->ml_info.ml_capable);
- ml_info->set_ml_enabled(info->ml_info.ml_enabled);
-
- struct capability *capa;
- if (info->node_capabilities) {
- capa = info->node_capabilities;
- while (capa->name) {
- aclk_lib::v1::Capability *proto_capa = msg.mutable_node_info()->add_capabilities();
- capability_set(proto_capa, capa);
- capa++;
- }
- }
- if (info->node_instance_capabilities) {
- capa = info->node_instance_capabilities;
- while (capa->name) {
- aclk_lib::v1::Capability *proto_capa = msg.mutable_node_instance_info()->add_capabilities();
- capability_set(proto_capa, capa);
- capa++;
- }
- }
-
- *len = PROTO_COMPAT_MSG_SIZE(msg);
- char *bin = (char*)mallocz(*len);
- if (bin)
- msg.SerializeToArray(bin, *len);
-
- return bin;
-}
-
-char *generate_update_node_collectors_message(size_t *len, struct update_node_collectors *upd_node_collectors)
-{
- nodeinstance::info::v1::UpdateNodeCollectors msg;
-
- msg.set_node_id(upd_node_collectors->node_id);
- msg.set_claim_id(upd_node_collectors->claim_id);
-
- void *colls;
- dfe_start_read(upd_node_collectors->node_collectors, colls) {
- struct collector_info *c =(struct collector_info *)colls;
- nodeinstance::info::v1::CollectorInfo *col = msg.add_collectors();
- col->set_plugin(c->plugin);
- col->set_module(c->module);
- }
- dfe_done(colls);
-
- *len = PROTO_COMPAT_MSG_SIZE(msg);
- char *bin = (char*)mallocz(*len);
- if (bin)
- msg.SerializeToArray(bin, *len);
-
- return bin;
-}