Skip to main content

Type Alias: IngestionStats

type IngestionStats = {
events_received: number;
events_matched: number;
events_dropped: number;
updates_applied: number;
components_written: number;
components_deduped: number;
directives_applied: number;
drops: Partial<Record<IngestionDropReason, number>>;
last_event_at: Date | null;
last_applied_at: Date | null;
bound_scene_count: number;
per_mapping: MappingStats[];
};

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:54

A snapshot of what an IngestionPipeline has actually done — the answer to "is data flowing?", which the transports and the scene cannot give on their own.

Note that events_matched and events_dropped overlap: an event a mapping selected but then applied nothing for (no id, no updates, unresolved entity) counts in both, so their sum can exceed events_received.

Properties

events_received

events_received: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:56

Events submitted to the pipeline, whatever became of them.


events_matched

events_matched: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:58

Events at least one mapping matched. Overlaps events_dropped.


events_dropped

events_dropped: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:60

Events no mapping applied at all, for any reason. Overlaps events_matched.


updates_applied

updates_applied: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:62

(entity update, scene) pairs successfully applied.


components_written

components_written: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:64

Component writes actually sent to the scene.


components_deduped

components_deduped: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:66

Component writes skipped because the value was unchanged.


directives_applied

directives_applied: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:68

Whole-entity directives (delete / hide / show) carried out.


drops

drops: Partial<Record<IngestionDropReason, number>>;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:70

Drop totals across every mapping.


last_event_at

last_event_at: Date | null;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:72

When the pipeline last received an event, whatever became of it.


last_applied_at

last_applied_at: Date | null;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:74

When the pipeline last wrote to a scene.


bound_scene_count

bound_scene_count: number;

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:76

Scenes currently bound.


per_mapping

per_mapping: MappingStats[];

Defined in: livelink.clients/livelink.agent/sources/data/IngestionStats.ts:78

Per-mapping breakdown, index-aligned with the pipeline's mappings.