List of all items

Structs

• CentralKvSyncConfig
• ChannelLogger
• CloseOutcome
• NestedConfig
• ParquetLogger
• ReplayState
• SampleConfig
• SensorConfig
• calibration::CalibrationSpec
• replay_guard::Checkpoint
• replay_guard::ReplayGuard
• replay_guard::SkipRun
• sample_data_generated::sampler::Scan
• sample_data_generated::sampler::ScanArgs
• sample_data_generated::sampler::ScanBuilder

Enums

• calibration::CalibrationFormula
• sample_data_generated::sampler::ScanOffset

Functions

• ack_messages
• archive_format::writer_properties
• archive_format::writer_properties_for_calibration
• archiver_consumer_config
• archiver_consumer_name
• central_kv_sync_config_from_env
• close_and_settle
• connect_nats_with_creds
• ensure_kv_bucket
• env_nonempty
• filtered_consumer_name
• main
• mirror_central_kv_once
• nats_config::jetstream_context
• nats_config::jetstream_context_for_domain
• nats_config::jetstream_context_from_env
• nats_config::servers_from_env
• nats_config::servers_from_env_var
• next_file_index
• parse_calibrations
• process_scan_payload
• quarantine_incomplete_files
• replay_guard::checkpoint_path
• replay_guard::file_token
• replay_guard::load
• replay_guard::save
• replay_guard::trusted_floor
• replay_state_dir
• replay_state_dir_from_env
• representable_samples
• rotation_window
• run_central_kv_sync
• sample_config_from_nested
• sample_data_generated::sampler::finish_scan_buffer
• sample_data_generated::sampler::finish_size_prefixed_scan_buffer
• sample_data_generated::sampler::root_as_scan
• sample_data_generated::sampler::root_as_scan_unchecked
• sample_data_generated::sampler::root_as_scan_with_opts
• sample_data_generated::sampler::size_prefixed_root_as_scan
• sample_data_generated::sampler::size_prefixed_root_as_scan_unchecked
• sample_data_generated::sampler::size_prefixed_root_as_scan_with_opts
• sample_timestamp_ns
• sanitize_consumer_token
• spawn_channel_logger
• subjects::archive_export_request_subject
• subjects::live_labjack_channel_subject
• subjects::live_labjack_stream_subject
• subjects::pad_asset
• subjects::pad_channel
• subjects::present
• subjects::sanitize_token
• subjects::source_token
• subjects::stream_subject_is_compatible
• subjects::uses_structured_namespace
• sync_directory_after_publish
• timestamp_ns_to_utc_date

Type Aliases

• DynError

Constants

• CHECKPOINT_INTERVAL
• CONSUMER_MAX_ACK_PENDING
• IDLE_CHECK_INTERVAL
• IDLE_CLOSE_AFTER
• MAX_PENDING_ACKS_PER_FILE
• MAX_ROW_GROUPS_PER_FILE
• ROWS_PER_ROW_GROUP
• SKIP_LOG_EVERY
• archive_format::SAMPLE_SCHEMA
• nats_config::DEFAULT_NATS_SERVERS