Directories
¶
| Path | Synopsis |
|---|---|
|
Package app assembles Sink dependencies and owns their process lifecycle.
|
Package app assembles Sink dependencies and owns their process lifecycle. |
|
Package backpressure controls Store dispatch using feedback from real work.
|
Package backpressure controls Store dispatch using feedback from real work. |
|
Package capacity gates new work using process memory high and low watermarks.
|
Package capacity gates new work using process memory high and low watermarks. |
|
Package config loads and validates Sink runtime configuration without opening dependencies.
|
Package config loads and validates Sink runtime configuration without opening dependencies. |
|
Package engine implements the identity-checked private forwarding endpoint.
|
Package engine implements the identity-checked private forwarding endpoint. |
|
Package forwarding defines the private Gateway-to-Engine transport contract.
|
Package forwarding defines the private Gateway-to-Engine transport contract. |
|
Package gateway routes public Sink requests without database or Kafka clients.
|
Package gateway routes public Sink requests without database or Kafka clients. |
|
Package logging configures bounded, structured internal diagnostics.
|
Package logging configures bounded, structured internal diagnostics. |
|
Package merge executes client-provided document merge programs.
|
Package merge executes client-provided document merge programs. |
|
Package metrics exposes bounded-cardinality Prometheus metrics for Sink.
|
Package metrics exposes bounded-cardinality Prometheus metrics for Sink. |
|
Package protocol contains tests and helpers for the public Sink protocol.
|
Package protocol contains tests and helpers for the public Sink protocol. |
|
Package queue defines the durable asynchronous mutation publisher contract.
|
Package queue defines the durable asynchronous mutation publisher contract. |
|
kafka
Package kafka provides a durable Kafka mutation publisher and consumer.
|
Package kafka provides a durable Kafka mutation publisher and consumer. |
|
Package service implements the public Sink gRPC service.
|
Package service implements the public Sink gRPC service. |
|
Package storage defines the database-independent record storage contract.
|
Package storage defines the database-independent record storage contract. |
|
memory
Package memory provides an in-memory Storage implementation for tests and local development.
|
Package memory provides an in-memory Storage implementation for tests and local development. |
|
mongodb
Package mongodb implements document storage backed by MongoDB.
|
Package mongodb implements document storage backed by MongoDB. |
|
search
Package search implements document storage compatible with Elasticsearch and OpenSearch.
|
Package search implements document storage compatible with Elasticsearch and OpenSearch. |
|
Package testuri constructs canonical URI fixtures for tests.
|
Package testuri constructs canonical URI fixtures for tests. |
|
Package worker applies queued mutations through the synchronous Sink path.
|
Package worker applies queued mutations through the synchronous Sink path. |
Click to show internal directories.
Click to hide internal directories.