Module singer 

Available on crate features source-rest and source-singer only.

Modules

assemble

Pure page-assembly state machine.

config

Configuration types for the Singer tap bridge source.

discover

Singer catalog discovery: run <tap> --config <tmp> --discover and return the catalog it prints. Used by faucet init --source singer --discover.

message

Singer message model + line parser.

process

Tap subprocess runner: spawn, stream stdout as parsed messages over a bounded channel (backpressure), drain stderr into tracing, and always reap the child (SIGTERM → grace → SIGKILL on the paths we control; kill_on_drop is the backstop for an abrupt drop/cancel).

stream

SingerSource — the Source implementation that bridges a Singer tap.

Structs

SingerSource

A source that runs a Singer tap and adapts its output into faucet records.

SingerSourceConfig

Configuration for the Singer tap bridge source.

StreamSelection

Result of select_streams: the rewritten catalog plus what was selected and any warnings the caller should surface to the user.

Enums

FaucetError

All possible errors returned by faucet-stream.

MalformedPolicy

What to do when the tap emits a line that is not valid Singer JSON.

SingerMessage

A parsed Singer protocol message.

Traits

Sink

A sink writes records to an external system.

Source

A source fetches records from an external system.

Functions

catalog_stream_ids

Extract the stream ids from a Singer catalog (tap_stream_id, falling back to stream), in catalog order.

discover

Run the tap in discovery mode and parse its stdout as a Singer catalog.

parse_line

Parse one line of tap stdout into a SingerMessage.

select_streams

Mark target — and any parent streams inferable from the catalog — as selected, returning the rewritten catalog.