Directories
¶
| Path | Synopsis |
|---|---|
|
Package conduit wires up everything under the hood of a Conduit instance including metrics, telemetry, logging, and server construction.
|
Package conduit wires up everything under the hood of a Conduit instance including metrics, telemetry, logging, and server construction. |
|
check
Package check is the neutral diagnostic engine shared by `conduit doctor` and the `connector|processor new` scaffold preflight (see docs/architecture-decision-records/20260707-check-engine-shared-by-doctor-and-scaffold.md).
|
Package check is the neutral diagnostic engine shared by `conduit doctor` and the `connector|processor new` scaffold preflight (see docs/architecture-decision-records/20260707-check-engine-shared-by-doctor-and-scaffold.md). |
|
dev
Package dev implements the file watcher behind `conduit run --dev` (see docs/design-documents/20260712-pipeline-dev-hot-reload.md, §4 "Surface").
|
Package dev implements the file watcher behind `conduit run --dev` (see docs/design-documents/20260712-pipeline-dev-hot-reload.md, §4 "Surface"). |
|
exitcode
Package exitcode computes Conduit's deterministic CLI process exit code from an error.
|
Package exitcode computes Conduit's deterministic CLI process exit code from an error. |
|
foundation
|
|
|
atomicfile
Package atomicfile writes a whole file's contents durably and atomically: a crash at any point leaves either the previous complete content or the new complete content, never a torn write (Invariant 5 — "state and checkpoint writes are atomic").
|
Package atomicfile writes a whole file's contents durably and atomically: a crash at any point leaves either the previous complete content or the new complete content, never a torn write (Invariant 5 — "state and checkpoint writes are atomic"). |
|
cerrors
Package cerrors contains functions related to error handling.
|
Package cerrors contains functions related to error handling. |
|
cerrors/conduiterr
Package conduiterr defines ConduitError, Conduit's uniform, machine-actionable error type.
|
Package conduiterr defines ConduitError, Conduit's uniform, machine-actionable error type. |
|
metrics/noop
Package noop exposes implementations of metrics which do not do anything.
|
Package noop exposes implementations of metrics which do not do anything. |
|
http
|
|
|
api/mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
Package lifecycle contains the logic to manage the lifecycle of pipelines.
|
Package lifecycle contains the logic to manage the lifecycle of pipelines. |
|
stream
Package stream defines a message and nodes that can be composed into a data pipeline.
|
Package stream defines a message and nodes that can be composed into a data pipeline. |
|
stream/mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
Package lifecycle contains the logic to manage the lifecycle of pipelines.
|
Package lifecycle contains the logic to manage the lifecycle of pipelines. |
|
mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
connector/mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
connector/standalone/test/testplugin
command
Package main contains a plugin used for testing purposes.
|
Package main contains a plugin used for testing purposes. |
|
processor/builtin/impl/avro
Package avro is a generated GoMock package.
|
Package avro is a generated GoMock package. |
|
processor/builtin/impl/ollama/mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
processor/builtin/internal/diff
Package diff computes differences between text files or strings.
|
Package diff computes differences between text files or strings. |
|
processor/builtin/internal/diff/difftest
Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff"
|
Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff" |
|
processor/builtin/internal/diff/lcs
package lcs contains code to find longest-common-subsequences (and diffs)
|
package lcs contains code to find longest-common-subsequences (and diffs) |
|
processor/mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
Package provisioning's plan.go implements the preview/diff engine behind `conduit pipelines deploy|apply` (see docs/design-documents/20260708-cli-pipeline-deploy-apply.md).
|
Package provisioning's plan.go implements the preview/diff engine behind `conduit pipelines deploy|apply` (see docs/design-documents/20260708-cli-pipeline-deploy-apply.md). |
|
mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
This file implements the offline/air-gapped install path (plan-v2/step5 §7): Bundle prepares a self-contained tarball on a networked machine, running the full real install-equivalent verification before ever writing the tarball; InstallFromBundle installs from that tarball on a machine with NO network access at all, re-verifying everything against the offline binary's own compiled-in trust anchors — it NEVER skips verification just because the network is down.
|
This file implements the offline/air-gapped install path (plan-v2/step5 §7): Bundle prepares a self-contained tarball on a networked machine, running the full real install-equivalent verification before ever writing the tarball; InstallFromBundle installs from that tarball on a machine with NO network access at all, re-verifying everything against the offline binary's own compiled-in trust anchors — it NEVER skips verification just because the network is down. |
|
boundedfetch
Package boundedfetch is the shared size-capped fetch primitive behind P0-2 (plan-v2 §2.4 item 1): attacker-controlled bytes (an index, a connector artifact, a signature bundle, a provenance bundle) are always read through an io.LimitReader capped one byte past the caller's limit, so a response that would exceed the cap is distinguished (ErrTooLarge) from one that happens to land exactly on it, and from any other fetch failure.
|
Package boundedfetch is the shared size-capped fetch primitive behind P0-2 (plan-v2 §2.4 item 1): attacker-controlled bytes (an index, a connector artifact, a signature bundle, a provenance bundle) are always read through an io.LimitReader capped one byte past the caller's limit, so a response that would exceed the cap is distinguished (ErrTooLarge) from one that happens to land exactly on it, and from any other fetch failure. |
|
index
Package index parses, freezes, and (eventually) verifies the signed connector registry index — the security-critical foundation `install`, `audit`, and the publish Action all trust.
|
Package index parses, freezes, and (eventually) verifies the signed connector registry index — the security-critical foundation `install`, `audit`, and the publish Action all trust. |
|
policy
Package policy is the --allow-unsigned gate (plan-v2 §6, P1-3).
|
Package policy is the --allow-unsigned gate (plan-v2 §6, P1-3). |
|
trust/adversarial
Package adversarial is the shared fixture corpus (plan-v2 §11, P1-4): a small set of hand-built, LOCALLY-generated (never touching production Sigstore or Conduit registry infrastructure) signed/attested test entities, each paired with the pkg/registry/trust error this build's verification pipeline must produce for it.
|
Package adversarial is the shared fixture corpus (plan-v2 §11, P1-4): a small set of hand-built, LOCALLY-generated (never touching production Sigstore or Conduit registry infrastructure) signed/attested test entities, each paired with the pkg/registry/trust error this build's verification pipeline must produce for it. |
|
trust/trustroot
Package trustroot embeds a pinned, offline snapshot of Sigstore's own public-good trust root (layer 1: Fulcio CA, Rekor transparency log, CTFE public keys — see pkg/registry/trust's package doc for the two-layer distinction).
|
Package trustroot embeds a pinned, offline snapshot of Sigstore's own public-good trust root (layer 1: Fulcio CA, Rekor transparency log, CTFE public keys — see pkg/registry/trust's package doc for the two-layer distinction). |
|
Package scaffold implements the engine behind `conduit connector new` and `conduit processor new`, per docs/design-documents/20260707-connector-processor-scaffolding.md.
|
Package scaffold implements the engine behind `conduit connector new` and `conduit processor new`, per docs/design-documents/20260707-connector-processor-scaffolding.md. |
|
steps
Package steps implements the post-rewrite pipeline scaffold.Generate runs against a staged, renamed template tree: install the code-gen tool, generate, verify the result builds, and initialize git.
|
Package steps implements the post-rewrite pipeline scaffold.Generate runs against a staged, renamed template tree: install the code-gen tool, generate, verify the result builds, and initialize git. |
|
template
Package template owns the vendored, go:embed'd snapshots of ConduitIO/conduit-connector-template and ConduitIO/conduit-processor-template (Extract), and the Go port of each template's setup.sh rename step (Rewrite).
|
Package template owns the vendored, go:embed'd snapshots of ConduitIO/conduit-connector-template and ConduitIO/conduit-processor-template (Extract), and the Go port of each template's setup.sh rename step (Rewrite). |
|
web
|
|
|
ui
Package ui embeds and serves conduit-ui, Conduit's built-in web UI (observe + operate).
|
Package ui embeds and serves conduit-ui, Conduit's built-in web UI (observe + operate). |
Click to show internal directories.
Click to hide internal directories.