kcenon::monitoring::protobuf_wire::reader Class Reference

Minimal protobuf wire reader used for round-trip tests. More...

#include <protobuf_wire.h>

Collaboration diagram for kcenon::monitoring::protobuf_wire::reader:

Public Member Functions
	reader (const std::uint8_t *data, std::size_t size)
bool	eof () const
std::size_t	position () const
std::size_t	size () const
std::optional< std::uint64_t >	read_varint ()
std::optional< std::uint64_t >	read_fixed64 ()
std::optional< std::uint32_t >	read_fixed32 ()
bool	read_length_delimited (const std::uint8_t **out_ptr, std::size_t *out_len)
	Read a length-delimited payload. Returns pointer into the underlying buffer and the length. The pointer is valid for the lifetime of the wrapped buffer.
bool	read_string (std::string &out)
bool	read_bytes (std::vector< std::uint8_t > &out)
bool	skip_field (wire_type wt)
	Skip a field whose wire type is given.

Private Attributes
const std::uint8_t *	data_
std::size_t	size_
std::size_t	pos_

Detailed Description

Minimal protobuf wire reader used for round-trip tests.

Definition at line 169 of file protobuf_wire.h.

Constructor & Destructor Documentation

reader()

kcenon::monitoring::protobuf_wire::reader::reader ( const std::uint8_t * data, std::size_t size )

inline

Definition at line 171 of file protobuf_wire.h.

        : data_(data), size_(size), pos_(0) {}

Member Function Documentation

eof()

bool kcenon::monitoring::protobuf_wire::reader::eof ( ) const

inline

Definition at line 174 of file protobuf_wire.h.

{ return pos_ >= size_; }

References pos_, and size_.

Referenced by kcenon::monitoring::zipkin_proto::decode_annotation(), kcenon::monitoring::jaeger_proto::decode_batch(), kcenon::monitoring::zipkin_proto::decode_endpoint(), kcenon::monitoring::jaeger_proto::decode_key_value(), kcenon::monitoring::zipkin_proto::decode_list_of_spans(), kcenon::monitoring::zipkin_proto::decode_map_entry(), kcenon::monitoring::jaeger_proto::decode_process(), kcenon::monitoring::jaeger_proto::decode_span(), kcenon::monitoring::zipkin_proto::decode_span(), kcenon::monitoring::jaeger_proto::decode_span_ref(), kcenon::monitoring::jaeger_proto::decode_timestamp(), and TEST().

Here is the caller graph for this function:

position()

std::size_t kcenon::monitoring::protobuf_wire::reader::position ( ) const

inline

Definition at line 175 of file protobuf_wire.h.

{ return pos_; }

References pos_.

read_bytes()

bool kcenon::monitoring::protobuf_wire::reader::read_bytes ( std::vector< std::uint8_t > & out )

inline

Definition at line 241 of file protobuf_wire.h.

                                                {
        const std::uint8_t* ptr = nullptr;
        std::size_t len = 0;
        if (!read_length_delimited(&ptr, &len)) return false;
        out.assign(ptr, ptr + len);
        return true;
    }

References read_length_delimited().

Referenced by kcenon::monitoring::zipkin_proto::decode_endpoint(), kcenon::monitoring::jaeger_proto::decode_key_value(), kcenon::monitoring::jaeger_proto::decode_span(), kcenon::monitoring::zipkin_proto::decode_span(), and kcenon::monitoring::jaeger_proto::decode_span_ref().

Here is the call graph for this function:

Here is the caller graph for this function:

read_fixed32()

std::optional< std::uint32_t > kcenon::monitoring::protobuf_wire::reader::read_fixed32 ( )

inline

Definition at line 206 of file protobuf_wire.h.

                                            {
        if (pos_ + 4 > size_) {
            return std::nullopt;
        }
        std::uint32_t result = 0;
        for (int i = 0; i < 4; ++i) {
            result |= static_cast<std::uint32_t>(data_[pos_++]) << (i * 8);
        }
        return result;
    }

References data_, pos_, and size_.

Referenced by skip_field().

Here is the caller graph for this function:

read_fixed64()

std::optional< std::uint64_t > kcenon::monitoring::protobuf_wire::reader::read_fixed64 ( )

inline

Definition at line 195 of file protobuf_wire.h.

                                            {
        if (pos_ + 8 > size_) {
            return std::nullopt;
        }
        std::uint64_t result = 0;
        for (int i = 0; i < 8; ++i) {
            result |= static_cast<std::uint64_t>(data_[pos_++]) << (i * 8);
        }
        return result;
    }

References data_, pos_, and size_.

Referenced by kcenon::monitoring::zipkin_proto::decode_annotation(), kcenon::monitoring::jaeger_proto::decode_key_value(), kcenon::monitoring::zipkin_proto::decode_span(), and skip_field().

Here is the caller graph for this function:

read_length_delimited()

bool kcenon::monitoring::protobuf_wire::reader::read_length_delimited ( const std::uint8_t ** out_ptr, std::size_t * out_len )

inline

Read a length-delimited payload. Returns pointer into the underlying buffer and the length. The pointer is valid for the lifetime of the wrapped buffer.

Definition at line 222 of file protobuf_wire.h.

                                                   {
        auto len = read_varint();
        if (!len) return false;
        if (pos_ + *len > size_) return false;
        *out_ptr = data_ + pos_;
        *out_len = static_cast<std::size_t>(*len);
        pos_ += *len;
        return true;
    }

References data_, pos_, read_varint(), and size_.

Referenced by kcenon::monitoring::jaeger_proto::decode_batch(), kcenon::monitoring::zipkin_proto::decode_list_of_spans(), kcenon::monitoring::zipkin_proto::decode_map_entry(), kcenon::monitoring::jaeger_proto::decode_process(), kcenon::monitoring::jaeger_proto::decode_span(), kcenon::monitoring::zipkin_proto::decode_span(), read_bytes(), read_string(), and skip_field().

Here is the call graph for this function:

Here is the caller graph for this function:

read_string()

bool kcenon::monitoring::protobuf_wire::reader::read_string ( std::string & out )

inline

Definition at line 233 of file protobuf_wire.h.

                                     {
        const std::uint8_t* ptr = nullptr;
        std::size_t len = 0;
        if (!read_length_delimited(&ptr, &len)) return false;
        out.assign(reinterpret_cast<const char*>(ptr), len);
        return true;
    }

References read_length_delimited().

Referenced by kcenon::monitoring::zipkin_proto::decode_annotation(), kcenon::monitoring::zipkin_proto::decode_endpoint(), kcenon::monitoring::jaeger_proto::decode_key_value(), kcenon::monitoring::zipkin_proto::decode_map_entry(), kcenon::monitoring::jaeger_proto::decode_process(), kcenon::monitoring::jaeger_proto::decode_span(), and kcenon::monitoring::zipkin_proto::decode_span().

Here is the call graph for this function:

Here is the caller graph for this function:

read_varint()

std::optional< std::uint64_t > kcenon::monitoring::protobuf_wire::reader::read_varint ( )

inline

Definition at line 178 of file protobuf_wire.h.

                                           {
        std::uint64_t result = 0;
        int shift = 0;
        while (pos_ < size_) {
            std::uint8_t byte = data_[pos_++];
            result |= static_cast<std::uint64_t>(byte & 0x7F) << shift;
            if ((byte & 0x80) == 0) {
                return result;
            }
            shift += 7;
            if (shift > 63) {
                return std::nullopt;
            }
        }
        return std::nullopt;
    }

References data_, pos_, and size_.

Referenced by kcenon::monitoring::zipkin_proto::decode_endpoint(), kcenon::monitoring::jaeger_proto::decode_key_value(), kcenon::monitoring::jaeger_proto::decode_span(), kcenon::monitoring::zipkin_proto::decode_span(), kcenon::monitoring::jaeger_proto::decode_span_ref(), kcenon::monitoring::protobuf_wire::decode_tag(), kcenon::monitoring::jaeger_proto::decode_timestamp(), read_length_delimited(), skip_field(), and TEST().

Here is the caller graph for this function:

size()

std::size_t kcenon::monitoring::protobuf_wire::reader::size ( ) const

inline

Definition at line 176 of file protobuf_wire.h.

{ return size_; }

References size_.

skip_field()

bool kcenon::monitoring::protobuf_wire::reader::skip_field ( wire_type wt )

inline

Skip a field whose wire type is given.

Definition at line 250 of file protobuf_wire.h.

                                  {
        switch (wt) {
            case wire_type::varint:
                return read_varint().has_value();
            case wire_type::fixed64:
                return read_fixed64().has_value();
            case wire_type::length_delimited: {
                const std::uint8_t* ptr;
                std::size_t len;
                return read_length_delimited(&ptr, &len);
            }
            case wire_type::fixed32:
                return read_fixed32().has_value();
        }
        return false;
    }

References kcenon::monitoring::protobuf_wire::fixed32, kcenon::monitoring::protobuf_wire::fixed64, kcenon::monitoring::protobuf_wire::length_delimited, read_fixed32(), read_fixed64(), read_length_delimited(), read_varint(), and kcenon::monitoring::protobuf_wire::varint.

Referenced by kcenon::monitoring::zipkin_proto::decode_annotation(), kcenon::monitoring::jaeger_proto::decode_batch(), kcenon::monitoring::zipkin_proto::decode_endpoint(), kcenon::monitoring::jaeger_proto::decode_key_value(), kcenon::monitoring::zipkin_proto::decode_list_of_spans(), kcenon::monitoring::zipkin_proto::decode_map_entry(), kcenon::monitoring::jaeger_proto::decode_process(), kcenon::monitoring::jaeger_proto::decode_span(), kcenon::monitoring::zipkin_proto::decode_span(), kcenon::monitoring::jaeger_proto::decode_span_ref(), and kcenon::monitoring::jaeger_proto::decode_timestamp().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

data_

const std::uint8_t* kcenon::monitoring::protobuf_wire::reader::data_

private

Definition at line 268 of file protobuf_wire.h.

Referenced by read_fixed32(), read_fixed64(), read_length_delimited(), and read_varint().

pos_

std::size_t kcenon::monitoring::protobuf_wire::reader::pos_

private

Definition at line 270 of file protobuf_wire.h.

Referenced by eof(), position(), read_fixed32(), read_fixed64(), read_length_delimited(), and read_varint().

size_

std::size_t kcenon::monitoring::protobuf_wire::reader::size_

private

Definition at line 269 of file protobuf_wire.h.

Referenced by eof(), read_fixed32(), read_fixed64(), read_length_delimited(), read_varint(), and size().

---

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

• include/kcenon/monitoring/exporters/internal/protobuf_wire.h