MON-34002 otl request are sent to broker

bbdo/CMakeLists.txt

@@ -91,6 +91,39 @@ add_dependencies(pb_remove_graph_message_lib target_remove_graph_message
 set_target_properties(pb_remove_graph_message_lib
                       PROPERTIES POSITION_INDEPENDENT_CODE ON)
 
+set(otl_protobuf_files
+    opentelemetry/proto/collector/metrics/v1/metrics_service
+    opentelemetry/proto/metrics/v1/metrics
+    opentelemetry/proto/common/v1/common
+    opentelemetry/proto/resource/v1/resource
+)
+
+foreach(name IN LISTS otl_protobuf_files)
+  set(proto_file "${name}.proto")
+  add_custom_command(
+    OUTPUT "${CMAKE_SOURCE_DIR}/bbdo/${name}.pb.cc"
+    COMMENT "Generating interface files of the otl file ${proto_file}"
+    DEPENDS ${CONAN_RES_DIRS_OPENTELEMETRY-PROTO}/${proto_file}
+    COMMAND
+      ${Protobuf_PROTOC_EXECUTABLE} ARGS --cpp_out=${CMAKE_SOURCE_DIR}/bbdo
+      --proto_path=${CONAN_RES_DIRS_OPENTELEMETRY-PROTO} ${proto_file}
+    VERBATIM)
+endforeach()
+
+add_library(pb_open_telemetry_lib STATIC 
+${CMAKE_SOURCE_DIR}/bbdo/opentelemetry/proto/collector/metrics/v1/metrics_service.pb.cc
+${CMAKE_SOURCE_DIR}/bbdo/opentelemetry/proto/metrics/v1/metrics.pb.cc
+${CMAKE_SOURCE_DIR}/bbdo/opentelemetry/proto/common/v1/common.pb.cc
+${CMAKE_SOURCE_DIR}/bbdo/opentelemetry/proto/resource/v1/resource.pb.cc
+)
+
+set_target_properties(pb_open_telemetry_lib
+                      PROPERTIES POSITION_INDEPENDENT_CODE ON)
+
+
+
+
+
 macro(get_protobuf_files name)
   set_source_files_properties("${CMAKE_SOURCE_DIR}/bbdo/${name}.pb.cc"
                               PROPERTIES GENERATED TRUE)

bbdo/events.hh

@@ -164,6 +164,9 @@ enum data_element {
   de_pb_status = 10,
   de_pb_index_mapping = 11,
   de_pb_metric_mapping = 12,
+  de_pb_otl_metrics =
+      13  // contain an
+          // ::opentelemetry::proto::collector::metrics::v1::ExportMetricsServiceRequest
 };
 }
 namespace bam {

broker/CMakeLists.txt

@@ -455,6 +455,7 @@ target_link_libraries(
   bbdo_bbdo
   pb_bbdo_lib
   pb_extcmd_lib
+  pb_open_telemetry_lib
   berpc
   CONAN_PKG::zlib
   CONAN_PKG::spdlog

broker/grpc/CMakeLists.txt

@@ -65,6 +65,7 @@ target_link_libraries(
   pb_tag_lib
   pb_bam_lib
   pb_extcmd_lib
+  pb_open_telemetry_lib
   pb_rebuild_message_lib
   pb_remove_graph_message_lib
   pb_header_lib
@@ -95,6 +96,7 @@ add_custom_command(
   COMMAND
     ${Protobuf_PROTOC_EXECUTABLE} ARGS --cpp_out=${SRC_DIR}
     --proto_path=${MODULE_DIR} --proto_path=${CMAKE_SOURCE_DIR}/bbdo
+    --proto_path=${CONAN_RES_DIRS_OPENTELEMETRY-PROTO}
     grpc_stream.proto
   VERBATIM)
 
@@ -106,6 +108,7 @@ add_custom_command(
     ${Protobuf_PROTOC_EXECUTABLE} ARGS --grpc_out=${SRC_DIR}
     --plugin=protoc-gen-grpc=${CONAN_BIN_DIRS_GRPC}/grpc_cpp_plugin
     --proto_path=${MODULE_DIR} --proto_path=${CMAKE_SOURCE_DIR}/bbdo
+    --proto_path=${CONAN_RES_DIRS_OPENTELEMETRY-PROTO}
     grpc_stream.proto
   VERBATIM)
 

broker/grpc/generate_proto.py

@@ -25,6 +25,7 @@
 
 file_begin_content = """syntax = "proto3";
 
+import "opentelemetry/proto/collector/metrics/v1/metrics_service.proto";
 """
 
 file_message_centreon_event = """
@@ -216,6 +217,34 @@ class received_protobuf : public io::protobuf<T, Typ> {
 
 """
 
+#The following message is not in bbdo protobuff files so we need to add manually.
+
+file_message_centreon_event += f"        opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest ExportMetricsServiceRequest_ = {one_of_index};\n"
+
+cc_file_protobuf_to_event_function += """
+        case ::stream::CentreonEvent::kExportMetricsServiceRequest:
+        return std::make_shared<detail::received_protobuf<
+            ::opentelemetry::proto::collector::metrics::v1::
+                ExportMetricsServiceRequest,
+            make_type(io::storage, storage::de_pb_otl_metrics)>>(
+            stream_content, &grpc_event_type::exportmetricsservicerequest_,
+            &grpc_event_type::mutable_exportmetricsservicerequest_);
+"""
+
+cc_file_create_event_with_data_function += """
+        case make_type(io::storage, storage::de_pb_otl_metrics):
+        ret = std::make_shared<channel::event_with_data>(
+            event, reinterpret_cast<channel::event_with_data::releaser_type>(
+                        &grpc_event_type::release_exportmetricsservicerequest_));
+        ret->grpc_event.set_allocated_exportmetricsservicerequest_(
+            &std::static_pointer_cast<io::protobuf<
+                ::opentelemetry::proto::collector::metrics::v1::
+                    ExportMetricsServiceRequest,
+                make_type(io::storage, storage::de_pb_otl_metrics)>>(event)
+                ->mut_obj());
+        break;
+"""
+
 with open(args.proto_file, 'w', encoding="utf-8") as fp:
     fp.write(file_begin_content)
     fp.write("""

broker/lua/src/broker_utils.cc

@@ -1,20 +1,20 @@
 /**
-* Copyright 2018-2021 Centreon
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* For more information : [email protected]
-*/
+ * Copyright 2018-2021 Centreon
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * For more information : [email protected]
+ */
 
 #include "com/centreon/broker/lua/broker_utils.hh"
 
@@ -37,6 +37,7 @@
 #include "com/centreon/broker/log_v2.hh"
 #include "com/centreon/broker/mapping/entry.hh"
 #include "com/centreon/broker/misc/misc.hh"
+#include "com/centreon/common/hex_dump.hh"
 #include "com/centreon/exceptions/msg_fmt.hh"
 
 using namespace com::centreon::broker;
@@ -189,6 +190,7 @@ static void _message_to_json(std::ostringstream& oss,
           }
           oss << ']';
           break;
+        case google::protobuf::FieldDescriptor::TYPE_SFIXED64:
         case google::protobuf::FieldDescriptor::TYPE_INT64:
           oss << fmt::format("\"{}\":[", entry_name);
           for (size_t j = 0; j < s; j++) {
@@ -198,6 +200,7 @@ static void _message_to_json(std::ostringstream& oss,
           }
           oss << ']';
           break;
+        case google::protobuf::FieldDescriptor::TYPE_FIXED64:
         case google::protobuf::FieldDescriptor::TYPE_UINT64:
           oss << fmt::format("\"{}\":[", entry_name);
           for (size_t j = 0; j < s; j++) {
@@ -237,9 +240,20 @@ static void _message_to_json(std::ostringstream& oss,
           }
           oss << ']';
           break;
+        case google::protobuf::FieldDescriptor::TYPE_BYTES:
+          oss << fmt::format("\"{}\":[", entry_name);
+          for (size_t j = 0; j < s; j++) {
+            if (j > 0)
+              oss << ',';
+            tmpl = refl->GetRepeatedStringReference(*p, f, j, &tmpl);
+            oss << '"' << com::centreon::common::hex_dump(tmpl, 0) << '"';
+          }
+          oss << ']';
+          break;
         default:  // Error, a type not handled
           throw msg_fmt(
-              "protobuf {} type ID is not handled in the broker json converter",
+              "protobuf {} type ID is not handled in the "
+              "broker json converter",
               f->type());
       }
     } else {
@@ -258,9 +272,11 @@ static void _message_to_json(std::ostringstream& oss,
         case google::protobuf::FieldDescriptor::TYPE_UINT32:
           oss << fmt::format("\"{}\":{}", entry_name, refl->GetUInt32(*p, f));
           break;
+        case google::protobuf::FieldDescriptor::TYPE_SFIXED64:
         case google::protobuf::FieldDescriptor::TYPE_INT64:
           oss << fmt::format("\"{}\":{}", entry_name, refl->GetInt64(*p, f));
           break;
+        case google::protobuf::FieldDescriptor::TYPE_FIXED64:
         case google::protobuf::FieldDescriptor::TYPE_UINT64:
           oss << fmt::format("\"{}\":{}", entry_name, refl->GetUInt64(*p, f));
           break;
@@ -277,6 +293,11 @@ static void _message_to_json(std::ostringstream& oss,
           _message_to_json(oss, &refl->GetMessage(*p, f));
           oss << '}';
           break;
+        case google::protobuf::FieldDescriptor::TYPE_BYTES:
+          tmpl = refl->GetStringReference(*p, f, &tmpl);
+          oss << fmt::format(R"("{}":"{}")", entry_name,
+                             com::centreon::common::hex_dump(tmpl, 0));
+          break;
         default:  // Error, a type not handled
           throw msg_fmt(
               "protobuf {} type ID is not handled in the broker json converter",

broker/neb/CMakeLists.txt

@@ -93,8 +93,13 @@ set(NEB_SOURCES
 add_library(nebbase STATIC ${NEB_SOURCES})
 add_dependencies(nebbase table_max_size target_neb target_severity target_tag)
 
-target_link_libraries(nebbase CONAN_PKG::protobuf pb_severity_lib pb_tag_lib
-                      pb_neb_lib pb_header_lib)
+target_link_libraries(nebbase 
+  CONAN_PKG::protobuf 
+  pb_severity_lib 
+  pb_tag_lib
+  pb_neb_lib 
+  pb_header_lib
+  pb_open_telemetry_lib)
 
 set(NEBBASE_CXXFLAGS "${NEBBASE_CXXFLAGS} -fPIC")
 set_property(TARGET nebbase PROPERTY COMPILE_FLAGS ${NEBBASE_CXXFLAGS})
@@ -162,6 +167,8 @@ endif()
 set_target_properties("${CBMOD}" PROPERTIES PREFIX "")
 target_precompile_headers(${CBMOD} REUSE_FROM nebbase)
 
+target_include_directories(${CBMOD} PRIVATE ${CMAKE_SOURCE_DIR}/bbdo)
+
 # Testing.
 if(WITH_TESTING)
   set(TESTS_SOURCES

broker/neb/inc/com/centreon/broker/neb/callbacks.hh

@@ -19,7 +19,6 @@
 #ifndef CCB_NEB_CALLBACKS_HH
 #define CCB_NEB_CALLBACKS_HH
 
-
 namespace com::centreon::broker {
 
 namespace neb {
@@ -67,9 +66,11 @@ int callback_tag(int callback_type, void* data) noexcept;
 
 int callback_pb_bench(int callback_type, void* data);
 
+int callback_otl_metrics(int callback_type, void* data);
+
 void unregister_callbacks();
 }  // namespace neb
 
-}
+}  // namespace com::centreon::broker
 
 #endif  // !CCB_NEB_CALLBACKS_HH

broker/neb/inc/com/centreon/broker/neb/internal.hh

@@ -27,6 +27,7 @@
 #include "com/centreon/broker/io/protobuf.hh"
 #include "com/centreon/broker/multiplexing/publisher.hh"
 #include "com/centreon/broker/neb/callback.hh"
+#include "opentelemetry/proto/collector/metrics/v1/metrics_service.pb.h"
 
 namespace com::centreon::broker {
 
@@ -122,8 +123,12 @@ using pb_service_group_member =
     io::protobuf<ServiceGroupMember,
                  make_type(io::neb, neb::de_pb_service_group_member)>;
 
+using pb_otl_metrics = io::protobuf<
+    opentelemetry::proto::collector::metrics::v1::ExportMetricsServiceRequest,
+    make_type(io::storage, storage::de_pb_otl_metrics)>;
+
 }  // namespace neb
 
-}
+}  // namespace com::centreon::broker
 
 #endif  // !CCB_NEB_INTERNAL_HH

broker/neb/src/broker.cc

@@ -1,20 +1,20 @@
 /**
-* Copyright 2009-2013,2015-2016 Centreon
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* For more information : [email protected]
-*/
+ * Copyright 2009-2013,2015-2016 Centreon
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * For more information : [email protected]
+ */
 
 #include "com/centreon/broker/io/events.hh"
 #include "com/centreon/broker/io/protocols.hh"
@@ -215,6 +215,8 @@ void broker_module_init(void const* arg) {
       e.register_event(
           neb::pb_service_group_member::static_type(), "ServiceGroupMember",
           &neb::pb_service_group_member::operations, "services_servicegroups");
+      e.register_event(neb::pb_otl_metrics::static_type(), "OTLMetrics",
+                       &neb::pb_otl_metrics::operations, "otl_metrics");
     }
   }
 }