MCPcopy Index your code
hub / github.com/redpanda-data/connect

github.com/redpanda-data/connect @v4.99.0 sqlite

repository ↗ · DeepWiki ↗ · release v4.99.0 ↗
9,085 symbols 45,156 edges 1,115 files 3,130 documented · 34%
README

README (FIPS tar.gz archive)

This tar contains a redpanda-connect-fips binary intended for automated installation by rpk. You probably want to install the redpanda-connect-fips RPM or debian package instead, if you want to actually use this software on a FIPS-enabled system.

Extension points exported contracts — how you extend this code

MessageDecoder (Interface)
MessageDecoder decodes message into struct. [12 implementers]
internal/impl/postgresql/pglogicalstream/replication_message.go
ProcessorConstructor (FuncType)
ProcessorConstructor is the factory function to create a new batch processor.
public/plugin/go/rpcn/rpcn.go
LocateLicenseOptFunc (FuncType)
LocateLicenseOptFunc defines an option to pass through the LocateLicense function call in order to customize its behavio
public/license/license.go
LookupFn (FuncType)
LookupFn defines the common closure that a secrets management client provides and is then fed into a Redpanda Connect cl
internal/secrets/secrets.go
Option (FuncType)
Option is a function that can configure a SubProcess.
internal/rpcplugin/subprocess/subprocess.go
Capped (Interface)
Capped is an object that reuses existing objects in a manner similar to sync.Pool, but it's more strict than sync.Pool i
internal/pool/pool.go
ServerOption (FuncType)
ServerOption customises optional NewServer behaviour.
internal/mcp/mcp.go
Options (FuncType)
Options is a function that modifies the options for the template creation.
internal/template/template.go

Core symbols most depended-on inside this repo

Errorf
called by 3205
internal/impl/pulsar/logger.go
Run
called by 1546
internal/impl/timeplus/interface.go
Len
called by 898
internal/impl/mssqlserver/replication/stream.go
Example
called by 712
internal/impl/javascript/functions.go
Log
called by 689
internal/impl/kafka/logger.go
Close
called by 661
internal/impl/gcp/bigquery.go
Unlock
called by 641
internal/syncx/mutex.go
Lock
called by 624
internal/syncx/mutex.go

Shape

Function 4,333
Method 3,283
Struct 1,223
TypeAlias 95
Interface 75
Class 38
FuncType 34
Route 4

Languages

Go98%
Python2%

Modules by API surface

internal/impl/salesforce/salesforcegrpc/pubsub_api.pb.go175 symbols
internal/rpcplugin/runtimepb/message.pb.go116 symbols
internal/rpcplugin/runtimepb/input.pb.go75 symbols
internal/rpcplugin/runtimepb/output.pb.go70 symbols
internal/impl/aws/dynamodb/input_cdc.go70 symbols
internal/impl/postgresql/pglogicalstream/replication_message_test.go59 symbols
internal/impl/salesforce/salesforcehttp/client.go53 symbols
internal/impl/mongodb/cdc/integration_test.go49 symbols
internal/agent/runtimepb/agent.pb.go48 symbols
internal/impl/postgresql/pglogicalstream/replication_message.go47 symbols
internal/rpcplugin/runtimepb/processor.pb.go46 symbols
internal/impl/iceberg/writer.go45 symbols

Dependencies from manifests, versioned

atomicgo.dev/cursorv0.2.0 · 1×
atomicgo.dev/keyboardv0.2.9 · 1×
atomicgo.dev/schedulev0.1.0 · 1×
buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/gov1.36.11-20260209202 · 1×
buf.build/gen/go/bufbuild/reflect/connectrpc/gov1.19.1-202401172023 · 1×
buf.build/gen/go/bufbuild/reflect/protocolbuffers/gov1.36.11-20240117202 · 1×
buf.build/gen/go/redpandadata/common/connectrpc/gov1.19.1-202603231710 · 1×
buf.build/gen/go/redpandadata/common/protocolbuffers/gov1.36.11-20260323171 · 1×
buf.build/gen/go/redpandadata/otel/protocolbuffers/gov1.36.11-20260323171 · 1×
buf.build/go/hyperpbv0.1.3 · 1×
cel.dev/exprv0.25.1 · 1×
cloud.google.com/gov0.123.0 · 1×

Datastores touched

TestCollectionCollection · 1 repos
fooCollection · 1 repos
testdbDatabase · 1 repos
(mysql)Database · 1 repos
(mongodb)Database · 1 repos
benchdbDatabase · 1 repos
defaultdbDatabase · 1 repos
TestDBDatabase · 1 repos

For agents

$ claude mcp add connect \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact