Dfanalyzer

Namespace: dftracer::utils::utilities::composites::dft::dfanalyzer

source

struct AggDbHandle

Public Members

std::shared_ptr<dftracer::utils::rocksdb::RocksDatabase> db

std::unique_ptr<aggregators::EventAggregator> agg

source

struct AggScanInput

Public Members

const aggregators::EventAggregator *agg

aggregators::AggMapType target_type

aggregators::AggregationBatchType batch_type

std::int64_t batch_size

std::uint16_t shard_begin

std::uint16_t shard_end

source

struct AggScanOutput

Public Members

std::vector<ArrowExportResult> results

source

struct DfanalyzerScanInput

Public Members

const aggregators::EventAggregator *agg

const aggregators::DfanalyzerContext *ctx

std::optional<aggregators::AggMapType> type_filter

std::int64_t batch_size

std::uint16_t shard_begin

std::uint16_t shard_end

const GroupByConfig *group_by

source

struct DfanalyzerScanOutput

Public Members

std::vector<ArrowExportResult> events

std::vector<ArrowExportResult> profiles

std::vector<ArrowExportResult> system

source

struct GroupByConfig

Public Members

std::uint32_t mask

std::vector<GroupByField> order

std::vector<std::string> names

Free Functions

source

std::unique_ptr<AggDbHandle> dftracer::utils::utilities::composites::dft::dfanalyzer::open_agg_db(const std::string &index_path, std::string &error_msg)

source

std::optional<GroupByField> dftracer::utils::utilities::composites::dft::dfanalyzer::parse_group_by_name(std::string_view name)

source

AggScanOutput dftracer::utils::utilities::composites::dft::dfanalyzer::scan_aggregation_shard_range(AggScanInput input)

source

DfanalyzerScanOutput dftracer::utils::utilities::composites::dft::dfanalyzer::scan_dfanalyzer_shards(DfanalyzerScanInput input)

source

std::vector<ArrowExportResult> dftracer::utils::utilities::composites::dft::dfanalyzer::scan_system_metrics_buffer(const aggregators::EventAggregator *agg, const aggregators::DfanalyzerContext *ctx, std::int64_t batch_size)