kcenon::container::integration::messaging_container_builder Class Reference

Builder pattern for messaging containers. More...

#include <messaging_integration.h>

Collaboration diagram for kcenon::container::integration::messaging_container_builder:

Public Member Functions
	messaging_container_builder ()
messaging_container_builder &	source (const std::string &id, const std::string &sub_id="")
messaging_container_builder &	target (const std::string &id, const std::string &sub_id="")
messaging_container_builder &	message_type (const std::string &type)
template<typename T >
messaging_container_builder &	set (const std::string &key, T &&value)
	Set a value by key (unified API)
messaging_container_builder &	optimize_for_size ()
messaging_container_builder &	optimize_for_speed ()
std::shared_ptr< value_container >	build ()

Private Attributes
std::shared_ptr< value_container >	container_
bool	size_optimized_ = false
bool	speed_optimized_ = false

Detailed Description

Builder pattern for messaging containers.

Definition at line 99 of file messaging_integration.h.

Constructor & Destructor Documentation

messaging_container_builder()

kcenon::container::integration::messaging_container_builder::messaging_container_builder

(

)

Definition at line 178 of file messaging_integration.cpp.

    : container_(std::make_shared<value_container>()) {
}

Member Function Documentation

build()

std::shared_ptr< value_container > kcenon::container::integration::messaging_container_builder::build

(

)

Definition at line 211 of file messaging_integration.cpp.

                                                                  {
    // Apply optimizations based on settings
    if (size_optimized_) {
        // TODO: Apply size optimizations
    } else if (speed_optimized_) {
        // TODO: Apply speed optimizations
    }
 
    auto result = container_;
    container_ = std::make_shared<value_container>();  // Reset for potential reuse
    return result;
}

References container_, size_optimized_, and speed_optimized_.

message_type()

messaging_container_builder & kcenon::container::integration::messaging_container_builder::message_type

(

const std::string &

type

)

Definition at line 194 of file messaging_integration.cpp.

                                                                                            {
    container_->set_message_type(type);
    return *this;
}

References container_.

optimize_for_size()

messaging_container_builder & kcenon::container::integration::messaging_container_builder::optimize_for_size

(

)

Definition at line 199 of file messaging_integration.cpp.

                                                                            {
    size_optimized_ = true;
    speed_optimized_ = false;
    return *this;
}

References size_optimized_, and speed_optimized_.

optimize_for_speed()

messaging_container_builder & kcenon::container::integration::messaging_container_builder::optimize_for_speed

(

)

Definition at line 205 of file messaging_integration.cpp.

                                                                             {
    speed_optimized_ = true;
    size_optimized_ = false;
    return *this;
}

References size_optimized_, and speed_optimized_.

set()

template<typename T >

messaging_container_builder & kcenon::container::integration::messaging_container_builder::set	(	const std::string &	key,
		T &&	value )

Set a value by key (unified API)

Parameters

key	The value key/name
value	The value to store

Returns

Reference to this builder for method chaining

Definition at line 150 of file messaging_integration.h.

                                                                                             {
    using DecayedT = std::decay_t<T>;
 
    if constexpr (std::is_same_v<DecayedT, std::shared_ptr<value_container>>) {
        // Handle nested containers by serializing and storing as bytes
        auto result = value->serialize_string(value_container::serialization_format::binary);
        if (result.is_ok()) {
            std::string serialized_data = result.value();
            std::vector<uint8_t> bytes(serialized_data.begin(), serialized_data.end());
            container_->set(key, bytes);
        }
    } else if constexpr (std::is_same_v<DecayedT, bool>) {
        container_->set(key, value);
    } else if constexpr (concepts::IntegralType<DecayedT>) {
        if constexpr (sizeof(DecayedT) <= 4) {
            container_->set(key, static_cast<int32_t>(value));
        } else {
            container_->set(key, static_cast<int64_t>(value));
        }
    } else if constexpr (concepts::FloatingPointType<DecayedT>) {
        if constexpr (std::is_same_v<DecayedT, float>) {
            container_->set(key, value);
        } else {
            container_->set(key, value);
        }
    } else if constexpr (std::is_same_v<DecayedT, std::string>) {
        container_->set(key, std::string(value));
    } else if constexpr (concepts::StringLike<DecayedT>) {
        container_->set(key, std::string(value));
    }
 
    return *this;
}

References container_.

source()

messaging_container_builder & kcenon::container::integration::messaging_container_builder::source	(	const std::string &	id,
		const std::string &	sub_id = "" )

Definition at line 182 of file messaging_integration.cpp.

                                                  {
    container_->set_source(id, sub_id);
    return *this;
}

References container_.

target()

messaging_container_builder & kcenon::container::integration::messaging_container_builder::target	(	const std::string &	id,
		const std::string &	sub_id = "" )

Definition at line 188 of file messaging_integration.cpp.

                                                  {
    container_->set_target(id, sub_id);
    return *this;
}

References container_.

Member Data Documentation

container_

std::shared_ptr<value_container> kcenon::container::integration::messaging_container_builder::container_

private

Definition at line 122 of file messaging_integration.h.

Referenced by build(), message_type(), set(), source(), and target().

size_optimized_

bool kcenon::container::integration::messaging_container_builder::size_optimized_ = false

private

Definition at line 123 of file messaging_integration.h.

Referenced by build(), optimize_for_size(), and optimize_for_speed().

speed_optimized_

bool kcenon::container::integration::messaging_container_builder::speed_optimized_ = false

private

Definition at line 124 of file messaging_integration.h.

Referenced by build(), optimize_for_size(), and optimize_for_speed().

---

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

• integration/messaging_integration.h
• integration/messaging_integration.cpp