Index A | B | C | D | E | F | H | I | L | M | N | P | Q | R | S | T | U | V | W A append() (battfeed.testing.replay.ReplayTape method) available_sources() (in module battfeed.registry) B backoff() (battfeed.harvester.ErrorPolicy method) batches (battfeed.importer.ImportStats attribute) battfeed.config module battfeed.harvester module battfeed.importer module battfeed.ingest_state module battfeed.protocols module battfeed.registry module battfeed.sinks.bdf_csv module battfeed.sinks.http_push module battfeed.sinks.parquet module battfeed.sinks.routing module battfeed.sources.streaming module battfeed.testing.contract module battfeed.testing.replay module BdfCsvSink (class in battfeed.sinks.bdf_csv) C check_source() (in module battfeed.testing.contract) close() (battfeed.protocols.Sink method) (battfeed.sinks.bdf_csv.BdfCsvSink method) (battfeed.sinks.http_push.HttpPushSink method) (battfeed.sinks.parquet.ParquetSink method) (battfeed.sinks.routing.RoutingSink method) (battfeed.sources.streaming.StreamingSource method) (battfeed.testing.replay.TapeRecorder method) collect() (battfeed.harvester.Harvester method) CollectStats (class in battfeed.harvester) columns (battfeed.harvester.CollectStats attribute) (battfeed.importer.ImportStats attribute) Config (class in battfeed.config) ConfigError create_source() (in module battfeed.registry) D data (battfeed.testing.replay.TapeFrame attribute) dataset_filename() (in module battfeed.sinks.bdf_csv) DataSource (class in battfeed.protocols) DeadReaderError dropped_total (battfeed.sources.streaming.StreamingSource property) duration_s (battfeed.harvester.CollectStats attribute) (battfeed.importer.ImportStats attribute) (battfeed.testing.replay.ReplayTape property) E ErrorPolicy (class in battfeed.harvester) errors (battfeed.harvester.CollectStats attribute) (battfeed.importer.ImportStats attribute) F files_by_series (battfeed.sinks.routing.RoutingSink property) flush() (battfeed.sinks.http_push.HttpPushSink method) H Harvester (class in battfeed.harvester) hash_of() (battfeed.ingest_state.ImportLedger method) HttpPushSink (class in battfeed.sinks.http_push) I ImportLedger (class in battfeed.ingest_state) ImportStats (class in battfeed.importer) ingested_count (battfeed.ingest_state.ImportLedger property) is_quarantined() (battfeed.ingest_state.ImportLedger method) is_secret_key() (in module battfeed.config) L load() (battfeed.testing.replay.ReplayTape class method) load_config() (in module battfeed.config) M mask_url_userinfo() (in module battfeed.config) meta (battfeed.testing.replay.TapeFrame attribute) metadata() (battfeed.protocols.DataSource method) (battfeed.sources.streaming.StreamingSource method) module battfeed.config battfeed.harvester battfeed.importer battfeed.ingest_state battfeed.protocols battfeed.registry battfeed.sinks.bdf_csv battfeed.sinks.http_push battfeed.sinks.parquet battfeed.sinks.routing battfeed.sources.streaming battfeed.testing.contract battfeed.testing.replay N name (battfeed.protocols.DataSource attribute) P ParquetSink (class in battfeed.sinks.parquet) path (battfeed.ingest_state.ImportLedger property) poll() (battfeed.protocols.DataSource method) (battfeed.sources.streaming.StreamingSource method) polls (battfeed.importer.ImportStats attribute) Q quarantine() (battfeed.ingest_state.ImportLedger method) quarantine_reason() (battfeed.ingest_state.ImportLedger method) quarantined_count (battfeed.ingest_state.ImportLedger property) R reader_alive (battfeed.sources.streaming.StreamingSource property) reader_restarts (battfeed.sources.streaming.StreamingSource property) received_total (battfeed.sources.streaming.StreamingSource property) record() (battfeed.ingest_state.ImportLedger method) (battfeed.testing.replay.TapeRecorder method) records_sent (battfeed.sinks.http_push.HttpPushSink attribute) records_spooled (battfeed.sinks.http_push.HttpPushSink attribute) redact_mapping() (in module battfeed.config) redact_text() (in module battfeed.config) redact_value() (in module battfeed.config) REDACTED (in module battfeed.config) register() (battfeed.harvester.Harvester method) ReplayReader (class in battfeed.testing.replay) ReplayTape (class in battfeed.testing.replay) REQUIRED_COLUMNS (in module battfeed.sinks.bdf_csv) RESERVED_KEYS (in module battfeed.protocols) reset() (battfeed.ingest_state.ImportLedger method) RoutingSink (class in battfeed.sinks.routing) run() (battfeed.testing.replay.ReplayReader method) run_import() (in module battfeed.importer) run_params() (battfeed.config.Config method) run_reader() (battfeed.sources.streaming.StreamingSource method) S Sample (in module battfeed.protocols) samples (battfeed.harvester.CollectStats attribute) (battfeed.importer.ImportStats attribute) SampleValue (in module battfeed.protocols) sanitize_cell_name() (in module battfeed.sinks.routing) save() (battfeed.testing.replay.ReplayTape method) seen() (battfeed.ingest_state.ImportLedger method) Sink (class in battfeed.protocols) source (battfeed.harvester.CollectStats attribute) (battfeed.importer.ImportStats attribute) source_block() (battfeed.config.Config method) SourceFailure sources (battfeed.harvester.Harvester property) started_at (battfeed.harvester.CollectStats attribute) (battfeed.importer.ImportStats attribute) status() (battfeed.harvester.Harvester method) stream_stats() (battfeed.sources.streaming.StreamingSource method) StreamingSource (class in battfeed.sources.streaming) T t (battfeed.testing.replay.TapeFrame attribute) TapeFrame (class in battfeed.testing.replay) TapeRecorder (class in battfeed.testing.replay) tee() (battfeed.testing.replay.TapeRecorder method) U url_userinfo_passwords() (in module battfeed.config) V validate_file() (in module battfeed.sinks.bdf_csv) W write() (battfeed.protocols.Sink method) (battfeed.sinks.bdf_csv.BdfCsvSink method) (battfeed.sinks.http_push.HttpPushSink method) (battfeed.sinks.parquet.ParquetSink method) (battfeed.sinks.routing.RoutingSink method)