Structs§
- Aligned
Buffer - Backpressure
Config - Thresholds for backpressure activation
- Backpressure
Guard - Guard that tracks an operation for backpressure
- Backpressure
Monitor - Backpressure monitor tracking system resource utilization
- Backpressure
Snapshot - Snapshot of backpressure metrics
- Batch
Pool - Chaos
Config - Chaos injection configuration
- Chaos
Injector - Chaos injection controller
- Chaos
Scenario - Scenario for chaos testing
- Header
- Parsed TLV header
- HlcTimestamp
- Hybrid Logical Clock timestamp (64-bit packed).
- Hybrid
Logical Clock - Hybrid Logical Clock for generating causally consistent timestamps.
- Ingestion
Batch - Loanable
Batch - Numa
Aligned Buffer - Numa
Allocator - NUMA-aware allocator for buffer pools
- Numa
Thread Pool Config - Thread pool configuration for NUMA-aware workloads
- Numa
Topology - NUMA topology information
- SortKey
- 128-bit composite sort key for total ordering across distributed nodes.
Enums§
- Backpressure
Level - Current backpressure level
- Clock
Health - Health status of the HLC clock.
- Fault
Type - Fault types for scenario testing
- Lance
Error
Constants§
- DEFAULT_
BATCH_ SIZE - DEFAULT_
SPARSE_ INDEX_ INTERVAL - EXTENDED_
TLV_ HEADER_ SIZE - EXTENDED_
TYPE_ MARKER - LANCE_
MAGIC - TIMESTAMP_
JITTER_ WINDOW_ NS - TLV_
HEADER_ SIZE
Functions§
- crc32c
- get_
current_ numa_ node - Get the NUMA node for the current thread
- parse_
header - Parse a TLV header from a byte slice.
- pin_
thread_ to_ cpu - Pin the current thread to a specific CPU.
- pin_
thread_ to_ numa_ node - Pin the current thread to CPUs on a specific NUMA node.
- shared_
injector - Create a shared chaos injector
Type Aliases§
- Result
- Shared
Chaos Injector - Shared chaos injector for use across threads