pkg/

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

Directories ¶

Path	Synopsis
conduit 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.
connector
foundation
cerrors Package cerrors contains functions related to error handling.	Package cerrors contains functions related to error handling.
ctxutil
grpcutil
log
metrics
metrics/measure
metrics/noop Package noop exposes implementations of metrics which do not do anything.	Package noop exposes implementations of metrics which do not do anything.
metrics/prometheus
http
api
api/fromproto
api/mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
api/status
api/toproto
openapi
inspector
lifecycle 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.
lifecycle-poc Package lifecycle contains the logic to manage the lifecycle of pipelines.	Package lifecycle contains the logic to manage the lifecycle of pipelines.
funnel
funnel/mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
orchestrator
mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
pipeline
plugin
connector
connector/builtin
connector/connutils
connector/mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
connector/standalone
connector/standalone/test/testplugin Package main contains a plugin used for testing purposes.	Package main contains a plugin used for testing purposes.
processor
processor/builtin
processor/builtin/impl
processor/builtin/impl/avro Package avro is a generated GoMock package.	Package avro is a generated GoMock package.
processor/builtin/impl/avro/internal
processor/builtin/impl/base64
processor/builtin/impl/custom
processor/builtin/impl/field
processor/builtin/impl/json
processor/builtin/impl/unwrap
processor/builtin/impl/webhook
processor/builtin/internal
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/builtin/internal/diff/testenv
processor/builtin/internal/exampleutil
processor/mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
processor/procutils
processor/standalone
processor/standalone/test/wasm_processors/chaos
processor/standalone/test/wasm_processors/specify_error
processor
mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
provisioning
config
config/yaml
config/yaml/internal
config/yaml/v1
config/yaml/v2
mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
test/pipelines1
test/pipelines2
test/pipelines3
test/pipelines4-integration-test
schemaregistry
fromschema
schemaregistrytest
toschema

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL