IngestMessage¶
Model of Ingester Heartbeat Message
Field | Type | Description | Required | Default |
---|---|---|---|---|
msg | Heartbeat | Heartbeat message | Yes |
None |
msg_loader | Enum | Loader class for message Supported values are: "assemblyline.odm.messages.ingest_heartbeat.IngestMessage" |
Yes |
assemblyline.odm.messages.ingest_heartbeat.IngestMessage |
msg_type | Enum | Type of message Supported values are: "IngestHeartbeat" |
Yes |
IngestHeartbeat |
sender | Keyword | Sender of message | Yes |
None |
Heartbeat¶
Heartbeat Model
Field | Type | Description | Required | Default |
---|---|---|---|---|
instances | Integer | Number of ingest processes | Yes |
None |
metrics | Metrics | Metrics | Yes |
None |
processing | Processing | Inflight queue sizes | Yes |
None |
processing_chance | ProcessingChance | Chance of processing items | Yes |
None |
queues | Queues | Queue lengths block | Yes |
None |
Metrics¶
Metrics
Field | Type | Description | Required | Default |
---|---|---|---|---|
cache_miss | Integer | Number of cache misses | Yes |
None |
cache_expired | Integer | Number of cache expires | Yes |
None |
cache_stale | Integer | Number of cache stales | Yes |
None |
cache_hit_local | Integer | Number of cache local hits | Yes |
None |
cache_hit | Integer | Number of cache hits | Yes |
None |
bytes_completed | Integer | Number of bytes completed | Yes |
None |
bytes_ingested | Integer | Number of bytes ingested | Yes |
None |
duplicates | Integer | Number of duplicate submissions | Yes |
None |
error | Integer | Number of errors | Yes |
None |
files_completed | Integer | Number of completed files | Yes |
None |
skipped | Integer | Number of skipped files | Yes |
None |
submissions_completed | Integer | Number of completed submissions | Yes |
None |
submissions_ingested | Integer | Number of ingested submissions | Yes |
None |
timed_out | Integer | Number of timed_out submissions | Yes |
None |
whitelisted | Integer | Number of safelisted submissions | Yes |
None |
cpu_seconds | PerformanceTimer | None | Yes |
None |
cpu_seconds_count | Integer | None | Yes |
None |
busy_seconds | PerformanceTimer | None | Yes |
None |
busy_seconds_count | Integer | None | Yes |
None |
Processing¶
Processing
Field | Type | Description | Required | Default |
---|---|---|---|---|
inflight | Integer | Number of inflight submissions | Yes |
None |
ProcessingChance¶
Chance of Processing
Field | Type | Description | Required | Default |
---|---|---|---|---|
critical | Float | Chance of processing critical items | Yes |
None |
high | Float | Chance of processing high items | Yes |
None |
low | Float | Chance of processing low items | Yes |
None |
medium | Float | Chance of processing medium items | Yes |
None |
Queues¶
Queues
Field | Type | Description | Required | Default |
---|---|---|---|---|
critical | Integer | Size of the critical priority queue | Yes |
None |
high | Integer | Size of the high priority queue | Yes |
None |
ingest | Integer | Size of the ingest queue | Yes |
None |
complete | Integer | Size of the complete queue | Yes |
None |
low | Integer | Size of the low priority queue | Yes |
None |
medium | Integer | Size of the medium priority queue | Yes |
None |