Expand description
§flusso-sinks-core
The sink abstraction for flusso — where assembled documents land.
§Quick reference
| Item | Role |
|---|---|
Sink | The trait every destination implements |
FanOutSink | A Sink that broadcasts each write to several sinks |
to_json | Renders a GenericValue as natural JSON (numbers as numbers, maps as objects) |
FlushReport / RejectedDocument | A flush’s outcome, including any documents the destination applied-but-rejected |
SinkError / Result | The shared error type |
A sink consumes neutral values — an IndexName, a string id, and a document GenericValue — so it depends on neither the source nor the engine. The engine is what feeds it.
to_json is the OpenSearch-flavored translation most sinks need at their boundary; a sink converts the canonical GenericValue into its own representation there.
Structs§
- FanOut
Sink - Dispatches every sink operation to a set of inner sinks in declaration order.
- Flush
Report - The outcome of a
flush: which buffered documents the destination rejected at the item level. - Rejected
Document - One document a sink rejected at the item level during a
flush. The names are the destination’s own (e.g. an OpenSearch physical index), for diagnostics and quarantine records.
Enums§
- Sink
Error - Why a sink write failed.
Traits§
- Sink
- A destination for assembled documents.
Functions§
- to_json
- Convert a document value into the JSON a sink ingests.
Type Aliases§
- Result
- Result alias for sink operations.