Module copy_in 

PostgreSQL COPY ... FROM STDIN (copy-in) support.

The wire handshake is driven by pgwire: returning [Response::CopyIn] from a query handler makes the server send a CopyInResponse and enter the copy-in sub-protocol; subsequent CopyData messages from the client are dispatched to [CopyHandler], whose implementation below parses the data stream incrementally and flushes it into the query handler as [RowInsertRequests] batches.

Formats

The supported formats are the explicit codec::CopyFormat enum — csv (table-bound, incremental row parsing) and influxdb (table-less, one bounded whole-payload request). Each format states its own target rule and ingestion shape in the match arms of the copy lifecycle below; adding a format is a new variant plus its arms. Builders resolve a FORMAT name (and its aliases) through REGISTERED_FORMATS. See the codec module docs.

Modules

codec 🔒

The COPY FROM STDIN formats.

csv 🔒

The csv format — currently the only implemented COPY FROM STDIN format.

influxdb 🔒

The influxdb line protocol format for COPY FROM STDIN.

options 🔒

Format-neutral collection of COPY WITH (...) options.

otlp 🔒

The otlp format for COPY FROM STDIN: one binary OTLP payload for any of the three signals — ExportMetricsServiceRequest, ExportTraceServiceRequest or ExportLogsServiceRequest.

parse 🔒

Textual parser for COPY ... FROM STDIN statements.

Structs

CopyFromStdin 🔒

The parsed COPY tbl [(columns)] FROM STDIN [(options)] statement.

CopyInState 🔒

Per-connection state of an in-progress COPY FROM STDIN.

Enums

Payload 🔒

Constants

COPY_IN_FLUSH_ROWS 🔒

Number of parsed rows buffered before flushing a batch to the handler.

COPY_IN_MAX_PAYLOAD_BYTES 🔒

Upper bound of a table-less COPY FROM STDIN payload (influxdb line protocol, OTLP). One COPY statement is one bounded ingestion request (the whole payload is buffered like one HTTP request body); a larger import is multiple COPY statements.

REGISTERED_FORMATS 🔒

The registered COPY FROM STDIN formats: accepted FORMAT name to builder. csv is the only implemented format; the others are registered so they report a clear “not supported yet” instead of an unknown-format error.

Functions

adjust_query_context 🔒

all_rejected_error 🔒

The error for an OTLP payload whose points/spans were all rejected, carrying the pipeline’s reason when it provided one.

bad_copy_data 🔒

build_grpc_column_schema 🔒

build_unimplemented_binary_codec 🔒

build_unimplemented_text_codec 🔒

copy_from_stdin_from_sql 🔒

Parses a leading COPY ... FROM STDIN statement from SQL text.

copy_in_error 🔒

copy_in_must_run_alone_error 🔒

invalid_text_repr 🔒

is_copy_from_stdin 🔒

Whether an already-parsed statement is a COPY ... FROM STDIN; used to reject copy-in statements trailing other statements, where the textual scanner (which only sees statement-leading COPYs) does not see them.

resolve_columns 🔒

resolve_format 🔒

Resolves the format from the parsed options.

resolve_table_name 🔒

Resolves table name parts against the query context defaults.

semantic_type_of 🔒

Derives a column’s semantic type the same way the flow adapter does (flow::adapter::util::column_schemas_to_proto): the time-index flag for timestamps, primary-key membership for tags.

unsupported 🔒

Type Aliases

FormatBuilder 🔒

Builds a format from the format-neutral option set.