Module metadata 

Access to the metadata stored in the relational database

Structs

ProcessMetadata

Analytics-optimized process metadata.

StreamMetadata

Analytics-optimized stream metadata.

Functions

block_from_batch_row

Creates a BlockMetadata from a recordbatch row.

find_process

Finds a process by its ID and returns it as ProcessMetadata with pre-serialized JSONB properties.

find_process_with_latest_timing

Finds a process and its latest timing information using DataFusion (optimized version). Returns (ProcessMetadata, last_block_end_ticks, last_block_end_time)

find_stream

Finds a stream by its ID and returns it as StreamMetadata.

get_thread_name_from_stream_metadata

Returns the thread name associated with the stream, if available. This function is only meaningful for streams associated with CPU threads. Returns format: “thread-name-thread-id” (e.g., “main-12345”) or just “thread-id” if no name.

process_metadata_from_row

Creates a ProcessMetadata from a database row with pre-serialized JSONB properties.

stream_metadata_from_row

Creates a StreamMetadata from a database row with pre-serialized JSONB properties.

Type Aliases

SharedJsonbSerialized

Type alias for shared, pre-serialized JSONB data. This represents JSONB properties that have been serialized once and can be reused.