kcenon::monitoring::file_storage_backend Class Reference

File storage backend for metrics snapshots. More...

#include <storage_backends.h>

Inheritance diagram for kcenon::monitoring::file_storage_backend:

Collaboration diagram for kcenon::monitoring::file_storage_backend:

Public Member Functions
	file_storage_backend ()
	file_storage_backend (const storage_config &config)
common::Result< bool >	store (const metrics_snapshot &snapshot) override
common::Result< metrics_snapshot >	retrieve (size_t index) override
common::Result< std::vector< metrics_snapshot > >	retrieve_range (size_t start, size_t count) override
size_t	size () const override
size_t	capacity () const override
common::Result< bool >	flush () override
common::Result< bool >	clear () override
std::unordered_map< std::string, size_t >	get_stats () const override
Public Member Functions inherited from kcenon::monitoring::snapshot_storage_backend
virtual	~snapshot_storage_backend ()=default

Private Attributes
storage_config	config_
std::deque< metrics_snapshot >	snapshots_
std::mutex	mutex_

Detailed Description

File storage backend for metrics snapshots.

Definition at line 123 of file storage_backends.h.

Constructor & Destructor Documentation

file_storage_backend() [1/2]

kcenon::monitoring::file_storage_backend::file_storage_backend ( )

inline

Definition at line 125 of file storage_backends.h.

: config_() {}

file_storage_backend() [2/2]

kcenon::monitoring::file_storage_backend::file_storage_backend ( const storage_config & config )

inlineexplicit

Definition at line 127 of file storage_backends.h.

        : config_(config) {}

Member Function Documentation

capacity()

size_t kcenon::monitoring::file_storage_backend::capacity ( ) const

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 170 of file storage_backends.h.

                                     {
        return config_.max_capacity;
    }

References config_, and kcenon::monitoring::storage_config::max_capacity.

Referenced by TEST_F().

Here is the caller graph for this function:

clear()

common::Result< bool > kcenon::monitoring::file_storage_backend::clear ( )

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 179 of file storage_backends.h.

                                        {
        std::lock_guard<std::mutex> lock(mutex_);
        snapshots_.clear();
        return common::ok(true);
    }

References mutex_, and snapshots_.

Referenced by TEST_F(), and TEST_F().

Here is the caller graph for this function:

flush()

common::Result< bool > kcenon::monitoring::file_storage_backend::flush ( )

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 174 of file storage_backends.h.

                                        {
        // Stub implementation - actual file I/O would go here
        return common::ok(true);
    }

Referenced by TEST_F().

Here is the caller graph for this function:

get_stats()

std::unordered_map< std::string, size_t > kcenon::monitoring::file_storage_backend::get_stats ( ) const

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 185 of file storage_backends.h.

                                                                   {
        std::lock_guard<std::mutex> lock(mutex_);
        return {
            {"total_snapshots", snapshots_.size()},
            {"capacity", config_.max_capacity}
        };
    }

References config_, kcenon::monitoring::storage_config::max_capacity, mutex_, and snapshots_.

Referenced by TEST_F().

Here is the caller graph for this function:

retrieve()

common::Result< metrics_snapshot > kcenon::monitoring::file_storage_backend::retrieve ( size_t index )

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 142 of file storage_backends.h.

                                                                   {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (index >= snapshots_.size()) {
            return common::Result<metrics_snapshot>::err(error_info(monitoring_error_code::not_found, "Snapshot index out of range").to_common_error());
        }
 
        return common::ok(snapshots_[index]);
    }

References mutex_, kcenon::monitoring::not_found, and snapshots_.

Referenced by TEST_F(), TEST_F(), TEST_F(), TEST_F(), and TEST_F().

Here is the caller graph for this function:

retrieve_range()

common::Result< std::vector< metrics_snapshot > > kcenon::monitoring::file_storage_backend::retrieve_range ( size_t start, size_t count )

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 152 of file storage_backends.h.

                                                                                                  {
        std::lock_guard<std::mutex> lock(mutex_);
 
        std::vector<metrics_snapshot> result;
        size_t end = std::min(start + count, snapshots_.size());
 
        for (size_t i = start; i < end; ++i) {
            result.push_back(snapshots_[i]);
        }
 
        return common::ok(std::move(result));
    }

References mutex_, and snapshots_.

Referenced by TEST_F(), TEST_F(), and TEST_F().

Here is the caller graph for this function:

size()

size_t kcenon::monitoring::file_storage_backend::size ( ) const

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 165 of file storage_backends.h.

                                 {
        std::lock_guard<std::mutex> lock(mutex_);
        return snapshots_.size();
    }

References mutex_, and snapshots_.

Referenced by TEST_F(), TEST_F(), TEST_F(), TEST_F(), and TEST_F().

Here is the caller graph for this function:

store()

common::Result< bool > kcenon::monitoring::file_storage_backend::store ( const metrics_snapshot & snapshot )

inlineoverridevirtual

Implements kcenon::monitoring::snapshot_storage_backend.

Definition at line 130 of file storage_backends.h.

                                                                        {
        std::lock_guard<std::mutex> lock(mutex_);
 
        // Remove oldest if at capacity
        if (snapshots_.size() >= config_.max_capacity) {
            snapshots_.pop_front();
        }
 
        snapshots_.push_back(snapshot);
        return common::ok(true);
    }

References config_, kcenon::monitoring::storage_config::max_capacity, mutex_, and snapshots_.

Referenced by TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), and TEST_F().

Here is the caller graph for this function:

Member Data Documentation

config_

storage_config kcenon::monitoring::file_storage_backend::config_

private

Definition at line 194 of file storage_backends.h.

Referenced by capacity(), get_stats(), and store().

mutex_

std::mutex kcenon::monitoring::file_storage_backend::mutex_

mutableprivate

Definition at line 196 of file storage_backends.h.

Referenced by clear(), get_stats(), retrieve(), retrieve_range(), size(), and store().

snapshots_

std::deque<metrics_snapshot> kcenon::monitoring::file_storage_backend::snapshots_

private

Definition at line 195 of file storage_backends.h.

Referenced by clear(), get_stats(), retrieve(), retrieve_range(), size(), and store().

---

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

• include/kcenon/monitoring/storage/storage_backends.h