Index

A

AbstractMetricsBackend (class in roastcoffea.backends.base) AbstractTrackingDataParser (class in roastcoffea.aggregation.backends.base)

aggregate() (roastcoffea.aggregation.core.MetricsAggregator method) aggregate_chunk_metrics() (in module roastcoffea.aggregation.chunk) aggregate_workflow_metrics() (in module roastcoffea.aggregation.workflow)

B

build_chunk_info() (in module roastcoffea.aggregation.chunk)

C

calculate_average_memory_per_worker() (in module roastcoffea.aggregation.backends.dask) calculate_efficiency_metrics() (in module roastcoffea.aggregation.efficiency) calculate_peak_memory() (in module roastcoffea.aggregation.backends.dask)

calculate_time_averaged_workers() (in module roastcoffea.aggregation.backends.dask) create_span() (roastcoffea.backends.base.AbstractMetricsBackend method) (roastcoffea.backends.dask.DaskMetricsBackend method)

D

DaskMetricsBackend (class in roastcoffea.backends.dask)

DaskTrackingDataParser (class in roastcoffea.aggregation.backends.dask)

E

extract_metrics_from_output() (roastcoffea.collector.MetricsCollector method)

F

format_chunk_metrics_table() (in module roastcoffea.export.reporter) format_event_processing_table() (in module roastcoffea.export.reporter) format_fine_metrics_table() (in module roastcoffea.export.reporter)

format_resources_table() (in module roastcoffea.export.reporter) format_throughput_table() (in module roastcoffea.export.reporter) format_timing_table() (in module roastcoffea.export.reporter)

G

get_metrics() (roastcoffea.collector.MetricsCollector method) get_process_memory() (in module roastcoffea.utils)

get_span_metrics() (roastcoffea.backends.base.AbstractMetricsBackend method) (roastcoffea.backends.dask.DaskMetricsBackend method)

L

load_measurement() (in module roastcoffea.export.measurements)

M

MetricsAggregator (class in roastcoffea.aggregation.core) MetricsCollector (class in roastcoffea.collector) module roastcoffea.aggregation.backends.base roastcoffea.aggregation.backends.dask roastcoffea.aggregation.chunk roastcoffea.aggregation.core roastcoffea.aggregation.efficiency roastcoffea.aggregation.fine_metrics roastcoffea.aggregation.workflow roastcoffea.backends.base roastcoffea.backends.dask roastcoffea.collector roastcoffea.decorator roastcoffea.export.measurements roastcoffea.export.reporter roastcoffea.instrumentation roastcoffea.utils roastcoffea.visualization.plots.cpu roastcoffea.visualization.plots.memory roastcoffea.visualization.plots.scaling roastcoffea.visualization.plots.throughput roastcoffea.visualization.plots.workers

P

parse_fine_metrics() (in module roastcoffea.aggregation.fine_metrics) parse_tracking_data() (roastcoffea.aggregation.backends.base.AbstractTrackingDataParser method) (roastcoffea.aggregation.backends.dask.DaskTrackingDataParser method) plot_cpu_utilization_mean_timeline() (in module roastcoffea.visualization.plots.cpu) plot_cpu_utilization_per_worker_timeline() (in module roastcoffea.visualization.plots.cpu) plot_efficiency_summary() (in module roastcoffea.visualization.plots.scaling) plot_executing_tasks_timeline() (in module roastcoffea.visualization.plots.cpu) plot_memory_utilization_mean_timeline() (in module roastcoffea.visualization.plots.memory)

plot_memory_utilization_per_worker_timeline() (in module roastcoffea.visualization.plots.memory) plot_occupancy_timeline() (in module roastcoffea.visualization.plots.cpu) plot_resource_utilization() (in module roastcoffea.visualization.plots.scaling) plot_throughput_timeline() (in module roastcoffea.visualization.plots.throughput) plot_total_active_tasks_timeline() (in module roastcoffea.visualization.plots.throughput) plot_worker_activity_timeline() (in module roastcoffea.visualization.plots.throughput) plot_worker_count_timeline() (in module roastcoffea.visualization.plots.workers) print_summary() (roastcoffea.collector.MetricsCollector method)

R

record_chunk_metrics() (roastcoffea.collector.MetricsCollector method) record_section_metrics() (roastcoffea.collector.MetricsCollector method) roastcoffea.aggregation.backends.base module roastcoffea.aggregation.backends.dask module roastcoffea.aggregation.chunk module roastcoffea.aggregation.core module roastcoffea.aggregation.efficiency module roastcoffea.aggregation.fine_metrics module roastcoffea.aggregation.workflow module roastcoffea.backends.base module roastcoffea.backends.dask module roastcoffea.collector module

roastcoffea.decorator module roastcoffea.export.measurements module roastcoffea.export.reporter module roastcoffea.instrumentation module roastcoffea.utils module roastcoffea.visualization.plots.cpu module roastcoffea.visualization.plots.memory module roastcoffea.visualization.plots.scaling module roastcoffea.visualization.plots.throughput module roastcoffea.visualization.plots.workers module

S

save_measurement() (in module roastcoffea.export.measurements) (roastcoffea.collector.MetricsCollector method) set_coffea_report() (roastcoffea.collector.MetricsCollector method) start_tracking() (roastcoffea.backends.base.AbstractMetricsBackend method) (roastcoffea.backends.dask.DaskMetricsBackend method)

stop_tracking() (roastcoffea.backends.base.AbstractMetricsBackend method) (roastcoffea.backends.dask.DaskMetricsBackend method) supports_fine_metrics() (roastcoffea.backends.base.AbstractMetricsBackend method) (roastcoffea.backends.dask.DaskMetricsBackend method)

T

track_bytes() (in module roastcoffea.instrumentation) track_memory() (in module roastcoffea.instrumentation)

track_metrics() (in module roastcoffea.decorator) track_time() (in module roastcoffea.instrumentation)