Module dataflow::source::file

Structs

FileOffset

Represents an index into a file. Files are 1-indexed by Unix convention

FileSourceReader

Contains all information necessary to ingest data from file sources

ForeverTailedFile

Wraps a file, producing a stream that is tailed forever.

Enums

FileReadStyle

Strategies for streaming content from a file.

Functions

open_file_stream

read_file_task

Blocking logic to read from a file, intended for its own thread.

send_records

Sends a sequence of records and activates a timely operator for each.